Struct Evento 

pub struct Evento(/* private fields */);

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,

fn get_event<'life0, 'async_trait>( &'life0 self, cursor: Value, ) -> Pin<Box<dyn Future<Output = Result<Event, ReadError>> + Send + 'async_trait>>

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

fn read_by_aggregator<'life0, 'async_trait>( &'life0 self, aggregator_type: String, id: String, args: Args, ) -> Pin<Box<dyn Future<Output = Result<ReadResult<Event>, ReadError>> + Send + 'async_trait>>

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

fn read<'life0, 'async_trait>( &'life0 self, aggregator_types: HashSet<String>, routing_key: RoutingKey, args: Args, ) -> Pin<Box<dyn Future<Output = Result<ReadResult<Event>, ReadError>> + Send + 'async_trait>>

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

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

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

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

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

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

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

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)>, ReadError>> + Send + 'async_trait>>

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

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<(), WriteError>> + Send + 'async_trait>>

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

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

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