Skip to main content

PersistPubSubClient

mz_persist_client::rpc

Trait 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.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§