Structs§
- History
Document - History event document.
id = “
:history: : ” Partition key = instanceId - Instance
Document - Instance metadata document.
id = “
:instance” Partition key = instanceId - KeyValue
Delta Document - Current-execution KV mutation entry.
id = “
:kv_delta: ” Partition key = instanceId - KeyValue
Document - Materialized KV entry for an orchestration instance.
id = “
:kv: ” Partition key = instanceId - Outbox
Intent Document - Outbox intent for cross-partition writes.
id = “intent:
” Partition key = sourceInstanceId - Queue
Item Document - Queue item document (orchestrator or worker). id = random UUID Partition key = instanceId
- Session
Document - Session affinity tracking document.
id = “
:session: ” Partition key = instanceId
Constants§
- DOC_
TYPE_ HISTORY - DOC_
TYPE_ INSTANCE - DOC_
TYPE_ KV - DOC_
TYPE_ KV_ DELTA - DOC_
TYPE_ ORCH_ QUEUE - DOC_
TYPE_ OUTBOX_ INTENT - DOC_
TYPE_ SESSION - DOC_
TYPE_ WORKER_ QUEUE
Functions§
- dispatch_
slot - Compute the dispatch slot for an instance ID. Returns a value 0-255 for partitioning across dispatchers.
- idempotency_
key - Build an idempotency key from the source context.
- now_ms
- Get current time in milliseconds since epoch.
- pack_
semver - Pack a semver::Version into an i64 for range comparison in queries. packed = major * 1_000_000 + minor * 1_000 + patch
- task_
id_ u64 - Get a u64 value representing the current tokio task ID. Used for lease slot allocation.
- unpack_
semver - Unpack an i64 back into semver::Version.
- work_
item_ instance - Extract the instance ID from a WorkItem.