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.