Struct AppState 

pub struct AppState { /* private fields */ }

Shared application state for metrics and status tracking.

This struct holds all the counters and state needed for the status endpoint. All fields are thread-safe and can be accessed concurrently.

Thread Safety

• start_time: Immutable after creation
• captures_processed: AtomicU64 for lock-free increments
• active_sse_connections: AtomicU64 for connection tracking
• latency_histogram: RwLock-wrapped for efficient reads

Usage

use std::sync::Arc;
use reasonkit_web::handlers::AppState;

let state = Arc::new(AppState::new());

// Record a capture
state.record_capture();

// Track SSE connection
state.increment_sse_connections();
// ... later
state.decrement_sse_connections();

// Record request latency
state.record_latency_us(12500); // 12.5ms

Implementations

impl AppState

pub fn new() -> Self

Create a new AppState instance with initial values.

The start time is set to the current instant.

pub fn uptime_seconds(&self) -> u64

Get the server uptime in seconds.

pub fn start_time(&self) -> Instant

Get the server start time.

pub fn captures_processed(&self) -> u64

Get the total number of captures processed.

pub fn record_capture(&self) -> u64

Increment the capture counter and return the new value.

pub fn active_sse_connections(&self) -> u64

Get the number of active SSE connections.

pub fn increment_sse_connections(&self) -> u64

Increment the SSE connection counter.

pub fn decrement_sse_connections(&self) -> u64

Decrement the SSE connection counter.

Uses saturating subtraction to prevent underflow.

pub fn record_latency_us(&self, latency_us: u64)

Record a request latency in microseconds.

pub fn record_latency(&self, duration: Duration)

Record a request latency duration.

pub fn latency_metrics(&self) -> LatencyMetrics

Get the latency metrics.

pub fn total_requests(&self) -> u64

Get the total number of requests processed.

pub fn record_error(&self) -> u64

Record an error.

pub fn error_count(&self) -> u64

Get the total error count.

pub fn reset_metrics(&self)

Reset all metrics (useful for testing).

Trait Implementations

impl Debug for AppState

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

Formats the value using the given formatter.

impl Default for AppState

fn default() -> Self

Returns the “default value” for a type.