Struct mz_storage_client::controller::rehydration::RehydratingStorageClient

pub struct RehydratingStorageClient<T> {
    command_tx: UnboundedSender<RehydrationCommand<T>>,
    response_rx: UnboundedReceiverStream<StorageResponse<T>>,
    _task: AbortOnDropHandle<()>,
}

A storage client that replays the command stream on failure.

See the module documentation for details.

Fields

command_tx: UnboundedSender<RehydrationCommand<T>>

response_rx: UnboundedReceiverStream<StorageResponse<T>>

_task: AbortOnDropHandle<()>

Implementations

impl<T> RehydratingStorageClient<T>where
    T: Timestamp + Lattice + Codec64,
    StorageGrpcClient: StorageClient<T>,

pub fn new(
    build_info: &'static BuildInfo,
    metrics: RehydratingStorageClientMetrics,
    envd_epoch: NonZeroI64
) -> RehydratingStorageClient<T>

Creates a RehydratingStorageClient that is not yet connected to a storage replica.

pub fn connect(&mut self, location: ClusterReplicaLocation)

Connects to the storage replica at the specified network address.

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

Sends a command to the underlying client.

pub fn response_stream(&mut self) -> impl Stream<Item = StorageResponse<T>> + '_

Returns a stream that produces responses from the underlying client.

Trait Implementations

impl<T: Debug> Debug for RehydratingStorageClient<T>

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

Formats the value using the given formatter.