Struct RunBudgetExceededEvent 

pub struct RunBudgetExceededEvent {
    pub run_id: Uuid,
    pub workflow_name: String,
    pub limit_usd: Decimal,
    pub spent_usd: Decimal,
    pub step_budget_usd: Decimal,
    pub at: DateTime<Utc>,
}

Payload of the Event::RunBudgetExceeded event.

Examples

use chrono::Utc;
use ironflow_engine::notify::RunBudgetExceededEvent;
use rust_decimal::Decimal;
use uuid::Uuid;

let payload = RunBudgetExceededEvent {
    run_id: Uuid::now_v7(),
    workflow_name: "deploy".to_string(),
    limit_usd: Decimal::new(200, 2),
    spent_usd: Decimal::new(180, 2),
    step_budget_usd: Decimal::new(50, 2),
    at: Utc::now(),
};
assert_eq!(payload.limit_usd, Decimal::new(200, 2));

Fields

run_id: Uuid

Run identifier.

workflow_name: String

Workflow name.

limit_usd: Decimal

The configured cost cap in USD.

spent_usd: Decimal

Cost already consumed when the cap was reached, in USD.

step_budget_usd: Decimal

Declared budget of the refused step, in USD.

at: DateTime<Utc>

When the refusal occurred.

Trait Implementations

impl Clone for RunBudgetExceededEvent

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RunBudgetExceededEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RunBudgetExceededEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RunBudgetExceededEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.