Struct TailLog 

pub struct TailLog<T> { /* private fields */ }

An append-only event log with terminal state and parked tail reads.

Implementations

impl<T: Clone> TailLog<T>

pub fn new() -> Self

Create an empty, open log.

pub fn push(&self, event: T) -> bool

Append an event and wake parked readers.

Returns false (dropping the event) if the log is already finished.

pub fn finish(&self)

Mark the log finished and wake parked readers. Idempotent.

pub fn is_done(&self) -> bool

Whether the log is finished.

pub fn len(&self) -> u64

Number of events appended so far.

pub fn is_empty(&self) -> bool

Whether no events have been appended.

pub fn snapshot_from(&self, seq: u64) -> TailPage<T>

Non-blocking snapshot of the tail from seq.

pub async fn read_from(&self, seq: u64) -> TailPage<T>

Atomic tail read: park until there are events past seq or the log is finished, then return them together with the terminal status.

pub async fn read_from_cancellable( &self, seq: u64, token: &CancelToken, ) -> Result<TailPage<T>, Cancelled>

TailLog::read_from, cancellable.

Trait Implementations

impl<T: Clone> Default for TailLog<T>

fn default() -> Self

Returns the “default value” for a type.