pub struct ProcSupervisionState {
pub world_id: WorldId,
pub proc_id: ProcId,
pub proc_addr: ChannelAddr,
pub proc_health: ProcStatus,
pub failed_actors: Vec<(ActorId, ActorStatus)>,
}
Expand description
The supervision state of a proc. It contains the supervision state of actors in the proc. This message is used for both supervision update and supervision state query.
Fields§
§world_id: WorldId
The world to which this proc belongs.
proc_id: ProcId
The proc id.
proc_addr: ChannelAddr
Address of the proc.
proc_health: ProcStatus
The proc health.
failed_actors: Vec<(ActorId, ActorStatus)>
Contains the supervision state of (failed) actors in the proc. Actors can appear more than once here if they have multiple failures
Implementations§
Source§impl ProcSupervisionState
impl ProcSupervisionState
Sourcepub fn has_failed_actor(&self) -> bool
pub fn has_failed_actor(&self) -> bool
Returns whether this proc has any failed actors.
Sourcepub fn is_healthy(&self) -> bool
pub fn is_healthy(&self) -> bool
Return whether this proc is healthy, proc is alive and there is not failed actor.
Trait Implementations§
Source§impl Clone for ProcSupervisionState
impl Clone for ProcSupervisionState
Source§fn clone(&self) -> ProcSupervisionState
fn clone(&self) -> ProcSupervisionState
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 moreSource§impl Debug for ProcSupervisionState
impl Debug for ProcSupervisionState
Source§impl<'de> Deserialize<'de> for ProcSupervisionState
impl<'de> Deserialize<'de> for ProcSupervisionState
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
Source§impl Named for ProcSupervisionState
impl Named for ProcSupervisionState
Source§fn typename() -> &'static str
fn typename() -> &'static str
The globally unique type name for the type.
This should typically be the fully qualified Rust name of the type.
Source§fn typehash() -> u64
fn typehash() -> u64
A globally unique hash for this type.
TODO: actually enforce perfect hashing
Source§fn typeid() -> TypeId
fn typeid() -> TypeId
The TypeId for this type. TypeIds are unique only within a binary,
and should not be used for global identification.
Source§fn port() -> u64
fn port() -> u64
The globally unique port for this type. Typed ports are in the range
of 1<<63..1<<64-1.
Source§impl PartialEq for ProcSupervisionState
impl PartialEq for ProcSupervisionState
Source§impl Serialize for ProcSupervisionState
impl Serialize for ProcSupervisionState
impl StructuralPartialEq for ProcSupervisionState
Auto Trait Implementations§
impl Freeze for ProcSupervisionState
impl RefUnwindSafe for ProcSupervisionState
impl Send for ProcSupervisionState
impl Sync for ProcSupervisionState
impl Unpin for ProcSupervisionState
impl UnwindSafe for ProcSupervisionState
Blanket Implementations§
§impl<T> AnySync for T
impl<T> AnySync for T
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> Checkpointable for Twhere
T: RemoteMessage + Clone,
impl<T> Checkpointable for Twhere
T: RemoteMessage + Clone,
Source§type State = T
type State = T
The type of the state that is saved. The state can be serialized and deserialized
from persistent storage.
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<A, M> Handler<IndexedErasedUnbound<M>> for A
impl<A, M> Handler<IndexedErasedUnbound<M>> for A
§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 more