Struct PeerDatabase 

pub struct PeerDatabase { /* private fields */ }

Database connection wrapper with automatic migrations

Implementations

impl PeerDatabase

pub fn open(db_path: PathBuf) -> Result<Self, Report>

Create or open a peer database at the given path

pub fn load_manager_peers( &self, profile: &str, ) -> Result<Vec<ManagerPeerEntry>, Report>

Load all manager peers for a given profile

pub fn save_manager_peers( &mut self, profile: &str, peers: &[ManagerPeerEntry], ) -> Result<(), Report>

Save manager peers for a given profile (replaces all existing peers)

pub fn add_manager_peer( &mut self, profile: &str, peer: ManagerPeerEntry, ) -> Result<(), Report>

Add or update a single manager peer

pub fn remove_manager_peer( &mut self, profile: &str, manager_id: &str, tenant: &str, cluster: &str, ) -> Result<bool, Report>

Remove a manager peer

pub fn load_manager_peers_for_gossip( &self, profile: &str, ) -> Result<Vec<ManagerPeerEntry>, Report>

Load manager peers for gossip (excludes temporary joining placeholders)

pub fn load_worker_peers( &self, profile: &str, ) -> Result<(Vec<WorkerPeerEntry>, u64), Report>

Load worker peers for a given profile

pub fn save_worker_peers( &mut self, profile: &str, peers: &[WorkerPeerEntry], version: u64, ) -> Result<(), Report>

Save worker peers for a given profile

pub fn add_worker_peer( &mut self, profile: &str, peer: WorkerPeerEntry, ) -> Result<(), Report>

Add a worker peer if it doesn’t already exist

pub fn get_peer_version(&self, profile: &str, role: &str) -> Result<u64, Report>

Get peer version for a given profile and role

pub fn set_peer_version( &mut self, profile: &str, role: &str, version: u64, ) -> Result<(), Report>

Set peer version for a given profile and role

pub fn increment_peer_version( &mut self, profile: &str, role: &str, ) -> Result<u64, Report>

Increment and return the new peer version for a profile/role

pub fn get_db_size(&self) -> Result<u64, Report>

Get database file size in bytes (for monitoring/debugging)

pub fn optimize(&mut self) -> Result<(), Report>

Optimize database (vacuum and analyze)