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.

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 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<ReadAggregator>>, 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 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, aggregator_type: String, aggregator_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, aggregator_type: String, aggregator_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.