Trait mz_service::client::PartitionedState

pub trait PartitionedState<C, R>: Debug + Send {
    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