Enum EventKind 

pub enum EventKind {
    WorkflowStarted {
        workflow_id: String,
        workflow_version: String,
        initial_input: Value,
    },
    WorkflowCompleted {
        final_state: Value,
    },
    WorkflowFailed {
        error: String,
    },
    WorkflowCancelled {
        reason: Option<String>,
    },
    NodeScheduled {
        node_id: NodeId,
        queue_type: String,
    },
    NodeStarted {
        node_id: NodeId,
        worker_id: String,
        attempt: u32,
    },
    NodeCompleted {
        node_id: NodeId,
        output: Value,
        state_patch: Value,
        duration_ms: u64,
        gen_ai_system: Option<String>,
        gen_ai_model: Option<String>,
        input_tokens: Option<u64>,
        output_tokens: Option<u64>,
        finish_reason: Option<String>,
        cost_usd: Option<f64>,
        provenance: Option<Box<ProvenanceMetadata>>,
    },
    NodeFailed {
        node_id: NodeId,
        error: String,
        attempt: u32,
        retryable: bool,
    },
    NodeSkipped {
        node_id: NodeId,
        reason: String,
    },
    NodeCancelled {
        node_id: NodeId,
    },
    RetryScheduled {
        node_id: NodeId,
        attempt: u32,
        delay_ms: u64,
    },
    InterruptRaised {
        node_id: NodeId,
        reason: String,
        state_for_review: Value,
    },
    ApprovalReceived {
        node_id: NodeId,
        user_id: String,
        decision: ApprovalDecision,
        comment: Option<String>,
        state_patch: Option<Value>,
    },
    TimerCreated {
        node_id: NodeId,
        fire_at: DateTime<Utc>,
        correlation_key: Option<String>,
    },
    TimerFired {
        node_id: NodeId,
        correlation_key: Option<String>,
    },
    ExternalEventReceived {
        correlation_key: String,
        payload: Value,
    },
    ChildWorkflowStarted {
        node_id: NodeId,
        child_execution_id: String,
        child_workflow_id: String,
    },
    ChildWorkflowCompleted {
        node_id: NodeId,
        child_execution_id: String,
        result: Value,
    },
    ChildWorkflowFailed {
        node_id: NodeId,
        child_execution_id: String,
        error: String,
    },
    BudgetExceeded {
        node_id: NodeId,
        kind: String,
        limit: u64,
        current: u64,
    },
    TokenBudgetExceeded {
        node_id: NodeId,
        kind: String,
        limit: u64,
        current: u64,
    },
    CostBudgetExceeded {
        node_id: NodeId,
        limit_usd: f64,
        current_usd: f64,
    },
    AutonomyLimitReached {
        node_id: NodeId,
        agent_ref: String,
        limit_type: String,
        limit_value: Value,
        actual_value: Value,
    },
    CircuitBreakerTripped {
        node_id: NodeId,
        agent_ref: String,
        consecutive_errors: u32,
        threshold: u32,
    },
    EscalationRequired {
        node_id: NodeId,
        agent_ref: String,
        reason: String,
        escalation_target: String,
    },
    PolicyViolation {
        node_id: NodeId,
        rule: String,
        decision: String,
        policy_scope: String,
    },
    ToolApprovalRequired {
        node_id: NodeId,
        tool_name: String,
        approver: String,
        context: Value,
    },
    StrategyStarted {
        strategy: String,
        config: Value,
    },
    PlanGenerated {
        steps: Vec<String>,
    },
    IterationStarted {
        iteration: u32,
    },
    ToolCalled {
        node_id: NodeId,
        tool: String,
    },
    CriticVerdict {
        node_id: NodeId,
        score: f64,
        passed: bool,
        feedback: Option<String>,
    },
    IterationCompleted {
        iteration: u32,
        cost_delta_usd: Option<f64>,
        input_tokens: u64,
        output_tokens: u64,
    },
    StrategyLimitHit {
        limit_type: String,
        limit_value: Value,
        actual_value: Value,
    },
    StrategyCompleted {
        iterations: u32,
        total_cost_usd: Option<f64>,
    },
    CoordinatorDiscovery {
        node_id: NodeId,
        query_skills: Vec<String>,
        query_trust_domain: Option<String>,
        candidates: Vec<Value>,
        filtered_out: Vec<Value>,
    },
    CoordinatorScoring {
        node_id: NodeId,
        rankings: Vec<Value>,
        spread: f64,
        weights: Value,
    },
    CoordinatorDecision {
        node_id: NodeId,
        selected: Option<String>,
        method: String,
        reasoning: Option<String>,
        confidence: f64,
        rejected: Vec<Value>,
        tiebreaker_tokens: Option<Value>,
        tiebreaker_cost: Option<f64>,
    },
    AgentToolInvoked {
        node_id: NodeId,
        agent_uri: String,
        mode: String,
        protocol: String,
        input_hash: String,
    },
    AgentToolProgress {
        node_id: NodeId,
        chunk_index: u32,
        partial_output_summary: String,
    },
    AgentToolTurn {
        node_id: NodeId,
        turn_number: u32,
        direction: String,
        content_summary: String,
        tokens: u32,
        cost: f64,
    },
    AgentToolCompleted {
        node_id: NodeId,
        output: Value,
        provenance: Option<Value>,
        total_cost: f64,
        latency_ms: u64,
        total_turns: Option<u32>,
    },
    AgentToolTerminated {
        node_id: NodeId,
        reason: String,
        chunks_received: u32,
        partial_output: Option<Value>,
        cost: f64,
    },
    AgentToolFailed {
        node_id: NodeId,
        failure_type: String,
        message: String,
        retryable: bool,
    },
}

All possible event kinds in the JamJet event log.

Variants

WorkflowStarted

Fields

workflow_id: String

workflow_version: String

initial_input: Value

WorkflowCompleted

Fields

final_state: Value

WorkflowFailed

Fields

error: String

WorkflowCancelled

Fields

reason: Option<String>

NodeScheduled

Fields

node_id: NodeId

queue_type: String

NodeStarted

Fields

node_id: NodeId

worker_id: String

attempt: u32

NodeCompleted

Fields

node_id: NodeId

output: Value

state_patch: Value

JSON merge patch to apply to workflow state.

duration_ms: u64

gen_ai_system: Option<String>

AI provider system (e.g. “anthropic”, “openai”). None for non-model nodes.

gen_ai_model: Option<String>

Model name used.

input_tokens: Option<u64>

Input tokens consumed.

output_tokens: Option<u64>

Output tokens generated.

finish_reason: Option<String>

Finish reason (e.g. “stop”, “length”, “tool_calls”).

cost_usd: Option<f64>

Estimated USD cost for this node.

provenance: Option<Box<ProvenanceMetadata>>

Provenance metadata for research traceability.

NodeFailed

Fields

node_id: NodeId

error: String

attempt: u32

retryable: bool

NodeSkipped

Fields

node_id: NodeId

reason: String

NodeCancelled

Fields

node_id: NodeId

RetryScheduled

Fields

node_id: NodeId

attempt: u32

delay_ms: u64

InterruptRaised

Fields

node_id: NodeId

reason: String

state_for_review: Value

ApprovalReceived

Fields

node_id: NodeId

user_id: String

decision: ApprovalDecision

comment: Option<String>

state_patch: Option<Value>

TimerCreated

Fields

node_id: NodeId

fire_at: DateTime<Utc>

correlation_key: Option<String>

TimerFired

Fields

node_id: NodeId

correlation_key: Option<String>

ExternalEventReceived

Fields

correlation_key: String

payload: Value

ChildWorkflowStarted

Fields

node_id: NodeId

child_execution_id: String

child_workflow_id: String

ChildWorkflowCompleted

Fields

node_id: NodeId

child_execution_id: String

result: Value

ChildWorkflowFailed

Fields

node_id: NodeId

child_execution_id: String

error: String

BudgetExceeded

Fields

node_id: NodeId

kind: String

limit: u64

current: u64

TokenBudgetExceeded

Fields

node_id: NodeId

kind: String

“input_tokens” | “output_tokens” | “total_tokens”

limit: u64

current: u64

CostBudgetExceeded

Fields

node_id: NodeId

limit_usd: f64

current_usd: f64

AutonomyLimitReached

Fields

node_id: NodeId

agent_ref: String

limit_type: String

“max_iterations” | “cost_budget” | “token_budget” | “max_tool_calls”

limit_value: Value

actual_value: Value

CircuitBreakerTripped

Fields

node_id: NodeId

agent_ref: String

consecutive_errors: u32

threshold: u32

EscalationRequired

Fields

node_id: NodeId

agent_ref: String

reason: String

“circuit_breaker” | “autonomy_limit” | “budget_exceeded”

escalation_target: String

“supervisor_agent:” | “human_approval”

PolicyViolation

Fields

node_id: NodeId

rule: String

Which rule triggered (e.g. “block_tool:payments.*”)

decision: String

“blocked” | “require_approval”

policy_scope: String

“global” | “tenant” | “workflow” | “node”

ToolApprovalRequired

Fields

node_id: NodeId

tool_name: String

approver: String

context: Value

StrategyStarted

Emitted when a reasoning strategy begins execution.

Fields

strategy: String

config: Value

PlanGenerated

Emitted by plan-and-execute when the plan is generated.

Fields

steps: Vec<String>

IterationStarted

Emitted at the start of each reasoning loop iteration.

Fields

iteration: u32

ToolCalled

Emitted each time a tool is invoked within a strategy loop.

Fields

node_id: NodeId

tool: String

CriticVerdict

Emitted by critic/verifier nodes with a quality score.

Fields

node_id: NodeId

score: f64

passed: bool

feedback: Option<String>

IterationCompleted

Emitted at the end of each iteration with cost/token delta.

Fields

iteration: u32

cost_delta_usd: Option<f64>

input_tokens: u64

output_tokens: u64

StrategyLimitHit

Emitted when a strategy limit (max_iterations, max_cost_usd, timeout) is hit. Workflow transitions to LimitExceeded after this event.

Fields

limit_type: String

limit_value: Value

actual_value: Value

StrategyCompleted

Emitted when strategy execution completes successfully.

Fields

iterations: u32

total_cost_usd: Option<f64>

CoordinatorDiscovery

Fields

node_id: NodeId

query_skills: Vec<String>

query_trust_domain: Option<String>

candidates: Vec<Value>

filtered_out: Vec<Value>

CoordinatorScoring

Fields

node_id: NodeId

rankings: Vec<Value>

spread: f64

weights: Value

CoordinatorDecision

Fields

node_id: NodeId

selected: Option<String>

method: String

reasoning: Option<String>

confidence: f64

rejected: Vec<Value>

tiebreaker_tokens: Option<Value>

tiebreaker_cost: Option<f64>

AgentToolInvoked

Fields

node_id: NodeId

agent_uri: String

mode: String

protocol: String

input_hash: String

AgentToolProgress

Fields

node_id: NodeId

chunk_index: u32

partial_output_summary: String

AgentToolTurn

Fields

node_id: NodeId

turn_number: u32

direction: String

content_summary: String

tokens: u32

cost: f64

AgentToolCompleted

Fields

node_id: NodeId

output: Value

provenance: Option<Value>

total_cost: f64

latency_ms: u64

total_turns: Option<u32>

AgentToolTerminated

Fields

node_id: NodeId

reason: String

chunks_received: u32

partial_output: Option<Value>

cost: f64

AgentToolFailed

Fields

node_id: NodeId

failure_type: String

message: String

retryable: bool

Implementations

impl EventKind

pub fn node_id(&self) -> Option<&str>

Returns the node_id associated with this event, if any.

Trait Implementations

impl Clone for EventKind

fn clone(&self) -> EventKind

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventKind

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for EventKind

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for EventKind

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

where __S: Serializer,

Serialize this value into the given Serde serializer.