Index

A

average_data_rate (kafka_dae_diagnostics.data.Data property)

B

bin_boundaries (kafka_dae_diagnostics.data.Data attribute)

C

callback_frequency_ms (kafka_dae_diagnostics.config.DiagnosticsConfig attribute) callbacks (kafka_dae_diagnostics.data.Data attribute)

callbacks_lock (kafka_dae_diagnostics.data.Data attribute) consume_from_kafka_forever() (in module kafka_dae_diagnostics.kafka.consumers)

D

Data (class in kafka_dae_diagnostics.data)

DiagnosticsConfig (class in kafka_dae_diagnostics.config) duration (kafka_dae_diagnostics.data.Data property)

E

event_processing_lag (kafka_dae_diagnostics.data.Data attribute)

events_topic (kafka_dae_diagnostics.config.DiagnosticsConfig attribute)

H

handle_6s4t() (in module kafka_dae_diagnostics.kafka.handlers) handle_ev44() (in module kafka_dae_diagnostics.kafka.handlers) handle_event_messages() (in module kafka_dae_diagnostics.kafka.handlers) handle_event_msg() (in module kafka_dae_diagnostics.kafka.handlers)

handle_pl72() (in module kafka_dae_diagnostics.kafka.handlers) handle_run_info_messages() (in module kafka_dae_diagnostics.kafka.handlers) handle_runinfo_msg() (in module kafka_dae_diagnostics.kafka.handlers) histogram_megabytes (kafka_dae_diagnostics.data.Data property)

K

kafka_dae_diagnostics module kafka_dae_diagnostics.config module kafka_dae_diagnostics.data module kafka_dae_diagnostics.kafka module kafka_dae_diagnostics.kafka.consumers module kafka_dae_diagnostics.kafka.handlers module

kafka_dae_diagnostics.pvs module kafka_dae_diagnostics.pvs.spectrum_handlers module kafka_dae_diagnostics.pvs.static_pvs module kafka_dae_diagnostics.serve module kafka_events_consumer (kafka_dae_diagnostics.config.DiagnosticsConfig attribute) kafka_runinfo_consumer (kafka_dae_diagnostics.config.DiagnosticsConfig attribute)

L

largest_kafka_timestamp (kafka_dae_diagnostics.data.Data attribute)

load_config() (in module kafka_dae_diagnostics.config)

M

make_event_consumer() (in module kafka_dae_diagnostics.kafka.consumers) make_runinfo_consumer() (in module kafka_dae_diagnostics.kafka.consumers) makeChannel() (kafka_dae_diagnostics.pvs.spectrum_handlers.SpectrumHandler method) mev (kafka_dae_diagnostics.data.Data property) mev_per_hour (kafka_dae_diagnostics.data.Data property) module kafka_dae_diagnostics kafka_dae_diagnostics.config kafka_dae_diagnostics.data kafka_dae_diagnostics.kafka kafka_dae_diagnostics.kafka.consumers kafka_dae_diagnostics.kafka.handlers kafka_dae_diagnostics.pvs kafka_dae_diagnostics.pvs.spectrum_handlers kafka_dae_diagnostics.pvs.static_pvs kafka_dae_diagnostics.serve

most_recent_kafka_timestamp (kafka_dae_diagnostics.data.Data attribute)

N

num_periods (kafka_dae_diagnostics.data.Data property)

num_spectra (kafka_dae_diagnostics.data.Data property) num_time_channels (kafka_dae_diagnostics.data.Data property)

P

pv_prefix (kafka_dae_diagnostics.config.DiagnosticsConfig attribute)

R

run_callbacks() (in module kafka_dae_diagnostics.kafka.consumers)

runinfo_topic (kafka_dae_diagnostics.config.DiagnosticsConfig attribute)

S

serve() (in module kafka_dae_diagnostics.serve) spectra (kafka_dae_diagnostics.data.Data attribute) SpectrumHandler (class in kafka_dae_diagnostics.pvs.spectrum_handlers)

start_time (kafka_dae_diagnostics.data.Data attribute) static_pv_provider() (in module kafka_dae_diagnostics.pvs.static_pvs) StaticPVs (class in kafka_dae_diagnostics.pvs.static_pvs) stop_time (kafka_dae_diagnostics.data.Data attribute)

T

testChannel() (kafka_dae_diagnostics.pvs.spectrum_handlers.SpectrumHandler method) total_event_megabytes (kafka_dae_diagnostics.data.Data attribute)

total_event_messages (kafka_dae_diagnostics.data.Data attribute) total_events (kafka_dae_diagnostics.data.Data attribute)

U

update_all() (kafka_dae_diagnostics.pvs.static_pvs.StaticPVs method)