Struct mz_dataflow_types::client::controller::ControllerConfig
source · [−]pub struct ControllerConfig {
pub orchestrator: Arc<dyn Orchestrator>,
pub linger: bool,
pub persist_location: PersistLocation,
pub persist_clients: Arc<Mutex<PersistClientCache>>,
pub storage_stash_url: String,
pub storaged_image: String,
pub computed_image: String,
}Expand description
Configures a controller.
Fields
orchestrator: Arc<dyn Orchestrator>The orchestrator implementation to use.
linger: boolWhether or not storage and compute processes should die when connection with their controller is lost.
persist_location: PersistLocationThe 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: StringThe stash URL for the storage controller.
storaged_image: StringThe storaged image to use when starting new storage processes.
computed_image: StringThe computed image to use when starting new compute processes.
Trait Implementations
sourceimpl Clone for ControllerConfig
impl Clone for ControllerConfig
sourcefn clone(&self) -> ControllerConfig
fn clone(&self) -> ControllerConfig
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read more
Auto Trait Implementations
impl !RefUnwindSafe for ControllerConfig
impl Send for ControllerConfig
impl Sync for ControllerConfig
impl Unpin for ControllerConfig
impl !UnwindSafe for ControllerConfig
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> 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