pub struct Config {
Show 22 fields pub arg_vars: BTreeMap<String, String>, pub seed: Option<u32>, pub reset: bool, pub temp_dir: Option<String>, pub default_timeout: Duration, pub default_max_tries: usize, pub initial_backoff: Duration, pub backoff_factor: f64, pub materialize_pgconfig: Config, pub materialize_http_port: u16, pub materialize_params: Vec<(String, String)>, pub materialize_catalog_postgres_stash: Option<String>, 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,
}
Expand description

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.

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.

materialize_pgconfig: Config

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

materialize_http_port: u16

The port for the public 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_postgres_stash: Option<String>

An optional Postgres connection string to the catalog stash.

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.

Trait Implementations

Formats the value using the given formatter. Read more

Auto Trait Implementations

Blanket Implementations

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

Converts self into T using Into<T>. Read more

Extract a subset of the possible types in a coproduct (or get the remaining possibilities) Read more

Causes self to use its Binary implementation when Debug-formatted. Read more

Causes self to use its Display implementation when Debug-formatted. Read more

Causes self to use its LowerExp implementation when Debug-formatted. Read more

Causes self to use its LowerHex implementation when Debug-formatted. Read more

Causes self to use its Octal implementation when Debug-formatted. Read more

Causes self to use its Pointer implementation when Debug-formatted. Read more

Causes self to use its UpperExp implementation when Debug-formatted. Read more

Causes self to use its UpperHex implementation when Debug-formatted. Read more

Formats each item in a sequence. Read more

Returns the argument unchanged.

Attaches the provided Context to this type, returning a WithContext wrapper. Read more

Attaches the current Context to this type, returning a WithContext wrapper. Read more

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Wrap the input message T in a tonic::Request

Performs the indexed conversion.

Pipes by value. This is generally the method you want to use. Read more

Borrows self and passes that borrow into the pipe function. Read more

Mutably borrows self and passes that borrow into the pipe function. Read more

Borrows self, then passes self.borrow() into the pipe function. Read more

Mutably borrows self, then passes self.borrow_mut() into the pipe function. Read more

Borrows self, then passes self.as_ref() into the pipe function.

Mutably borrows self, then passes self.as_mut() into the pipe function. Read more

Borrows self, then passes self.deref() into the pipe function.

Mutably borrows self, then passes self.deref_mut() into the pipe function. Read more

The alignment of pointer.

The type for initializers.

Initializes a with the given initializer. Read more

Dereferences the given pointer. Read more

Mutably dereferences the given pointer. Read more

Drops the object pointed to by the given pointer. Read more

Should always be Self

Consumes the current HList and returns an HList with the requested shape. Read more

Immutable access to a value. Read more

Mutable access to a value. Read more

Immutable access to the Borrow<B> of a value. Read more

Mutable access to the BorrowMut<B> of a value. Read more

Immutable access to the AsRef<R> view of a value. Read more

Mutable access to the AsMut<R> view of a value. Read more

Immutable access to the Deref::Target of a value. Read more

Mutable access to the Deref::Target of a value. Read more

Calls .tap() only in debug builds, and is erased in release builds.

Calls .tap_mut() only in debug builds, and is erased in release builds. Read more

Calls .tap_borrow() only in debug builds, and is erased in release builds. Read more

Calls .tap_borrow_mut() only in debug builds, and is erased in release builds. Read more

Calls .tap_ref() only in debug builds, and is erased in release builds. Read more

Calls .tap_ref_mut() only in debug builds, and is erased in release builds. Read more

Calls .tap_deref() only in debug builds, and is erased in release builds. Read more

Calls .tap_deref_mut() only in debug builds, and is erased in release builds. Read more

Attempts to convert self into T using TryInto<T>. Read more

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more