Struct mz_clusterd::Args

pub(crate) struct Args {

    pub(crate) storage_controller_listen_addr: SocketAddr,
    pub(crate) compute_controller_listen_addr: SocketAddr,
    pub(crate) internal_http_listen_addr: SocketAddr,
    pub(crate) grpc_host: Option<String>,
    pub(crate) persist_pubsub_url: String,
    pub(crate) aws_external_id_prefix: Option<AwsExternalIdPrefix>,
    pub(crate) aws_connection_role_arn: Option<String>,
    pub(crate) secrets: SecretsReaderCliArgs,
    pub(crate) tracing: TracingCliArgs,
    pub(crate) environment_id: String,
    pub(crate) scratch_directory: Option<PathBuf>,
    pub(crate) announce_memory_limit: Option<usize>,
    pub(crate) is_cc: bool,
    pub(crate) worker_core_affinity: bool,
}

Independent cluster server for Materialize.

Fields

storage_controller_listen_addr: SocketAddr

The address on which to listen for a connection from the storage controller.

compute_controller_listen_addr: SocketAddr

The address on which to listen for a connection from the compute controller.

internal_http_listen_addr: SocketAddr

The address of the internal HTTP server.

grpc_host: Option<String>

The FQDN of this process, for GRPC request validation.

Not providing this value or setting it to the empty string disables host validation for GRPC requests.

persist_pubsub_url: String

The URL for the Persist PubSub service.

aws_external_id_prefix: Option<AwsExternalIdPrefix>

An external ID to be supplied to all AWS AssumeRole operations.

Details: https://docs.aws.amazon.com/IAM/latest/UserGuide/id_roles_create_for-user_externalid.html

aws_connection_role_arn: Option<String>

The ARN for a Materialize-controlled role to assume before assuming a customer’s requested role for an AWS connection.

secrets: SecretsReaderCliArgs

tracing: TracingCliArgs

environment_id: String

An opaque identifier for the environment in which this process is running.

scratch_directory: Option<PathBuf>

A scratch directory that can be used for ephemeral storage.

announce_memory_limit: Option<usize>

Optional memory limit (bytes) of the cluster replica

is_cc: bool

Whether this size represents a modern “cc” size rather than a legacy T-shirt size.

worker_core_affinity: bool

Set core affinity for Timely workers.

This flag should only be set if the process is provided with exclusive access to its supplied CPU cores. If other processes are competing over the same cores, setting core affinity might degrade dataflow performance rather than improving it.

Trait Implementations

impl Args for Args

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

Append to Command so it can instantiate Self.

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

Append to Command so it can update self.

impl CommandFactory for Args

fn into_app<'b>() -> Command<'b>

Deprecated, replaced with CommandFactory::command

fn into_app_for_update<'b>() -> Command<'b>

Deprecated, replaced with CommandFactory::command_for_update

fn command<'help>() -> App<'help>

Build a Command that can instantiate Self.

fn command_for_update<'help>() -> App<'help>

Build a Command that can update self.

impl FromArgMatches for Args

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 Args

fn parse() -> Self

Parse from std::env::args_os(), 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 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 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.