Streaming Chaos Adapter

[bwsw]

The streaming Chaos Adapter is intended to test whether a pipeline works correctly.

It works similarly to the Multistream Source Adapter, with the difference that it generates individual stream frame lengths according to the normal distribution. When the stream ends, but it hasn't sent the configured amount of frames, it starts from the current position, and it happens with every parallel stream until all the configured frames are set.

s1 |--------------------------------||----------------------|
s2 ...
s3 |----||----------------||-||--------------------------||-|
s4 |------------------||------------------------------------|

Also, stream naming space can be configured wider than the number of parallelly served streams. It means that in parallel work, only N streams, while when a certain stream ends the system decides what idle stream to launch from the whole space. All streams must send the configured number of frames.

Parameters:

• min_frames cannot send less than before the EOS;
• max_frames cannot send more than before the EOS;
• stream_space - the total number of streams to handle;
• per_stream_frames - the total number of frames every stream must send in total;
• parallelization - the number of streams cast in parallel.