Trait mz_dataflow_types::client::partitioned::Partitionable
source · [−]pub trait Partitionable<C, R> {
type PartitionedState: PartitionedState<C, R>;
fn new(parts: usize) -> Self::PartitionedState;
}
Expand description
A trait for command–response pairs that can be partitioned across multiple
workers via Partitioned
.
Associated Types
type PartitionedState: PartitionedState<C, R>
type PartitionedState: PartitionedState<C, R>
The type which functions as the state machine for the partitioning.
Required methods
fn new(parts: usize) -> Self::PartitionedState
fn new(parts: usize) -> Self::PartitionedState
Construct a PartitionedState
for the command–response pair.