Struct EventStream 

pub struct EventStream { /* private fields */ }

Event stream with broadcast capability for real-time subscribers

Implementations

impl EventStream

pub fn new() -> Self

Create a new event stream with specified channel capacity

pub fn with_capacity(capacity: usize) -> Self

Create event stream with custom channel capacity

pub fn append( &self, scope: EventScope, event_type: EventType, component_id: String, status: ComponentStatus, workflow_id: WorkflowId, message: Option<String>, data: JsonValue, ) -> JoinHandle<Result<Event, String>>

Append a new event and broadcast to all subscribers

Events are emitted asynchronously in a spawned task to avoid blocking agent execution. Returns a JoinHandle that can be awaited if the caller needs to ensure the event was processed or needs the Event object.

Examples

use agent_runtime::event::{EventStream, EventScope, EventType, ComponentStatus};
use serde_json::json;

let stream = EventStream::new();

// Fire and forget (most common)
stream.append(
    EventScope::Agent,
    EventType::Started,
    "my_agent".to_string(),
    ComponentStatus::Running,
    "workflow_1".to_string(),
    None,
    json!({})
);

// Wait for event if needed
let event = stream.append(
    EventScope::Agent,
    EventType::Completed,
    "my_agent".to_string(),
    ComponentStatus::Completed,
    "workflow_1".to_string(),
    Some("Agent completed successfully".to_string()),
    json!({})
).await.unwrap();

pub fn append_with_parent( &self, scope: EventScope, event_type: EventType, component_id: String, status: ComponentStatus, workflow_id: WorkflowId, parent_workflow_id: Option<WorkflowId>, message: Option<String>, data: JsonValue, ) -> JoinHandle<Result<Event, String>>

Append event with optional parent workflow ID

Events are emitted asynchronously to avoid blocking execution. Returns a JoinHandle that resolves to the created Event.

pub fn agent_started( &self, agent_name: &str, workflow_id: WorkflowId, data: JsonValue, ) -> JoinHandle<Result<Event, String>>

Emit Agent::Started event

pub fn agent_completed( &self, agent_name: &str, workflow_id: WorkflowId, message: Option<String>, data: JsonValue, ) -> JoinHandle<Result<Event, String>>

Emit Agent::Completed event

pub fn agent_failed( &self, agent_name: &str, workflow_id: WorkflowId, error: &str, data: JsonValue, ) -> JoinHandle<Result<Event, String>>

Emit Agent::Failed event

pub fn llm_started( &self, agent_name: &str, iteration: usize, workflow_id: WorkflowId, data: JsonValue, ) -> JoinHandle<Result<Event, String>>

Emit LlmRequest::Started event

pub fn llm_progress( &self, agent_name: &str, iteration: usize, workflow_id: WorkflowId, chunk: String, ) -> JoinHandle<Result<Event, String>>

Emit LlmRequest::Progress event (streaming chunk)

pub fn llm_completed( &self, agent_name: &str, iteration: usize, workflow_id: WorkflowId, data: JsonValue, ) -> JoinHandle<Result<Event, String>>

Emit LlmRequest::Completed event

pub fn llm_failed( &self, agent_name: &str, iteration: usize, workflow_id: WorkflowId, error: &str, ) -> JoinHandle<Result<Event, String>>

Emit LlmRequest::Failed event

pub fn tool_started( &self, tool_name: &str, workflow_id: WorkflowId, data: JsonValue, ) -> JoinHandle<Result<Event, String>>

Emit Tool::Started event

pub fn tool_progress( &self, tool_name: &str, workflow_id: WorkflowId, message: &str, percent: Option<u8>, ) -> JoinHandle<Result<Event, String>>

Emit Tool::Progress event

pub fn tool_completed( &self, tool_name: &str, workflow_id: WorkflowId, data: JsonValue, ) -> JoinHandle<Result<Event, String>>

Emit Tool::Completed event

pub fn tool_failed( &self, tool_name: &str, workflow_id: WorkflowId, error: &str, data: JsonValue, ) -> JoinHandle<Result<Event, String>>

Emit Tool::Failed event

pub fn workflow_started( &self, workflow_name: &str, data: JsonValue, ) -> JoinHandle<Result<Event, String>>

Emit Workflow::Started event

pub fn workflow_completed( &self, workflow_name: &str, data: JsonValue, ) -> JoinHandle<Result<Event, String>>

Emit Workflow::Completed event

pub fn workflow_failed( &self, workflow_name: &str, error: &str, data: JsonValue, ) -> JoinHandle<Result<Event, String>>

Emit Workflow::Failed event

pub fn step_started( &self, workflow_name: &str, step_index: usize, data: JsonValue, ) -> JoinHandle<Result<Event, String>>

Emit WorkflowStep::Started event

pub fn step_completed( &self, workflow_name: &str, step_index: usize, data: JsonValue, ) -> JoinHandle<Result<Event, String>>

Emit WorkflowStep::Completed event

pub fn step_failed( &self, workflow_name: &str, step_index: usize, error: &str, data: JsonValue, ) -> JoinHandle<Result<Event, String>>

Emit WorkflowStep::Failed event

pub fn subscribe(&self) -> Receiver<Event>

Subscribe to real-time event stream Returns a receiver that will get all future events

pub fn from_offset(&self, offset: EventOffset) -> Vec<Event>

Get events from a specific offset (for replay)

pub fn all(&self) -> Vec<Event>

Get all events

pub fn len(&self) -> usize

Get event count

pub fn is_empty(&self) -> bool

pub fn current_offset(&self) -> EventOffset

Get the current offset (next event will have this offset)

Trait Implementations

impl Clone for EventStream

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for EventStream

fn default() -> Self

Returns the “default value” for a type.