Struct mz_adapter::catalog::config::StateConfig
source · pub struct StateConfig {Show 18 fields
pub unsafe_mode: bool,
pub all_features: bool,
pub build_info: &'static BuildInfo,
pub environment_id: EnvironmentId,
pub now: NowFn,
pub skip_migrations: bool,
pub cluster_replica_sizes: ClusterReplicaSizeMap,
pub default_storage_cluster_size: Option<String>,
pub builtin_cluster_replica_size: String,
pub system_parameter_defaults: BTreeMap<String, String>,
pub remote_system_parameters: Option<BTreeMap<String, OwnedVarInput>>,
pub availability_zones: Vec<String>,
pub egress_ips: Vec<Ipv4Addr>,
pub aws_principal_context: Option<AwsPrincipalContext>,
pub aws_privatelink_availability_zones: Option<BTreeSet<String>>,
pub http_host_name: Option<String>,
pub connection_context: ConnectionContext,
pub active_connection_count: Arc<Mutex<ConnectionCounter>>,
}
Fields§
§unsafe_mode: bool
Whether to enable unsafe mode.
all_features: bool
Whether the build is a local dev build.
build_info: &'static BuildInfo
Information about this build of Materialize.
environment_id: EnvironmentId
A persistent ID associated with the environment.
now: NowFn
Function to generate wall clock now; can be mocked.
skip_migrations: bool
Whether or not to skip catalog migrations.
cluster_replica_sizes: ClusterReplicaSizeMap
Map of strings to corresponding compute replica sizes.
default_storage_cluster_size: Option<String>
Default storage cluster size. Must be a key from cluster_replica_sizes.
builtin_cluster_replica_size: String
Builtin cluster replica size.
system_parameter_defaults: BTreeMap<String, String>
Dynamic defaults for system parameters.
remote_system_parameters: Option<BTreeMap<String, OwnedVarInput>>
A optional map of system parameters pulled from a remote frontend.
A None
value indicates that the initial sync was skipped.
availability_zones: Vec<String>
Valid availability zones for replicas.
egress_ips: Vec<Ipv4Addr>
IP Addresses which will be used for egress.
aws_principal_context: Option<AwsPrincipalContext>
Context for generating an AWS Principal.
aws_privatelink_availability_zones: Option<BTreeSet<String>>
Supported AWS PrivateLink availability zone ids.
http_host_name: Option<String>
Host name or URL for connecting to the HTTP server of this instance.
connection_context: ConnectionContext
Context for source and sink connections.
active_connection_count: Arc<Mutex<ConnectionCounter>>
Global connection limit and count
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for StateConfig
impl Send for StateConfig
impl Sync for StateConfig
impl Unpin for StateConfig
impl !UnwindSafe for StateConfig
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
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>
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>
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
RustType::into_proto
.