Skip to main content

Module rpc

Module rpc 

Source
Expand description

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.