Struct Evento 

pub struct Evento { /* private fields */ }

Type-erased wrapper around any Executor implementation.

Evento wraps an executor in Arc<Box<dyn Executor>> for dynamic dispatch. This allows storing different executor implementations in the same collection.

Example

let sql_executor: Sql<sqlx::Sqlite> = pool.into();
let evento = Evento::new(sql_executor);

// Use like any executor
evento.write(events).await?;

Implementations

impl Evento

pub fn new<E: Executor>(executor: E) -> Self

Creates a new type-erased executor wrapper.

pub fn default_routing_key(self, key: impl Into<String>) -> Self

Sets a default routing key applied to writes and inherited by subscriptions built from this executor.

Per-event/per-aggregate routing keys still take precedence on writes. Subscriptions inherit this key only when the user has not called .routing_key() or .all().

Trait Implementations

impl Clone for Evento

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Executor for Evento

fn default_routing_key(&self) -> Option<&str>

Default routing key applied to writes and inherited by subscriptions.

fn write<'life0, 'async_trait>( &'life0 self, events: Vec<Event>, ) -> Pin<Box<dyn Future<Output = Result<(), WriteError>> + Send + 'async_trait>>

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

Persists events atomically.

fn read<'life0, 'async_trait>( &'life0 self, aggregators: Option<Vec<EventFilter>>, routing_key: Option<RoutingKey>, args: Args, ) -> Pin<Box<dyn Future<Output = Result<ReadResult<Event>>> + Send + 'async_trait>>

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

Queries events with filtering and pagination.

fn latest_timestamp<'life0, 'async_trait>( &'life0 self, aggregators: Option<Vec<EventFilter>>, routing_key: Option<RoutingKey>, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Returns the timestamp of the most recent event matching the filter.

fn get_subscriber_cursor<'life0, 'async_trait>( &'life0 self, key: String, ) -> Pin<Box<dyn Future<Output = Result<Option<Value>>> + Send + 'async_trait>>

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

Gets the current cursor position for a subscription.

fn is_subscriber_running<'life0, 'async_trait>( &'life0 self, key: String, worker_id: Ulid, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Checks if a subscription is running with the given worker ID.

fn upsert_subscriber<'life0, 'async_trait>( &'life0 self, key: String, worker_id: Ulid, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Creates or updates a subscription record.

fn acknowledge<'life0, 'async_trait>( &'life0 self, key: String, cursor: Value, lag: u64, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Updates subscription cursor after processing events.

fn get_snapshot<'life0, 'async_trait>( &'life0 self, aggregate_type: String, aggregate_revision: String, id: String, ) -> Pin<Box<dyn Future<Output = Result<Option<(Vec<u8>, Value)>>> + Send + 'async_trait>>

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

Retrieves a stored snapshot for an aggregate.

fn save_snapshot<'life0, 'async_trait>( &'life0 self, aggregate_type: String, aggregate_revision: String, id: String, data: Vec<u8>, cursor: Value, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Stores a snapshot for an aggregate.

fn delete_snapshot<'life0, 'async_trait>( &'life0 self, aggregate_type: String, id: String, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Deletes a stored snapshot for an aggregate.