Struct SyncManager 

pub struct SyncManager { /* private fields */ }

Thread-safe sync manager.

Implementations

impl SyncManager

pub fn new() -> Self

pub fn with_cipher(cipher: Cipher) -> Self

Create a sync manager with encryption enabled.

pub fn with_geo_router(cipher: Option<Cipher>, router: GeoRouter) -> Self

Create a sync manager with a geographic router for latency-aware routing.

pub fn update_cipher(&mut self, cipher: Cipher)

Update the cipher (used after unseal to re-derive keys).

pub fn load_subscriptions(&self, store: &TensorStore)

Load subscriptions from storage.

pub fn register_target(&self, target: Box<dyn SyncTarget>) -> Result<()>

Register a sync target.

pub fn subscribe( &self, store: &TensorStore, secret_key: &str, target_name: &str, ) -> Result<()>

Subscribe a secret to a sync target.

pub fn unsubscribe( &self, store: &TensorStore, secret_key: &str, target_name: &str, ) -> Result<()>

Unsubscribe a secret from a sync target.

pub fn trigger_sync(&self, key: &str, value: &str) -> Result<usize>

Trigger sync for a specific secret key and value.

When a cipher is set, the value is encrypted before pushing to targets. Format: base64(nonce(12) || ciphertext).

pub fn trigger_delete(&self, key: &str) -> Result<usize>

Trigger delete sync for a key.

pub fn trigger_sync_routed( &self, key: &str, value: &str, location: Option<&GeoCoordinate>, ) -> Result<usize>

Trigger sync using the geo router to select optimal targets.

Falls back to trigger_sync if no geo router is configured.

pub fn list_targets(&self) -> Vec<String>

List all registered sync target names.

pub fn health_check(&self) -> Vec<(String, bool)>

Health check for all targets.

Trait Implementations

impl Default for SyncManager

fn default() -> Self

Returns the “default value” for a type.