pub struct TransportSignalPlane { /* private fields */ }Expand description
SWIM-style signal-plane engine over the secured intra-cluster transport.
Implementations§
Source§impl TransportSignalPlane
impl TransportSignalPlane
pub fn new( local_member: String, transport: SharedSignalTransport, limits: SignalPlaneLimits, ) -> TransportSignalPlane
pub fn advance_round(&mut self)
pub fn knows(&self, message: &SignalPlaneMessage) -> bool
pub fn metrics(&self) -> SignalPlaneMetrics
Trait Implementations§
Source§impl Debug for TransportSignalPlane
impl Debug for TransportSignalPlane
Source§impl SignalPlane for TransportSignalPlane
impl SignalPlane for TransportSignalPlane
Source§fn set_members(&mut self, members: Vec<String>)
fn set_members(&mut self, members: Vec<String>)
Replace the admitted-member set this signal plane may talk to.
Source§fn publish(&mut self, from: String, message: SignalPlaneMessage)
fn publish(&mut self, from: String, message: SignalPlaneMessage)
Publish a non-authoritative signal from an admitted member.
Source§fn drain_received(&mut self, member: &String) -> Vec<ReceivedSignal>
fn drain_received(&mut self, member: &String) -> Vec<ReceivedSignal>
Drain signals delivered to
member.Auto Trait Implementations§
impl Freeze for TransportSignalPlane
impl RefUnwindSafe for TransportSignalPlane
impl Send for TransportSignalPlane
impl Sync for TransportSignalPlane
impl Unpin for TransportSignalPlane
impl UnsafeUnpin for TransportSignalPlane
impl UnwindSafe for TransportSignalPlane
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