Struct ChannelServer

pub struct ChannelServer { /* private fields */ }

Channel server

• channel server will handle query and broadcast transmissions between two machines

Implementations

impl ChannelServer

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

Build channel server

• addr: A : Socket address to be bound to
• A: ToSocketAddrs : type of the socket address
• Output: the channel server or an error

pub async fn kill(&mut self)

Kill the server

pub async fn accept( &mut self, clients: &mut HashSet<SocketAddr>, capacity: Option<usize>, ) -> Result<(), String>

Accept a list of clients

• clients: &mut HashSet<SocketAddr> : list of clients identified with their socket address
• capacity: Option<usize> : size parameter for defining bounded or unbounnded channels Nothing or an error

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

where U: SlxData, V: SlxData,

Register a query receiver 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 receiver for archived data

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

where U: SlxData,

Register a broadcast receiver for archived data

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

Trait Implementations

impl Debug for ChannelServer

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

Formats the value using the given formatter.