Struct rerun::sink::TcpSink

pub struct TcpSink {
    client: Client,
}

Stream log messages to a Rerun TCP server.

Fields

client: Client

Implementations

impl TcpSink

pub fn new(addr: SocketAddr, flush_timeout: Option<Duration>) -> TcpSink

Connect to the given address in a background thread. Retries until successful.

flush_timeout is the minimum time the TcpSink will wait during a flush before potentially dropping data. Note: Passing None here can cause a call to flush to block indefinitely if a connection cannot be established.

Trait Implementations

impl Debug for TcpSink

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

Formats the value using the given formatter.

impl LogSink for TcpSink

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 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_all(&self, messages: Vec<LogMsg>)

Send all these log messages.

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

Drain all buffered LogMsges and return them.

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

Send a blueprint directly to the log-sink.