Struct materialized::Config
source · [−]pub struct Config {Show 20 fields
pub logical_compaction_window: Option<Duration>,
pub timestamp_frequency: Duration,
pub sql_listen_addr: SocketAddr,
pub http_listen_addr: SocketAddr,
pub internal_sql_listen_addr: SocketAddr,
pub internal_http_listen_addr: SocketAddr,
pub tls: Option<TlsConfig>,
pub frontegg: Option<FronteggAuthentication>,
pub cors_allowed_origin: AllowOrigin,
pub persist_location: PersistLocation,
pub catalog_postgres_stash: String,
pub storage_postgres_stash: String,
pub connection_context: ConnectionContext,
pub orchestrator: OrchestratorConfig,
pub secrets_controller: SecretsControllerConfig,
pub unsafe_mode: bool,
pub metrics_registry: MetricsRegistry,
pub now: NowFn,
pub replica_sizes: ClusterReplicaSizeMap,
pub availability_zones: Vec<String>,
}
Expand description
Configuration for a materialized
server.
Fields
logical_compaction_window: Option<Duration>
The historical window in which distinctions are maintained for arrangements.
As arrangements accept new timestamps they may optionally collapse prior
timestamps to the same value, retaining their effect but removing their
distinction. A large value or None
results in a large amount of
historical detail for arrangements; this increases the logical times at
which they can be accurately queried, but consumes more memory. A low
value reduces the amount of memory required but also risks not being
able to use the arrangement in a query that has other constraints on the
timestamps used (e.g. when joined with other arrangements).
timestamp_frequency: Duration
The interval at which sources should be timestamped.
sql_listen_addr: SocketAddr
The IP address and port to listen for pgwire connections on.
http_listen_addr: SocketAddr
The IP address and port to listen for HTTP connections on.
internal_sql_listen_addr: SocketAddr
The IP address and port to listen for pgwire connections from the cloud system on.
internal_http_listen_addr: SocketAddr
The IP address and port to serve the metrics registry from.
tls: Option<TlsConfig>
TLS encryption configuration.
frontegg: Option<FronteggAuthentication>
Materialize Cloud configuration to enable Frontegg JWT user authentication.
cors_allowed_origin: AllowOrigin
Origins for which cross-origin resource sharing (CORS) for HTTP requests is permitted.
persist_location: PersistLocation
Where the persist library should store its data.
catalog_postgres_stash: String
Postgres connection string for catalog’s stash.
storage_postgres_stash: String
Postgres connection string for storage’s stash.
connection_context: ConnectionContext
Configuration for source and sink connections created by the storage layer. This can include configuration for external sources.
orchestrator: OrchestratorConfig
Configuration of service orchestration.
secrets_controller: SecretsControllerConfig
Configuration for a secrets controller.
unsafe_mode: bool
Whether to permit usage of unsafe features.
metrics_registry: MetricsRegistry
The place where the server’s metrics will be reported from.
now: NowFn
Now generation function.
replica_sizes: ClusterReplicaSizeMap
Map of strings to corresponding compute replica sizes.
availability_zones: Vec<String>
Availability zones compute resources may be deployed in.
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for Config
impl Send for Config
impl Sync for Config
impl Unpin for Config
impl !UnwindSafe for Config
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> FutureExt for T
impl<T> FutureExt for T
sourcefn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
sourcefn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
sourcefn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message T
in a tonic::Request
sourceimpl<T> Pointable for T
impl<T> Pointable for T
sourceimpl<T> ProgressEventTimestamp for T where
T: Data + Debug + Any,
impl<T> ProgressEventTimestamp for T where
T: Data + Debug + Any,
sourceimpl<P, R> ProtoType<R> for P where
R: RustType<P>,
impl<P, R> ProtoType<R> for P where
R: RustType<P>,
sourcefn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See RustType::from_proto
.
sourcefn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See RustType::into_proto
.
sourceimpl<T> ToOwned for T where
T: Clone,
impl<T> ToOwned for T where
T: Clone,
type Owned = T
type Owned = T
The resulting type after obtaining ownership.
sourcefn clone_into(&self, target: &mut T)
fn clone_into(&self, target: &mut T)
toowned_clone_into
)Uses borrowed data to replace owned data, usually by cloning. Read more
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more