Struct mz_compute_client::controller::replicated::ActiveReplication

pub(super) struct ActiveReplication<T> {
    build_info: &'static BuildInfo,
    replicas: HashMap<ReplicaId, ReplicaState<T>>,
    state: ActiveReplicationState<T>,
}

A client backed by multiple replicas.

Fields

build_info: &'static BuildInfo

The build information for this process.

replicas: HashMap<ReplicaId, ReplicaState<T>>

State for each replica.

state: ActiveReplicationState<T>

All other internal state of the client

Implementations

impl<T> ActiveReplication<T>

pub(super) fn new(build_info: &'static BuildInfo) -> Self

impl<T> ActiveReplication<T>where
    T: Timestamp + Lattice,
    ComputeGrpcClient: ComputeClient<T>,

pub(super) fn add_replica(
    &mut self,
    id: ReplicaId,
    addrs: Vec<String>,
    logging_config: Option<LoggingConfig>,
    communication_config: CommunicationConfig
)

Introduce a new replica, and catch it up to the commands of other replicas.

It is not yet clear under which circumstances a replica can be removed.

pub(super) fn get_replica_ids(&self) -> impl Iterator<Item = ReplicaId> + '_

Returns an iterator over the IDs of the replicas.

pub(super) fn remove_replica(&mut self, id: ReplicaId)

Remove a replica by its identifier.

fn rehydrate_replica(&mut self, id: ReplicaId)

pub(super) fn send(&mut self, cmd: ComputeCommand<T>)

Sends a command to all replicas.

pub(super) async fn recv(&mut self) -> ActiveReplicationResponse<T>

Receives the next response from any replica.

This method is cancellation safe.

Trait Implementations

impl<T: Debug> Debug for ActiveReplication<T>

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

Formats the value using the given formatter.