Struct mz_testdrive::action::State

pub struct State {

    arg_vars: BTreeMap<String, String>,
    cmd_vars: BTreeMap<String, String>,
    seed: u32,
    temp_path: PathBuf,
    _tempfile: Option<TempDir>,
    default_timeout: Duration,
    timeout: Duration,
    max_tries: usize,
    initial_backoff: Duration,
    backoff_factor: f64,
    consistency_checks: Level,
    consistency_checks_adhoc_skip: bool,
    regex: Option<Regex>,
    regex_replacement: String,
    materialize: MaterializeState,
    persist_consensus_url: Option<SensitiveUrl>,
    persist_blob_url: Option<SensitiveUrl>,
    build_info: &'static BuildInfo,
    persist_clients: PersistClientCache,
    schema_registry_url: Url,
    ccsr_client: Client,
    kafka_addr: String,
    kafka_admin: AdminClient<MzClientContext>,
    kafka_admin_opts: AdminOptions,
    kafka_config: ClientConfig,
    kafka_default_partitions: usize,
    kafka_producer: FutureProducer<MzClientContext>,
    kafka_topics: BTreeMap<String, usize>,
    aws_account: String,
    aws_config: SdkConfig,
    mysql_clients: BTreeMap<String, Conn>,
    postgres_clients: BTreeMap<String, Client>,
    sql_server_clients: BTreeMap<String, Client<Compat<TcpStream>>>,
    fivetran_destination_url: String,
    fivetran_destination_files_path: String,
    rewrite_results: bool,
    pub rewrites: Vec<Rewrite>,
    pub rewrite_pos_start: usize,
    pub rewrite_pos_end: usize,
}

Fields

arg_vars: BTreeMap<String, String>

cmd_vars: BTreeMap<String, String>

seed: u32

temp_path: PathBuf

_tempfile: Option<TempDir>

default_timeout: Duration

timeout: Duration

max_tries: usize

initial_backoff: Duration

backoff_factor: f64

consistency_checks: Level

consistency_checks_adhoc_skip: bool

regex: Option<Regex>

regex_replacement: String

materialize: MaterializeState

persist_consensus_url: Option<SensitiveUrl>

persist_blob_url: Option<SensitiveUrl>

build_info: &'static BuildInfo

persist_clients: PersistClientCache

schema_registry_url: Url

ccsr_client: Client

kafka_addr: String

kafka_admin: AdminClient<MzClientContext>

kafka_admin_opts: AdminOptions

kafka_config: ClientConfig

kafka_default_partitions: usize

kafka_producer: FutureProducer<MzClientContext>

kafka_topics: BTreeMap<String, usize>

aws_account: String

aws_config: SdkConfig

mysql_clients: BTreeMap<String, Conn>

postgres_clients: BTreeMap<String, Client>

sql_server_clients: BTreeMap<String, Client<Compat<TcpStream>>>

fivetran_destination_url: String

fivetran_destination_files_path: String

rewrite_results: bool

rewrites: Vec<Rewrite>

Current file, results are replaced inline

rewrite_pos_start: usize

Start position of currently expected result

rewrite_pos_end: usize

End position of currently expected result

Implementations

impl State

pub async fn initialize_cmd_vars(&mut self) -> Result<(), Error>

pub async fn with_catalog_copy<F, T>( &self, system_parameter_defaults: BTreeMap<String, String>, version: Version, bootstrap_args: &BootstrapArgs, enable_expression_cache_override: Option<bool>, f: F, ) -> Result<Option<T>, Error>

where F: FnOnce(ConnCatalog<'_>) -> T,

Makes of copy of the durable catalog and runs a function on its state. Returns None if there’s no catalog information in the State.

pub fn aws_endpoint(&self) -> &str

pub fn aws_region(&self) -> &str

pub fn clear_skip_consistency_checks(&mut self) -> bool

Resets the adhoc skip consistency check that users can toggle per-file, and returns whether the consistency checks should be skipped for this current run.

pub async fn reset_materialize(&self) -> Result<(), Error>

pub async fn reset_kafka(&self) -> Result<(), Error>

Delete Kafka topics + CCSR subjects that were created in this run