Struct StartCommand

struct StartCommand {

    rpc_bind_addr: Option<String>,
    rpc_server_addr: Option<String>,
    store_addrs: Option<Vec<String>>,
    config_file: Option<String>,
    selector: Option<String>,
    use_memory_store: Option<bool>,
    enable_region_failover: Option<bool>,
    http_addr: Option<String>,
    http_timeout: Option<u64>,
    env_prefix: String,
    data_home: Option<String>,
    store_key_prefix: String,
    max_txn_ops: Option<usize>,
    backend: Option<BackendImpl>,
}

Fields

rpc_bind_addr: Option<String>

The address to bind the gRPC server.

rpc_server_addr: Option<String>

The communication server address for the frontend and datanode to connect to metasrv. If left empty or unset, the server will automatically use the IP address of the first network interface on the host, with the same port number as the one specified in rpc_bind_addr.

store_addrs: Option<Vec<String>>

config_file: Option<String>

selector: Option<String>

use_memory_store: Option<bool>

enable_region_failover: Option<bool>

http_addr: Option<String>

http_timeout: Option<u64>

env_prefix: String

data_home: Option<String>

The working home directory of this metasrv instance.

store_key_prefix: String

If it’s not empty, the metasrv will store all data with this key prefix.

max_txn_ops: Option<usize>

The max operations per txn

backend: Option<BackendImpl>

The database backend.

Implementations

impl StartCommand

fn load_options( &self, global_options: &GlobalOptions, ) -> Result<GreptimeOptions<MetasrvOptions>>

fn merge_with_cli_options( &self, global_options: &GlobalOptions, opts: &mut GreptimeOptions<MetasrvOptions>, ) -> Result<()>

async fn build(&self, opts: GreptimeOptions<MetasrvOptions>) -> Result<Instance>

Trait Implementations

impl Args for StartCommand

fn group_id() -> Option<Id>

Report the [ArgGroup::id][crate::ArgGroup::id] for this set of arguments

fn augment_args<'b>(__clap_app: Command) -> Command

Append to [Command] so it can instantiate Self via [FromArgMatches::from_arg_matches_mut]

fn augment_args_for_update<'b>(__clap_app: Command) -> Command

Append to [Command] so it can instantiate self via [FromArgMatches::update_from_arg_matches_mut]

impl CommandFactory for StartCommand

fn command<'b>() -> Command

Build a [Command] that can instantiate Self.

fn command_for_update<'b>() -> Command

Build a [Command] that can update self.

impl Debug for StartCommand

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for StartCommand

fn default() -> StartCommand

Returns the “default value” for a type.

impl FromArgMatches for StartCommand

fn from_arg_matches(__clap_arg_matches: &ArgMatches) -> Result<Self, Error>

Instantiate Self from [ArgMatches], parsing the arguments as needed.

fn from_arg_matches_mut( __clap_arg_matches: &mut ArgMatches, ) -> Result<Self, Error>

Instantiate Self from [ArgMatches], parsing the arguments as needed.

fn update_from_arg_matches( &mut self, __clap_arg_matches: &ArgMatches, ) -> Result<(), Error>

Assign values from ArgMatches to self.

fn update_from_arg_matches_mut( &mut self, __clap_arg_matches: &mut ArgMatches, ) -> Result<(), Error>

Assign values from ArgMatches to self.

impl Parser for StartCommand

fn parse() -> Self

Parse from std::env::args_os(), [exit][Error::exit] on error.

fn try_parse() -> Result<Self, Error>

Parse from std::env::args_os(), return Err on error.

fn parse_from<I, T>(itr: I) -> Self

where I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Parse from iterator, [exit][Error::exit] on error.

fn try_parse_from<I, T>(itr: I) -> Result<Self, Error>

where I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Parse from iterator, return Err on error.

fn update_from<I, T>(&mut self, itr: I)

where I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Update from iterator, [exit][Error::exit] on error.

fn try_update_from<I, T>(&mut self, itr: I) -> Result<(), Error>

where I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Update from iterator, return Err on error.