Struct mz_persist_client::rpc::SubscriptionTrackingSender

struct SubscriptionTrackingSender {
    delegate: Arc<dyn PubSubSenderInternal>,
    subscribes: Arc<Mutex<BTreeMap<ShardId, Weak<ShardSubscriptionToken>>>>,
}

An wrapper for a PubSubSenderInternal that implements PubSubSender by maintaining a map of active shard subscriptions to their tokens.

Fields

delegate: Arc<dyn PubSubSenderInternal>

subscribes: Arc<Mutex<BTreeMap<ShardId, Weak<ShardSubscriptionToken>>>>

Implementations

impl SubscriptionTrackingSender

fn new(sender: Arc<dyn PubSubSenderInternal>) -> Self

fn reconnect(&self)

Trait Implementations

impl Debug for SubscriptionTrackingSender

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PubSubSender for SubscriptionTrackingSender

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.