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

SubscribeBacklogAccounting

Footprints of the subscribe messages queued to the client but not yet drained, oldest first. The producer pushes one per message sent, the client-writer task pops as it drains. FIFO delivery keeps the queue aligned with the channel.

Enums

ActiveComputeSink

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

ActiveComputeSinkRetireReason

The reason for removing an ActiveComputeSink.

ActiveSubscribeOwner

Ownership and cleanup scope of an active subscribe.

Constants

SUBSCRIBE_MESSAGE_OVERHEAD_BYTES 🔒

Overhead charged to every queued message on top of its payload.