Struct WalStreamer 

pub struct WalStreamer { /* private fields */ }

Implementations

impl WalStreamer

pub fn new() -> Self

pub fn append(&self, data: &[u8]) -> u64

pub fn subscribe(&self) -> usize

pub fn stream_since(&self, subscriber_id: usize) -> Vec<WalStreamEntry>

pub fn entry_count(&self) -> usize

pub fn subscriber_count(&self) -> usize

Trait Implementations

impl Default for WalStreamer

fn default() -> Self

Returns the “default value” for a type.