Struct DistributedRegionRecord 

pub struct DistributedRegionRecord {
    pub id: RegionId,
    pub state: DistributedRegionState,
    pub config: DistributedRegionConfig,
    pub replicas: Vec<ReplicaInfo>,
    pub transitions: VecDeque<StateTransition>,
    pub last_replicated: Option<Time>,
    pub parent: Option<RegionId>,
    pub budget: Budget,
}

Internal record for a distributed region.

Fields

id: RegionId

Unique identifier for this region.

state: DistributedRegionState

Distributed-specific state.

config: DistributedRegionConfig

Configuration for this region.

replicas: Vec<ReplicaInfo>

Active replicas (by replica ID).

transitions: VecDeque<StateTransition>

State transition history (bounded).

last_replicated: Option<Time>

Last successful replication timestamp.

parent: Option<RegionId>

Parent region (if nested).

budget: Budget

Budget allocated to this region.

Implementations

impl DistributedRegionRecord

pub fn new( id: RegionId, config: DistributedRegionConfig, parent: Option<RegionId>, budget: Budget, ) -> Self

Creates a new distributed region in Initializing state.

pub fn activate(&mut self, now: Time) -> Result<StateTransition, Error>

Attempts to transition to Active state.

Returns error if quorum not reached or invalid transition.

pub fn replica_lost( &mut self, replica_id: &str, now: Time, ) -> Result<StateTransition, Error>

Marks a replica as lost and potentially degrades the region.

pub fn trigger_recovery( &mut self, initiator: &str, now: Time, ) -> Result<StateTransition, Error>

Triggers recovery from degraded state.

pub fn complete_recovery( &mut self, symbols_used: u32, now: Time, ) -> Result<StateTransition, Error>

Marks recovery as complete. Returns to Active.

pub fn fail_recovery( &mut self, reason: String, now: Time, ) -> Result<StateTransition, Error>

Marks recovery as failed. Transitions to Closing.

pub fn begin_close( &mut self, reason: TransitionReason, now: Time, ) -> Result<StateTransition, Error>

Begins the closing process.

pub fn complete_close(&mut self, now: Time) -> Result<StateTransition, Error>

Completes the close (terminal transition).

pub fn current_quorum(&self) -> u32

Returns the current quorum count (healthy replicas).

pub fn has_quorum(&self) -> bool

Returns true if quorum is maintained.

pub fn healthy_replicas(&self) -> u32

Returns healthy replica count.

pub fn add_replica(&mut self, info: ReplicaInfo) -> Result<(), Error>

Adds a replica to the region.

pub fn remove_replica(&mut self, replica_id: &str) -> Result<ReplicaInfo, Error>

Removes a replica from the region.

pub fn update_replica_status( &mut self, replica_id: &str, status: ReplicaStatus, now: Time, ) -> Result<(), Error>

Updates replica status based on heartbeat.

Trait Implementations

impl Debug for DistributedRegionRecord

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

Formats the value using the given formatter.