Struct mz_testdrive::action::State
source · pub struct State {Show 40 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>>>,
}
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§
source§impl State
impl State
pub async fn initialize_cmd_vars(&mut self) -> Result<(), Error>
sourcepub async fn with_catalog_copy<F, T>(&self, f: F) -> Result<Option<T>, Error>where
F: FnOnce(ConnCatalog<'_>) -> T,
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>
sourcepub async fn reset_kafka(&mut self) -> Result<(), Error>
pub async fn reset_kafka(&mut self) -> Result<(), Error>
Delete Kafka topics + CCSR subjects that were created in this run
Auto Trait Implementations§
impl !RefUnwindSafe for State
impl Send for State
impl Sync for State
impl Unpin for State
impl !UnwindSafe for State
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
RustType::into_proto
.