a2a-rs 0.8.2

Rust implementation of the Agent-to-Agent (A2A) Protocol
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

//! Ports (interfaces) for the A2A protocol
//!
//! Ports define the interfaces that our application needs, independent of implementation details.
//! They represent the "what" - what operations our application needs to perform.
//!
//! ## Organization
//!
//! - **Business capability ports**: Focused interfaces for specific business capabilities
//!   - `authenticator`: Authentication and authorization
//!   - `message_handler`: Message processing
//!   - `task_manager`: Task lifecycle management  
//!   - `notification_manager`: Push notifications
//!   - `streaming_handler`: Real-time updates
//!   - `event_log`: What a task's stream already said, for resuming it
//!   - `conversation_store`: Durable conversation memory for a context
//!   - `context_state`: The facts an agent keeps about a context, apart from
//!     the transcript
//!   - `request_context`: Who is calling, carried from the transport inward

// Business capability ports (focused domain interfaces)
pub mod authenticator;
pub mod client;
pub mod context_state;
pub mod conversation_store;
pub mod event_log;
pub mod interceptor;
pub mod message_handler;
pub mod notification_manager;
pub mod request_context;
pub mod retention;
pub mod streaming_handler;
pub mod task_manager;

// Re-export business capability interfaces
pub use authenticator::{
    AuthContext, AuthContextExtractor, AuthPrincipal, Authenticator, CompositeAuthenticator,
};
pub use client::{StreamEvent, StreamItem, Transport};
pub use context_state::{AsyncContextStateStore, NoContextState};
pub use conversation_store::{
    AsyncConversationStore, AsyncConversationStoreExt, NoConversationMemory,
};
pub use event_log::{AsyncEventLog, Replay};
pub use interceptor::{CallContext, CallInterceptor, CallSide, run_after, run_before};
pub use message_handler::AsyncMessageHandler;
pub use notification_manager::{
    AsyncNotificationManager, AsyncNotificationManagerExt, AsyncPushNotifier, NoopPushNotifier,
};
pub use request_context::RequestContext;
pub use retention::AsyncRetention;
pub use streaming_handler::{
    AsyncStreamingHandler, SeqEvent, Subscriber as StreamingSubscriber, UpdateEvent,
};
pub use task_manager::{
    AsyncTaskLifecycle, AsyncTaskLifecycleExt, AsyncTaskQuery, AsyncTaskVersioning,
};