Struct WriteAheadLog 

pub struct WriteAheadLog { /* private fields */ }

Available on crate feature servers only.

A reference to a single unique ‘write-ahead log’ for SATA.

This keeps track of requests, and responses coming in and out of a sata server, to determine what is actually happening.

This WAL is expected to be from the ‘servers’ point of view, NOT the clients.

Implementations

impl WriteAheadLog

pub fn new(wal: PathBuf) -> Result<Self, CatBridgeError>

Create a new WAL for sata requests/responses.

This is the ‘entrypoint’, and as a result will spawn the task to start receiving messages.

Errors

If we cannot spawn the background task.

pub async fn record_open_stream(&self, stream_id: u64)

Communicate that a stream has opened up.

pub async fn record_close_stream(&self, stream_id: u64)

Communicate that a stream has closed.

pub async fn record_oob_file_write_read( &self, stream_id: u64, fd: i32, length: usize, )

Communicate that an out of band (e.g. nor equest/response flow) read for write file.

pub async fn record_request(&self, stream_id: u64, request: Bytes)

Communicate that a request has come into the server.

pub async fn record_response(&self, stream_id: u64, request: Bytes)

Communicate that a response has come into the server.

Trait Implementations

impl Clone for WriteAheadLog

fn clone(&self) -> WriteAheadLog

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WriteAheadLog

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

Formats the value using the given formatter.