The agent team runs 102 E2E tests across 8 test modules — the figure a plain cargo run -p agent-team reports, because WebSocket, gRPC, Axum, SQLite, signing and OTel are the example's default features. --no-default-features compiles all six out and runs 87. All pass in ~6 seconds.
# Test Transport What it exercises
1 sync-jsonrpc-send JSON-RPC Synchronous SendMessage, artifact count 2 streaming-jsonrpc JSON-RPC SSE streaming, event ordering, artifact metadata 3 sync-rest-send REST REST synchronous path 4 streaming-rest REST REST SSE streaming 5 build-failure-path REST TaskState::Failed lifecycle6 get-task JSON-RPC GetTask retrieval by ID7 list-tasks JSON-RPC ListTasks with pagination token8 push-config-crud REST Push config create/get/list/delete/verify lifecycle 9 multi-part-message JSON-RPC Text + data parts, HealthMonitor agent-to-agent 10 agent-to-agent REST Coordinator delegates to CodeAnalyzer
# Test Transport What it exercises
11 full-orchestration REST Coordinator -> CodeAnalyzer + BuildMonitor fan-out 12 health-orchestration REST Coordinator -> HealthMonitor -> all agents (3-level) 13 message-metadata JSON-RPC Request metadata passthrough 14 cancel-task REST Mid-stream cancellation via CancelTask 15 get-nonexistent-task JSON-RPC Error: TaskNotFound (-32001) 16 pagination-walk JSON-RPC ListTasks page_size=1, no duplicates17 agent-card-discovery REST resolve_agent_card on REST endpoint18 agent-card-jsonrpc JSON-RPC resolve_agent_card on JSON-RPC endpoint19 push-not-supported JSON-RPC Error: NotSupported (-32003) for no-push agent 20 cancel-completed REST Error: InvalidState for completed task cancel
# Test Transport What it exercises
21 cancel-nonexistent REST Error: TaskNotFound for fake task ID 22 return-immediately REST return_immediately client config propagation23 concurrent-requests JSON-RPC 5 parallel requests to same agent 24 empty-parts-rejected JSON-RPC Validation: empty message parts 25 get-task-rest REST GetTask via REST transport26 list-tasks-rest REST ListTasks via REST transport27 push-crud-jsonrpc JSON-RPC Push config CRUD via JSON-RPC (HealthMonitor) 28 resubscribe-rest REST SubscribeToTask concurrent resubscription29 metrics-nonzero — All 4 agents have non-zero request counts 30 error-metrics-tracked JSON-RPC Error metric increments on invalid request
# Test Transport What it exercises
31 high-concurrency JSON-RPC 20 parallel requests to same agent 32 mixed-transport Both REST + JSON-RPC simultaneously 33 context-continuation JSON-RPC Two messages with same context_id 34 large-payload JSON-RPC 64KB text payload processing 35 stream-with-get-task REST GetTask during active SSE stream36 push-delivery-e2e REST Push config set during streaming task 37 list-status-filter JSON-RPC ListTasks with TaskState::Completed filter38 store-durability JSON-RPC Create 5 tasks, retrieve all 5 39 queue-depth-metrics — Cumulative metrics tracking (>20 total requests) 40 event-ordering JSON-RPC Working -> artifacts -> Completed sequence
# Test Transport What it exercises
41 card-url-correct JSON-RPC Agent card URL matches actual bound address 42 card-skills-valid Both All 4 agent cards have name, description, version, skills, interface 43 push-list-regression JSON-RPC ListTaskPushNotificationConfigs via JSON-RPC (regression for bug 11)44 push-event-classify REST Webhook event classifier uses correct field names 45 resubscribe-jsonrpc JSON-RPC SubscribeToTask via JSON-RPC transport46 multiple-artifacts JSON-RPC Multiple artifacts per task (>=2) 47 concurrent-streams REST 5 parallel SSE streams on same agent 48 list-context-filter JSON-RPC ListTasks with context_id filter49 file-parts JSON-RPC Part::file_bytes with base64 content50 history-length JSON-RPC history_length configuration via builder
# Test Transport What it exercises
51 ws-send-message WebSocket JSON-RPC SendMessage over WebSocket (feature-gated) 52 ws-streaming WebSocket SendStreamingMessage with multi-frame streaming (feature-gated)53 tenant-isolation JSON-RPC Different tenants cannot see each other's tasks 54 tenant-id-independence Direct store Same task ID in different tenants doesn't collide 55 tenant-count Direct store TenantAwareInMemoryTaskStore::tenant_count() tracking56 grpc-send-message gRPC SendMessage over the gRPC transport (feature-gated)57 grpc-streaming gRPC SendStreamingMessage over gRPC transport (feature-gated)58 grpc-get-task gRPC GetTask after SendMessage over gRPC (feature-gated)
Note: Tests 51-52 need the websocket feature and tests 56-58 the grpc feature — both
on by default. With --no-default-features, add --features websocket / --features grpc.
# Test Category What it exercises
61 batch-single-element Batch JSON-RPC Single-element batch [{...}] with SendMessage 62 batch-multi-request Batch JSON-RPC Multi-request batch: SendMessage + GetTask 63 batch-empty Batch JSON-RPC Empty batch [] is answered Invalid Request (-32600) 64 batch-mixed Batch JSON-RPC Mixed valid/invalid requests in batch 65 batch-streaming-rejected Batch JSON-RPC SendStreamingMessage in batch returns error66 batch-subscribe-rejected Batch JSON-RPC SubscribeToTask in batch returns error67 real-auth-rejection Auth Interceptor rejects unauthenticated requests 68 extended-agent-card Cards GetExtendedAgentCard via JSON-RPC68b extended-card-requires-auth Cards Extended card refused without an authenticating interceptor (spec §13.3) 69 dynamic-agent-card Cards DynamicAgentCardHandler runtime card generation70 agent-card-caching Caching ETag, If-None-Match, 304 Not Modified 71 backpressure-lagged Streaming Slow reader receives a stream_lagged error, not a silent gap (capacity=2) 72 push-global-limit Push config Global push config limit enforcement (DoS prevention) 73 webhook-url-scheme Push config Rejects non-HTTP webhook URL schemes (ftp://, file://) 74 combined-filter ListTasks Combined status + context_id filtering 75 latency-metrics Metrics Verifies on_request() callback fires 76 timeout-retryable Retry Timeout errors are classified as retryable 77 concurrent-cancels Stress 10 parallel cancels of non-existent tasks 78 stale-page-token Pagination Graceful handling of invalid page tokens 79 agent-card-signing Signing ES256 key generation, JWS sign/verify, tamper detection (signing feature)
SDK Feature Tests exercising it
AgentExecutor trait1-5, 9-14, 22, 31-36, 38, 40, 46, 49, 51-52 JSON-RPC dispatch 1-2, 6-7, 9, 13, 15-16, 18-19, 23-24, 27, 29-34, 37-43, 45-46, 48-50, 53 REST dispatch 3-5, 8, 10-12, 14, 17, 20-22, 25-26, 28, 32, 35-36, 44, 47 WebSocket dispatch 51, 52 SSE streaming 2, 4, 14, 28, 35-36, 40, 44, 45, 47 WebSocket streaming 52 GetTask6, 14, 25, 35 ListTasks + pagination7, 16, 26, 37, 48, 50 CancelTask14, 20, 21 Push config CRUD 8, 19, 27, 36, 43 Agent card discovery 17, 18, 41, 42 ServerInterceptorAll tests (audit interceptor on every agent) Metrics hooks29, 30, 39 return_immediately22 CancellationToken14 Error handling 15, 19, 20, 21, 24, 30 Multi-agent orchestration 10, 11, 12 Concurrent requests 23, 31, 32, 47 SubscribeToTask resubscribe28, 45 Multiple artifacts 46 File parts (binary) 49 History length config 50 Context ID filtering 33, 48 Multi-tenancy 53, 54, 55 TenantAwareInMemoryTaskStore53, 54, 55 TenantContext::scope54, 55 Batch JSON-RPC 61, 62, 63, 64, 65, 66 Auth rejection (interceptor) 67 GetExtendedAgentCard68 DynamicAgentCardHandler69 Agent card HTTP caching (ETag/304) 70 Agent card signing (JWS/ES256) 79 Backpressure / Lagged events 71 Push config global limit 72 Webhook URL scheme validation 73 Combined status+context filter 74 Metrics callbacks29, 30, 39, 75 Timeout retryability (Bug #32) 76 Concurrent cancel stress 77 Stale page token handling 78 Agent card signing (JWS/ES256) 79 State transition validation 81 Executor error propagation 82 Streaming event completeness 83 Oversized metadata rejection 84 Artifact content correctness 85 Rapid sequential throughput 87 Cancel terminal-state task 88 Agent card semantic validation 89 A2aRouter (Axum adapter)93, 94, 95, 98 SqliteTaskStore96, 98 SqlitePushConfigStore97 Axum + SQLite combined stack 98
# Test Transport What it exercises
81 state-transition-order JSON-RPC Validates streaming state transitions are monotonically forward 82 executor-error-failed REST Executor error produces Failed state with error metadata 83 stream-completeness JSON-RPC Working→Artifact→Completed event sequence verified completely 84 oversized-metadata JSON-RPC Rejects messages with metadata exceeding 1 MiB limit 85 artifact-content JSON-RPC Artifact text contains actual analysis, not just present 86 get-task-history JSON-RPC GetTask with history_length returns history data 87 rapid-sequential JSON-RPC 30 sequential requests without degradation 88 cancel-already-failed REST Cancel on terminal-state task handled gracefully 89 card-semantic-valid JSON-RPC Agent card fields (name, version, skills, interfaces) validated 90 get-after-stream JSON-RPC GetTask reflects streaming state (documents Bug #38 race)
# Test Feature What it exercises
93 axum-send-message axumA2aRouter → SendMessage → Completed task94 axum-streaming axumA2aRouter SSE streaming with event completeness95 axum-agent-card axumAgent card discovery via /.well-known/agent-card.json through Axum 96 sqlite-task-store sqliteSqliteTaskStore full lifecycle: send→get→list persistence97 sqlite-push-config sqliteSqlitePushConfigStore CRUD: set→list→delete98 axum-sqlite-combo axum+sqliteCombined production stack: Axum server + SQLite stores
In addition to the 102 agent-team E2E tests (87 with --no-default-features), the SDK includes dedicated integration test suites:
Suite Location Tests What it covers
TLS/mTLS crates/a2a-protocol-client/tests/tls_integration_tests.rs7 Client cert validation, SNI hostname verification, unknown CA rejection, mutual TLS WebSocket server crates/a2a-protocol-server/tests/websocket_tests.rs9 Send/stream, error handling, ping/pong, connection reuse, close frames Memory & load stress crates/a2a-protocol-server/tests/stress_tests.rs5 200 concurrent requests, sustained load (500 requests/10 waves), eviction under load, multi-tenant isolation (10×50), rapid connect/disconnect
All previously uncovered features now have E2E test coverage. Agent card signing is covered by test 79 (#[cfg(feature = "signing")]).