Add some models for redis-cli

Author: mstmdev

redis-cli/src/conf.rs

@@ -0,0 +1,12 @@
+mod cli_config;
+mod cli_conn_info;
+mod cli_ssl_config;
+mod cluster_manager_command;
+pub mod consts;
+mod pref;
+
+pub use cli_config::CliConfig;
+pub use cli_conn_info::CliConnInfo;
+pub use cli_ssl_config::CliSSLConfig;
+pub use cluster_manager_command::ClusterManagerCommand;
+pub use pref::Pref;

redis-cli/src/conf/cli_config.rs

@@ -0,0 +1,132 @@
+use super::CliSSLConfig;
+use super::CliConnInfo;
+use super::ClusterManagerCommand;
+use super::consts;
+
+pub struct CliConfig {
+    pub conn_info: CliConnInfo,
+    pub host_socket: String,
+    pub tls: i32,
+    pub ssl_config: CliSSLConfig,
+    pub repeat: i64,
+    pub interval: i64,
+    pub db_num: i32,
+    pub interactive: i32,
+    pub shutdown: i32,
+    pub monitor_mode: i32,
+    pub pub_sub_mode: i32,
+    pub blocking_state_aborted: i32,
+    pub latency_mode: i32,
+    pub latency_dist_mode: i32,
+    pub latency_history: i32,
+    pub lru_test_mode: i32,
+    pub lru_test_sample_size: i64,
+    pub cluster_mode: i32,
+    pub cluster_reissue_command: i32,
+    pub cluster_send_asking: i32,
+    pub slave_mode: i32,
+    pub pipe_mode: i32,
+    pub pipe_timeout: i32,
+    pub get_rdb_mode: i32,
+    pub get_functions_rdb_mode: i32,
+    pub stat_mode: i32,
+    pub scan_mode: i32,
+    pub intrinsic_latency_mode: i32,
+    pub intrinsic_latency_duration: i32,
+    pub pattern: String,
+    pub rdb_filename: String,
+    pub big_keys: i32,
+    pub mem_keys: i32,
+    pub mem_keys_samples: u32,
+    pub hot_keys: i32,
+    pub stdin_last_arg: i32,
+    pub stdin_tag_arg: i32,
+    pub stdin_tag_name: String,
+    pub ask_pass: i32,
+    pub quoted_input: i32,
+    pub output: i32,
+    pub push_output: i32,
+    pub mb_delim: String,
+    pub cmd_delim: String,
+    pub prompt: [char; 128],
+    pub eval: String,
+    pub eval_ldb: i32,
+    pub eval_ldb_sync: i32,
+    pub eval_ldb_end: i32,
+    pub enable_ldb_on_eval: i32,
+    pub last_cmd_type: i32,
+    pub verbose: i32,
+    pub set_errcode: i32,
+    pub cluster_manager_command: ClusterManagerCommand,
+    pub no_auth_warning: i32,
+    pub resp2: i32,
+    pub resp3: i32,
+    pub in_multi: i32,
+    pub pre_multi_db_num: i32,
+}
+
+impl CliConfig {
+    pub fn new() -> CliConfig {
+        CliConfig {
+            conn_info: CliConnInfo::new(),
+            host_socket: "".to_string(),
+            tls: 0,
+            ssl_config: CliSSLConfig::new(),
+            repeat: 1,
+            interval: 0,
+            db_num: 0,
+            interactive: 0,
+            shutdown: 0,
+            monitor_mode: 0,
+            pub_sub_mode: 0,
+            blocking_state_aborted: 0,
+            latency_mode: 0,
+            latency_dist_mode: 0,
+            latency_history: 0,
+            lru_test_mode: 0,
+            lru_test_sample_size: 0,
+            cluster_mode: 0,
+            cluster_reissue_command: 0,
+            cluster_send_asking: 0,
+            slave_mode: 0,
+            pipe_mode: 0,
+            pipe_timeout: consts::REDIS_CLI_DEFAULT_PIPE_TIMEOUT,
+            get_rdb_mode: 0,
+            get_functions_rdb_mode: 0,
+            stat_mode: 0,
+            scan_mode: 0,
+            intrinsic_latency_mode: 0,
+            intrinsic_latency_duration: 0,
+            pattern: "".to_string(),
+            rdb_filename: "".to_string(),
+            big_keys: 0,
+            mem_keys: 0,
+            mem_keys_samples: 0,
+            hot_keys: 0,
+            stdin_last_arg: 0,
+            stdin_tag_arg: 0,
+            stdin_tag_name: "".to_string(),
+            ask_pass: 0,
+            quoted_input: 0,
+            output: consts::OUTPUT_STANDARD,
+            push_output: 1,
+            mb_delim: "\n".to_string(),
+            cmd_delim: "\n".to_string(),
+            prompt: [' '; 128],
+            eval: "".to_string(),
+            eval_ldb: 0,
+            eval_ldb_sync: 0,
+            eval_ldb_end: 0,
+            enable_ldb_on_eval: 0,
+            last_cmd_type: -1,
+            verbose: 0,
+            set_errcode: 0,
+            cluster_manager_command: ClusterManagerCommand::new(),
+            no_auth_warning: 0,
+            resp2: 0,
+            resp3: 0,
+            in_multi: 0,
+            pre_multi_db_num: 0,
+        }
+    }
+}

redis-cli/src/conf/cli_conn_info.rs

@@ -0,0 +1,19 @@
+pub struct CliConnInfo {
+    pub host_ip: String,
+    pub host_port: i32,
+    pub input_db_num: i32,
+    pub auth: String,
+    pub user: String,
+}
+
+impl CliConnInfo {
+    pub fn new() -> CliConnInfo {
+        CliConnInfo {
+            host_ip: "127.0.0.1".to_string(),
+            host_port: 6379,
+            input_db_num: 0,
+            auth: "".to_string(),
+            user: "".to_string(),
+        }
+    }
+}

redis-cli/src/conf/cli_ssl_config.rs

@@ -0,0 +1,25 @@
+pub struct CliSSLConfig {
+    pub sni: String,
+    pub ca_cert: String,
+    pub ca_cert_dir: String,
+    pub skip_cert_verify: i32,
+    pub cert: String,
+    pub key: String,
+    pub ciphers: String,
+    pub cipher_suites: String,
+}
+
+impl CliSSLConfig {
+    pub fn new() -> CliSSLConfig {
+        CliSSLConfig {
+            sni: "".to_string(),
+            ca_cert: "".to_string(),
+            ca_cert_dir: "".to_string(),
+            skip_cert_verify: 0,
+            cert: "".to_string(),
+            key: "".to_string(),
+            ciphers: "".to_string(),
+            cipher_suites: "".to_string(),
+        }
+    }
+}

redis-cli/src/conf/cluster_manager_command.rs

@@ -0,0 +1,49 @@
+use super::consts;
+
+pub struct ClusterManagerCommand {
+    pub name: String,
+    pub argc: i32,
+    pub argv: Vec<String>,
+    pub stdin_arg: String,
+    pub flags: i32,
+    pub replicas: i32,
+    pub from: String,
+    pub to: String,
+    pub weight: Vec<String>,
+    pub weight_argc: i32,
+    pub master_id: String,
+    pub slots: i32,
+    pub timeout: i32,
+    pub pipeline: i32,
+    pub threshold: f32,
+    pub backup_dir: String,
+    pub from_user: String,
+    pub from_pass: String,
+    pub from_ask_pass: i32,
+}
+
+impl ClusterManagerCommand {
+    pub fn new() -> ClusterManagerCommand {
+        ClusterManagerCommand {
+            name: "".to_string(),
+            argc: 0,
+            argv: vec![],
+            stdin_arg: "".to_string(),
+            flags: 0,
+            replicas: 0,
+            from: "".to_string(),
+            to: "".to_string(),
+            weight: vec![],
+            weight_argc: 0,
+            master_id: "".to_string(),
+            slots: 0,
+            timeout: consts::CLUSTER_MANAGER_MIGRATE_TIMEOUT,
+            pipeline: consts::CLUSTER_MANAGER_MIGRATE_PIPELINE,
+            threshold: consts::CLUSTER_MANAGER_REBALANCE_THRESHOLD,
+            backup_dir: "".to_string(),
+            from_user: "".to_string(),
+            from_pass: "".to_string(),
+            from_ask_pass: 0,
+        }
+    }
+}

redis-cli/src/conf/consts.rs

@@ -0,0 +1,11 @@
+pub const REDIS_CLI_DEFAULT_PIPE_TIMEOUT: i32 = 30;
+pub const CLUSTER_MANAGER_MIGRATE_TIMEOUT: i32 = 60000;
+pub const CLUSTER_MANAGER_MIGRATE_PIPELINE: i32 = 10;
+pub const CLUSTER_MANAGER_REBALANCE_THRESHOLD: f32 = 2.0;
+pub const CLUSTER_MANAGER_CMD_FLAG_MASTERS_ONLY: i32 = 1 << 11;
+pub const CLUSTER_MANAGER_CMD_FLAG_SLAVES_ONLY: i32 = 1 << 12;
+pub const OUTPUT_STANDARD: i32 = 0;
+pub const OUTPUT_RAW: i32 = 1;
+pub const OUTPUT_CSV: i32 = 2;
+pub const OUTPUT_JSON: i32 = 3;
+pub const OUTPUT_QUOTED_JSON: i32 = 4;

redis-cli/src/conf/pref.rs

@@ -0,0 +1,9 @@
+pub struct Pref {
+    pub hints: i32,
+}
+
+impl Pref {
+    pub fn new() -> Pref {
+        Pref { hints: 1 }
+    }
+}