Struct Inbox 

pub struct Inbox { /* private fields */ }

Implementations

impl Inbox

pub fn open(path: &Path) -> Result<Self>

pub fn listener_lock(&self) -> Result<Option<File>>

pub fn append(&self, record: &str) -> Result<()>

pub fn read_batch(&self) -> Result<Batch>

pub fn commit(&self, batch: &Batch) -> Result<()>

pub async fn wait(&self, renew_after: Duration) -> Result<Wake>