Struct DatabaseHandler 

pub struct DatabaseHandler { /* private fields */ }

Database handler for executing database commands

Implementations

impl DatabaseHandler

pub fn new(client: RestClient) -> Self

pub async fn list(&self) -> Result<Vec<DatabaseInfo>>

List all databases (BDB.LIST)

pub async fn info(&self, uid: u32) -> Result<DatabaseInfo>

Get specific database info (BDB.INFO)

pub async fn get(&self, uid: u32) -> Result<DatabaseInfo>

Get specific database info (alias for info)

pub async fn create( &self, request: CreateDatabaseRequest, ) -> Result<DatabaseInfo>

Create a new database (BDB.CREATE)

pub async fn update(&self, uid: u32, updates: Value) -> Result<DatabaseInfo>

Update database configuration (BDB.UPDATE)

pub async fn delete(&self, uid: u32) -> Result<()>

Delete a database (BDB.DELETE)

pub async fn stats(&self, uid: u32) -> Result<Value>

Get database stats (BDB.STATS)

pub async fn metrics(&self, uid: u32) -> Result<Value>

Get database metrics (BDB.METRICS)

pub async fn start(&self, uid: u32) -> Result<Value>

Start database (BDB.START)

pub async fn stop(&self, uid: u32) -> Result<Value>

Stop database (BDB.STOP)

pub async fn restart(&self, uid: u32) -> Result<DatabaseActionResponse>

Restart database (BDB.RESTART)

pub async fn export( &self, uid: u32, export_location: &str, ) -> Result<ExportResponse>

Export database (BDB.EXPORT)

pub async fn import( &self, uid: u32, import_location: &str, flush: bool, ) -> Result<ImportResponse>

Import database (BDB.IMPORT)

pub async fn flush(&self, uid: u32) -> Result<DatabaseActionResponse>

Flush database (BDB.FLUSH)

pub async fn backup(&self, uid: u32) -> Result<BackupResponse>

Backup database (BDB.BACKUP)

pub async fn restore( &self, uid: u32, backup_uid: Option<&str>, ) -> Result<DatabaseActionResponse>

Restore database from backup (BDB.RESTORE)

pub async fn shards(&self, uid: u32) -> Result<Value>

Get database shards (BDB.SHARDS)

pub async fn endpoints(&self, uid: u32) -> Result<Vec<EndpointInfo>>

Get database endpoints (BDB.ENDPOINTS)

pub async fn optimize_shards_placement(&self, uid: u32) -> Result<Value>

Optimize shards placement (status) - GET

pub async fn recover_status(&self, uid: u32) -> Result<Value>

Recover database (status) - GET

pub async fn recover(&self, uid: u32) -> Result<DatabaseActionResponse>

Recover database - POST

pub async fn resume_traffic(&self, uid: u32) -> Result<DatabaseActionResponse>

Resume traffic - POST

pub async fn stop_traffic(&self, uid: u32) -> Result<DatabaseActionResponse>

Stop traffic - POST

pub async fn rebalance(&self, uid: u32) -> Result<DatabaseActionResponse>

Rebalance database - PUT

pub async fn revamp(&self, uid: u32) -> Result<DatabaseActionResponse>

Revamp database - PUT

pub async fn backup_reset_status(&self, uid: u32) -> Result<Value>

Reset backup status - PUT

pub async fn export_reset_status(&self, uid: u32) -> Result<Value>

Reset export status - PUT

pub async fn import_reset_status(&self, uid: u32) -> Result<Value>

Reset import status - PUT

pub async fn peer_stats(&self, uid: u32) -> Result<Value>

Peer stats for a database - GET

pub async fn peer_stats_for(&self, uid: u32, peer_uid: u32) -> Result<Value>

Peer stats for a specific peer - GET

pub async fn sync_source_stats(&self, uid: u32) -> Result<Value>

Sync source stats for a database - GET

pub async fn sync_source_stats_for( &self, uid: u32, src_uid: u32, ) -> Result<Value>

Sync source stats for a specific source - GET

pub async fn syncer_state(&self, uid: u32) -> Result<Value>

Syncer state (all) - GET

pub async fn syncer_state_crdt(&self, uid: u32) -> Result<Value>

Syncer state for CRDT - GET

pub async fn syncer_state_replica(&self, uid: u32) -> Result<Value>

Syncer state for replica - GET

pub async fn passwords_delete(&self, uid: u32) -> Result<()>

Database passwords delete - DELETE

pub async fn alerts_all(&self) -> Result<Value>

List all database alerts - GET

pub async fn alerts_for(&self, uid: u32) -> Result<Value>

List alerts for a specific database - GET

pub async fn alert_detail(&self, uid: u32, alert: &str) -> Result<Value>

Get a specific alert for a database - GET

pub async fn crdt_source_alerts_all(&self) -> Result<Value>

CRDT source alerts - GET

pub async fn crdt_source_alerts_for(&self, uid: u32) -> Result<Value>

CRDT source alerts for DB - GET

pub async fn crdt_source_alerts_source( &self, uid: u32, source_id: u32, ) -> Result<Value>

CRDT source alerts for specific source - GET

pub async fn crdt_source_alert_detail( &self, uid: u32, source_id: u32, alert: &str, ) -> Result<Value>

CRDT source alert detail - GET

pub async fn replica_source_alerts_all(&self) -> Result<Value>

Replica source alerts - GET

pub async fn replica_source_alerts_for(&self, uid: u32) -> Result<Value>

Replica source alerts for DB - GET

pub async fn replica_source_alerts_source( &self, uid: u32, source_id: u32, ) -> Result<Value>

Replica source alerts for specific source - GET

pub async fn replica_source_alert_detail( &self, uid: u32, source_id: u32, alert: &str, ) -> Result<Value>

Replica source alert detail - GET

pub async fn upgrade( &self, uid: u32, module_name: &str, new_version: &str, ) -> Result<DatabaseActionResponse>

Upgrade database with new module version (BDB.UPGRADE)

pub async fn reset_password( &self, uid: u32, new_password: &str, ) -> Result<DatabaseActionResponse>

Reset database password (BDB.RESET_PASSWORD)

pub async fn availability(&self, uid: u32) -> Result<Value>

Check database availability

pub async fn endpoint_availability(&self, uid: u32) -> Result<Value>

Check local database endpoint availability

pub async fn create_v2(&self, request: Value) -> Result<DatabaseInfo>

Create database using v2 API (supports recovery plan)