Module service 

Compute layer client and server.

Structs

PartitionedComputeState

Maintained state for partitioned compute clients.

PendingPeek 🔒

Accumulates the per-worker responses to one peek into the single response the controller hands upwards.

PendingSubscribe 🔒

TrackedFrontiers 🔒

Tracked frontiers for an index or a sink collection.

Traits

ComputeClient

A client to a compute server.

Functions

merge_peek_errors 🔒

Merge two PeekErrors into the one we report.

merge_peek_responses 🔒

Merge two PeekResponses.