redisctl 0.10.1

Unified CLI for Redis Cloud and Enterprise
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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129

use crate::cli::OutputFormat;
use crate::connection::ConnectionManager;
use crate::error::{RedisCtlError, Result as CliResult};
use clap::Subcommand;

#[derive(Debug, Clone, Subcommand)]
pub enum LocalCommands {
    /// Get local node master healthcheck
    #[command(name = "healthcheck")]
    MasterHealthcheck,

    /// List local services
    Services,

    /// Update local services configuration
    #[command(
        name = "services-update",
        after_help = "EXAMPLES:
    # Update service action
    redisctl enterprise local services-update --action start --service cm_server

    # Using JSON for full configuration
    redisctl enterprise local services-update --data @services.json"
    )]
    ServicesUpdate {
        /// Service action (start, stop, restart)
        #[arg(long)]
        action: Option<String>,
        /// Service name
        #[arg(long)]
        service: Option<String>,
        /// Service configuration as JSON string or @file.json (optional)
        #[arg(long, value_name = "FILE|JSON")]
        data: Option<String>,
    },
}

impl LocalCommands {
    #[allow(dead_code)]
    pub async fn execute(
        &self,
        conn_mgr: &ConnectionManager,
        profile_name: Option<&str>,
        output_format: OutputFormat,
        query: Option<&str>,
    ) -> CliResult<()> {
        let client = conn_mgr.create_enterprise_client(profile_name).await?;

        match self {
            LocalCommands::MasterHealthcheck => {
                let response: serde_json::Value = client
                    .get("/v1/local/node/master_healthcheck")
                    .await
                    .map_err(RedisCtlError::from)?;

                let output_data = if let Some(q) = query {
                    super::utils::apply_jmespath(&response, q)?
                } else {
                    response
                };
                super::utils::print_formatted_output(output_data, output_format)?;
            }

            LocalCommands::Services => {
                let response: serde_json::Value = client
                    .get("/v1/local/services")
                    .await
                    .map_err(RedisCtlError::from)?;

                let output_data = if let Some(q) = query {
                    super::utils::apply_jmespath(&response, q)?
                } else {
                    response
                };
                super::utils::print_formatted_output(output_data, output_format)?;
            }

            LocalCommands::ServicesUpdate {
                action,
                service,
                data,
            } => {
                // Start with JSON from --data if provided, otherwise empty object
                let mut json_data = if let Some(data_str) = data {
                    super::utils::read_json_data(data_str)?
                } else {
                    serde_json::json!({})
                };

                let data_obj = json_data.as_object_mut().unwrap();

                // CLI parameters override JSON values
                if let Some(a) = action {
                    data_obj.insert("action".to_string(), serde_json::json!(a));
                }
                if let Some(s) = service {
                    data_obj.insert("service".to_string(), serde_json::json!(s));
                }

                let response: serde_json::Value = client
                    .post("/v1/local/services", &json_data)
                    .await
                    .map_err(RedisCtlError::from)?;

                let output_data = if let Some(q) = query {
                    super::utils::apply_jmespath(&response, q)?
                } else {
                    response
                };
                super::utils::print_formatted_output(output_data, output_format)?;
            }
        }

        Ok(())
    }
}

#[allow(dead_code)]
pub async fn handle_local_command(
    conn_mgr: &ConnectionManager,
    profile_name: Option<&str>,
    local_cmd: LocalCommands,
    output_format: OutputFormat,
    query: Option<&str>,
) -> CliResult<()> {
    local_cmd
        .execute(conn_mgr, profile_name, output_format, query)
        .await
}