Struct WorkflowEventBus 

pub struct WorkflowEventBus { /* private fields */ }

Typed wrapper around an EngineEventBus. Per-subsystem wrappers (workflow, auth, secrets) share the underlying bus instance at the engine level but produce/consume their own typed events.

Implementations

impl WorkflowEventBus

pub fn new(inner: Arc<dyn EngineEventBus>) -> Self

pub async fn publish( &self, namespace: &str, ev: WorkflowBusEvent, ) -> Result<i64>

Publish a typed workflow event. namespace is the owning workflow’s namespace.

pub async fn read_since( &self, namespace: &str, after: Option<i64>, filter: &EventFilter, limit: u32, ) -> Result<Vec<Event>, CursorGoneError>

Read a cursor’s worth of events for this namespace (any subsystem — SSE uses this for the replay phase).

pub fn inner(&self) -> Arc<dyn EngineEventBus>

Expose the underlying bus so the scheduler + SSE can subscribe at the generic level and filter for any subsystem.

Trait Implementations

impl Clone for WorkflowEventBus

fn clone(&self) -> WorkflowEventBus

Returns a duplicate of the value.

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

Performs copy-assignment from source.