Struct ChannelClient

pub struct ChannelClient { /* private fields */ }

Channel client

• channel lient will connect to channel server for query and broadcast transmissions between two machines

Implementations

impl ChannelClient

pub async fn kill(&mut self)

Kill the client

pub async fn connect<A: ToSocketAddrs>( id_client: SocketAddr, addr: A, ) -> Result<Self, String>

Connect to a channel server and build a channel client

• id_client: SocketAddr : socket address of the client
• addr: A : socket address of the channel server
• A: ToSocketAddrs : type of the server socket address
• Output: the channel client or an error

pub async fn sender_query<U, V>( &mut self, channel: u64, capacity: Option<usize>, ) -> ArchQuerySender<U, V>

where U: SlxData, V: SlxData,

Register a query sender for archived data

• channel: ChannelIdType : channel identifier
• capacity: Option<usize> : size parameter for defining bounded or unbounnded channels
• U : type of the query data; needs to implement SlxData
• V : type of the reply data; needs to implement SlxData
• Output: query sender for archived data

pub async fn sender_broadcast<U>( &mut self, channel: u64, capacity: usize, ) -> RootArchBroadcastSender<U>

where U: SlxData,

Register a broadcast sender for archived data

• channel: ChannelIdType : channel identifier
• capacity: usize : capacity of the channel
• U : type of the data; needs to implement SlxData
• Output: broadcast sender for archived data

Trait Implementations

impl Debug for ChannelClient

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

Formats the value using the given formatter.