Struct MessageSink

pub struct MessageSink { /* private fields */ }

A high level file writer that mux messages and beacon

Implementations

impl MessageSink

pub async fn new( file_id: FileId, beacon_interval: u32, limit: u64, ) -> Result<Self, FileErr>

Create a fresh sink. Overwrite if file already exists.

pub async fn append( file_id: FileId, beacon_interval: u32, limit: u64, ) -> Result<Self, FileErr>

Create a sink. Append if file already exists, and follow its beacon interval.

pub fn write(&mut self, message: OwnedMessage) -> Result<Checksum, FileErr>

This method does not block. To make sure messages have been written, call MessageSink::flush.

pub fn offset(&self) -> u64

pub fn started_from(&self) -> u64

Where this sink was started

pub async fn flush(&mut self) -> Result<(), FileErr>

pub async fn end(self, eos: bool) -> Result<(), FileErr>

End this stream gracefully, with an optional EOS message