Struct re_grpc_server::MessageProxy

pub struct MessageProxy {
    pub(crate) _queue_task_handle: JoinHandle<()>,
    pub(crate) event_tx: Sender<Event>,
}

Fields

_queue_task_handle: JoinHandle<()>

event_tx: Sender<Event>

Implementations

impl MessageProxy

pub fn new(server_memory_limit: MemoryLimit) -> Self

pub(crate) async fn push(&self, msg: LogMsgProto)

pub(crate) async fn new_client_stream( &self, ) -> Pin<Box<dyn Stream<Item = Result<LogMsg>> + Send>>

Trait Implementations

impl MessageProxy for MessageProxy

fn write_messages<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<LogMsgProto>>, ) -> Pin<Box<dyn Future<Output = Result<Response<Empty>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

TODO(jan): Would it be more efficient to send a “message batch” instead of individual messages? It may allow us to amortize the overhead of the gRPC protocol.

type ReadMessagesStream = Pin<Box<dyn Stream<Item = Result<LogMsg, Status>> + Send>>

Server streaming response type for the ReadMessages method.

fn read_messages<'life0, 'async_trait>( &'life0 self, __arg1: Request<Empty>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::ReadMessagesStream>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,