Trait mz_persist_client::rpc::PersistPubSubClient

source · 
pub trait PersistPubSubClient {
    // Required method
    fn connect(
        pubsub_config: PersistPubSubClientConfig,
        metrics: Arc<Metrics>,
    ) -> PubSubClientConnection;
}
Expand description

Top-level Trait to create a PubSubClient.

Returns a PubSubClientConnection with a PubSubSender for issuing RPCs to the PubSub server, and a PubSubReceiver that receives messages, such as state diffs.

Required Methods§

source

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

Receive handles with which to push and subscribe to diffs.

Object Safety§

This trait is not object safe.

Implementors§