Struct 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 group_id() -> Option<Id>

Report the 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 Args

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 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.