Struct mz_persist_client::rpc::GrpcPubSubClient

pub struct GrpcPubSubClient;

A PersistPubSubClient implementation backed by gRPC.

Returns a PubSubClientConnection backed by channels that submit and receive messages to and from a long-lived bidirectional gRPC stream. The gRPC stream will be transparently reestablished if the connection is lost.

Implementations

impl GrpcPubSubClient

async fn reconnect_to_server_forever( send_requests: Sender<ProtoPubSubMessage>, receiver_input: &Sender<ProtoPubSubMessage>, sender: Arc<SubscriptionTrackingSender>, metadata: MetadataMap, config: PersistPubSubClientConfig, metrics: Arc<Metrics>, )

async fn consume_grpc_stream( responses: Streaming<ProtoPubSubMessage>, receiver_input: &Sender<ProtoPubSubMessage>, config: &PersistPubSubClientConfig, metrics: &Metrics, ) -> Result<(), Error>

Trait Implementations

impl Debug for GrpcPubSubClient

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

Formats the value using the given formatter.

impl PersistPubSubClient for GrpcPubSubClient

fn connect( config: PersistPubSubClientConfig, metrics: Arc<Metrics>, ) -> PubSubClientConnection

Receive handles with which to push and subscribe to diffs.