Struct mz_persist_client::internal::watch::StateWatchNotifier

pub struct StateWatchNotifier {
    metrics: Arc<Metrics>,
    tx: Sender<SeqNo>,
}

Fields

metrics: Arc<Metrics>

tx: Sender<SeqNo>

Implementations

impl StateWatchNotifier

pub(crate) fn new(metrics: Arc<Metrics>) -> Self

pub(crate) fn notify(&self, seqno: SeqNo)

Wake up any watchers of this state.

This must be called while under the same lock that modified the state to avoid any potential for out of order SeqNos in the broadcast channel.

This restriction can be lifted (i.e. we could notify after releasing the write lock), but we’d have to reason about out of order SeqNos in the broadcast channel. In particular, if we see RecvError::Lagged then it’s possible we lost X+1 and got X, so if X isn’t sufficient to return, we’d need to grab the read lock and verify the real SeqNo.

Trait Implementations

impl Debug for StateWatchNotifier

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

Formats the value using the given formatter.