Module codes 

Constants

AGDX_AGENT_BASE

Base of the agent and workflow control band.

AGDX_AGENT_CANCEL_CODE

Managed command code: cancel a submitted task.

AGDX_AGENT_LIST_CODE

Managed command code: list tasks.

AGDX_AGENT_STATUS_CODE

Managed command code: read a task’s status.

AGDX_AGENT_SUBMIT_CODE

Managed command code: submit a task to an agent or workflow.

AGDX_AUTHZ_BASE

Base of the authorization and system-management band (first management band).

AGDX_AUTHZ_BIND_ROLES_CODE

Managed command code: bind roles to a user (replace the user’s role set).

AGDX_AUTHZ_DEFINE_ROLE_CODE

Managed command code: define or replace a role (upsert).

AGDX_AUTHZ_DELETE_ROLE_CODE

Managed command code: delete a role by name.

AGDX_AUTHZ_GET_BINDINGS_CODE

Managed command code: read one user’s bound role names.

AGDX_AUTHZ_GET_ROLE_CODE

Managed command code: read one role by name.

AGDX_AUTHZ_HISTORY_CODE

Managed command code: read the authorization change history (audit).

AGDX_AUTHZ_LIST_ROLES_CODE

Managed command code: list defined roles (optionally filtered).

AGDX_AUTHZ_WHOAMI_CODE

Managed command code: read the caller’s own effective capabilities (self-read).

AGDX_BACKEND_HELLO_CODE

Internal command code: the managed backend announces its served capabilities (an OpVersions) to the streaming server over their private socket on connect. The streaming server caches it and answers the client AGDX_HELLO with it, so the binary feature bits and the HTTP capability flags cannot drift from what the backend actually serves (the backend is the single source of its own truth). Not a client-facing code, a client never sends it.

AGDX_BATCH_CODE

Managed command code: the mixed-operation batch. The request body is a CBOR BatchRequest carrying up to MAX_BATCH_OPS managed requests, each with its own code and payload. The reply a BatchReply with each op’s own reply bytes in order. One round trip amortized over several ops, per-op results, explicitly NOT atomic. A nested batch is rejected. An old backend answers the unknown code with CommandError, decoded client-side as the typed unsupported, so no capability bit is needed.

AGDX_CHECKPOINT_CODE

Fork-native command code: submit one public checkpoint mutation to Iggy metadata.

AGDX_COMMAND_BASE

Base of LaserData’s reserved managed-command range.

AGDX_DECODE_RECORD_CODE

Managed command code: decode one payload under a registered schema id.

AGDX_DESTINATION_GET_CODE

Fork-native command code: read one destination and its checkpoint status.

AGDX_DESTINATION_LIST_CODE

Fork-native command code: list destinations and their checkpoint status.

AGDX_FORK_BASE

Base of the fork managed-command block.

AGDX_FORK_CREATE_CODE

Managed command code: open a fork.

AGDX_FORK_DELETE_CODE

Managed command code: squash a fork.

AGDX_FORK_LIST_CODE

Managed command code: list forks.

AGDX_FORK_PROMOTE_CODE

Managed command code: promote a fork onto the trunk.

AGDX_FORK_PUT_CODE

Managed command code: write a speculative fork row.

AGDX_GET_CLIENTS_METADATA_CODE

Fork-native command code: list every connection with its advertised metadata. The discovery read, answered by the streaming server from its connection table. A LaserData-owned reply (crate::clients::ClientMetadataList), never the upstream Apache Iggy get_clients shape, so an Apache Iggy SDK against LaserData Cloud and the metadata read stay byte-independent.

AGDX_GET_PROJECTION_CODE

Managed command code: browse one projection.

AGDX_GET_SCHEMA_CODE

Managed command code: browse one registered schema by id.

AGDX_GRAPH_BASE

Base of the graph managed-command block.

AGDX_GRAPH_NEIGHBORS_CODE

Managed command code: one-hop neighbor read.

AGDX_GRAPH_QUERY_CODE

Managed command code: run a graph traversal.

AGDX_GRAPH_UPSERT_CODE

Managed command code: write nodes and edges (the projector path).

AGDX_HELLO_CODE

Managed command code: capability probe.

AGDX_KV_BASE

Base of the KV managed-command block.

AGDX_KV_CAS_CODE

Managed command code: compare-and-swap a key (optimistic concurrency). Additive over KV_OP_VERSION 1: a backend or server that does not serve it rejects the code, which the client surfaces as an unsupported error. Whether it is served is advertised by the kv_cas capability flag.

AGDX_KV_CAS_FENCED_CODE

Managed command code: fenced compare-and-swap. Applies the CAS in one backend transaction that also requires a live lease at the request’s coordination namespace and key plus a fence sequence equal to the presented token (the at-most-one effective-writer gate). Rides KV_LEASE_OP_VERSION; served only under the KV_FENCED_LEASES feature bit, which subsumes the older fence-only kv_cas_fenced flag.

AGDX_KV_COPY_CODE

Managed command code: copy the value at one key to another key (possibly in another namespace) in a single backend transaction. Reuses the kv outcomes: Committed on success, NotFound when the source is absent.

AGDX_KV_DELETE_CODE

Managed command code: KV delete one.

AGDX_KV_DELETE_MANY_CODE

Managed command code: KV bulk delete by filter.

AGDX_KV_EXISTS_CODE

Managed command code: test presence and read metadata without the value (the formal EXISTS object primitive).

AGDX_KV_EXPIRE_CODE

Managed command code: set, refresh, or clear a key’s expiry in place without rewriting its value (the formal EXPIRE primitive).

AGDX_KV_GET_CODE

Managed command code: KV get.

AGDX_KV_LEASE_CODE

Managed command code: acquire a revocable lease on a key (the formal LEASE primitive). Carries the stable holder identity and an optional delegated subject at KV_LEASE_OP_VERSION. Served only by a deployment advertising the KV_FENCED_LEASES feature bit; a backend that cannot serve it returns a clean unsupported error.

AGDX_KV_LEASE_RENEW_CODE

Managed command code: extend a held lease without changing its token (the formal RENEW primitive). Requires the same holder and subject, a live lease, and the current fence token; never bumps the fence. Rides KV_LEASE_OP_VERSION under the KV_FENCED_LEASES feature bit.

AGDX_KV_MOVE_CODE

Managed command code: move the value at one key to another key. Copy plus delete of the source, one backend transaction, the same outcomes.

AGDX_KV_NAMESPACES_CODE

Managed command code: list the caller’s namespaces.

AGDX_KV_PATCH_CODE

Managed command code: apply a merge patch to a structured value (the formal PATCH primitive).

AGDX_KV_RELEASE_CODE

Managed command code: release a held lease early (the formal RELEASE primitive). Requires the same holder and the current fence token, validated against the fence sequence, never the resetting lease-row version.

AGDX_KV_SCAN_CODE

Managed command code: KV scan.

AGDX_KV_SET_CODE

Managed command code: KV set.

AGDX_LIST_PROJECTIONS_CODE

Managed command code: list projections.

AGDX_LIST_SCHEMAS_CODE

Managed command code: list registered schemas.

AGDX_QUERY_BASE

Base of the query managed-command block.

AGDX_QUERY_CANCEL_CODE

Managed command code: cancel an executing query.

AGDX_QUERY_CODE

Managed command code: execute a query.

AGDX_QUERY_PAGE_CODE

Managed command code: retrieve the next page of an executing query.

AGDX_QUERY_ROUTE_LIST_CODE

Fork-native command code: list explicit query-route declarations.

AGDX_QUERY_STATUS_CODE

Managed command code: read query execution status.

AGDX_REGISTER_SCHEMA_CODE

Managed command code: advisory next free schema id.

AGDX_SET_CLIENT_METADATA_CODE

Fork-native command code: set this connection’s advertised metadata (the transport-level discovery primitive). Handled by the streaming server itself, not forwarded to the plane, because it touches per-connection session state the plane never sees. Connection-scoped and cleared on disconnect.

AGENT_OP_VERSION

Wire version of the agent envelope (the Agent Data Exchange Protocol). Carried out-of-band as the typed agdx.av header, never inside the body: a durable log record must select its decoder before any body byte is read.

AGENT_WORKFLOW_OP_VERSION

Wire version of the agent and workflow control-band envelopes. Distinct from AGENT_OP_VERSION (the on-the-log envelope), this versions the request and reply types of the control band.

AUTHZ_OP_VERSION

Wire version of the authorization command envelopes.

BATCH_OP_VERSION

Wire version of the mixed-operation batch request and reply (crate::batch). The items inside version themselves: each rides its own op’s request frame with that op’s own v.

CHANGE_OP_VERSION

Versions the change-feed record (ChangeRecord.v). Checked by consumers of the changes topic. The feed is advertised by the WATCH feature bit.

CHECKPOINT_OP_VERSION

Wire version of public checkpoint mutation requests and status replies.

CLIENT_METADATA_OP_VERSION

Wire version of the client-metadata discovery request and reply (crate::clients).

CONTROL_OP_VERSION

Wire version of the control envelope.

FORK_OP_VERSION

Wire version of the fork op envelopes.

GRAPH_OP_VERSION

Wire version of the graph op envelopes.

KV_LEASE_OP_VERSION

Wire version of the fenced-lease op family: KvLease, KvLeaseRenew, KvRelease, and KvCasFenced. Bumped past KV_OP_VERSION by the holder-identity reshape so a v1 payload and a v2 payload can never be mistaken for each other: the reshaped fields are required with no serde defaults (an old payload fails decode) and crate::validate::Validate rejects any other v (a typed error, fail-closed). The rest of the KV surface stays at KV_OP_VERSION.

KV_OP_VERSION

Wire version of the KV op envelopes.

PRESENCE_OP_VERSION

Wire version of the agent presence body (crate::agent::AgentPresence) an agent advertises in its connection metadata. Carried in the body’s own v field, not out-of-band, because presence rides the opaque connection-metadata bytes with no envelope header to select a decoder.

QUERY_OP_VERSION

Wire version of the query envelope.

Functions

is_idempotent_managed_request

Whether a managed command can change plane-owned state and therefore must carry a stable operation identity across transport retries.