pub struct RemoteSubscriptions { /* private fields */ }
Implementations§
Source§impl RemoteSubscriptions
impl RemoteSubscriptions
pub fn add_subscription(&self, source: Agent, name: Agent, conn: u64)
pub fn remove_subscription(&self, source: Agent, name: Agent, conn: u64)
pub fn get_subscriptions_on_connection( &self, conn: u64, ) -> HashSet<SubscriptionInfo>
pub fn remove_connection(&self, conn: u64)
Trait Implementations§
Source§impl Debug for RemoteSubscriptions
impl Debug for RemoteSubscriptions
Source§impl Default for RemoteSubscriptions
impl Default for RemoteSubscriptions
Source§fn default() -> RemoteSubscriptions
fn default() -> RemoteSubscriptions
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl !Freeze for RemoteSubscriptions
impl !RefUnwindSafe for RemoteSubscriptions
impl Send for RemoteSubscriptions
impl Sync for RemoteSubscriptions
impl Unpin for RemoteSubscriptions
impl UnwindSafe for RemoteSubscriptions
Blanket Implementations§
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> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§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
Source§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