Struct mz_controller::ControllerConfig
source · pub struct ControllerConfig {
pub build_info: &'static BuildInfo,
pub orchestrator: Arc<dyn Orchestrator>,
pub persist_location: PersistLocation,
pub persist_clients: Arc<Mutex<PersistClientCache>>,
pub storage_stash_url: String,
pub clusterd_image: String,
pub init_container_image: Option<String>,
pub now: NowFn,
pub postgres_factory: StashFactory,
pub metrics_registry: MetricsRegistry,
}
Expand description
Configures a controller.
Fields§
§build_info: &'static BuildInfo
The build information for this process.
orchestrator: Arc<dyn Orchestrator>
The orchestrator implementation to use.
persist_location: PersistLocation
The persist location where all storage collections will be written to.
persist_clients: Arc<Mutex<PersistClientCache>>
A process-global cache of (blob_uri, consensus_uri) -> PersistClient. This is intentionally shared between workers.
storage_stash_url: String
The stash URL for the storage controller.
clusterd_image: String
The clusterd image to use when starting new cluster processes.
init_container_image: Option<String>
The init container image to use for clusterd.
now: NowFn
The now function to advance the controller’s introspection collections.
postgres_factory: StashFactory
The postgres stash factory.
metrics_registry: MetricsRegistry
The metrics registry.
Trait Implementations§
source§impl Clone for ControllerConfig
impl Clone for ControllerConfig
source§fn clone(&self) -> ControllerConfig
fn clone(&self) -> ControllerConfig
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreAuto Trait Implementations§
impl !RefUnwindSafe for ControllerConfig
impl Send for ControllerConfig
impl Sync for ControllerConfig
impl Unpin for ControllerConfig
impl !UnwindSafe for ControllerConfig
Blanket Implementations§
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
.