Struct mz_service::client::Partitioned
source · pub struct Partitioned<P, C, R>where
(C, R): Partitionable<C, R>,{
pub parts: Vec<P>,
/* private fields */
}
Expand description
A client whose implementation is partitioned across a number of other clients.
Such a client needs to broadcast (partitioned) commands to all of its clients, and await responses from each of the client partitions before it can respond.
Fields§
§parts: Vec<P>
The individual partitions representing per-worker clients.
Implementations§
source§impl<P, C, R> Partitioned<P, C, R>where
(C, R): Partitionable<C, R>,
impl<P, C, R> Partitioned<P, C, R>where
(C, R): Partitionable<C, R>,
Trait Implementations§
source§impl<P: Debug, C: Debug, R: Debug> Debug for Partitioned<P, C, R>where
(C, R): Partitionable<C, R>,
impl<P: Debug, C: Debug, R: Debug> Debug for Partitioned<P, C, R>where
(C, R): Partitionable<C, R>,
source§impl<P, C, R> GenericClient<C, R> for Partitioned<P, C, R>
impl<P, C, R> GenericClient<C, R> for Partitioned<P, C, R>
source§fn send<'life0, 'async_trait>(
&'life0 mut self,
cmd: C
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn send<'life0, 'async_trait>(
&'life0 mut self,
cmd: C
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Sends a command to the dataflow server. Read more