klieo-a2a 0.4.0

Durable A2A v1.0 protocol layer atop klieo-bus traits.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

#![deny(missing_docs)]
#![deny(rust_2018_idioms)]

//! Durable A2A v1.0 protocol layer for klieo agents.
//!
//! Implements the [Agent-to-Agent (A2A) v1.0 specification](https://a2a-protocol.org/latest/specification/)
//! wire types, JSON-RPC envelope, and a server-side dispatcher atop
//! [`klieo_core::Pubsub`] + [`klieo_core::KvStore`].
//!
//! # Why durable A2A?
//!
//! Today A2A runs over HTTP/JSON-RPC + WebSocket. Klieo's angle:
//! implement the same wire shape over **NATS JetStream + KV +
//! JobQueue**. Inter-agent calls inherit the durability, leasing,
//! dedup, and DLQ semantics of [`klieo_core::JobQueue`] — *A2A but
//! work-doesn't-get-stuck.*
//!
//! Wire-compatible at the JSON-RPC envelope level: a payload
//! produced by `adk-python` deserialises into our `SendMessageParams`
//! cleanly. Only the transport differs.
//!
//! # Architecture asymmetry
//!
//! [`server::A2aServer`] takes `Arc<dyn Pubsub>` (not
//! `Arc<dyn RequestReply>`) because `klieo-core`'s
//! [`klieo_core::RequestReply`] trait is *client-side only*. The
//! server listens on `<app_prefix>.a2a.<agent_id>.rpc` via
//! [`klieo_core::Pubsub::subscribe`] and replies by publishing on a
//! per-request reply subject extracted from message headers. A typed
//! server-side trait would tighten the API; deferred until a second
//! protocol-server consumer exists.

pub mod auth;
#[cfg(feature = "conformance")]
pub mod conformance;
pub mod envelope;
pub mod error;
pub mod handler;
pub mod server;
pub mod task_store;
pub mod types;

#[cfg(any(feature = "test-fixtures", test))]
pub use auth::AllowAnonymous;
pub use auth::{AuthError, Authenticator, BearerTokenAuthenticator, Identity, RequestContext};
#[cfg(feature = "conformance")]
pub use conformance::{run_conformance_suite, CaseStatus, ConformanceCase, ConformanceReport};
pub use envelope::{A2aHeaders, A2aMethod, JsonRpcError, JsonRpcRequest, JsonRpcResponse};
pub use error::A2aError;
pub use handler::A2aHandler;
#[cfg(any(test, feature = "test-fixtures"))]
pub use handler::EchoHandler;
pub use server::A2aServer;
pub use task_store::A2aTaskStore;
pub use types::{
    AgentCapabilities, AgentCard, AgentCardSignature, AgentInterface, AgentProvider, AgentSkill,
    Artifact, CancelTaskParams, DeletePushNotificationConfigParams, GetExtendedAgentCardParams,
    GetPushNotificationConfigParams, GetTaskParams, ListPushNotificationConfigsParams,
    ListPushNotificationConfigsResult, ListTasksParams, ListTasksResult, Message, Part,
    PushNotificationConfig, PushNotificationConfigParams, Role, SendMessageParams,
    SendMessageResult, SubscribeToTaskParams, Task, TaskStatus,
};