Struct AgentRunner 

pub struct AgentRunner {
    pub event_sender: Sender<AgentEvent>,
    pub cancel_token: CancellationToken,
    pub status: AgentStatus,
    pub started_at: DateTime<Utc>,
    pub completed_at: Option<DateTime<Utc>>,
    pub last_budget_event: Option<AgentEvent>,
}

Runner that manages agent execution for a session

Each active agent run has an associated AgentRunner that coordinates event broadcasting, cancellation, and status tracking.

Event Broadcasting

Uses a broadcast channel to support multiple subscribers watching the same agent run simultaneously.

Cancellation

Provides a cancellation token that can be used to gracefully stop an in-progress agent execution.

Fields

event_sender: Sender<AgentEvent>

Broadcast sender for agent events

Allows multiple clients to subscribe to agent events via event_sender.subscribe().

cancel_token: CancellationToken

Cancellation token for graceful shutdown

When triggered, the agent should stop execution at the next safe point.

status: AgentStatus

Current status of the agent run

started_at: DateTime<Utc>

Timestamp when the run was started

completed_at: Option<DateTime<Utc>>

Timestamp when the run completed (if finished)

last_budget_event: Option<AgentEvent>

Last token budget event to replay for new subscribers

When a new client subscribes to an ongoing run, this allows them to receive the most recent token usage info.

Implementations

impl AgentRunner

pub fn new() -> Self

Create a new agent runner with default settings

Initializes a broadcast channel with capacity for 1000 events, a fresh cancellation token, and Pending status.

Trait Implementations

impl Clone for AgentRunner

fn clone(&self) -> AgentRunner

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AgentRunner

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

Formats the value using the given formatter.

impl Default for AgentRunner

fn default() -> Self

Returns the “default value” for a type.