Struct WorkerMetrics 

pub struct WorkerMetrics {
    pub jobs_processed: AtomicU64,
    pub jobs_succeeded: AtomicU64,
    pub jobs_failed: AtomicU64,
    pub jobs_retried: AtomicU64,
}

Performance and operational metrics for monitoring worker health.

These metrics provide insight into worker performance and can be used for monitoring, alerting, and performance optimization.

All metrics use atomic integers for thread-safe updates and reads.

Metrics Tracked

• jobs_processed: Total number of jobs dequeued and processed
• jobs_succeeded: Number of jobs that completed successfully
• jobs_failed: Number of jobs that failed permanently (after all retries)
• jobs_retried: Total number of retry attempts across all jobs

Examples

use riglr_core::{ToolWorker, ExecutionConfig, idempotency::InMemoryIdempotencyStore};
use std::sync::atomic::Ordering;

let worker = ToolWorker::<InMemoryIdempotencyStore>::new(
    ExecutionConfig::default()
);

let metrics = worker.metrics();

// Read current metrics
let processed = metrics.jobs_processed.load(Ordering::Relaxed);
let succeeded = metrics.jobs_succeeded.load(Ordering::Relaxed);
let failed = metrics.jobs_failed.load(Ordering::Relaxed);
let retried = metrics.jobs_retried.load(Ordering::Relaxed);

println!("Worker Stats:");
println!("  Processed: {}", processed);
println!("  Succeeded: {}", succeeded);
println!("  Failed: {}", failed);
println!("  Retried: {}", retried);
println!("  Success Rate: {:.2}%",
    if processed > 0 { (succeeded as f64 / processed as f64) * 100.0 } else { 0.0 });

Fields

jobs_processed: AtomicU64

Total number of jobs processed (dequeued and executed)

jobs_succeeded: AtomicU64

Number of jobs that completed successfully

jobs_failed: AtomicU64

Number of jobs that failed permanently (after all retries)

jobs_retried: AtomicU64

Total number of retry attempts across all jobs

Trait Implementations

impl Debug for WorkerMetrics

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

Formats the value using the given formatter.

impl Default for WorkerMetrics

fn default() -> WorkerMetrics

Returns the “default value” for a type.