kafka_dae_control.process_worker_event

Process worker events on the queue.

Members

process_worker_event

Process a worker event.
kafka_dae_control.process_worker_event.process_worker_event(queue: Queue[SetIPEvent | BeginEvent | EndEvent | HardwareUpdateEvent | BlocksUpdateEvent | FrameSyncSelectChangeEvent], worker_event: SetIPEvent | BeginEvent | EndEvent | HardwareUpdateEvent | BlocksUpdateEvent | FrameSyncSelectChangeEvent, config: ControlConfig, data: Data, producer: Producer, sock: socket, sock_lock: RLock) → None[source]

Process a worker event.

This is the only part of the program which can mutate the data class. It is responsible for filtering the type of worker event and acting on it accordingly.

Parameters:

  • queue – the worker event queue which may be added to

  • worker_event – the worker event to process

  • config – the program’s configuration options

  • data – the data class containing the program’s state

  • producer – the Kafka producer

  • sock – the socket instance

  • sock_lock – the lock to use when using the socket instance