Struct HttpClient 

pub struct HttpClient<T> { /* private fields */ }

A typed /agdx/* client over an injected Transport.

Binary KV keys are base64url-encoded into the path by the client, so raw user bytes never enter a path segment. A namespace, fork id, or projection id argument, by contrast, is placed in the path verbatim, so the caller must pass a path-safe identifier (no /, ?, or #). Fork ids are already constrained by validate_fork_id.

Implementations

impl<T: Transport> HttpClient<T>

pub fn new(transport: T) -> Self

Wrap a transport. The transport owns the base URL and auth.

pub fn transport(&self) -> &T

The underlying transport, for a caller that needs an escape hatch.

pub async fn capabilities(&self) -> Result<Capabilities, ClientError<T::Error>>

GET /agdx/capabilities: feature-detect before showing a view.

pub async fn query( &self, query: &Query, ) -> Result<QueryResult, ClientError<T::Error>>

POST /agdx/query: run a query, get the result page back.

pub async fn list_projections( &self, filter: &ProjectionListQuery, ) -> Result<Vec<ProjectionInfo>, ClientError<T::Error>>

GET /agdx/projections: list projections and their bindings, optionally filtered.

pub async fn list_schemas( &self, filter: &SchemaListQuery, ) -> Result<Vec<SchemaInfo>, ClientError<T::Error>>

GET /agdx/schemas: list registered schemas, optionally filtered.

pub async fn register_schema( &self, source: SchemaSource, name: Option<String>, version: Option<u32>, ) -> Result<u32, ClientError<T::Error>>

POST /agdx/schemas: register a schema, get its allocated id.

pub async fn kv_get( &self, namespace: &str, key: &[u8], ) -> Result<Option<KvValue>, ClientError<T::Error>>

GET /agdx/kv/{namespace}/{key}: fetch one entry, or None on a 404. The value rides the raw response body (no base64 inflation, symmetric with kv_set), and the optional expiry rides the KV_EXPIRES_AT_MICROS_HEADER response header.

pub async fn kv_set( &self, namespace: &str, key: &[u8], value: &[u8], expires_at_micros: Option<u64>, ) -> Result<(), ClientError<T::Error>>

PUT /agdx/kv/{namespace}/{key}: set a value, with an optional absolute expiry (epoch microseconds).

pub async fn kv_cas( &self, namespace: &str, key: &[u8], value: &[u8], expect: CasExpect, expires_at_micros: Option<u64>, ) -> Result<u64, ClientError<T::Error>>

PUT /agdx/kv/{namespace}/{key}/cas: a conditional write (compare-and-swap). Applies value only if expect holds, returning the new version on commit. A precondition miss surfaces as ClientError::Api with ResultCode::Conflict (the response’s ErrorBody.detail carries the current version). Backend-gated by the kv_cas capability: a deployment that does not serve it answers unsupported.

pub async fn kv_delete( &self, namespace: &str, key: &[u8], ) -> Result<bool, ClientError<T::Error>>

DELETE /agdx/kv/{namespace}/{key}: delete one entry, returning true if it existed.

pub async fn kv_scan( &self, namespace: &str, filter: &KvScanQuery, ) -> Result<KvPageView, ClientError<T::Error>>

GET /agdx/kv/{namespace}: scan a page of entries.

pub async fn create_fork( &self, body: &ForkCreateBody, ) -> Result<ForkInfo, ClientError<T::Error>>

POST /agdx/forks: create a fork.

pub async fn list_forks(&self) -> Result<Vec<ForkInfo>, ClientError<T::Error>>

GET /agdx/forks: list the caller’s forks.

pub async fn clients( &self, query: &ClientsQuery, ) -> Result<ClientMetadataListView, ClientError<T::Error>>

GET /agdx/clients: one page of live connections with their advertised metadata, filtered and paginated per query. Follow next_cursor as the next after to page.

pub async fn submit_run( &self, body: &AgentSubmit, ) -> Result<AgentRunInfo, ClientError<T::Error>>

POST /agdx/runs: submit a task to an agent or workflow, returning the minted (or converged) run.

pub async fn run_status( &self, id: &str, ) -> Result<Option<AgentRunInfo>, ClientError<T::Error>>

GET /agdx/runs/{id}: read one run’s status, or None on a 404.

pub async fn list_runs( &self, query: &RunsQuery, ) -> Result<RunPageView, ClientError<T::Error>>

GET /agdx/runs: one page of runs, filtered and paged per query. Follow cursor as the next request’s cursor to page.

pub async fn cancel_run( &self, id: &str, ) -> Result<AgentRunInfo, ClientError<T::Error>>

POST /agdx/runs/{id}/cancel: record the cancel intent, returning the run (the engine observes the intent at its next step boundary).

pub async fn get_projection( &self, id: &str, ) -> Result<Option<ProjectionInfo>, ClientError<T::Error>>

GET /agdx/projections/{id}: read one projection and its bindings, or None on a 404.

pub async fn register_projection( &self, projection: &Projection, ) -> Result<(), ClientError<T::Error>>

POST /agdx/projections: register or replace a projection (a control command, durable on the control topic).

pub async fn drop_projection( &self, id: &str, ) -> Result<(), ClientError<T::Error>>

DELETE /agdx/projections/{id}: drop a projection.

pub async fn apply_binding( &self, binding: &ProjectionBinding, ) -> Result<(), ClientError<T::Error>>

POST /agdx/bindings: apply (add or update) a binding.

pub async fn remove_binding( &self, source: &SourceSelector, projection_ref: Option<String>, ) -> Result<(), ClientError<T::Error>>

DELETE /agdx/bindings: remove a binding for a source, or one projection from it when projection_ref is set.

pub async fn get_schema( &self, id: u32, ) -> Result<Option<SchemaInfo>, ClientError<T::Error>>

GET /agdx/schemas/{id}: read one writer schema, or None on a 404.

pub async fn drop_schema(&self, id: u32) -> Result<(), ClientError<T::Error>>

DELETE /agdx/schemas/{id}: drop (tombstone) a schema.

pub async fn decode_record( &self, id: u32, payload: &[u8], ) -> Result<Option<Value>, ClientError<T::Error>>

POST /agdx/schemas/{id}/decode: decode a record body under the schema, returning its JSON form, or None when the body does not decode under it.

pub async fn kv_namespaces( &self, ) -> Result<Vec<KvNamespaceInfo>, ClientError<T::Error>>

GET /agdx/kv: list the caller’s namespaces and their entry counts.

pub async fn kv_delete_many( &self, namespace: &str, filter: &KvScanQuery, ) -> Result<usize, ClientError<T::Error>>

DELETE /agdx/kv/{namespace}: bulk-delete entries matching the bounds (no bounds clears the namespace). Returns the number removed.

pub async fn promote_fork( &self, id: &str, ) -> Result<usize, ClientError<T::Error>>

POST /agdx/forks/{id}/promote: promote a fork’s rows onto the trunk. Returns the number of rows applied.

pub async fn delete_fork(&self, id: &str) -> Result<(), ClientError<T::Error>>

DELETE /agdx/forks/{id}: squash (discard) a fork.

pub async fn put_fork_row( &self, id: &str, body: &ForkPutBody, ) -> Result<(), ClientError<T::Error>>

PUT /agdx/forks/{id}/rows: write one speculative row into a fork.

pub async fn graph_query( &self, name: &str, query: &GraphQuery, ) -> Result<GraphResultView, ClientError<T::Error>>

POST /agdx/graph/{name}/query: run a traversal over a named graph, get back the reachable nodes and traversed edges. Backend-gated by the graph capability: a deployment without a graph backend answers unsupported.

pub async fn graph_neighbors( &self, name: &str, node: &str, query: &GraphNeighborsQuery, ) -> Result<GraphResultView, ClientError<T::Error>>

GET /agdx/graph/{name}/neighbors/{node}: the neighbor read, the cheap common traversal. node is the Crockford-base32 node id. query carries the direction, an optional edge-type filter, the hop depth, and a limit (a default query reads one hop outward with no filter).

pub async fn list_graphs( &self, filter: &ProjectionListQuery, ) -> Result<Vec<ProjectionInfo>, ClientError<T::Error>>

GET /agdx/graphs: list the registered graph projections, the discovery surface a graph explorer reads to offer the available graphs. Reuses the projection-list filter, narrowed to graph-kind projections server-side.

pub async fn register_graph( &self, projection: &Projection, ) -> Result<(), ClientError<T::Error>>

POST /agdx/graphs: register a graph projection (a Projection with kind = Graph and an entity schema). Applied asynchronously, like every control command.

pub async fn get_graph( &self, id: &str, ) -> Result<Option<ProjectionInfo>, ClientError<T::Error>>

GET /agdx/graphs/{id}: read one graph projection by id, or None when no graph projection has it.

pub async fn drop_graph(&self, id: &str) -> Result<(), ClientError<T::Error>>

DELETE /agdx/graphs/{id}: drop the graph projection registered under id. The materialized nodes and edges are left untouched.

pub async fn authz_whoami(&self) -> Result<WhoamiReply, ClientError<T::Error>>

GET /agdx/authz/whoami: the caller’s own bound roles and effective grants. Backend-gated by the authz capability: a deployment that does not serve the authorization band answers unsupported.

pub async fn list_roles(&self) -> Result<Vec<Role>, ClientError<T::Error>>

GET /agdx/authz/roles: every defined role with its full grant set.

pub async fn get_role( &self, name: &str, ) -> Result<Option<Role>, ClientError<T::Error>>

GET /agdx/authz/roles/{name}: one role by name, or None on a 404.

pub async fn define_role( &self, role: &Role, ) -> Result<(), ClientError<T::Error>>

PUT /agdx/authz/roles/{name}: define or replace a role. The path name is authoritative, so role.name must match it.

pub async fn delete_role(&self, name: &str) -> Result<(), ClientError<T::Error>>

DELETE /agdx/authz/roles/{name}: delete a role.

pub async fn user_roles( &self, user_id: u32, ) -> Result<Vec<String>, ClientError<T::Error>>

GET /agdx/authz/users/{id}/roles: one user’s bound role names.

pub async fn bind_user_roles( &self, user_id: u32, roles: &[String], ) -> Result<(), ClientError<T::Error>>

PUT /agdx/authz/users/{id}/roles: replace the user’s whole role set.

Trait Implementations

impl<T: Clone> Clone for HttpClient<T>

fn clone(&self) -> HttpClient<T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for HttpClient<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.