Struct RecordingSession 

pub struct RecordingSession<W: Write + Send> { /* private fields */ }

Live recording session.

Thread-safe: multiple threads can call record_sample concurrently.

Implementations

impl<W: Write + Send> RecordingSession<W>

pub fn new(sink: W, opts: SessionOptions) -> Self

Creates a new session over sink. The header is written on the first record_sample.

pub fn record_sample( &self, now_unix_ns: i64, participant_guid: [u8; 16], topic: &TopicKey, sample_kind: SampleKind, payload: Vec<u8>, ) -> Result<(), SessionError>

Writes a sample. now_unix_ns must be the current wall-clock time in nanoseconds since the epoch.

Errors

See SessionError.

pub fn stats(&self) -> SessionStats

Returns the current counters (snapshot).