Struct mz_compute_client::controller::replicated::ReplicaState

struct ReplicaState<T> {
    command_tx: UnboundedSender<ComputeCommand<T>>,
    response_rx: UnboundedReceiver<ComputeResponse<T>>,
    _task: AbortOnDropHandle<()>,
    addrs: Vec<String>,
    logging_config: Option<LoggingConfig>,
    communication_config: CommunicationConfig,
}

State for a single replica.

Fields

command_tx: UnboundedSender<ComputeCommand<T>>

A sender for commands for the replica.

If sending to this channel fails, the replica has failed and requires rehydration.

response_rx: UnboundedReceiver<ComputeResponse<T>>

A receiver for responses from the replica.

If receiving from the channel returns None, the replica has failed and requires rehydration.

_task: AbortOnDropHandle<()>

A handle to the task that aborts it when the replica is dropped.

addrs: Vec<String>

The network addresses of the processes that make up the replica.

logging_config: Option<LoggingConfig>

The logging config specific to this replica.

communication_config: CommunicationConfig

The communication config specific to this replica.

Implementations

impl<T> ReplicaState<T>

fn specialize_command(
    &self,
    command: &mut ComputeCommand<T>,
    replica_id: ReplicaId
)

Specialize a command for the given Replica and ReplicaId.

Most ComputeCommands are independent of the target replica, but some contain replica-specific fields that must be adjusted before sending.

Trait Implementations

impl<T: Debug> Debug for ReplicaState<T>

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

Formats the value using the given formatter.