Struct mz_environmentd::test_util::TestHarness

pub struct TestHarness {

    data_directory: Option<PathBuf>,
    tls: Option<TlsCertConfig>,
    frontegg: Option<Authenticator>,
    unsafe_mode: bool,
    workers: usize,
    now: NowFn,
    seed: u32,
    storage_usage_collection_interval: Duration,
    storage_usage_retention_period: Option<Duration>,
    default_cluster_replica_size: String,
    builtin_system_cluster_replica_size: String,
    builtin_catalog_server_cluster_replica_size: String,
    builtin_probe_cluster_replica_size: String,
    builtin_support_cluster_replica_size: String,
    builtin_analytics_cluster_replica_size: String,
    propagate_crashes: bool,
    enable_tracing: bool,
    orchestrator_tracing_cli_args: TracingCliArgs,
    bootstrap_role: Option<String>,
    deploy_generation: u64,
    system_parameter_defaults: BTreeMap<String, String>,
    internal_console_redirect_url: Option<String>,
    metrics_registry: Option<MetricsRegistry>,
    code_version: Version,
    capture: Option<SharedStorage>,
    pub environment_id: EnvironmentId,
}

Entry point for creating and configuring an environmentd test harness.

Fields

data_directory: Option<PathBuf>

tls: Option<TlsCertConfig>

frontegg: Option<Authenticator>

unsafe_mode: bool

workers: usize

now: NowFn

seed: u32

storage_usage_collection_interval: Duration

storage_usage_retention_period: Option<Duration>

default_cluster_replica_size: String

builtin_system_cluster_replica_size: String

builtin_catalog_server_cluster_replica_size: String

builtin_probe_cluster_replica_size: String

builtin_support_cluster_replica_size: String

builtin_analytics_cluster_replica_size: String

propagate_crashes: bool

enable_tracing: bool

orchestrator_tracing_cli_args: TracingCliArgs

bootstrap_role: Option<String>

deploy_generation: u64

system_parameter_defaults: BTreeMap<String, String>

internal_console_redirect_url: Option<String>

metrics_registry: Option<MetricsRegistry>

code_version: Version

capture: Option<SharedStorage>

environment_id: EnvironmentId

Implementations

impl TestHarness

pub async fn start(self) -> TestServer

Starts a test TestServer, panicking if the server could not be started.

For cases when startup might fail, see TestHarness::try_start.

pub async fn start_with_trigger( self, tls_reload_certs: ReloadTrigger, ) -> TestServer

Like TestHarness::start but can specify a cert reload trigger.

pub async fn try_start(self) -> Result<TestServer, Error>

Starts a test TestServer, returning an error if the server could not be started.

pub async fn try_start_with_trigger( self, tls_reload_certs: ReloadTrigger, ) -> Result<TestServer, Error>

Like TestHarness::try_start but can specify a cert reload trigger.

pub fn start_blocking(self) -> TestServerWithRuntime

Starts a runtime and returns a TestServerWithRuntime.

pub fn data_directory(self, data_directory: impl Into<PathBuf>) -> Self

pub fn with_tls( self, cert_path: impl Into<PathBuf>, key_path: impl Into<PathBuf>, ) -> Self

pub fn unsafe_mode(self) -> Self

pub fn workers(self, workers: usize) -> Self

pub fn with_frontegg(self, frontegg: &FronteggAuthentication) -> Self

pub fn with_now(self, now: NowFn) -> Self

pub fn with_storage_usage_collection_interval( self, storage_usage_collection_interval: Duration, ) -> Self

pub fn with_storage_usage_retention_period( self, storage_usage_retention_period: Duration, ) -> Self

pub fn with_default_cluster_replica_size( self, default_cluster_replica_size: String, ) -> Self

pub fn with_builtin_system_cluster_replica_size( self, builtin_system_cluster_replica_size: String, ) -> Self

pub fn with_builtin_catalog_server_cluster_replica_size( self, builtin_catalog_server_cluster_replica_size: String, ) -> Self

pub fn with_propagate_crashes(self, propagate_crashes: bool) -> Self

pub fn with_enable_tracing(self, enable_tracing: bool) -> Self

pub fn with_bootstrap_role(self, bootstrap_role: Option<String>) -> Self

pub fn with_deploy_generation(self, deploy_generation: u64) -> Self

pub fn with_system_parameter_default(self, param: String, value: String) -> Self

pub fn with_internal_console_redirect_url( self, internal_console_redirect_url: Option<String>, ) -> Self

pub fn with_metrics_registry(self, registry: MetricsRegistry) -> Self

pub fn with_code_version(self, version: Version) -> Self

pub fn with_capture(self, storage: SharedStorage) -> Self

Trait Implementations

impl Clone for TestHarness

fn clone(&self) -> TestHarness

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for TestHarness

fn default() -> TestHarness

Returns the “default value” for a type.