Testistics Streams

This process consumes messages from the testruns topic of kafka.

It currently simply adds the messages to project specific testrun topics in order to support the UI.

Usage

npm install

npm start

Components

Server

The component is the CLI insterface to create a Stream

Stream

This component starts the Consumer, Router and Producer

It provides a message handler for incoming messages. The Router is asked where to Route messages. The Producer will write the payloads to the destinations

Consumer

The Consumer subscribes to kafka topics and pass them to a message handler

Router

A component which has the logic for where to dispatch entities

Producer

A component which uses a Repository to produce entities on appropriate topic destinations