pub struct Member {
pub node_id: NodeId,
pub address: SocketAddr,
pub health: NodeHealth,
pub last_seen: DateTime<Utc>,
pub incarnation: u64,
pub metadata: HashMap<String, String>,
pub failure_count: u32,
}Expand description
Member information in the gossip protocol
Fields§
§node_id: NodeIdNode identifier
address: SocketAddrNetwork address
health: NodeHealthCurrent health status
last_seen: DateTime<Utc>Last time we heard from this node
incarnation: u64Incarnation number (for conflict resolution)
metadata: HashMap<String, String>Node metadata
failure_count: u32Number of consecutive ping failures
Implementations§
Source§impl Member
impl Member
Sourcepub fn new(node_id: NodeId, address: SocketAddr) -> Self
pub fn new(node_id: NodeId, address: SocketAddr) -> Self
Create a new member
Sourcepub fn is_healthy(&self) -> bool
pub fn is_healthy(&self) -> bool
Check if member is healthy
Sourcepub fn increment_failures(&mut self)
pub fn increment_failures(&mut self)
Increment failure count
Trait Implementations§
Source§impl<'de> Deserialize<'de> for Member
impl<'de> Deserialize<'de> for Member
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations§
impl Freeze for Member
impl RefUnwindSafe for Member
impl Send for Member
impl Sync for Member
impl Unpin for Member
impl UnwindSafe for Member
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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