kafka_dae_diagnostics.serve

Main loop of kafka_dae_diagnostics.

Listen to Kafka forever, updating data as new messages come in, while also serving data over EPICS.

Members

serve

Serve PVs while consuming from Kafka (forever).

kafka_dae_diagnostics.serve.serve(config: DiagnosticsConfig) None[source]

Serve PVs while consuming from Kafka (forever).

Parameters:

config – Diagnostics IOC configuration parameters