Struct BudgetState 

pub struct BudgetState {
    pub total_input_tokens: u64,
    pub total_output_tokens: u64,
    pub total_cost_usd: f64,
    pub iteration_count: u32,
    pub tool_call_count: u32,
    pub consecutive_error_count: u32,
    pub circuit_breaker_tripped: bool,
}

Accumulated runtime budget for a single workflow execution.

Embedded in Snapshot.state under "__budget". Updated after every NodeCompleted event that carries token / cost telemetry.

Fields

total_input_tokens: u64

total_output_tokens: u64

total_cost_usd: f64

iteration_count: u32

Number of agent reasoning iterations across all agent nodes.

tool_call_count: u32

Number of tool calls across all nodes.

consecutive_error_count: u32

Consecutive error count for circuit-breaker logic.

circuit_breaker_tripped: bool

True once the circuit breaker has fired for this execution.

Implementations

impl BudgetState

pub fn total_tokens(&self) -> u64

Total tokens (input + output).

pub fn from_snapshot_state(state: &Value) -> Self

Load BudgetState from the __budget key of a snapshot state value.

pub fn patch_into_snapshot_state(&self, state: &mut Value)

Merge this BudgetState back into the snapshot state JSON as __budget.

pub fn accumulate( &mut self, input_tokens: Option<u64>, output_tokens: Option<u64>, cost_usd: Option<f64>, )

Accumulate token / cost values from a completed model node.

pub fn record_success(&mut self)

Record a successful node — resets the consecutive error counter.

pub fn record_error(&mut self)

Record a failed node — increments the consecutive error counter.

Trait Implementations

impl Clone for BudgetState

fn clone(&self) -> BudgetState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BudgetState

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

Formats the value using the given formatter.

impl Default for BudgetState

fn default() -> BudgetState

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for BudgetState

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for BudgetState

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.