Struct FlownodeOptions

pub struct FlownodeOptions {
    pub node_id: Option<u64>,
    pub flow: FlowConfig,
    pub grpc: GrpcOptions,
    pub http: HttpOptions,
    pub meta_client: Option<MetaClientOptions>,
    pub logging: LoggingOptions,
    pub tracing: TracingOptions,
    pub heartbeat: HeartbeatOptions,
}

Options for flow node

Fields

node_id: Option<u64>

flow: FlowConfig

grpc: GrpcOptions

http: HttpOptions

meta_client: Option<MetaClientOptions>

logging: LoggingOptions

tracing: TracingOptions

heartbeat: HeartbeatOptions

Trait Implementations

impl Clone for FlownodeOptions

fn clone(&self) -> FlownodeOptions

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Configurable for FlownodeOptions

fn validate_sanitize(&mut self) -> Result<()>

Validate(and possibly sanitize) the configuration.

fn load_layered_options( config_file: Option<&str>, env_prefix: &str, ) -> Result<Self, Error>

Load the configuration from multiple sources and merge them. The precedence order is: config file > environment variables > default values. env_prefix is the prefix of environment variables, e.g. “FRONTEND__xxx”. The function will use dunder(double underscore) __ as the separator for environment variables, for example: DATANODE__STORAGE__MANIFEST__CHECKPOINT_MARGIN will be mapped to DatanodeOptions.storage.manifest.checkpoint_margin field in the configuration. list_keys is the list of keys that should be parsed as a list, for example, you can pass Some(&["meta_client_options.metasrv_addrs"] to parse GREPTIMEDB_METASRV__META_CLIENT_OPTIONS__METASRV_ADDRS as a list. The function will use comma , as the separator for list values, for example: 127.0.0.1:3001,127.0.0.1:3002,127.0.0.1:3003.

fn env_list_keys() -> Option<&'static [&'static str]>

List of toml keys that should be parsed as a list.

fn to_toml(&self) -> Result<String, Error>

Serialize the configuration to a TOML string.

impl Debug for FlownodeOptions

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

Formats the value using the given formatter.

impl Default for FlownodeOptions

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for FlownodeOptions

where FlownodeOptions: Default,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for FlownodeOptions

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.