Struct mz_compute_client::command::CommunicationConfig
source · pub struct CommunicationConfig {
pub workers: usize,
pub process: usize,
pub addresses: Vec<String>,
}
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
Trait Implementations§
source§impl Arbitrary for CommunicationConfig
impl Arbitrary for CommunicationConfig
§type Parameters = (<usize as Arbitrary>::Parameters, <usize as Arbitrary>::Parameters, <Vec<String, Global> as Arbitrary>::Parameters)
type Parameters = (<usize as Arbitrary>::Parameters, <usize as Arbitrary>::Parameters, <Vec<String, Global> 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), fn(_: (usize, usize, Vec<String, Global>)) -> CommunicationConfig>
type Strategy = Map<(<usize as Arbitrary>::Strategy, <usize as Arbitrary>::Strategy, <Vec<String, Global> as Arbitrary>::Strategy), fn(_: (usize, usize, Vec<String, Global>)) -> CommunicationConfig>
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 CommunicationConfig
impl Clone for CommunicationConfig
source§fn clone(&self) -> CommunicationConfig
fn clone(&self) -> CommunicationConfig
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 CommunicationConfig
impl Debug for CommunicationConfig
source§impl Default for CommunicationConfig
impl Default for CommunicationConfig
source§fn default() -> CommunicationConfig
fn default() -> CommunicationConfig
Returns the “default value” for a type. Read more
source§impl<'de> Deserialize<'de> for CommunicationConfig
impl<'de> Deserialize<'de> for CommunicationConfig
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<CommunicationConfig> for CommunicationConfig
impl PartialEq<CommunicationConfig> for CommunicationConfig
source§fn eq(&self, other: &CommunicationConfig) -> bool
fn eq(&self, other: &CommunicationConfig) -> bool
This method tests for
self
and other
values to be equal, and is used
by ==
.source§impl RustType<ProtoCommunicationConfig> for CommunicationConfig
impl RustType<ProtoCommunicationConfig> for CommunicationConfig
source§fn into_proto(&self) -> ProtoCommunicationConfig
fn into_proto(&self) -> ProtoCommunicationConfig
Convert a
Self
into a Proto
value.source§fn from_proto(
proto: ProtoCommunicationConfig
) -> Result<Self, TryFromProtoError>
fn from_proto(
proto: ProtoCommunicationConfig
) -> Result<Self, TryFromProtoError>
source§impl Serialize for CommunicationConfig
impl Serialize for CommunicationConfig
impl StructuralPartialEq for CommunicationConfig
Auto Trait Implementations§
impl RefUnwindSafe for CommunicationConfig
impl Send for CommunicationConfig
impl Sync for CommunicationConfig
impl Unpin for CommunicationConfig
impl UnwindSafe for CommunicationConfig
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
.