pub struct RelayManagerChannels {
pub tx_relay_manager_to_refill: AquaSender<bool>,
pub rx_relay_manager_from_refill: AquaReceiver<InternalCommand>,
pub tx_relay_manager_to_heating: AquaSender<bool>,
pub rx_relay_manager_from_heating: AquaReceiver<InternalCommand>,
pub tx_relay_manager_to_ventilation: AquaSender<bool>,
pub rx_relay_manager_from_ventilation: AquaReceiver<InternalCommand>,
pub tx_relay_manager_to_balling: AquaSender<bool>,
pub rx_relay_manager_from_balling: AquaReceiver<InternalCommand>,
pub tx_relay_manager_to_feed: AquaSender<bool>,
pub rx_relay_manager_from_feed: AquaReceiver<InternalCommand>,
pub tx_relay_manager_to_signal_handler: AquaSender<bool>,
pub rx_relay_manager_from_signal_handler: AquaReceiver<InternalCommand>,
}Expand description
Container for channels used by relay manager
Fields§
§tx_relay_manager_to_refill: AquaSender<bool>sender part of the channel for communication to the refill thread
rx_relay_manager_from_refill: AquaReceiver<InternalCommand>receiver part of the channel for communication from the refill thread
tx_relay_manager_to_heating: AquaSender<bool>sender part of the channel for communication to the heating thread
rx_relay_manager_from_heating: AquaReceiver<InternalCommand>receiver part of the channel for communication from the heating thread
tx_relay_manager_to_ventilation: AquaSender<bool>sender part of the channel for communication to the ventilation thread
rx_relay_manager_from_ventilation: AquaReceiver<InternalCommand>receiver part of the channel for communication from the ventilation thread
tx_relay_manager_to_balling: AquaSender<bool>sender part of the channel for communication to the Balling dosing thread
rx_relay_manager_from_balling: AquaReceiver<InternalCommand>receiver part of the channel for communication from the Balling dosing thread
tx_relay_manager_to_feed: AquaSender<bool>sender part of the channel for communication to the feed thread
rx_relay_manager_from_feed: AquaReceiver<InternalCommand>receiver part of the channel for communication from the feed thread
tx_relay_manager_to_signal_handler: AquaSender<bool>sender part of the channel for communication to the signal handler
rx_relay_manager_from_signal_handler: AquaReceiver<InternalCommand>receiver part of the channel for communication from the signal handler
Implementations§
Source§impl RelayManagerChannels
impl RelayManagerChannels
Sourcepub fn send_to_refill(&mut self, ack: bool) -> Result<(), AquaChannelError>
pub fn send_to_refill(&mut self, ack: bool) -> Result<(), AquaChannelError>
Sends a response to the refill module.
Sourcepub fn receive_from_refill(
&mut self,
) -> Result<InternalCommand, AquaChannelError>
pub fn receive_from_refill( &mut self, ) -> Result<InternalCommand, AquaChannelError>
Receives a command from the refill module (non-blocking).
Sourcepub fn send_to_heating(&mut self, ack: bool) -> Result<(), AquaChannelError>
pub fn send_to_heating(&mut self, ack: bool) -> Result<(), AquaChannelError>
Sends a response to the heating module.
Sourcepub fn receive_from_heating(
&mut self,
) -> Result<InternalCommand, AquaChannelError>
pub fn receive_from_heating( &mut self, ) -> Result<InternalCommand, AquaChannelError>
Receives a command from the heating module (non-blocking).
Sourcepub fn send_to_ventilation(&mut self, ack: bool) -> Result<(), AquaChannelError>
pub fn send_to_ventilation(&mut self, ack: bool) -> Result<(), AquaChannelError>
Sends a response to the ventilation module.
Sourcepub fn receive_from_ventilation(
&mut self,
) -> Result<InternalCommand, AquaChannelError>
pub fn receive_from_ventilation( &mut self, ) -> Result<InternalCommand, AquaChannelError>
Receives a command from the ventilation module (non-blocking).
Sourcepub fn send_to_balling(&mut self, ack: bool) -> Result<(), AquaChannelError>
pub fn send_to_balling(&mut self, ack: bool) -> Result<(), AquaChannelError>
Sends a response to the balling module.
Sourcepub fn receive_from_balling(
&mut self,
) -> Result<InternalCommand, AquaChannelError>
pub fn receive_from_balling( &mut self, ) -> Result<InternalCommand, AquaChannelError>
Receives a command from the balling module (non-blocking).
Sourcepub fn send_to_feed(&mut self, ack: bool) -> Result<(), AquaChannelError>
pub fn send_to_feed(&mut self, ack: bool) -> Result<(), AquaChannelError>
Sends a response to the feed module.
Sourcepub fn receive_from_feed(&mut self) -> Result<InternalCommand, AquaChannelError>
pub fn receive_from_feed(&mut self) -> Result<InternalCommand, AquaChannelError>
Receives a command from the feed module (non-blocking).
Sourcepub fn send_to_signal_handler(
&mut self,
ack: bool,
) -> Result<(), AquaChannelError>
pub fn send_to_signal_handler( &mut self, ack: bool, ) -> Result<(), AquaChannelError>
Sends a response to the signal handler.
Sourcepub fn receive_from_signal_handler(
&mut self,
) -> Result<InternalCommand, AquaChannelError>
pub fn receive_from_signal_handler( &mut self, ) -> Result<InternalCommand, AquaChannelError>
Receives a command from the signal handler (non-blocking).
Trait Implementations§
Source§impl AcknowledgeSignalHandlerTrait for RelayManagerChannels
impl AcknowledgeSignalHandlerTrait for RelayManagerChannels
Source§fn send_true_to_signal_handler(&mut self) -> Result<(), AquaChannelError>
fn send_true_to_signal_handler(&mut self) -> Result<(), AquaChannelError>
Source§fn location(&self) -> String
fn location(&self) -> String
Source§fn acknowledge_signal_handler(&mut self)
fn acknowledge_signal_handler(&mut self)
SignalHandler by sending a confirmation message. Read more