Struct testdrive::Args

pub(crate) struct Args {

    pub(crate) var: Vec<String>,
    pub(crate) seed: Option<u32>,
    pub(crate) no_reset: bool,
    pub(crate) temp_dir: Option<String>,
    pub(crate) source: Option<String>,
    pub(crate) default_timeout: Duration,
    pub(crate) default_max_tries: usize,
    pub(crate) initial_backoff: Duration,
    pub(crate) backoff_factor: f64,
    pub(crate) max_errors: usize,
    pub(crate) max_tests: usize,
    pub(crate) shuffle_tests: bool,
    pub(crate) shard: Option<usize>,
    pub(crate) shard_count: Option<usize>,
    pub(crate) junit_report: Option<PathBuf>,
    pub(crate) consistency_checks: ConsistencyCheckLevel,
    pub(crate) log_filter: EnvFilter,
    pub(crate) globs: Vec<String>,
    pub(crate) materialize_url: Config,
    pub(crate) materialize_internal_url: Config,
    pub(crate) materialize_use_https: bool,
    pub(crate) materialize_http_port: u16,
    pub(crate) materialize_internal_http_port: u16,
    pub(crate) materialize_param: Vec<(String, String)>,
    pub(crate) validate_catalog_store: bool,
    pub(crate) persist_consensus_url: Option<String>,
    pub(crate) persist_blob_url: Option<String>,
    pub(crate) kafka_addr: String,
    pub(crate) kafka_default_partitions: usize,
    pub(crate) kafka_option: Vec<(String, String)>,
    pub(crate) schema_registry_url: Url,
    pub(crate) cert: Option<String>,
    pub(crate) cert_password: Option<String>,
    pub(crate) ccsr_username: Option<String>,
    pub(crate) ccsr_password: Option<String>,
    pub(crate) aws_region: Option<String>,
    pub(crate) aws_endpoint: Option<String>,
    pub(crate) aws_access_key_id: String,
    pub(crate) aws_secret_access_key: String,
    pub(crate) fivetran_destination_url: String,
    pub(crate) fivetran_destination_files_path: String,
}

Integration test driver for Materialize.

Fields

var: Vec<String>

Variables to make available to the testdrive script.

Passing --var foo=bar will create a variable named arg.foo with the value bar. Can be specified multiple times to set multiple variables.

seed: Option<u32>

A random number to distinguish each testdrive run.

no_reset: bool

Whether to reset Materialize state before executing each script and to clean up AWS state after each script.

temp_dir: Option<String>

Force the use of the specified temporary directory.

If unspecified, testdrive creates a temporary directory with a random name.

source: Option<String>

Source string to print out on errors.

default_timeout: Duration

Default timeout for cancellable operations.

default_max_tries: usize

The default number of times to retry a query expecting it to converge to the desired result.

initial_backoff: Duration

Initial backoff interval for retry operations.

Set to 0 to retry immediately on failure.

backoff_factor: f64

Backoff factor when retrying.

Set to 1 to retry at a steady pace.

max_errors: usize

Maximum number of errors to accumulate before aborting.

max_tests: usize

Maximum number of tests to run before terminating.

shuffle_tests: bool

Shuffle tests.

The shuffled order reflects the seed specified by –seed, if any.

shard: Option<usize>

Divide the test files into shards and run only the test files in this shard.

shard_count: Option<usize>

Total number of shards in use.

junit_report: Option<PathBuf>

Generate a JUnit-compatible XML report to the specified file.

consistency_checks: ConsistencyCheckLevel

Whether we skip coordinator and catalog consistency checks.

log_filter: EnvFilter

Which log messages to emit.

See environmentd’s --startup-log-filter option for details.

globs: Vec<String>

Glob patterns of testdrive scripts to run.

materialize_url: Config

materialize SQL connection string.

materialize_internal_url: Config

materialize internal SQL connection string.

materialize_use_https: bool

materialize_http_port: u16

The port on which Materialize is listening for untrusted HTTP connections.

The hostname is taken from materialize_url.

materialize_internal_http_port: u16

The port on which Materialize is listening for trusted HTTP connections.

The hostname is taken from materialize_internal_url.

materialize_param: Vec<(String, String)>

Arbitrary session parameters for testdrive to set after connecting to Materialize.

validate_catalog_store: bool

Validate the catalog state of the specified catalog kind.

persist_consensus_url: Option<String>

Handle to the persist consensus system.

persist_blob_url: Option<String>

Handle to the persist blob storage.

kafka_addr: String

Address of the Kafka broker that testdrive will interact with.

kafka_default_partitions: usize

Default number of partitions to create for topics

kafka_option: Vec<(String, String)>

Arbitrary rdkafka options for testdrive to use when connecting to the Kafka broker.

schema_registry_url: Url

URL of the schema registry that testdrive will connect to.

cert: Option<String>

Path to a TLS certificate that testdrive will present when performing client authentication.

The keystore must be in the PKCS#12 format.

cert_password: Option<String>

Password for the TLS certificate.

ccsr_username: Option<String>

Username for basic authentication with the Confluent Schema Registry.

ccsr_password: Option<String>

Password for basic authentication with the Confluent Schema Registry.

aws_region: Option<String>

Named AWS region to target for AWS API requests.

Cannot be specified if –aws-endpoint is specified.

aws_endpoint: Option<String>

Custom AWS endpoint.

Defaults to http://localhost:4566 unless –aws-region is specified. Cannot be specified if –aws-region is specified.

aws_access_key_id: String

aws_secret_access_key: String

fivetran_destination_url: String

Address of the Fivetran Destination that testdrive will interact with.

fivetran_destination_files_path: String

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.