Struct mz_storage::protocol::client::PartitionedStorageState

pub struct PartitionedStorageState<T> {
    parts: usize,
    uppers: HashMap<GlobalId, (MutableAntichain<T>, Vec<Antichain<T>>)>,
}

Maintained state for partitioned storage clients.

This helper type unifies the responses of multiple partitioned workers in order to present as a single worker.

Fields

parts: usize

Number of partitions the state machine represents.

uppers: HashMap<GlobalId, (MutableAntichain<T>, Vec<Antichain<T>>)>

Upper frontiers for sources and sinks, both unioned across all partitions and from each individual partition.

Implementations

impl<T> PartitionedStorageState<T>where
    T: Timestamp,

fn observe_command(&mut self, command: &StorageCommand<T>)

Trait Implementations

impl<T: Debug> Debug for PartitionedStorageState<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> PartitionedState<StorageCommand<T>, StorageResponse<T>> for PartitionedStorageState<T>where
    T: Timestamp + Lattice,

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

Splits a command into multiple partitions.

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

Absorbs a response from a single partition.