pub struct Config {
Show 24 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_internal_pgconfig: Config, pub materialize_http_port: u16, pub materialize_internal_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_internal_pgconfig: Config

The internal 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_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_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