Trait mz_persist_client::rpc::PubSubSender

pub trait PubSubSender:
    Debug
    + Send
    + Sync {
    // Required methods
    fn push_diff(&self, shard_id: &ShardId, diff: &VersionedData);
    fn subscribe(
        self: Arc<Self>,
        shard_id: &ShardId,
    ) -> Arc<ShardSubscriptionToken>;
}

The public send-side client to Persist PubSub.

Required Methods

fn push_diff(&self, shard_id: &ShardId, diff: &VersionedData)

Push a diff to subscribers.

fn subscribe(self: Arc<Self>, shard_id: &ShardId) -> Arc<ShardSubscriptionToken>

Subscribe the corresponding PubSubReceiver to diffs for the given shard.

Returns a token that, when dropped, will unsubscribe the client from the shard.

If the client is already subscribed to the shard, repeated calls will make no further calls to the server and instead return clones of the Arc<ShardSubscriptionToken>.

Implementors

impl PubSubSender for MetricsSameProcessPubSubSender

impl PubSubSender for NoopPubSubSender

impl PubSubSender for SubscriptionTrackingSender