Type Alias mz_compute_client::controller::replica::Client

type Client<T> = SequentialHydration<T>;

Aliased Type

struct Client<T> {
    command_tx: UnboundedSender<ComputeCommand<T>>,
    response_rx: UnboundedReceiver<Result<ComputeResponse<T>, Error>>,
    dyncfg: Arc<ConfigSet>,
    metrics: ReplicaMetrics,
    collections: BTreeMap<GlobalId, Collection<T>>,
    hydration_queue: VecDeque<GlobalId>,
    hydration_token: Arc<()>,
    _forwarder_task: AbortOnDropHandle<()>,
}

Fields

command_tx: UnboundedSender<ComputeCommand<T>>

A sender for commands to the wrapped client.

response_rx: UnboundedReceiver<Result<ComputeResponse<T>, Error>>

A receiver for responses from the wrapped client.

dyncfg: Arc<ConfigSet>

Dynamic system configuration.

metrics: ReplicaMetrics

Tracked metrics.

collections: BTreeMap<GlobalId, Collection<T>>

Tracked collections.

Entries are inserted in response to observed CreateDataflow commands. Entries are removed in response to Frontiers commands that report collection hydration, or in response to AllowCompaction commands that specify the empty frontier.

hydration_queue: VecDeque<GlobalId>

A queue of scheduled collections that are awaiting hydration.

hydration_token: Arc<()>

A token held by hydrating collections.

Useful to efficiently determine how many collections are currently in the process of hydration, and thus how much capacity is available.

_forwarder_task: AbortOnDropHandle<()>

Handle to the forwarder task, to abort it when SequentialHydration is dropped.