pub struct IntraClusterSignalBus { /* private fields */ }Expand description
Secured member-to-member signal transport for admitted cluster members.
Implementations§
Source§impl IntraClusterSignalBus
impl IntraClusterSignalBus
pub fn new(limits: SignalPlaneLimits) -> IntraClusterSignalBus
pub fn set_limits(&mut self, limits: SignalPlaneLimits)
pub fn set_admitted_members(&mut self, members: Vec<String>)
pub fn register_endpoint(&mut self, member: String)
pub fn unregister_endpoint(&mut self, member: &String)
pub fn send(&mut self, frame: SignalFrame) -> Result<(), SignalTransportError>
pub fn drain(&mut self, member: String) -> Vec<SignalFrame>
pub fn metrics(&self) -> SignalPlaneMetrics
Trait Implementations§
Source§impl Debug for IntraClusterSignalBus
impl Debug for IntraClusterSignalBus
Source§impl Default for IntraClusterSignalBus
impl Default for IntraClusterSignalBus
Source§fn default() -> IntraClusterSignalBus
fn default() -> IntraClusterSignalBus
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for IntraClusterSignalBus
impl RefUnwindSafe for IntraClusterSignalBus
impl Send for IntraClusterSignalBus
impl Sync for IntraClusterSignalBus
impl Unpin for IntraClusterSignalBus
impl UnsafeUnpin for IntraClusterSignalBus
impl UnwindSafe for IntraClusterSignalBus
Blanket Implementations§
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§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> 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> 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::Request