pub struct DMSCBaseProtocol { /* private fields */ }Implementations§
Source§impl DMSCBaseProtocol
impl DMSCBaseProtocol
pub fn new(receiver_id: String) -> Self
pub async fn is_ready(&self) -> bool
pub async fn initialize(&mut self, config: DMSCProtocolConfig)
pub async fn send_message( &mut self, _target: &str, data: &[u8], ) -> DMSCResult<Vec<u8>>
pub async fn receive_message(&mut self) -> DMSCResult<Vec<u8>>
pub async fn get_connection_info( &self, connection_id: &str, ) -> DMSCResult<DMSCConnectionInfo>
pub async fn close_connection(&mut self, connection_id: &str) -> DMSCResult<()>
pub fn get_stats(&self) -> DMSCProtocolStats
pub async fn get_health(&self) -> DMSCProtocolHealth
pub async fn shutdown(&mut self)
Trait Implementations§
Source§impl Clone for DMSCBaseProtocol
impl Clone for DMSCBaseProtocol
Source§fn clone(&self) -> DMSCBaseProtocol
fn clone(&self) -> DMSCBaseProtocol
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for DMSCBaseProtocol
impl !RefUnwindSafe for DMSCBaseProtocol
impl Send for DMSCBaseProtocol
impl Sync for DMSCBaseProtocol
impl Unpin for DMSCBaseProtocol
impl !UnwindSafe for DMSCBaseProtocol
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::RequestSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request