Struct EventPublisher 

pub struct EventPublisher { /* private fields */ }

Event publisher for sending events to the bus.

Implementations

impl EventPublisher

pub fn publish(&self, event: Event)

Publish an event to the bus.

pub fn progress( &self, resource_id: &str, current: u64, total: u64, message: &str, )

Publish a progress event.

pub fn mcp_progress( &self, progress_token: &str, progress: f64, total: Option<f64>, message: Option<&str>, )

Publish an MCP-compatible progress notification.

The event body follows the notifications/progress schema used by Claude MCP, OpenAI Agents SDK, Cursor, Cline, and other agent frameworks, so it can be forwarded verbatim without translation.

Arguments

• progress_token – opaque token identifying the in-progress operation.
• progress – units of work completed.
• total – total units, or None for indeterminate progress.
• message – optional human-readable status string.

pub fn log(&self, resource_id: &str, level: &str, message: &str)

Publish a log event.

pub fn stdout(&self, resource_id: &str, line: &str)

Publish a stdout log event.

pub fn stderr(&self, resource_id: &str, line: &str)

Publish a stderr log event.

pub fn task_started(&self, task_id: &str, data: Value)

Publish a task started event.

pub fn task_completed(&self, task_id: &str, result: Value)

Publish a task completed event.

pub fn task_failed(&self, task_id: &str, error: &str)

Publish a task failed event.

pub fn task_cancelled(&self, task_id: &str)

Publish a task cancelled event.

Trait Implementations

impl Clone for EventPublisher

fn clone(&self) -> EventPublisher

Returns a duplicate of the value.

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

Performs copy-assignment from source.