Struct CloudDatabaseHandler 

pub struct CloudDatabaseHandler { /* private fields */ }

Handler for Cloud database operations

Provides methods for managing Redis Cloud databases including creation, updates, backups, imports, metrics collection, and scaling operations.

All database operations require both a subscription ID and database ID, as databases are scoped within subscriptions in Redis Cloud.

Implementations

impl CloudDatabaseHandler

pub fn new(client: CloudClient) -> Self

Create a new database handler instance

Arguments

• client - The configured CloudClient instance

pub async fn get( &self, subscription_id: u32, database_id: u32, ) -> Result<CloudDatabase>

Retrieve a specific database by ID

Returns detailed information about a database including its configuration, status, endpoints, and current metrics.

Arguments

• subscription_id - The ID of the subscription containing the database
• database_id - The unique database identifier

Examples

let db_handler = CloudDatabaseHandler::new(client);
let database = db_handler.get(123, 456).await?;
println!("Database name: {}", database.name);
println!("Memory limit: {} GB", database.memory_limit_in_gb);

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

Create a new database in a subscription

Creates a new Redis database with the specified configuration. The database will be deployed across the subscription’s defined regions and cloud providers.

Arguments

• subscription_id - The ID of the subscription to create the database in
• request - Database configuration including name, memory, replication settings

Examples

let db_handler = CloudDatabaseHandler::new(client);
let config = json!({
    "name": "production-cache",
    "memory_limit_in_gb": 5.0,
    "replication": true,
    "data_persistence": "aof-every-1-sec",
    "password": "secure-password"
});
// Note: create() takes a typed request struct, not JSON
// let result = db_handler.create(123, create_request).await?;

pub async fn update( &self, subscription_id: u32, database_id: u32, request: UpdateDatabaseRequest, ) -> Result<CloudDatabase>

Update an existing database configuration

Modifies database settings such as memory limits, replication, persistence, and other configuration options. Some changes may require a database restart.

Arguments

• subscription_id - The ID of the subscription containing the database
• database_id - The unique database identifier
• request - Updated configuration settings

Examples

let db_handler = CloudDatabaseHandler::new(client);
let updates = json!({
    "memory_limit_in_gb": 10.0,
    "replication": false
});
// Note: update() takes a typed request struct, not JSON
// let updated_db = db_handler.update(123, 456, update_request).await?;

pub async fn delete( &self, subscription_id: u32, database_id: u32, ) -> Result<Value>

Delete a database permanently

Warning: This operation is irreversible and will permanently delete all data in the database. Consider creating a backup before deletion.

Arguments

• subscription_id - The ID of the subscription containing the database
• database_id - The unique database identifier

Examples

let db_handler = CloudDatabaseHandler::new(client);
let result = db_handler.delete(123, 456).await?;
println!("Database deleted successfully");

pub async fn resize( &self, subscription_id: u32, database_id: u32, memory_limit_in_gb: f64, ) -> Result<CloudDatabase>

Resize database

pub async fn list_all(&self) -> Result<Vec<CloudDatabase>>

List all databases across all subscriptions

pub async fn list(&self, subscription_id: u32) -> Result<Value>

List databases for subscription as Value

pub async fn get_raw( &self, subscription_id: u32, database_id: u32, ) -> Result<Value>

Get database as Value

pub async fn create_raw( &self, subscription_id: u32, request: Value, ) -> Result<Value>

Create database with Value

pub async fn update_raw( &self, subscription_id: u32, database_id: u32, request: Value, ) -> Result<Value>

Update database with Value

pub async fn backup( &self, subscription_id: u32, database_id: u32, ) -> Result<Value>

Backup database

pub async fn import( &self, subscription_id: u32, database_id: u32, request: Value, ) -> Result<Value>

Import data

pub async fn get_metrics( &self, subscription_id: u32, database_id: u32, metrics: &str, period: &str, ) -> Result<Value>

Get metrics

pub async fn backup_status( &self, subscription_id: u32, database_id: u32, ) -> Result<Value>

Get database backup status