Struct PersistGrpcPubSubServer

pub struct PersistGrpcPubSubServer {
    cfg: PersistConfig,
    state: Arc<PubSubState>,
}

A gRPC-based implementation of a Persist PubSub server.

Fields

cfg: PersistConfig

state: Arc<PubSubState>

Implementations

impl PersistGrpcPubSubServer

pub fn new(cfg: &PersistConfig, metrics_registry: &MetricsRegistry) -> Self

Creates a new PersistGrpcPubSubServer.

pub fn new_same_process_connection(&self) -> PubSubClientConnection

Creates a connection to PersistGrpcPubSubServer that is directly connected to the server state. Calls into this connection do not go over the network nor require message serde.

pub async fn serve(self, listen_addr: SocketAddr) -> Result<(), Error>

Starts the gRPC server. Consumes self and runs until the task is cancelled.

pub async fn serve_with_stream( self, listener: TcpListenerStream, ) -> Result<(), Error>

Starts the gRPC server with the given listener stream. Consumes self and runs until the task is cancelled.

Trait Implementations

impl Debug for PersistGrpcPubSubServer

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

Formats the value using the given formatter.

impl ProtoPersistPubSub for PersistGrpcPubSubServer

type PubSubStream = Pin<Box<dyn Stream<Item = Result<ProtoPubSubMessage, Status>> + Send>>

Server streaming response type for the PubSub method.

fn pub_sub<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<ProtoPubSubMessage>>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::PubSubStream>, Status>> + Send + 'async_trait>>

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