Skip to content
DUNE Run Control (drunc) Developer Documentation
kafka_sender
Initializing search
DUNE-DAQ/drunc
DUNE Run Control (drunc) Developer Documentation
DUNE-DAQ/drunc
DUNE Run Control (drunc)
Controller interface
Controller
FAQ
FSM
Messaging format
Process manager interface
Process manager
Release notes
Running drunc
Unified shell reference
Code Reference
Code Reference
exceptions
grpc_settings
k8s_exceptions
Apps
Apps
controller
controller_shell
fake_daqapp_rest
pm
pm_shell
session_manager
ssh_configurator
ssh_doctor
ssh_validator
unified_shell
Authoriser
Authoriser
configuration
decorators
dummy_authoriser
exceptions
Broadcast
Broadcast
types
utils
Client
Client
broadcast_handler
broadcast_handler_implementation
configuration
grpc_stdout_broadcast_handler
kafka_stdout_broadcast_handler
Server
Server
broadcast_sender
broadcast_sender_implementation
configuration
decorators
grpc_servicer
kafka_sender
kafka_sender
Table of contents
kafka_sender
Connectivity service
Connectivity service
client
exceptions
Controller
Controller
configuration
controller
controller_actor
controller_driver
decorators
exceptions
stateful_node
utils
Children interface
Children interface
child_node
client_side_state
grpc_child
rest_api_child
Interface
Interface
commands
context
controller
shell
shell_utils
Fsm
Fsm
action_factory
configuration
core
exceptions
transition
utils
Actions
Actions
db_run_registry
file_logbook
file_run_registry
some_test_action
thread_pinning
trigger_rate_specifier
user_provided_run_number
usvc_elisa_logbook
usvc_provided_run_number
utils
Timing
Timing
master_send_fl_command
Grpc testing tools
Grpc testing tools
available_grpc_servers
child_controller
child_controller_server_cli
connection_utils
grpc_log_file_manager
grpc_log_util
grpc_running_server_data
grpc_server_config
grpc_server_manager
grpc_testing_ports
multiprocessing_connection_manager
port_cleaner
process_connection_manager
process_manager
process_manager_server_cli
root_controller
root_controller_server_cli
run_grpc_services
test_services_pb2
test_services_pb2_grpc
Process manager
Process manager
configuration
exceptions
k8s_process_manager
oks_parser
process_manager
process_manager_driver
ssh_process_manager
ssh_process_manager_paramiko_client
ssh_process_manager_shell
utils
Interface
Interface
cli_argument
commands
context
process_manager
shell
Processes
Processes
ssh_process_lifetime_manager
ssh_process_lifetime_manager_paramiko
ssh_process_lifetime_manager_shell
Session manager
Session manager
configuration
exceptions
session_manager
session_manager_driver
Interface
Interface
session_manager
Unified shell
Unified shell
commands
context
shell
shell_utils
Utils
Utils
configuration
flask_manager
grpc_utils
shell_utils
utils
Developer documentation
Developer documentation
Base
Base
Release notes
FAQs
FAQs
SSH key setup
Troubleshooting
Operation
Operation
Connectivity service
Controller
FSM
Process manager
Unified shell
Setup
Setup
Running drunc fddaq v5.1.0
Setup drunc with DUNE DAQ
Testing
Testing
Testing prior to PR merges
Update documentation
Update documentation
How to Update Developer Documentation
Table of contents
kafka_sender
kafka_sender
drunc.broadcast.server.kafka_sender