Struct rerun::sdk::sink::MemorySink

pub struct MemorySink(MemorySinkStorage);

Store log messages directly in memory.

Although very similar to BufferedSink this sink is a real-endpoint. When creating a new sink the logged messages stay with the MemorySink (drain_backlog does nothing).

Additionally the raw storage can be accessed and used to create an in-memory RRD. This is useful for things like the inline rrd-viewer in Jupyter notebooks.

Tuple Fields

0: MemorySinkStorage

Implementations

impl MemorySink

pub fn new(rec: RecordingStream) -> MemorySink

Create a new MemorySink with an associated RecordingStream.

pub fn buffer(&self) -> MemorySinkStorage

Access the raw MemorySinkStorage

Trait Implementations

impl Debug for MemorySink

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

Formats the value using the given formatter.

impl LogSink for MemorySink

fn send(&self, msg: LogMsg)

Send this log message.

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

Send all these log messages.

fn flush_blocking(&self)

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

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

Drain all buffered LogMsges and return them.

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.