Struct rerun::sdk::external::re_log_encoding::FileSink

pub struct FileSink {
    tx: Mutex<RawMutex, Sender<Option<Command>>>,
    join_handle: Option<JoinHandle<()>>,
    path: Option<PathBuf>,
}

Stream log messages to an .rrd file.

Fields

tx: Mutex<RawMutex, Sender<Option<Command>>>

join_handle: Option<JoinHandle<()>>

path: Option<PathBuf>

Implementations

impl FileSink

pub fn new(path: impl Into<PathBuf>) -> Result<FileSink, FileSinkError>

Start writing log messages to a file at the given path.

pub fn stdout() -> Result<FileSink, FileSinkError>

Start writing log messages to standard output.

pub fn flush_blocking(&self)

pub fn send(&self, log_msg: LogMsg)

Trait Implementations

impl Debug for FileSink

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

Formats the value using the given formatter.

impl Drop for FileSink

fn drop(&mut self)

Executes the destructor for this type.

impl LogSink for FileSink

fn send(&self, msg: LogMsg)

Send this log message.

fn flush_blocking(&self)

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

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 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.