Struct LogCollection 

pub struct LogCollection { /* private fields */ }

Append-only log collection.

Implementations

impl LogCollection

pub fn new(store: Arc<UnifiedStore>, config: LogCollectionConfig) -> Self

pub fn append(&self, fields: HashMap<String, Value>) -> LogId

Append a single log entry. Returns the assigned ID.

pub fn append_fields(&self, fields: Vec<(&str, Value)>) -> LogId

Append a log entry from (key, value) pairs.

pub fn flush_buffer(&self)

Flush the write buffer to storage.

pub fn recent(&self, limit: usize) -> Vec<LogEntry>

Query recent entries (newest first).

pub fn range(&self, from_id: LogId, to_id: LogId, limit: usize) -> Vec<LogEntry>

Query entries within a time range (by ID boundaries).

pub fn apply_retention(&self) -> u64

Apply retention policy: delete entries older than the threshold.

pub fn len(&self) -> usize

Total number of entries.

pub fn config(&self) -> &LogCollectionConfig

Config reference.

Trait Implementations

impl Drop for LogCollection

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.