mirror of
https://github.com/ruvnet/RuVector.git
synced 2026-05-25 23:24:03 +00:00
6c224b809c
New subcrate at crates/rvAgent/rvagent-a2a/ implementing all four
ADR-159 milestones (M1-M4) plus the rvagent-cli a2a subcommand.
Library scope (~7500 LoC + 1500 tests):
- Core types: AgentCard, Task, Message, Part, Artifact, TaskSpec, plus
TaskStatusUpdateEvent / TaskArtifactUpdateEvent SSE events
- Server: axum-based JSON-RPC 2.0 with tasks/{send, get, cancel,
sendSubscribe, resubscribe, pushNotification/{set,get}}; bounded
broadcast; SSE replay from task history with Last-Event-Id support
- Client: discovery with ETag cache + signature verification, retry
with exponential backoff, streaming
- Identity (r2): AgentID = SHAKE-256(ed25519_pubkey), JCS-canonical
signed AgentCards, verify-on-discover
- Policy (r2): TaskPolicy + PolicyGuard with concurrency tickets,
per-task max_tokens / max_cost_usd / max_duration_ms / allowed_skills
- Executor (r2): unified Local(TaskRunner) / Remote(Peer) abstraction
- Artifacts (r2+r3): #[non_exhaustive] ArtifactKind with
Text/StructuredJson/VectorRef/RuLakeWitness/Raw + version negotiation
- Routing (r2): PeerSelector trait + 4 stock impls (CheapestUnderLatency,
LowestLatency, RoundRobin, CapabilityMatch) + ChainedSelector +
PeerRegistry with 3-strike circuit breaker; live peer-forwarding
wired through tasks/send dispatch chain
- Budget (r3): GlobalBudget + BudgetLedger with parking_lot::Mutex,
100ms lazy eviction, uncapped fast-path (442 M ops/s), Shed/Queue
overflow policies (custom deserializer accepts both bare-string and
tagged-table TOML forms)
- Context (r3): TaskContext with W3C trace_id, parent_task_id, depth,
visited_agents propagated as metadata.ruvector.context
- Recursion guard (r3): RecursionPolicy depth + revisit cycle detection
- Config (r3): TOML loader for routing/budget/policy/recursion sections
- Push webhooks (M4): HMAC-SHA256 + optional Ed25519 (feature-gated),
3-attempt exponential retry on 5xx, no-retry on 4xx, registry per
task_id
Dispatch chain (server/json_rpc.rs tasks/send):
budget → recursion → policy → router (peer-forward) → local executor
CLI integration (crates/rvAgent/rvagent-cli/src/a2a.rs):
rvagent a2a serve [--bind] [--config] [--generate-key]
rvagent a2a discover <URL>
rvagent a2a send-task <URL> --skill <id> [--input ...]
End-to-end smoke test in tests/a2a_cli.rs spawns the binary, asserts
serve → discover → send-task roundtrip with signed AgentCard.
Verification:
- 136/136 tests passing on default features
- 137/137 with `--features ed25519-webhooks`
- Three-point ADR-159 acceptance test all green:
- executor_remote: local ≡ remote PASS
- witness_handoff: 765-byte body for 100k-vector payload (≤ 2 KiB)
- dispatch_order + recursion_guard + budget_guard: cost bounded PASS
Workspace member registration for rvagent-a2a + examples/a2a-swarm
included in this commit.
Refs: ADR-159
Co-Authored-By: claude-flow <ruv@ruv.net>
|
||
|---|---|---|
| .. | ||
| src | ||
| tests | ||
| Cargo.toml | ||