pub struct ActorAttrsView {Show 13 fields
pub status: String,
pub status_reason: Option<String>,
pub actor_type: String,
pub instance_id: String,
pub messages_processed: u64,
pub created_at: Option<SystemTime>,
pub last_handler: Option<String>,
pub total_processing_time_us: u64,
pub queue_depth: u64,
pub flight_recorder: Option<String>,
pub is_system: bool,
pub inbound_ordering: Option<OrderingSnapshot>,
pub failure: Option<FailureAttrs>,
}Expand description
Typed view over attrs for an actor node.
Fields§
§status: StringLifecycle status: “running”, “stopped”, “failed”.
status_reason: Option<String>Reason for stop/failure, if any.
actor_type: StringFully-qualified actor type name.
instance_id: StringStable per-instance identifier (Uuid::now_v7) as a string.
messages_processed: u64Number of messages processed.
created_at: Option<SystemTime>When this actor was created.
last_handler: Option<String>Name of the last message handler invoked.
total_processing_time_us: u64Total CPU time in message handlers (microseconds).
queue_depth: u64Accepted handler work not yet dequeued by the actor loop
(PD-5a/b). Independent diagnostic from inbound_ordering;
no arithmetic contract between the two – see IO-3. Defaults
to 0 when the attr is absent.
flight_recorder: Option<String>Flight recorder JSON, if available.
is_system: boolWhether this is a system/infrastructure actor.
inbound_ordering: Option<OrderingSnapshot>Per-session reorder state. None means no snapshot callback was
installed (structural absence per IO-1); Some({enabled: false, ..})
means buffering is disabled; Some({enabled: true, ..}) means active.
Consumers must distinguish all three states.
failure: Option<FailureAttrs>Failure details, present iff status == “failed”.
Implementations§
Source§impl ActorAttrsView
impl ActorAttrsView
Sourcepub fn from_attrs(attrs: &Attrs) -> Result<Self, AttrsViewError>
pub fn from_attrs(attrs: &Attrs) -> Result<Self, AttrsViewError>
Decode from an Attrs bag (AV-2, AV-3). Requires STATUS
and ACTOR_TYPE. Enforces IA-3 (status_reason must not be
present for non-terminal status), IA-4 (failure attrs iff
failed), and failure completeness (if any required failure
key is present, all three required keys must be).
Trait Implementations§
Source§impl Clone for ActorAttrsView
impl Clone for ActorAttrsView
Source§fn clone(&self) -> ActorAttrsView
fn clone(&self) -> ActorAttrsView
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for ActorAttrsView
impl Debug for ActorAttrsView
Source§impl PartialEq for ActorAttrsView
impl PartialEq for ActorAttrsView
impl StructuralPartialEq for ActorAttrsView
Auto Trait Implementations§
impl Freeze for ActorAttrsView
impl RefUnwindSafe for ActorAttrsView
impl Send for ActorAttrsView
impl Sync for ActorAttrsView
impl Unpin for ActorAttrsView
impl UnsafeUnpin for ActorAttrsView
impl UnwindSafe for ActorAttrsView
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
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>
§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>
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>
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§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Layered].