Struct mz_testdrive::action::Config

pub struct Config {

    pub arg_vars: BTreeMap<String, String>,
    pub seed: Option<u32>,
    pub reset: bool,
    pub temp_dir: Option<String>,
    pub source: Option<String>,
    pub default_timeout: Duration,
    pub default_max_tries: usize,
    pub initial_backoff: Duration,
    pub backoff_factor: f64,
    pub consistency_checks: Level,
    pub rewrite_results: bool,
    pub materialize_pgconfig: Config,
    pub materialize_internal_pgconfig: Config,
    pub materialize_use_https: bool,
    pub materialize_http_port: u16,
    pub materialize_internal_http_port: u16,
    pub materialize_params: Vec<(String, String)>,
    pub materialize_catalog_config: Option<CatalogConfig>,
    pub build_info: &'static BuildInfo,
    pub materialize_cluster_replica_sizes: ClusterReplicaSizeMap,
    pub persist_consensus_url: Option<SensitiveUrl>,
    pub persist_blob_url: Option<SensitiveUrl>,
    pub kafka_addr: String,
    pub kafka_default_partitions: usize,
    pub kafka_opts: Vec<(String, String)>,
    pub schema_registry_url: Url,
    pub cert_path: Option<String>,
    pub cert_password: Option<String>,
    pub ccsr_username: Option<String>,
    pub ccsr_password: Option<String>,
    pub aws_config: SdkConfig,
    pub aws_account: String,
    pub fivetran_destination_url: String,
    pub fivetran_destination_files_path: String,
}

User-settable configuration parameters.

Fields

arg_vars: BTreeMap<String, String>

Variables to make available to the testdrive script.

The value of each entry will be made available to the script in a variable named arg.KEY.

seed: Option<u32>

A random number to distinguish each run of a testdrive script.

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

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

source: Option<String>

Source string to print out on errors.

default_timeout: Duration

The default timeout for cancellable operations.

default_max_tries: usize

The default number of tries for retriable operations.

initial_backoff: Duration

The initial backoff interval for retry operations.

Set to 0 to retry immediately on failure.

backoff_factor: f64

Backoff factor to use for retry operations.

Set to 1 to retry at a steady pace.

consistency_checks: Level

Should we skip coordinator and catalog consistency checks.

rewrite_results: bool

Whether to automatically rewrite wrong results instead of failing.

materialize_pgconfig: Config

The pgwire connection parameters for the Materialize instance that testdrive will connect to.

materialize_internal_pgconfig: Config

The internal pgwire connection parameters for the Materialize instance that testdrive will connect to.

materialize_use_https: bool

Whether to use HTTPS instead of plain HTTP for the HTTP(S) connections.

materialize_http_port: u16

The port for the public endpoints of the materialize instance that testdrive will connect to via HTTP.

materialize_internal_http_port: u16

The port for the internal endpoints of the materialize instance that testdrive will connect to via HTTP.

materialize_params: Vec<(String, String)>

Session parameters to set after connecting to materialize.

materialize_catalog_config: Option<CatalogConfig>

An optional catalog configuration.

build_info: &'static BuildInfo

Build information

materialize_cluster_replica_sizes: ClusterReplicaSizeMap

Configured cluster replica sizes

persist_consensus_url: Option<SensitiveUrl>

Handle to the persist consensus system.

persist_blob_url: Option<SensitiveUrl>

Handle to the persist blob storage.

kafka_addr: String

The address of the Kafka broker that testdrive will interact with.

kafka_default_partitions: usize

Default number of partitions to use for topics

kafka_opts: Vec<(String, String)>

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

schema_registry_url: Url

The URL of the schema registry that testdrive will connect to.

cert_path: Option<String>

An optional 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>

An optional password for the TLS certificate.

ccsr_username: Option<String>

An optional username for basic authentication with the Confluent Schema Registry.

ccsr_password: Option<String>

An optional password for basic authentication with the Confluent Schema Registry.

aws_config: SdkConfig

The configuration to use when connecting to AWS.

aws_account: String

The ID of the AWS account that aws_config configures.

fivetran_destination_url: String

Address of the Fivetran Destination that is currently running.

fivetran_destination_files_path: String

Directory that is accessible to the Fivetran Destination.

Trait Implementations

impl Debug for Config

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

Formats the value using the given formatter.