Struct BallingChannels

pub struct BallingChannels {
    pub tx_balling_to_relay_manager: AquaSender<InternalCommand>,
    pub rx_balling_from_relay_manager: AquaReceiver<bool>,
    pub tx_balling_to_signal_handler: AquaSender<bool>,
    pub rx_balling_from_signal_handler: AquaReceiver<InternalCommand>,
    pub tx_balling_to_schedule_check: AquaSender<InternalCommand>,
    pub rx_balling_from_schedule_check: AquaReceiver<bool>,
    pub rx_balling_from_messaging_opt: Option<AquaReceiver<InternalCommand>>,
}

Container for the channels used by Balling for inter-thread communication

Fields

tx_balling_to_relay_manager: AquaSender<InternalCommand>

sender part of the channel for communication to relay manager

rx_balling_from_relay_manager: AquaReceiver<bool>

receiver part of the channel for communication from the relay manager

tx_balling_to_signal_handler: AquaSender<bool>

sender part of the channel for communication to the signal handler

rx_balling_from_signal_handler: AquaReceiver<InternalCommand>

receiver part of the channel for communication from the signal handler

tx_balling_to_schedule_check: AquaSender<InternalCommand>

sender part of the channel for communication to the schedule checker

rx_balling_from_schedule_check: AquaReceiver<bool>

receiver part of the channel for communication from the schedule checker

rx_balling_from_messaging_opt: Option<AquaReceiver<InternalCommand>>

receiver part of the channel communication wrapped in Option from Messaging

Implementations

impl BallingChannels

pub fn send_to_relay_manager( &mut self, command: InternalCommand, ) -> Result<(), AquaChannelError>

Sends a command to the relay manager.

pub fn receive_from_relay_manager(&mut self) -> Result<bool, AquaChannelError>

Receives a response from the relay manager.

pub fn send_to_signal_handler( &mut self, ack: bool, ) -> Result<(), AquaChannelError>

Sends an acknowledgment to the signal handler.

pub fn send_to_schedule_check( &mut self, command: InternalCommand, ) -> Result<(), AquaChannelError>

Sends a command to the schedule checker.

pub fn receive_from_schedule_check(&mut self) -> Result<bool, AquaChannelError>

Receives a response from the schedule checker.

Trait Implementations

impl AcknowledgeSignalHandlerTrait for BallingChannels

fn send_true_to_signal_handler(&mut self) -> Result<(), AquaChannelError>

Sends the raw acknowledgment message (true) to the SignalHandler.

fn location(&self) -> String

Returns the source location (module path) for logging purposes.

fn acknowledge_signal_handler(&mut self)

Acknowledges the SignalHandler by sending a confirmation message.

impl Display for BallingChannels

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.