Functions§
- collect_
orch_ messages - Collect all pending messages for an instance from the orchestrator queue.
- count_
by_ type - Count documents by type (cross-partition). Uses client-side counting since cross-partition aggregates aren’t supported via gateway.
- fetch_
history - Fetch history for an instance/execution.
- find_
candidate_ orch_ item - Query for visible, unlocked orchestrator queue items in specific dispatch slots.
- find_
candidate_ work_ item - Query for visible, unlocked worker queue items in specific dispatch slots.
- find_
instance_ by_ lock_ token - Find instance by lock token.
- find_
items_ by_ lock_ token - Find orch_queue items locked by a specific lock token.
- query_
all_ in_ partition - Query all documents in a partition (for deletion).
- query_
by_ type_ in_ partition - Query for all documents by type in a partition.
- query_
instances - Query instances across all partitions with optional status filter.
- query_
pending_ intents - Query pending outbox intents older than a threshold.