Module mz_persist_client::rpc

gRPC-based implementations of Persist PubSub client and server.

Structs

• GrpcPubSubClient
  A PersistPubSubClient implementation backed by gRPC.
• MetricsSameProcessPubSubSender
  A wrapper intended to provide client-side metrics for a connection that communicates directly with the server state, such as one created by PersistGrpcPubSubServer::new_same_process_connection.
• PersistGrpcPubSubServer
  A gRPC-based implementation of a Persist PubSub server.
• PersistPubSubClientConfig
  Client configuration for connecting to a remote PubSub server.
• PubSubClientConnection
  Wrapper type for a matching PubSubSender and PubSubReceiver client pair.
• ShardSubscriptionToken
  A token corresponding to a subscription to diffs for a particular shard.

Constants

• PERSIST_PUBSUB_CALLER_KEY
  A gRPC metadata key to indicate the caller id of a client.

Traits

• PersistPubSubClient
  Top-level Trait to create a PubSubClient.
• PubSubReceiver
  The receive-side client to Persist PubSub.
• PubSubSender
  The public send-side client to Persist PubSub.