Struct MetaState 

pub struct MetaState {

    pub format_version: u32,
    pub metadata_version: MetadataVersion,
    pub nodes: BTreeMap<NodeId, NodeRecord>,
    pub databases: BTreeMap<DatabaseId, DatabaseDescriptor>,
    pub tables: BTreeMap<TableId, TableSchemaRecord>,
    pub tablets: BTreeMap<TabletId, TabletRecord>,
    pub placements: BTreeMap<RaftGroupId, ReplicaPlacement>,
    pub placement_policies: BTreeMap<String, PlacementPolicyRecord>,
    pub schema_jobs: BTreeMap<u64, SchemaJobRecord>,
    pub txn_status_partitions: BTreeMap<u32, TxnStatusPartition>,
    pub settings: ClusterSettings,
    pub feature_level: ClusterFeatureLevel,
    pub feature_activations: Vec<FeatureActivation>,
    pub rejections: VecDeque<MetaRejection>,
    pub next_raft_node_id: u64,
    pub raft_id_allocations: BTreeMap<String, u64>,
    pub raft_id_allocation_order: VecDeque<String>,
}

The replicated control-plane state of the meta group (spec section 12.1).

Deterministic: every replica applies the same commands in the same order and reaches byte-identical state. Versioned: format_version gates the snapshot format and metadata_version ticks once per applied command (accepted or refused — a refusal appends to the rejection journal, which is itself state), giving readers a monotonic watermark.

Fields

format_version: u32

Snapshot format version; see META_STATE_FORMAT_VERSION.

metadata_version: MetadataVersion

Monotonic per-applied-command version.

nodes: BTreeMap<NodeId, NodeRecord>

Cluster membership: registered node descriptors and locality.

databases: BTreeMap<DatabaseId, DatabaseDescriptor>

Logical databases.

tables: BTreeMap<TableId, TableSchemaRecord>

Replicated table schemas.

tablets: BTreeMap<TabletId, TabletRecord>

Tablet records (canonical descriptor + modification version).

placements: BTreeMap<RaftGroupId, ReplicaPlacement>

Replica placements by raft group.

placement_policies: BTreeMap<String, PlacementPolicyRecord>

Named placement policy records (spec section 12.7).

schema_jobs: BTreeMap<u64, SchemaJobRecord>

Schema/index jobs.

txn_status_partitions: BTreeMap<u32, TxnStatusPartition>

Transaction status partitions (spec section 12.8).

settings: ClusterSettings

Dynamic cluster settings (spec section 16.2).

feature_level: ClusterFeatureLevel

Cluster feature level (never lowers; ADR-0010).

feature_activations: Vec<FeatureActivation>

Applied feature activations, oldest first.

rejections: VecDeque<MetaRejection>

Bounded journal of refused commands, oldest first (META_REJECTION_LIMIT).

next_raft_node_id: u64

Next per-group raft node id the meta-owned allocator hands out (MetaCommand::AllocateRaftNodeIds); monotonic and never reused. Starts at FIRST_RAFT_NODE_ID.

raft_id_allocations: BTreeMap<String, u64>

Recent raft-node-id allocations by command id (hex-encoded, base of each allocated range), the idempotent-replay record of MetaCommand::AllocateRaftNodeIds; bounded by RAFT_ID_ALLOCATION_RECORD_LIMIT. (Hex keys: JSON map keys must be strings.)

raft_id_allocation_order: VecDeque<String>

Eviction order of Self::raft_id_allocations, oldest first.

Implementations

impl MetaState

pub fn apply( &mut self, command: &MetaCommand, command_id: Option<[u8; 16]>, commit_ts: HlcTimestamp, registry: &FeatureRegistry, ) -> Result<(), MetaRejectionReason>

Applies one committed command. metadata_version ticks first (every applied command moves the watermark); a refusal journals the reason and leaves the records untouched.

commit_ts is the leader-assigned commit timestamp of the command’s log entry: an FeatureActivation::activated_at left as HlcTimestamp::ZERO by the proposer is stamped with it here, so every replica records the identical timestamp.

pub fn node(&self, node_id: NodeId) -> Option<&NodeDescriptor>

One registered node’s descriptor.

pub fn node_record(&self, node_id: NodeId) -> Option<&NodeRecord>

One registered node’s record (descriptor + modification version).

pub fn node_descriptors(&self) -> Vec<NodeDescriptor>

Every registered node descriptor, in node-id order.

pub fn database(&self, database_id: DatabaseId) -> Option<&DatabaseDescriptor>

One database descriptor by id.

pub fn database_by_name(&self, name: &str) -> Option<&DatabaseDescriptor>

One database descriptor by name.

pub fn table(&self, table_id: TableId) -> Option<&TableSchemaRecord>

One table’s schema record.

pub fn tablet(&self, tablet_id: TabletId) -> Option<&TabletDescriptor>

One tablet descriptor (the canonical crate::tablet shape).

pub fn tablet_record(&self, tablet_id: TabletId) -> Option<&TabletRecord>

One tablet record (descriptor + modification version).

pub fn placement(&self, raft_group_id: RaftGroupId) -> Option<&ReplicaPlacement>

One raft group’s replica placement.

pub fn placement_policy(&self, name: &str) -> Option<&PlacementPolicy>

One named placement policy (the canonical crate::placement shape).

pub fn placement_policy_record( &self, name: &str, ) -> Option<&PlacementPolicyRecord>

One named placement policy record (policy + modification version).

pub fn schema_job(&self, job_id: u64) -> Option<&SchemaJobRecord>

One schema job record.

pub fn txn_status_partition( &self, partition_id: u32, ) -> Option<&TxnStatusPartition>

One transaction status partition.

pub fn settings(&self) -> &ClusterSettings

The dynamic cluster settings.

pub fn feature_level(&self) -> ClusterFeatureLevel

The cluster feature level.

pub fn feature_active(&self, registry: &FeatureRegistry, feature: &str) -> bool

Whether feature is active at the state’s current feature level.

pub fn feature_activations(&self) -> &[FeatureActivation]

The applied feature activations, oldest first.

pub fn rejections(&self) -> &VecDeque<MetaRejection>

The bounded refusal journal, oldest first.

pub fn next_raft_node_id(&self) -> u64

The next id the meta-owned raft-node-id allocator hands out.

pub fn raft_id_allocation(&self, command_id: &[u8; 16]) -> Option<u64>

The base of the range allocated by the command with id command_id, when the allocation record is still retained (RAFT_ID_ALLOCATION_RECORD_LIMIT).

Trait Implementations

impl Clone for MetaState

fn clone(&self) -> MetaState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MetaState

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

Formats the value using the given formatter.

impl Default for MetaState

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for MetaState

where MetaState: Default,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for MetaState

fn eq(&self, other: &MetaState) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for MetaState

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for MetaState