Struct mz_persist_client::cache::LockingTypedState

pub(crate) struct LockingTypedState<K, V, T, D> {
    shard_id: ShardId,
    state: RwLock<TypedState<K, V, T, D>>,
    notifier: StateWatchNotifier,
    cfg: Arc<PersistConfig>,
    metrics: Arc<Metrics>,
    shard_metrics: Arc<ShardMetrics>,
    _subscription_token: Arc<ShardSubscriptionToken>,
}

A locked decorator for TypedState that abstracts out the specific lock implementation used. Guards the private lock with public accessor fns to make locking scopes more explicit and simpler to reason about.

Fields

shard_id: ShardId

state: RwLock<TypedState<K, V, T, D>>

notifier: StateWatchNotifier

cfg: Arc<PersistConfig>

metrics: Arc<Metrics>

shard_metrics: Arc<ShardMetrics>

_subscription_token: Arc<ShardSubscriptionToken>

Implementations

impl<K, V, T, D> LockingTypedState<K, V, T, D>

fn new( shard_id: ShardId, initial_state: TypedState<K, V, T, D>, metrics: Arc<Metrics>, cfg: Arc<PersistConfig>, subscription_token: Arc<ShardSubscriptionToken>, diagnostics: &Diagnostics ) -> Self

pub(crate) fn shard_id(&self) -> &ShardId

pub(crate) fn read_lock<R, F: FnMut(&TypedState<K, V, T, D>) -> R>( &self, metrics: &LockMetrics, f: F ) -> R

pub(crate) fn write_lock<R, F: FnOnce(&mut TypedState<K, V, T, D>) -> R>( &self, metrics: &LockMetrics, f: F ) -> R

pub(crate) fn notifier(&self) -> &StateWatchNotifier

Trait Implementations

impl<K, V, T: Debug, D> Debug for LockingTypedState<K, V, T, D>

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

Formats the value using the given formatter.

impl<K, V, T, D> DynState for LockingTypedState<K, V, T, D>where K: Codec, V: Codec, T: Timestamp + Lattice + Codec64, D: Codec64,

fn codecs(&self) -> (String, String, String, String, Option<CodecConcreteType>)

fn as_any(self: Arc<Self>) -> Arc<dyn Any + Send + Sync>

fn push_diff(&self, diff: VersionedData)