Struct CacheApplier 

pub struct CacheApplier { /* private fields */ }

Default applier that writes committed entries to an in-memory MetadataCache. The cache is shared with the rest of the process via Arc<RwLock<_>>.

Implementations

impl CacheApplier

pub fn new(cache: Arc<RwLock<MetadataCache>>) -> Self

pub fn with_live_state( self, topology: Arc<RwLock<ClusterTopology>>, routing: Arc<RwLock<RoutingTable>>, ) -> Self

Extend this applier with live topology/routing handles. When set, committed TopologyChange and RoutingChange entries mutate the handles in place in addition to the in-memory history log kept in MetadataCache. Backward-compatible: existing callers that don’t attach handles see no behaviour change.

pub fn with_migration_state( self, migration_state: SharedMigrationStateTable, ) -> Self

Attach a migration state table so that committed MigrationCheckpoint and MigrationAbort entries are durably persisted. Backward-compatible: existing callers that don’t manage migrations can omit this.

pub fn with_token_state(self, token_state: SharedTokenStateMirror) -> Self

Attach a token state mirror so that committed JoinTokenTransition entries are reflected into the shared mirror immediately after apply. The same Arc must be passed to RaftBackedTokenStore::new so both sides share the same table. Backward-compatible: existing callers that don’t use join tokens omit this.

pub fn cache(&self) -> Arc<RwLock<MetadataCache>>

Trait Implementations

impl Clone for CacheApplier

fn clone(&self) -> CacheApplier

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl MetadataApplier for CacheApplier

fn apply(&self, entries: &[(u64, Vec<u8>)]) -> u64

Apply a batch of committed raft entries. Entries with empty data (raft no-ops) are skipped. Returns the highest log index applied.