ethos_penalps.stream_handler

Module Contents

Classes

StreamHandler

Attributes

logger

ethos_penalps.stream_handler.logger

class ethos_penalps.stream_handler.StreamHandler

print_all_streams_with_parameters() → None

Prints all attributes of all streams that are stored in the stream_dict. Is only used for debugging purposes.

json_dumps_streams() → str

json_dump_streams(path: str | None = None)

json_loads_streams(json_string: str)

json_load_streams(path: str)

create_continuous_stream(continuous_stream_static_data: ethos_penalps.stream.ContinuousStreamStaticData) → ethos_penalps.stream.ContinuousStream

add_stream(new_stream: ethos_penalps.stream.ContinuousStream | ethos_penalps.stream.BatchStream, overwrite_stream: bool = False)

get_list_of_all_stream_names_in_stream_handler() → list[str]

Gets the names of all streams stored in the StreamHandler instance. Includes inactive streams.

Returns:

_description_

Return type:

list[str]

get_stream(stream_name: str) → ethos_penalps.stream.ContinuousStream | ethos_penalps.stream.BatchStream

returns a stream based on the name as a key

Parameters:

stream_name (str) – [description]

Returns:

[description]

Return type:

Stream

create_batch_stream(batch_stream_static_data: ethos_penalps.stream.BatchStreamStaticData) → ethos_penalps.stream.BatchStream