Struct MonitorsChannels

pub struct MonitorsChannels {
    pub rx_monitors_from_refill: AquaReceiver<RefillMonitorView>,
    pub tx_monitors_to_signal_handler: AquaSender<bool>,
    pub rx_monitors_from_signal_handler: AquaReceiver<InternalCommand>,
    pub rx_monitors_from_messaging_opt: Option<AquaReceiver<InternalCommand>>,
}

Struct collects the channels for communication between Monitors and other components.

Fields

rx_monitors_from_refill: AquaReceiver<RefillMonitorView>

Receiver part of the channel for communication from Refill

tx_monitors_to_signal_handler: AquaSender<bool>

Sender part of the channel for communication to the signal handler

rx_monitors_from_signal_handler: AquaReceiver<InternalCommand>

Receiver part of the channel for communication from the signal handler

rx_monitors_from_messaging_opt: Option<AquaReceiver<InternalCommand>>

Receiver part of the channel for communication from the messaging

Implementations

impl MonitorsChannels

pub fn receive_from_refill( &mut self, ) -> Result<RefillMonitorView, AquaChannelError>

Receives a monitor view from the refill module.

This wrapper performs a non-blocking receive-operation and increments the debug counter on success.

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

Sends an acknowledgment to the signal handler.

This wrapper sends a boolean acknowledgment and increments the debug counter.

pub fn receive_from_signal_handler( &mut self, ) -> Result<InternalCommand, AquaChannelError>

Receives a command from the signal handler.

This wrapper performs a non-blocking receive-operation and increments the debug counter on success.

pub fn receive_from_messaging( &mut self, ) -> Option<Result<InternalCommand, AquaChannelError>>

Receives a command from messaging if the channel exists.

This wrapper performs a non-blocking receive-operation and increments the debug counter on success.

Trait Implementations

impl AcknowledgeSignalHandlerTrait for MonitorsChannels

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 MonitorsChannels

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

Formats the value using the given formatter.