Crate jamjet_a2a_proto

Expand description

A2A protocol integration — re-exports from the published jamjet-a2a crate plus the local ProtocolAdapter bridge.

Re-exports§

A2aArtifact: An output artifact produced by an agent while executing a task.
A2aClient: Async HTTP client for communicating with A2A v1.0 agents.
A2aMessage: A single conversational message exchanged between user and agent.
A2aPart: A single content part within a Message or Artifact.
A2aServer: An A2A v1.0 server that serves an Agent Card, handles JSON-RPC requests, and streams SSE events.
A2aTask: Top-level task object in the A2A protocol.
A2aTaskStatus: Snapshot of a task’s current state, optionally carrying a status message.
CancelTaskRequest: Request to cancel a running task.
FederationIdentity: Result of federation auth validation.
FederationPolicy: Authorization policy for incoming A2A requests.
FederationToken: A federation token with associated metadata.
GetTaskRequest: Request to retrieve a task by ID.
InMemoryTaskStore: A simple in-memory TaskStore backed by a tokio::sync::Mutex.
SendMessageConfiguration: Per-request configuration for SendMessage.
SendMessageRequest: Request body for the SendMessage / StreamMessage RPC method.
TaskArtifactUpdateEvent: A streaming event delivering an artifact chunk.
TaskStatusUpdateEvent: A streaming event indicating that a task’s status has changed.
TlsConfig: TLS / mTLS configuration for A2A federation.

A2aError: Top-level error enum combining protocol, transport, and auth errors.
A2aProtocolError: Errors defined by the A2A v1.0 protocol specification.
A2aStreamEvent: A single frame in a streaming response — one of several event types.
A2aTaskState: Terminal and non-terminal states a task can occupy.
A2aTransportError: Transport-level errors (connection, timeout, SSE).
PartContent: The payload of a Part.
Role: Who authored a message.
SendMessageResponse: Response for SendMessage — a wrapped Task or Message per A2A v1.0.

TaskHandler: User-provided handler that processes an incoming message for a task.
TaskStore: Async storage backend for A2A tasks.

build_mtls_client: Build a reqwest::Client with mTLS configuration for outbound A2A calls.
check_method_scopes: Check if an identity has the required scopes for a given RPC method.
federation_auth_layer: Axum middleware layer for federation auth.
validate_federation_token: Validate a Bearer token against the federation policy.

SendTaskRequest: Backward-compatible alias: the old SendTaskRequest maps to the v1.0 SendMessageRequest.