kafka_dae_control.pvs.camonitor_callbacks

Utilities for parsing block values.

Members

run_control_update_callback

Act on a run control PV update.

update_blocks

Update the list of blocks in the data class.
kafka_dae_control.pvs.camonitor_callbacks.run_control_update_callback(queue: PriorityQueue[QueueItem], *, value: int, **_: int) → None[source]

Act on a run control PV update.

Parameters:

  • queue – The main queue on which to put events.

  • value – The value of the PV.

  • **_ – Everything else.

kafka_dae_control.pvs.camonitor_callbacks.update_blocks(queue: PriorityQueue[QueueItem], prefix: str, *, char_value: str, **_: int) → None[source]

Update the list of blocks in the data class.