pswamp.streaming.time_series_io

Classes

`TimeSeriesIO`
`Decoder`

Module Contents

class pswamp.streaming.time_series_io.TimeSeriesIO(time_stamps, measurements)

time_stamps

dt

measurements

iterator

output

metadata

get_config_frame()

get_sample_data_frame()

get_next_data_frame()

handle_result(result)

handle_output(topic, output)

handle_status(status)

seek_relative_input_offset(offset)

get_next_command()

class pswamp.streaming.time_series_io.Decoder(**app_kwargs)

data_dtype

get_data_rate(data_frame)

generate_header(sample_data_frame)

get_time_stamp(data_frame)

data_frame_to_row(data_frame)