Module active_compute_sink

Coordinator bookkeeping for active compute sinks.

Structs

ActiveCopyFrom 🔒

State we keep in the Coordinator to track active COPY FROM statements.

ActiveCopyTo

A description of an active copy to sink from the coordinator’s perspective.

ActiveSubscribe

A description of an active subscribe from coord’s perspective

Enums

ActiveComputeSink

A description of an active compute sink from the coordinator’s perspective.

ActiveComputeSinkRetireReason

The reason for removing an ActiveComputeSink.