Struct mz_compute_client::command::TimelyConfig
source · pub struct TimelyConfig {
pub workers: usize,
pub process: usize,
pub addresses: Vec<String>,
pub idle_arrangement_merge_effort: u32,
}
Expand description
Configuration of the cluster we will spin up
Fields§
§workers: usize
Number of per-process worker threads
process: usize
Identity of this process
addresses: Vec<String>
Addresses of all processes
idle_arrangement_merge_effort: u32
The amount of effort to be spent on arrangement compaction during idle times.
Trait Implementations§
source§impl Arbitrary for TimelyConfig
impl Arbitrary for TimelyConfig
§type Parameters = (<usize as Arbitrary>::Parameters, <usize as Arbitrary>::Parameters, <Vec<String, Global> as Arbitrary>::Parameters, <u32 as Arbitrary>::Parameters)
type Parameters = (<usize as Arbitrary>::Parameters, <usize as Arbitrary>::Parameters, <Vec<String, Global> as Arbitrary>::Parameters, <u32 as Arbitrary>::Parameters)
The type of parameters that
arbitrary_with
accepts for configuration
of the generated Strategy
. Parameters must implement Default
.§type Strategy = Map<(<usize as Arbitrary>::Strategy, <usize as Arbitrary>::Strategy, <Vec<String, Global> as Arbitrary>::Strategy, <u32 as Arbitrary>::Strategy), fn(_: (usize, usize, Vec<String, Global>, u32)) -> TimelyConfig>
type Strategy = Map<(<usize as Arbitrary>::Strategy, <usize as Arbitrary>::Strategy, <Vec<String, Global> as Arbitrary>::Strategy, <u32 as Arbitrary>::Strategy), fn(_: (usize, usize, Vec<String, Global>, u32)) -> TimelyConfig>
The type of
Strategy
used to generate values of type Self
.source§fn arbitrary_with(_top: Self::Parameters) -> Self::Strategy
fn arbitrary_with(_top: Self::Parameters) -> Self::Strategy
source§impl Clone for TimelyConfig
impl Clone for TimelyConfig
source§fn clone(&self) -> TimelyConfig
fn clone(&self) -> TimelyConfig
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 moresource§impl Debug for TimelyConfig
impl Debug for TimelyConfig
source§impl Default for TimelyConfig
impl Default for TimelyConfig
source§fn default() -> TimelyConfig
fn default() -> TimelyConfig
Returns the “default value” for a type. Read more
source§impl<'de> Deserialize<'de> for TimelyConfig
impl<'de> Deserialize<'de> for TimelyConfig
source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
source§impl PartialEq<TimelyConfig> for TimelyConfig
impl PartialEq<TimelyConfig> for TimelyConfig
source§fn eq(&self, other: &TimelyConfig) -> bool
fn eq(&self, other: &TimelyConfig) -> bool
This method tests for
self
and other
values to be equal, and is used
by ==
.source§impl RustType<ProtoTimelyConfig> for TimelyConfig
impl RustType<ProtoTimelyConfig> for TimelyConfig
source§fn into_proto(&self) -> ProtoTimelyConfig
fn into_proto(&self) -> ProtoTimelyConfig
Convert a
Self
into a Proto
value.source§fn from_proto(proto: ProtoTimelyConfig) -> Result<Self, TryFromProtoError>
fn from_proto(proto: ProtoTimelyConfig) -> Result<Self, TryFromProtoError>
source§impl Serialize for TimelyConfig
impl Serialize for TimelyConfig
impl StructuralPartialEq for TimelyConfig
Auto Trait Implementations§
impl RefUnwindSafe for TimelyConfig
impl Send for TimelyConfig
impl Sync for TimelyConfig
impl Unpin for TimelyConfig
impl UnwindSafe for TimelyConfig
Blanket Implementations§
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>
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
.