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,
    no_consistency_checks: bool,
    regex: Option<Regex>,
    regex_replacement: String,
    postgres_factory: StashFactory,
    materialize_catalog_config: Option<CatalogConfig>,
    materialize_sql_addr: String,
    materialize_http_addr: String,
    materialize_internal_sql_addr: String,
    materialize_internal_http_addr: String,
    materialize_user: String,
    pgclient: Client,
    environment_id: EnvironmentId,
    persist_consensus_url: Option<String>,
    persist_blob_url: Option<String>,
    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>>>,
}

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

no_consistency_checks: bool

regex: Option<Regex>

regex_replacement: String

postgres_factory: StashFactory

materialize_catalog_config: Option<CatalogConfig>

materialize_sql_addr: String

materialize_http_addr: String

materialize_internal_sql_addr: String

materialize_internal_http_addr: String

materialize_user: String

pgclient: Client

environment_id: EnvironmentId

persist_consensus_url: Option<String>

persist_blob_url: Option<String>

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

Implementations

impl State

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

pub async fn with_catalog_copy<F, T>(&self, 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 async fn reset_materialize(&mut self) -> Result<(), Error>

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

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