Struct mz_persist_client::cache::StateCache

pub struct StateCache { /* private fields */ }

A cache of TypedState, shared between all machines for that shard.

This is shared between all machines that come out of the same PersistClientCache, but in production there is one of those per process, so in practice, we have one copy of state per shard per process.

The mutex contention between commands is not an issue, because if two command for the same shard are executing concurrently, only one can win anyway, the other will retry. With the mutex, we even get to avoid the retry if the racing commands are on the same process.

Implementations

impl StateCache

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

Returns a new StateCache.

Trait Implementations

impl Debug for StateCache

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

Formats the value using the given formatter.