Struct 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>,
    schema_cache: Arc<dyn Any + Send + Sync>,
    _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>

schema_cache: Arc<dyn Any + Send + Sync>

A SchemaCacheMaps<K, V>, but stored as an Any so the : Codec bounds don’t propagate to basically every struct in persist.

_subscription_token: Arc<ShardSubscriptionToken>

Implementations

impl<K: Codec, V: Codec, 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 schema_cache(&self) -> Arc<SchemaCacheMaps<K, V>>

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

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 + Sync, 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)