redis-enterprise 0.8.7

Redis Enterprise REST API client library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

//! Cluster Manager configuration
//!
//! ## Overview
//! - Configure CM settings
//! - Manage cluster-wide parameters
//! - Query configuration status

use crate::client::RestClient;
use crate::error::Result;
use serde::{Deserialize, Serialize};

/// Cluster Manager settings
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct CmSettings {
    /// Port number for the Cluster Manager service
    #[serde(skip_serializing_if = "Option::is_none")]
    pub cm_port: Option<u16>,
    /// Session timeout for Cluster Manager connections in seconds
    #[serde(skip_serializing_if = "Option::is_none")]
    pub cm_session_timeout: Option<u32>,
    /// Enable automatic recovery of failed databases
    #[serde(skip_serializing_if = "Option::is_none")]
    pub auto_recovery: Option<bool>,
    /// Enable automatic failover for high availability
    #[serde(skip_serializing_if = "Option::is_none")]
    pub auto_failover: Option<bool>,
    /// Enable slave high availability for replica databases
    #[serde(skip_serializing_if = "Option::is_none")]
    pub slave_ha: Option<bool>,
    /// Grace period in seconds before triggering slave high availability
    #[serde(skip_serializing_if = "Option::is_none")]
    pub slave_ha_grace_period: Option<u32>,
    /// Maximum number of simultaneous backup operations allowed
    #[serde(skip_serializing_if = "Option::is_none")]
    pub max_simultaneous_backups: Option<u32>,
}

/// Cluster Manager settings handler
pub struct CmSettingsHandler {
    client: RestClient,
}

impl CmSettingsHandler {
    pub fn new(client: RestClient) -> Self {
        CmSettingsHandler { client }
    }

    /// Get Cluster Manager settings
    pub async fn get(&self) -> Result<CmSettings> {
        self.client.get("/v1/cm_settings").await
    }

    /// Update Cluster Manager settings
    pub async fn update(&self, settings: CmSettings) -> Result<CmSettings> {
        self.client.put("/v1/cm_settings", &settings).await
    }

    /// Reset Cluster Manager settings to defaults
    pub async fn reset(&self) -> Result<()> {
        self.client.delete("/v1/cm_settings").await
    }
}