Struct mz_persist_client::rpc::MetricsSameProcessPubSubSender

pub struct MetricsSameProcessPubSubSender {
    delegate_subscribe: bool,
    metrics: Arc<Metrics>,
    delegate: Arc<dyn PubSubSender>,
}

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.

Fields

delegate_subscribe: bool

metrics: Arc<Metrics>

delegate: Arc<dyn PubSubSender>

Implementations

impl MetricsSameProcessPubSubSender

pub fn new( cfg: &PersistConfig, pubsub_sender: Arc<dyn PubSubSender>, metrics: Arc<Metrics>, ) -> Self

Returns a new MetricsSameProcessPubSubSender, wrapping the given Arc<dyn PubSubSender>’s calls to provide client-side metrics.

Trait Implementations

impl Debug for MetricsSameProcessPubSubSender

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

Formats the value using the given formatter.

impl PubSubSender for MetricsSameProcessPubSubSender

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.