Struct InMemoryEventStore 

pub struct InMemoryEventStore { /* private fields */ }

内存事件存储

基于内存的事件存储实现，用于开发和测试。

Implementations

impl InMemoryEventStore

pub fn new() -> Self

创建新的内存事件存储

pub fn with_capacity(capacity: usize) -> Self

创建带初始容量的内存事件存储

Trait Implementations

impl Default for InMemoryEventStore

fn default() -> Self

Returns the “default value” for a type.

impl EventStore for InMemoryEventStore

fn append<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 EventData, ) -> Pin<Box<dyn Future<Output = WaeResult<()>> + Send + 'async_trait>>

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

追加事件到存储

fn append_batch<'life0, 'life1, 'async_trait>( &'life0 self, new_events: &'life1 [EventData], ) -> Pin<Box<dyn Future<Output = WaeResult<()>> + Send + 'async_trait>>

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

批量追加事件

fn get_events<'life0, 'life1, 'async_trait>( &'life0 self, event_type: &'life1 str, ) -> Pin<Box<dyn Future<Output = WaeResult<Vec<EventData>>> + Send + 'async_trait>>

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

获取指定类型的事件流

fn get_events_by_time<'life0, 'async_trait>( &'life0 self, start: u64, end: u64, ) -> Pin<Box<dyn Future<Output = WaeResult<Vec<EventData>>> + Send + 'async_trait>>

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

获取指定时间范围的事件

fn get_all_events<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = WaeResult<Vec<EventData>>> + Send + 'async_trait>>

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

获取所有事件

fn count<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = WaeResult<u64>> + Send + 'async_trait>>

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

获取事件数量

fn clear<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = WaeResult<()>> + Send + 'async_trait>>

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

清空所有事件