Index

A

address (kafka_dae_control.defaults.Register attribute)

B

BeginEvent (class in kafka_dae_control.worker_event) blocks (kafka_dae_control.data.Data attribute)

BlocksUpdateEvent (class in kafka_dae_control.worker_event) board_ip (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)

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

F

flush_timeout_s (kafka_dae_control.config.ControlConfig attribute)

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)

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

I

instrument_name (kafka_dae_control.data.Data 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.pvs module kafka_dae_control.pvs.blocks 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 module kafka_dae_control.worker_event_handlers 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.pvs kafka_dae_control.pvs.blocks 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 kafka_dae_control.worker_event_handlers

P

poll_interval_s (kafka_dae_control.config.ControlConfig attribute) process_worker_event() (in module kafka_dae_control.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)

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

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) 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)

T

title (kafka_dae_control.data.Data attribute)

TitleUpdateEvent (class in kafka_dae_control.worker_event)

U

update_all() (kafka_dae_control.pvs.static_pvs.StaticPVs method) update_blocks() (in module kafka_dae_control.pvs.blocks)

update_pvs_thread() (in module kafka_dae_control.threads.update_pvs_thread) users (kafka_dae_control.data.Data attribute) UsersUpdateEvent (class in kafka_dae_control.worker_event)

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) 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)