Struct mz_persist_txn::txn_cache::TxnsCache

pub struct TxnsCache<T: Timestamp + Lattice + Codec64, C: TxnsCodec = TxnsCodecDefault> { /* private fields */ }

A self-updating TxnsCacheState.

Implementations

impl<T: Timestamp + Lattice + TotalOrder + StepForward + Codec64, C: TxnsCodec> TxnsCache<T, C>

pub async fn open( client: &PersistClient, txns_id: ShardId, only_data_id: Option<ShardId> ) -> Self

Returns a TxnsCache reading from the given txn shard.

txns_id identifies which shard will be used as the txns WAL. MZ will likely have one of these per env, used by all processes and the same across restarts.

pub async fn update_gt(&mut self, ts: &T)

Invariant: afterward, self.progress_exclusive will be > ts

pub async fn update_ge(&mut self, ts: &T)

Invariant: afterward, self.progress_exclusive will be >= ts

Methods from Deref<Target = TxnsCacheState<T>>

pub fn txns_id(&self) -> ShardId

Returns the ShardId of the txns shard.

pub fn registered_at(&self, data_id: &ShardId, ts: &T) -> bool

Returns whether the data shard was registered to the txns set at the given timestamp.

Specifically, a data shard is registered at a timestamp ts if it has a register_ts <= ts but no register_ts < forget_ts < ts.

pub fn data_snapshot(&self, data_id: ShardId, as_of: T) -> DataSnapshot<T>

Returns a token exchangeable for a snapshot of a data shard.

A data shard might be definite at times past the physical upper because of invariants maintained by this txn system. As a result, this method discovers the latest potentially unapplied write before the as_of.

Callers must first wait for TxnsCache::update_gt with the same or later timestamp to return. Panics otherwise.

pub fn data_listen_next(&self, data_id: &ShardId, ts: &T) -> DataListenNext<T>

Returns the next action to take when iterating a Listen on a data shard.

A data shard Listen is executed by repeatedly calling this method with an exclusive progress frontier. The returned value indicates an action to take. Some of these actions advance the progress frontier, which results in calling this method again with a higher timestamp, and thus a new action. See DataListenNext for specifications of the actions.

Note that this is a state machine on self.progress_exclusive and the listen progress. DataListenNext indicates which state transitions to take.

pub fn min_unapplied_ts(&self) -> &T

Returns the minimum timestamp not known to be applied by this cache.

Trait Implementations

impl<T: Debug + Timestamp + Lattice + Codec64, C: Debug + TxnsCodec> Debug for TxnsCache<T, C>

where C::Key: Debug, C::Val: Debug,

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

Formats the value using the given formatter.

impl<T: Timestamp + Lattice + Codec64, C: TxnsCodec> Deref for TxnsCache<T, C>

type Target = TxnsCacheState<T>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<T: Timestamp + Lattice + Codec64, C: TxnsCodec> DerefMut for TxnsCache<T, C>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.