Index

A

address (kafka_dae_control.defaults.Register attribute)

B

BadFirmwareXMLError BeginEvent (class in kafka_dae_control.worker_event_types) blocks (kafka_dae_control.data.Data attribute)

BlocksUpdateEvent (class in kafka_dae_control.worker_event_types) board_ip (kafka_dae_control.config.ControlConfig attribute) board_xml (kafka_dae_control.config.ControlConfig attribute)

C

ControlConfig (class in kafka_dae_control.config)

D

Data (class in kafka_dae_control.data)

delivery_report_run_info() (in module kafka_dae_control.worker_event_handlers)

E

EndEvent (class in kafka_dae_control.worker_event_types) err (kafka_dae_control.event_with_value.EventWithValue property)

events_topic (kafka_dae_control.config.ControlConfig attribute) EventWithValue (class in kafka_dae_control.event_with_value)

F

flush_timeout_s (kafka_dae_control.config.ControlConfig attribute) frame_sync_select_rbv (kafka_dae_control.data.Data attribute)

frame_sync_select_sp (kafka_dae_control.data.Data attribute) FrameSyncSelect (class in kafka_dae_control.defaults) FrameSyncSelectChangeEvent (class in kafka_dae_control.worker_event_types)

G

generate_nexus_structure() (in module kafka_dae_control.run_start_nexus_structure)

H

handle_begin() (in module kafka_dae_control.worker_event_handlers) handle_end() (in module kafka_dae_control.worker_event_handlers) handle_frame_sync_sp_change() (in module kafka_dae_control.worker_event_handlers)

hardware_poll_thread() (in module kafka_dae_control.threads.hardware_polling_thread) HardwareUpdate (class in kafka_dae_control.worker_event_types) HardwareUpdateEvent (class in kafka_dae_control.worker_event_types)

I

instrument_name (kafka_dae_control.config.ControlConfig attribute)

J

job_id (kafka_dae_control.data.Data attribute)

K

kafka_dae_control module kafka_dae_control.cli module kafka_dae_control.comms module kafka_dae_control.config module kafka_dae_control.data module kafka_dae_control.defaults module kafka_dae_control.event_with_value module kafka_dae_control.firmware_xml module kafka_dae_control.process_worker_event module kafka_dae_control.pvs module kafka_dae_control.pvs.camonitor_callbacks module

kafka_dae_control.pvs.static_pvs module kafka_dae_control.run_start_nexus_structure module kafka_dae_control.save_restore module kafka_dae_control.serve module kafka_dae_control.threads module kafka_dae_control.threads.hardware_polling_thread module kafka_dae_control.threads.update_pvs_thread module kafka_dae_control.udptalk module kafka_dae_control.version module kafka_dae_control.worker_event_handlers module kafka_dae_control.worker_event_types module kafka_producer (kafka_dae_control.config.ControlConfig attribute)

L

load_config() (in module kafka_dae_control.config)

load_data() (in module kafka_dae_control.save_restore) local_ip (kafka_dae_control.config.ControlConfig attribute)

M

main() (in module kafka_dae_control.cli) (in module kafka_dae_control.udptalk) model_config (kafka_dae_control.config.ControlConfig attribute) (kafka_dae_control.data.Data attribute) module kafka_dae_control kafka_dae_control.cli kafka_dae_control.comms kafka_dae_control.config kafka_dae_control.data kafka_dae_control.defaults kafka_dae_control.event_with_value kafka_dae_control.firmware_xml kafka_dae_control.process_worker_event kafka_dae_control.pvs kafka_dae_control.pvs.camonitor_callbacks kafka_dae_control.pvs.static_pvs kafka_dae_control.run_start_nexus_structure kafka_dae_control.save_restore kafka_dae_control.serve kafka_dae_control.threads kafka_dae_control.threads.hardware_polling_thread kafka_dae_control.threads.update_pvs_thread kafka_dae_control.udptalk kafka_dae_control.version kafka_dae_control.worker_event_handlers kafka_dae_control.worker_event_types

P

parse_register_map() (in module kafka_dae_control.firmware_xml) poll_hardware() (in module kafka_dae_control.threads.hardware_polling_thread) poll_interval_s (kafka_dae_control.config.ControlConfig attribute)

process_worker_event() (in module kafka_dae_control.process_worker_event) pv_prefix (kafka_dae_control.config.ControlConfig attribute) pv_update_interval_s (kafka_dae_control.config.ControlConfig attribute)

R

read() (in module kafka_dae_control.comms) read_port (kafka_dae_control.config.ControlConfig attribute) Register (class in kafka_dae_control.defaults) register_map (kafka_dae_control.config.ControlConfig property)

Registers (class in kafka_dae_control.defaults) run_number (kafka_dae_control.data.Data attribute) runinfo_topic (kafka_dae_control.config.ControlConfig attribute) running (kafka_dae_control.data.Data attribute) RunRegister (class in kafka_dae_control.defaults)

S

sample_env_topic (kafka_dae_control.config.ControlConfig attribute) save_file() (in module kafka_dae_control.save_restore) serve() (in module kafka_dae_control.serve) set() (kafka_dae_control.event_with_value.EventWithValue method) set_board_response_ip() (in module kafka_dae_control.comms)

SetIPEvent (class in kafka_dae_control.worker_event_types) size (kafka_dae_control.defaults.Register attribute) state_file (kafka_dae_control.config.ControlConfig attribute) static_pv_provider() (in module kafka_dae_control.pvs.static_pvs) StaticPVs (class in kafka_dae_control.pvs.static_pvs)

U

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

update_blocks() (in module kafka_dae_control.pvs.camonitor_callbacks) update_pvs_thread() (in module kafka_dae_control.threads.update_pvs_thread)

V

value (kafka_dae_control.event_with_value.EventWithValue property)

W

wait() (kafka_dae_control.event_with_value.EventWithValue method) WorkerEventWithValue (class in kafka_dae_control.worker_event_types) write() (in module kafka_dae_control.comms)

write_and_inv_then_verify() (in module kafka_dae_control.comms) write_port (kafka_dae_control.config.ControlConfig attribute) write_verify() (in module kafka_dae_control.comms)