Trait PartitionedState

pub trait PartitionedState<C, R>: Debug + Send {
    // Required methods
    fn split_command(&mut self, command: C) -> Vec<Option<C>>;
    fn absorb_response(
        &mut self,
        shard_id: usize,
        response: R,
    ) -> Option<Result<R, Error>>;
}

A state machine for a partitioned client that partitions commands across and amalgamates responses from multiple partitions.

Required Methods

fn split_command(&mut self, command: C) -> Vec<Option<C>>

Splits a command into multiple partitions.

fn absorb_response( &mut self, shard_id: usize, response: R, ) -> Option<Result<R, Error>>

Absorbs a response from a single partition.

If responses from all partitions have been absorbed, returns an amalgamated response.

Implementors

impl<T> PartitionedState<ComputeCommand<T>, ComputeResponse<T>> for PartitionedComputeState<T>

where T: ComputeControllerTimestamp,

impl<T> PartitionedState<StorageCommand<T>, StorageResponse<T>> for PartitionedStorageState<T>

where T: Timestamp + Lattice,