Struct mz_persist_client::rpc::PubSubState

pub(crate) struct PubSubState {
    connection_id_counter: AtomicUsize,
    shard_subscribers: Arc<RwLock<BTreeMap<ShardId, BTreeMap<usize, Sender<Result<ProtoPubSubMessage, Status>>>>>>,
    connections: Arc<RwLock<HashSet<usize>>>,
    metrics: Arc<PubSubServerMetrics>,
}

Internal state of a PubSub server implementation.

Fields

connection_id_counter: AtomicUsize

Assigns a unique ID to each incoming connection.

shard_subscribers: Arc<RwLock<BTreeMap<ShardId, BTreeMap<usize, Sender<Result<ProtoPubSubMessage, Status>>>>>>

Maintains a mapping of ShardId --> [ConnectionId -> Tx].

connections: Arc<RwLock<HashSet<usize>>>

Active connections.

metrics: Arc<PubSubServerMetrics>

Server-side metrics.

Implementations

impl PubSubState

fn new_connection( self: Arc<Self>, notifier: Sender<Result<ProtoPubSubMessage, Status>>, ) -> PubSubConnection

fn remove_connection(&self, connection_id: usize)

fn push_diff( &self, connection_id: usize, shard_id: &ShardId, data: &VersionedData, )

fn subscribe( &self, connection_id: usize, notifier: Sender<Result<ProtoPubSubMessage, Status>>, shard_id: &ShardId, )

fn unsubscribe(&self, connection_id: usize, shard_id: &ShardId)

Trait Implementations

impl Debug for PubSubState

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

Formats the value using the given formatter.