Struct TypedRedexFile 

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

Typed wrapper over a RedexFile. T is the domain event type; it must be Serialize + DeserializeOwned for postcard.

Implementations

impl<T> TypedRedexFile<T>

pub fn new(file: RedexFile) -> Self

Wrap an existing RedexFile. Cheap — just stores the handle.

pub fn file(&self) -> &RedexFile

Borrow the underlying file for untyped operations (length, retention sweep, close, etc.).

impl<T: Serialize> TypedRedexFile<T>

pub fn append(&self, value: &T) -> Result<u64, RedexError>

Serialize with postcard and append. Returns the assigned seq.

pub fn append_batch(&self, values: &[T]) -> Result<Option<u64>, RedexError>

Serialize a batch and append atomically (all entries land in the index contiguously or none do).

Returns Some(first_seq) on non-empty input, None on empty input — propagates the underlying RedexFile::append_batch contract.

impl<T: DeserializeOwned + Send + 'static> TypedRedexFile<T>

pub fn tail( &self, from_seq: u64, ) -> impl Stream<Item = Result<(u64, T), RedexError>> + Send + 'static

Tail the file from from_seq onward, yielding (seq, value) pairs. Deserialization errors surface as RedexError::Encode items — the stream continues.

pub fn read_range( &self, start: u64, end: u64, ) -> Vec<Result<(u64, T), RedexError>>

Read the half-open range [start, end), returning (seq, value) pairs. Deserialization errors are returned per-entry — callers decide whether to skip or abort.

Trait Implementations

impl<T> Clone for TypedRedexFile<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> Debug for TypedRedexFile<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.