Struct GrpcServerSink

pub struct GrpcServerSink {
    uri: ProxyUri,
    sender: Sender<LogMsg>,
    _server_handle: JoinHandle<()>,
    server_shutdown_signal: Signal,
}

A crate::sink::LogSink tied to a hosted Rerun gRPC server.

The hosted gRPC server may be connected to by any SDK or Viewer.

All data sent through this sink is immediately redirected to the gRPC server.

Fields

uri: ProxyUri

sender: Sender<LogMsg>

Sender to send messages to the gRPC server.

_server_handle: JoinHandle<()>

The gRPC server thread.

server_shutdown_signal: Signal

Rerun websocket server.

Implementations

impl GrpcServerSink

pub fn new( bind_ip: &str, grpc_port: u16, server_memory_limit: MemoryLimit, ) -> Result<Self, AddrParseError>

A bind_ip of "0.0.0.0" is a good default.

pub fn uri(&self) -> ProxyUri

What to connect the viewer to

Trait Implementations

impl Drop for GrpcServerSink

fn drop(&mut self)

Executes the destructor for this type.

impl LogSink for GrpcServerSink

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.

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

Send a blueprint directly to the log-sink.