Load and validate a policy file.

Create a governance policy for testing.

Create a governance policy for testing.

Create a governance policy for testing.

The base policy of this hierarchy node.

Return the :class:`GovernancePolicy` driving the bridge, if any.

Create a client with policies loaded from a temp directory.

Total number of registered policies.

Create a temp directory with test policy files.

The underlying policy engine.

Create a PolicyEngine with test policies.

Create and connect a PostgreSQL storage provider.

Calculate power.

Prepare messages with caching hints. Args: system_prompt: Optional system prompt context: The contex

No special preparation needed for local caching.

Create a policy that only allows specific principals.

Get the principle set.

Get the list of principles.

Print a step header.

Process a message through the agent.

Process raw content into a Document.

Process HTML content.

Process source code content.

Process a secure banking transaction. This agent demonstrates best practices: - Idempotent operations - Transaction tracking

Process a list of numbers.

Process a list of items. Args: items: List of strings to process reverse: Whether to reverse the list

Process a request - but store everything permanently! This simulates a rogue agent that doesn't respect privacy. The sidecar should

Process a request from the sidecar. The agent receives clean, validated JSON and doesn't need to worry about security checks or priv

Process text with various operations. Args: text: The text to process operation: The operation (upper, lower, reverse, title)

Product Manager: Creates technical specifications. This is a PROBABILISTIC AI worker.

Decorator that profiles execution time (and optionally memory) of a method. Usage: @profile_governance def my_method(self, ...):

Prometheus-compatible metrics endpoint.

Immediately promote — not available in Public Preview.

Directory with mixed prompts.

A well-defended system prompt.

All protocol spans recorded so far.

Yield a real DockerSandboxProvider and destroy all sessions on teardown.

One provider per module — sandboxes are created/destroyed per test.

Return the provider this strategy is for.

Provision a session and inject a stub evaluator under the lock.

Start an AgentMesh MCP proxy. Wraps an existing MCP server with governance, policy enforcement, and trust scoring. Examples:

Forward requests to the appropriate upstream component.

Main proxy endpoint that forwards requests to the backend agent. Headers: - X-User-Override: Must equal the secr

The Main Gateway - Intercepts and validates all requests. Flow: 1. Generate/validate trace ID 2. Parse and validate the payload

Raw 32-byte public key.

Publish a message to the broker. Args: message: The message to publish wait_for_confirmation: If Tru

Publish message to NATS subject. Args: message: Message to publish wait_for_confirmation: Wait for a

Publish forecast to AMB

Publish the agent's metadata manifest. In a real system, this would register the agent in a marketplace or registry

Sign and register a plugin with the registry.

Sign and register a plugin with the registry.