Struct ExecutionUsage 

pub struct ExecutionUsage {
    pub execution_id: ExecutionId,
    pub tenant_id: TenantId,
    pub steps: AtomicU32,
    pub input_tokens: AtomicU32,
    pub output_tokens: AtomicU32,
    pub started_at: Instant,
    pub last_activity: RwLock<Instant>,
    pub discovered_steps: AtomicU32,
    pub discovery_depth: AtomicU32,
    pub max_discovery_depth_reached: AtomicU32,
    pub cost_cents: AtomicU64,
}

Tracks resource usage for a single execution

Fields

execution_id: ExecutionId

Execution ID

tenant_id: TenantId

Tenant ID

steps: AtomicU32

Number of steps executed

input_tokens: AtomicU32

Total input tokens consumed

output_tokens: AtomicU32

Total output tokens consumed

started_at: Instant

Wall clock start time

last_activity: RwLock<Instant>

Last activity timestamp

discovered_steps: AtomicU32

Number of dynamically discovered steps (StepSource::Discovered)

discovery_depth: AtomicU32

Current discovery chain depth (how deep in the discovery tree)

max_discovery_depth_reached: AtomicU32

Maximum discovery depth reached during execution

cost_cents: AtomicU64

Cumulative cost in cents (USD * 100 for integer precision)

Implementations

impl ExecutionUsage

pub fn new(execution_id: ExecutionId, tenant_id: TenantId) -> Self

Create a new usage tracker for an execution

pub fn record_step(&self)

Record step execution

pub fn record_discovered_step(&self)

Record a discovered step (dynamically added to DAG)

pub fn record_tokens(&self, input: u32, output: u32)

Record token usage

pub fn record_cost_usd(&self, cost_usd: f64)

Record cost in USD (converted to cents for storage)

pub fn push_discovery_depth(&self)

Push discovery depth (entering a discovered step)

pub fn pop_discovery_depth(&self)

Pop discovery depth (exiting a discovered step)

pub async fn touch(&self)

Update last activity timestamp

pub fn step_count(&self) -> u32

Get current step count

pub fn discovered_step_count(&self) -> u32

Get discovered step count

pub fn current_discovery_depth(&self) -> u32

Get current discovery depth

pub fn total_tokens(&self) -> u32

Get total token count

pub fn cost_usd(&self) -> f64

Get cumulative cost in USD

pub fn wall_time(&self) -> Duration

Get wall clock duration

pub fn wall_time_ms(&self) -> u64

Get wall time in milliseconds

pub async fn idle_duration(&self) -> Duration

Get idle duration (time since last activity)

pub async fn idle_seconds(&self) -> u64

Get idle duration in seconds

Trait Implementations

impl Debug for ExecutionUsage

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

Formats the value using the given formatter.

impl From<&ExecutionUsage> for UsageSnapshot

fn from(usage: &ExecutionUsage) -> Self

Converts to this type from the input type.