Module service

Compute layer client and server.

Structs

PartitionedComputeState

Maintained state for partitioned compute clients.

PendingSubscribe 🔒

TrackedFrontiers 🔒

Tracked frontiers for an index or a sink collection.

Traits

ComputeClient

A client to a compute server.

Functions

merge_peek_responses 🔒

Merge two PeekResponses.