Register a callback for health events

Register a callback for revocation events. Args: callback: A callable that receives the revoked Credential.

Register callback for automatic revocations.

Record successful tool execution.

Parse a SPIFFE ID into trust domain and path. Format: ``spiffe://trust-domain/path`` Args: spiffe_id: The full SPIFFE ID

Deserialize raw rule dicts into SharedPolicyRule objects.

Immediately promote the candidate to full traffic.

* Propagate health status through dependency graph. * When a node fails, its dependents are notified and may degrade.

Count of spans per protocol type.

Return a copy of this identity without the private key.

Push raw data into the onmessage handler — caller controls JSON validity.

Flexible query with multiple filters.

Query with RAG pipeline. Args: query_text: Query text query_embedding: Query vector embedding

Get all events of a specific type.

randomHex returns 2*n hex characters drawn from crypto/rand. A failure from crypto/rand indicates a broken entropy source (e.g. dev/urandom is unreac

Receive the next message from the queue. Args: timeout: Maximum seconds to wait. Returns: Parsed message pay

* Disconnect and reconnect to the relay. * * Resets the WebSocket connection and sends a fresh connect + * fetch_pending sequence, triggering

Record activity for an agent (resets idle timer)

Record an agent error.

Record agent task execution time.

Record an LLM API call by an agent.

Record a blocked violation (SIGKILL issued).

Record a compliance result for a period.

Add ``usd`` to the running ``cost_usd`` budget.

Record a policy denial metric.

Add ``seconds`` to the running ``elapsed_seconds`` budget.

Record a failed action, penalizing specified dimensions.

Record a trust handshake. Args: duration_seconds: Handshake latency in seconds. result: Outcome label, e.g. ``success

Record a signal sent.

Record SLO status, error budget, and all SLI values to OpenLit.

Add ``tokens`` to the running ``token_count`` budget.

Record a tool call and check for unusual sequences. Returns an ``AnomalyAlert`` if a rare transition is detected.

Recursively redact nested strings in dicts, lists, and tuples. Args: value: Any Python value that may contain nested strings.

Register a scanner class. Can be used as a decorator.

Register an agent for hot reload

Register an agent for orchestration. Args: agent_id: Unique identifier role: Agent's role

Register a tool name alias. Args: alias: The alternative tool name (case-insensitive). canonical: The canonical capab

Register a new architectural design proposal.

Register all actions from a manifest. Returns count registered.

Register or replace a per-agent capability profile.

Register an MCP resource. Args: uri_pattern: URI pattern (e.g., "file://", "db://") resource_info: R

Register a tool with trust requirements. Args: name: Tool name handler: Async handler function d

Register a healthcare system user.

Register a system user.

Release escrow based on outcome. - success: Credits go to provider, provider reputation +2 - failure: Credits return

Manually release an agent from quarantine.

Release all bonds for a session.

Remove an agent from sponsorship. Args: agent_did: DID of the agent to remove.

Remove a specific item by ID.

Remove a server from the allowlist.

Determine if a proposed wisdom update requires human policy review. Args: proposed_wisdom: The new wisdom/instru

Reset usage counters. If *agent_id* is provided only that agent's counters are cleared; otherwise all agents are reset.

Reset state. If conversation_id given, reset only that conversation. Thread-safe.

Reset counters and start time (for new execution runs).

Reset the circuit-breaker and clear the call window for this agent.

Resume a paused rollout.

Revoke all active grants issued by a specific grantor. Args: grantor_did: DID of the grantor whose grants should be

Revoke trust for a previously verified peer.

Create a policy that only allows specific roles.

Switch back to the previous active environment. Returns: The restored active environment. Raises: RuntimeErr

Get top-level spans (no parent).

Flowise-compatible run method.

Run the Carbon Auditor demo. Args: simulate_fraud: If True, simulate deforestation (fraud case) If False,

Run a task through an ordered pipeline of agent IDs.