Struct StoreConfig 

pub struct StoreConfig {
    pub store_addrs: Vec<String>,
    pub max_txn_ops: usize,
    pub backend: BackendImpl,
    pub store_key_prefix: String,
    pub meta_table_name: String,
    pub meta_schema_name: Option<String>,
    pub auto_create_schema: bool,
    pub backend_tls_mode: TlsMode,
    pub backend_tls_cert_path: String,
    pub backend_tls_key_path: String,
    pub backend_tls_ca_cert_path: String,
    pub backend_tls_watch: bool,
}

Fields

store_addrs: Vec<String>

The endpoint of store. one of etcd, postgres or mysql.

For postgres store, the format is: “password=password dbname=postgres user=postgres host=localhost port=5432”

For etcd store, the format is: “127.0.0.1:2379”

For mysql store, the format is: “mysql://user:password@ip:port/dbname”

max_txn_ops: usize

The maximum number of operations in a transaction. Only used when using [etcd-store].

backend: BackendImpl

The metadata store backend.

store_key_prefix: String

The key prefix of the metadata store.

meta_table_name: String

The table name in RDS to store metadata. Only used when using [postgres-store] or [mysql-store].

meta_schema_name: Option<String>

Optional PostgreSQL schema for metadata table (defaults to current search_path if unset).

auto_create_schema: bool

Automatically create PostgreSQL schema if it doesn’t exist (default: true).

backend_tls_mode: TlsMode

TLS mode for backend store connections (etcd, PostgreSQL, MySQL)

backend_tls_cert_path: String

Path to TLS certificate file for backend store connections

backend_tls_key_path: String

Path to TLS private key file for backend store connections

backend_tls_ca_cert_path: String

Path to TLS CA certificate file for backend store connections

backend_tls_watch: bool

Enable watching TLS certificate files for changes

Implementations

impl StoreConfig

pub fn tls_config(&self) -> Option<TlsOption>

pub async fn build(&self) -> Result<KvBackendRef, BoxedError>

Builds a KvBackendRef from the store configuration.

Trait Implementations

impl Args for StoreConfig

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 StoreConfig

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 StoreConfig

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

Formats the value using the given formatter.

impl Default for StoreConfig

fn default() -> StoreConfig

Returns the “default value” for a type.

impl FromArgMatches for StoreConfig

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 StoreConfig

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.