Struct rerun::sdk::sink::BufferedSink

pub struct BufferedSink(Mutex<RawMutex, Vec<LogMsg>>);

Store log messages in memory until you call LogSink::drain_backlog.

Tuple Fields

0: Mutex<RawMutex, Vec<LogMsg>>

Implementations

impl BufferedSink

pub fn new() -> BufferedSink

An empty buffer.

Trait Implementations

impl Debug for BufferedSink

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

Formats the value using the given formatter.

impl Default for BufferedSink

fn default() -> BufferedSink

Returns the “default value” for a type.

impl Drop for BufferedSink

fn drop(&mut self)

Executes the destructor for this type.

impl LogSink for BufferedSink

fn send(&self, msg: LogMsg)

Send this log message.

fn send_all(&self, messages: Vec<LogMsg>)

Send all these log messages.

fn drain_backlog(&self) -> Vec<LogMsg>

Drain all buffered LogMsges and return them.

fn flush_blocking(&self)

Blocks until all pending data in the sink’s send buffers has been fully flushed.

fn drop_if_disconnected(&self)

Drops all pending data currently sitting in the sink’s send buffers if it is unable to flush it for any reason (e.g. a broken TCP connection for a TcpSink).

fn send_blueprint( &self, blueprint: Vec<LogMsg>, activation_cmd: BlueprintActivationCommand )

Send a blueprint directly to the log-sink.