Struct FileEventPersister 

pub struct FileEventPersister { /* private fields */ }

File-based event persister using JSONL format with rotation

Events are written to date-partitioned JSONL files in the configured directory. Files are named events-YYYY-MM-DD.jsonl with optional index suffix for size-based rotation: events-YYYY-MM-DD.N.jsonl.

Implementations

impl FileEventPersister

pub async fn new(config: FileEventPersisterConfig) -> Result<Self>

Create a new file-based event persister

Creates the configured directory if it does not exist and opens the initial event file for writing.

pub fn events_written(&self) -> u64

Get the total number of events written since creation

Trait Implementations

impl EventEmitter for FileEventPersister

fn emit<'life0, 'async_trait>( &'life0 self, event: Event, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Emit an event to the transport

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

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

Emit multiple events

fn is_enabled(&self) -> bool

Check if the emitter is enabled/active

impl EventPersister for FileEventPersister

fn query_events<'life0, 'life1, 'async_trait>( &'life0 self, from: DateTime<Utc>, to: DateTime<Utc>, event_type_filter: Option<&'life1 str>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>>> + Send + 'async_trait>>

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

Query events within a time range, optionally filtering by event type

fn count_events<'life0, 'life1, 'async_trait>( &'life0 self, event_type: Option<&'life1 str>, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Count events, optionally filtering by event type

fn cleanup<'life0, 'async_trait>( &'life0 self, older_than: Duration, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Remove events older than the given duration, returning the count of removed files

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

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

Flush any buffered data to persistent storage