Struct mz_storage::client::controller::rehydration::RehydrationTask

struct RehydrationTask<T> {
    addr: String,
    build_info: &'static BuildInfo,
    command_rx: UnboundedReceiver<StorageCommand<T>>,
    response_tx: UnboundedSender<StorageResponse<T>>,
    ingestions: BTreeMap<GlobalId, IngestSourceCommand<T>>,
    uppers: HashMap<GlobalId, (Antichain<T>, MutableAntichain<T>)>,
}

A task that manages rehydration.

Fields

addr: String

The network address of the storage host.

build_info: &'static BuildInfo

The build information for this process.

command_rx: UnboundedReceiver<StorageCommand<T>>

A channel upon which commands intended for the storage host are delivered.

response_tx: UnboundedSender<StorageResponse<T>>

A channel upon which responses from the storage host are delivered.

ingestions: BTreeMap<GlobalId, IngestSourceCommand<T>>

The ingestions that have been observed.

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

The upper frontier information received.

Implementations

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

async fn run(&mut self)

async fn step_rehydrate(&mut self) -> RehydrationTaskState

async fn step_pump(&mut self, client: StorageGrpcClient) -> RehydrationTaskState

async fn send_command(
    &mut self,
    client: StorageGrpcClient,
    command: StorageCommand<T>
) -> RehydrationTaskState

async fn send_response(
    &mut self,
    client: StorageGrpcClient,
    response: Result<StorageResponse<T>, Error>
) -> RehydrationTaskState

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

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