Struct ActorMetrics 

pub struct ActorMetrics {
    pub messages_received: AtomicU64,
    pub messages_processed: AtomicU64,
    pub messages_failed: AtomicU64,
    pub heartbeats: AtomicU64,
    pub last_message_at: AtomicU64,
    pub restart_count: AtomicU64,
    pub llm_input_tokens: AtomicU64,
    pub llm_output_tokens: AtomicU64,
    pub llm_cost_nano_usd: AtomicU64,
}

Atomic runtime counters for an actor.

All fields use relaxed ordering because cross-thread ordering guarantees are not required for telemetry — occasional skew is acceptable.

Fields

messages_received: AtomicU64

Total messages received since the actor started.

messages_processed: AtomicU64

Total messages successfully processed.

messages_failed: AtomicU64

Total messages that raised an error during processing.

heartbeats: AtomicU64

Number of heartbeat ticks emitted.

last_message_at: AtomicU64

UNIX timestamp (seconds) of the last received message.

restart_count: AtomicU64

Number of supervisor-triggered restarts for this actor.

llm_input_tokens: AtomicU64

Total LLM input tokens consumed by this actor.

llm_output_tokens: AtomicU64

Total LLM output tokens produced by this actor.

llm_cost_nano_usd: AtomicU64

Total LLM cost in nano-USD (divide by 1_000_000_000 for USD).

Implementations

impl ActorMetrics

pub fn new() -> Self

pub fn record_received(&self)

pub fn record_processed(&self)

pub fn record_failed(&self)

pub fn record_heartbeat(&self)

pub fn record_restart(&self)

pub fn record_llm_usage( &self, input_tokens: u64, output_tokens: u64, cost_nano_usd: u64, )

Record LLM usage: token counts and cost (in nano-USD).

pub fn snapshot(&self) -> MetricsSnapshot

Snapshot current counters as a serializable struct.

Trait Implementations

impl Debug for ActorMetrics

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ActorMetrics

fn default() -> ActorMetrics

Returns the “default value” for a type.