Struct raftstore::store::replication_mode::StoreGroup

pub struct StoreGroup {
    labels: HashMap<u64, Vec<StoreLabel>>,
    label_ids: HashMap<String, u64>,
    stores: HashMap<u64, u64>,
    label_key: String,
    version: u64,
    dirty: bool,
}

A registry that maps store to a group.

A group ID is generated according to the label value. Stores with same label value will be mapped to the same group ID.

Fields

labels: HashMap<u64, Vec<StoreLabel>>

label_ids: HashMap<String, u64>

stores: HashMap<u64, u64>

label_key: String

version: u64

dirty: bool

Implementations

impl StoreGroup

pub fn backup_store_labels(&mut self, store: &mut Store)

Backs store labels.

When using majority mode, labels still need to be backup for future usage. Should only call it in majority mode.

pub fn register_store(
    &mut self,
    store_id: u64,
    labels: Vec<StoreLabel>
) -> Option<u64>

Registers the store with given label value.

Panics

Panics if the store is registered twice with different store ID.

pub fn group_id(&self, version: u64, store_id: u64) -> Option<u64>

Gets the group ID of store.

Different version may indicates different label key. If version is less than recorded one, then label key has to be changed, new value can’t be mixed with old values, so None is returned. If version is larger, then label key must still matches. Because recalculate is called before updating regions’ replication status, so unchanged recorded version means unchanged label key.

fn recalculate(&mut self, status: &ReplicationStatus)

Clears id caches and recalculates if necessary.

If label key is not changed, the function is no-op.

Trait Implementations

impl Debug for StoreGroup

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

Formats the value using the given formatter.

impl Default for StoreGroup

fn default() -> StoreGroup

Returns the “default value” for a type.