Struct A3sEventBusFlowEventSink 

pub struct A3sEventBusFlowEventSink { /* private fields */ }

Sink that publishes bridged Flow events into an A3S Event bus.

The sink uses A3S Event as the transport and history layer while preserving the durable Flow event store as the source of truth. Publish failures are recorded in last_error() and logged; they do not roll back workflow events that have already been committed.

Implementations

impl A3sEventBusFlowEventSink

pub fn new(bus: Arc<EventBus>) -> Self

Creates a sink using the default flow category and a3s-flow source.

pub fn with_category(self, category: impl Into<String>) -> Self

Replaces the A3S Event category.

pub fn with_source(self, source: impl Into<String>) -> Self

Replaces the A3S Event source identity.

pub fn bus(&self) -> Arc<EventBus>

Returns the configured A3S Event bus.

pub fn category(&self) -> &str

Returns the configured A3S Event category.

pub fn source(&self) -> &str

Returns the configured A3S Event source identity.

pub async fn last_error(&self) -> Option<String>

Returns the most recent conversion or publish error.

pub fn to_a3s_event(&self, event: &A3sFlowEvent) -> Result<Event, Error>

Converts a bridged record into the A3S Event transport shape.

Trait Implementations

impl A3sFlowEventSink for A3sEventBusFlowEventSink

fn emit<'life0, 'async_trait>( &'life0 self, event: A3sFlowEvent, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Publishes one best-effort observer record.

impl Debug for A3sEventBusFlowEventSink

Available on crate feature a3s-event only.

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

Formats the value using the given formatter.