Struct ReplicationController 

pub struct ReplicationController { /* private fields */ }

Replication controller for managing cross-region replication

Implementations

impl ReplicationController

pub fn new() -> Self

Create new replication controller

pub fn set_default_policy(&self, policy: ReplicationPolicy)

Set default replication policy

pub fn register_region(&self, region: impl Into<String>)

Register available region

pub fn unregister_region(&self, region: &str)

Unregister region

pub fn add_callback<C: ReplicationCallback + 'static>(&self, callback: C)

Add replication callback

pub fn replicate( &self, resource_id: impl Into<String>, primary_region: impl Into<String>, policy: Option<ReplicationPolicy>, )

Start replication for a resource

pub fn update_state(&self, resource_id: &str, region: &str, state: ReplicaState)

Update replica state

pub fn update_lag(&self, resource_id: &str, region: &str, lag_ms: u64)

Update replication lag

pub fn get_status(&self, resource_id: &str) -> Option<ReplicationStatus>

Get replication status

pub fn list_replicated(&self) -> Vec<ReplicationStatus>

Get all replicated resources

pub fn stop_replication(&self, resource_id: &str)

Stop replication for a resource

pub fn promote(&self, resource_id: &str, new_primary: &str) -> bool

Promote a replica to primary

pub fn is_replicated_to(&self, resource_id: &str, region: &str) -> bool

Check if resource is replicated to a region

pub fn healthy_replicas(&self, resource_id: &str) -> Vec<String>

Get healthy replicas for a resource

Trait Implementations

impl Default for ReplicationController

fn default() -> Self

Returns the “default value” for a type.