Struct FileEventLog 

pub struct FileEventLog { /* private fields */ }

File-based event log implementation

Implementations

impl FileEventLog

pub fn open(config: FileEventLogConfig) -> Result<Self>

Open or create a file-based event log

pub fn set_event_notify(&mut self, notify: Arc<Notify>)

Set the event notification handle.

When set, notify_waiters() is called after every successful append_with_id / append_batch_with_ids, waking any task that is awaiting notified().

pub fn event_notify(&self) -> Option<Arc<Notify>>

Get a clone of the event notification handle (if set).

Trait Implementations

impl Drop for FileEventLog

Ensure metadata is saved on drop

fn drop(&mut self)

Executes the destructor for this type.

impl EventLog for FileEventLog

fn append_with_id(&self, event_id: EventId, event_bytes: &[u8]) -> Result<()>

Append an event with a pre-allocated EventId

fn append_batch_with_ids( &self, first_event_id: EventId, events: &[Vec<u8>], ) -> Result<()>

Append multiple events in a batch with pre-allocated EventIds

fn next_event_id(&self) -> Result<EventId>

Get the next EventId that will be assigned

fn iter_range( &self, start: EventId, end: Option<EventId>, ) -> Result<Box<dyn EventLogIterator>>

Iterate over events in a range

fn get(&self, event_id: EventId) -> Result<Option<Vec<u8>>>

Get a single event by ID

fn delete_range(&self, start: EventId, end: EventId) -> Result<usize>

Delete events up to (and including) the given EventId

fn rotate(&self) -> Result<PathBuf>

Rotate the current log file

fn oldest_event_id(&self) -> Result<EventId>

Get the oldest event ID still in storage

fn newest_event_id(&self) -> Result<EventId>

Get the newest event ID in storage

fn sync(&self) -> Result<()>

Sync all writes to disk

fn stats(&self) -> Result<EventLogStats>

Get statistics about the event log