Struct RiBaseProtocol 

pub struct RiBaseProtocol { /* private fields */ }

Implementations

impl RiBaseProtocol

pub fn new(receiver_id: String) -> Self

pub async fn is_ready(&self) -> bool

pub async fn initialize(&mut self, config: RiProtocolConfig)

pub async fn send_message( &mut self, _target: &str, data: &[u8], ) -> RiResult<Vec<u8>>

pub async fn receive_message(&mut self) -> RiResult<Vec<u8>>

pub async fn get_connection_info( &self, connection_id: &str, ) -> RiResult<RiConnectionInfo>

pub async fn close_connection(&mut self, connection_id: &str) -> RiResult<()>

pub fn get_stats(&self) -> RiProtocolStats

pub async fn get_health(&self) -> RiProtocolHealth

pub async fn shutdown(&mut self)

Trait Implementations

impl Clone for RiBaseProtocol

fn clone(&self) -> RiBaseProtocol

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RiBaseProtocol

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

Formats the value using the given formatter.