Struct EventStore 

pub struct EventStore { /* private fields */ }

High-performance event store with columnar storage

Implementations

impl EventStore

pub fn new() -> Self

Create a new in-memory event store

pub fn with_config(config: EventStoreConfig) -> Self

Create event store with custom configuration

pub fn ingest(&self, event: Event) -> Result<()>

Ingest a new event into the store

pub fn websocket_manager(&self) -> Arc<WebSocketManager>

Get the WebSocket manager for this store

pub fn snapshot_manager(&self) -> Arc<SnapshotManager>

Get the snapshot manager for this store

pub fn compaction_manager(&self) -> Option<Arc<CompactionManager>>

Get the compaction manager for this store

pub fn schema_registry(&self) -> Arc<SchemaRegistry>

Get the schema registry for this store (v0.5 feature)

pub fn replay_manager(&self) -> Arc<ReplayManager>

Get the replay manager for this store (v0.5 feature)

pub fn pipeline_manager(&self) -> Arc<PipelineManager>

Get the pipeline manager for this store (v0.5 feature)

pub fn metrics(&self) -> Arc<MetricsRegistry>

Get the metrics registry for this store (v0.6 feature)

pub fn projection_manager(&self) -> RwLockReadGuard<'_, ProjectionManager>

Get the projection manager for this store (v0.7 feature)

pub fn projection_state_cache(&self) -> Arc<DashMap<String, Value>>

Get the projection state cache for this store (v0.7 feature) Used by Elixir Query Service for state synchronization

pub fn flush_storage(&self) -> Result<()>

Manually flush any pending events to persistent storage

pub fn create_snapshot(&self, entity_id: &str) -> Result<()>

Manually create a snapshot for an entity

pub fn query(&self, request: QueryEventsRequest) -> Result<Vec<Event>>

Query events based on filters (optimized with indices)

pub fn reconstruct_state( &self, entity_id: &str, as_of: Option<DateTime<Utc>>, ) -> Result<Value>

Reconstruct entity state as of a specific timestamp v0.2: Now uses snapshots for fast reconstruction

pub fn get_snapshot(&self, entity_id: &str) -> Result<Value>

Get snapshot from projection (faster than reconstructing)

pub fn stats(&self) -> StoreStats

Get statistics about the event store

Trait Implementations

impl Default for EventStore

fn default() -> Self

Returns the “default value” for a type.