Struct RefillChannels

pub struct RefillChannels {
    pub tx_refill_to_relay_manager: AquaSender<InternalCommand>,
    pub rx_refill_from_relay_manager: AquaReceiver<bool>,
    pub tx_refill_to_signal_handler: AquaSender<bool>,
    pub rx_refill_from_signal_handler: AquaReceiver<InternalCommand>,
    pub tx_refill_to_schedule_check: AquaSender<InternalCommand>,
    pub rx_refill_from_schedule_check: AquaReceiver<bool>,
    pub rx_refill_from_messaging_opt: Option<AquaReceiver<InternalCommand>>,
    pub tx_refill_to_monitors: AquaSender<RefillMonitorView>,
}

Struct collects the channels for the communication between the refill control and the other components. Additionally, the struct contains counters for debug purposes. The implementation of the struct contains functions for those channels which are frequently used. The functions increment the usage counters.

Fields

tx_refill_to_relay_manager: AquaSender<InternalCommand>

Sender part of the channel for communication to relay manager

rx_refill_from_relay_manager: AquaReceiver<bool>

Receiver part of the channel for communication from the relay manager

tx_refill_to_signal_handler: AquaSender<bool>

Sender part of the channel for communication to the signal handler

rx_refill_from_signal_handler: AquaReceiver<InternalCommand>

Receiver part of the channel for communication from the signal handler

tx_refill_to_schedule_check: AquaSender<InternalCommand>

Sender part of the channel for communication to the schedule checker

rx_refill_from_schedule_check: AquaReceiver<bool>

Receiver part of the channel for communication from the schedule checker

rx_refill_from_messaging_opt: Option<AquaReceiver<InternalCommand>>

Receiver part of the channel for communication from the messaging

tx_refill_to_monitors: AquaSender<RefillMonitorView>

Sender part of the channel for communication to the monitors

Implementations

impl RefillChannels

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

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

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

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

pub fn send_to_monitor( &mut self, view: RefillMonitorView, ) -> Result<(), AquaChannelError>

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

Trait Implementations

impl AcknowledgeSignalHandlerTrait for RefillChannels

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 RefillChannels

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

Formats the value using the given formatter.