Struct ReplicationStatus 

pub struct ReplicationStatus {
    pub node_status: HashMap<NodeId, NodeStatus>,
    pub failed_nodes: HashSet<NodeId>,
    pub total_operations_processed: u64,
    pub total_operations_failed: u64,
}

Replication status tracking

Fields

node_status: HashMap<NodeId, NodeStatus>

failed_nodes: HashSet<NodeId>

total_operations_processed: u64

total_operations_failed: u64

Implementations

impl ReplicationStatus

pub fn new() -> Self

pub fn update_node_lag(&mut self, node_id: &NodeId, lag: Duration)

pub fn mark_node_failed(&mut self, node_id: &NodeId)

pub fn record_operation_success(&mut self, node_id: &NodeId)

pub fn record_operation_failure(&mut self, node_id: &NodeId)

pub fn get_average_lag(&self) -> Duration

Trait Implementations

impl Debug for ReplicationStatus

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

Formats the value using the given formatter.