oxirs-cluster 0.2.4

Raft-backed distributed dataset for high availability and horizontal scaling
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

//! # RegionManager - perform_region_failover_group Methods
//!
//! This module contains method implementations for `RegionManager`.
//!
//! 🤖 Generated with [SplitRS](https://github.com/cool-japan/splitrs)

use anyhow::Result;

use super::types::ConnectivityStatus;

use super::regionmanager_type::RegionManager;

impl RegionManager {
    /// Perform region failover
    pub async fn perform_region_failover(
        &self,
        failed_region: &str,
        target_region: &str,
    ) -> Result<()> {
        tracing::warn!(
            "Performing region failover from {} to {}",
            failed_region,
            target_region
        );
        let topology = self.topology.read().await;
        if !topology.regions.contains_key(target_region) {
            return Err(anyhow::anyhow!("Invalid target region: {}", target_region));
        }
        let region_ids: Vec<String> = topology.regions.keys().cloned().collect();
        drop(topology);
        let mut topology = self.topology.write().await;
        for region_id in region_ids {
            topology.connectivity_status.insert(
                (failed_region.to_string(), region_id.clone()),
                ConnectivityStatus::Disconnected,
            );
            topology.connectivity_status.insert(
                (region_id, failed_region.to_string()),
                ConnectivityStatus::Disconnected,
            );
        }
        tracing::info!(
            "Region failover completed from {} to {}",
            failed_region,
            target_region
        );
        Ok(())
    }
}