Struct EventPublisher 

pub struct EventPublisher<Q: WriteQueueBackend> { /* private fields */ }

Publishes events to the write-side queue for durable processing.

Implementations

impl<Q: WriteQueueBackend> EventPublisher<Q>

pub fn new(queue: Q) -> Self

pub async fn publish<N: Namespace>( &self, namespace: &N, payload: &[u8], filter_value: Option<&str>, ) -> Result<()>

Trait Implementations

impl<Q: Clone + WriteQueueBackend> Clone for EventPublisher<Q>

fn clone(&self) -> EventPublisher<Q>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Q: WriteQueueBackend> TypedPublisher for EventPublisher<Q>

fn publish_typed<'life0, 'life1, 'life2, 'life3, 'async_trait, N, C>( &'life0 self, namespace: &'life1 N, codec: &'life2 C, event: &'life3 C::Event, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where N: Namespace + 'async_trait, C: EventCodec + ?Sized + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,