Skip to content

feat: add stdio transport binding #46

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
Ketankhunti wants to merge 17 commits into
base: main
Choose a base branch
from
Open

feat: add stdio transport binding #46

Show file tree
Hide file tree
Changes from 8 commits
Commits
Show all changes
17 commits
Select commit Hold shift + click to select a range
4713797
a2a-stdio: scaffold crate with error types and STDIO transport constant
Ketankhunti Apr 13, 2026
0bf6caa
a2a-stdio: implement LSP-style Content-Length framing module
Ketankhunti Apr 15, 2026
5fef643
a2a-stdio: implement handshake types and negotiation logic
Ketankhunti Apr 15, 2026
242c0d4
a2a-stdio: implement StdioTransport client with true async streaming
Ketankhunti Apr 15, 2026
d6197ef
feat(a2a-stdio): implement StdioServer with macro-based dispatch
Ketankhunti Apr 15, 2026
1c3bd1a
test(a2a-stdio): add end-to-end integration tests
Ketankhunti Apr 15, 2026
1a28864
style(a2a-stdio): fix clippy warnings
Ketankhunti Apr 15, 2026
d2df2dd
chore: update Cargo.lock for a2a-stdio crate
Ketankhunti Apr 15, 2026
2ab6d45
fix(a2a-stdio): handle malformed JSON and stream results gracefully
Ketankhunti Apr 15, 2026
c74e09e
style(a2a-stdio): apply rustfmt formatting
Ketankhunti Apr 15, 2026
20e7cf1
fix(a2a-stdio): address quick review items
Ketankhunti Apr 18, 2026
af03f94
fix(a2a-stdio): serialize requests and bound handshake/close waits
Ketankhunti Apr 18, 2026
217cf5b
test(a2a-stdio): cover all Transport methods, factory, and error paths
Ketankhunti Apr 18, 2026
52d8754
test(a2a-stdio): cover handshake error branches and server dispatch e…
Ketankhunti Apr 18, 2026
0bd45f3
style(a2a-client): drop useless .into_iter() in rest error parsing
Ketankhunti Apr 18, 2026
877e7fc
style(a2a-stdio): apply rustfmt to client and tests
Ketankhunti Apr 18, 2026
b3ca336
test(a2a-stdio): cover server::serve and streaming reader error paths
Ketankhunti Apr 18, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
159 changes: 89 additions & 70 deletions Cargo.lock
View file
Open in desktop

Large diffs are not rendered by default.

2 changes: 2 additions & 0 deletions Cargo.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@ members = [
"a2a-pb",
"a2a-grpc",
"a2a-slimrpc",
"a2a-stdio",
"a2acli",
"examples/helloworld",
]
Expand All @@ -25,6 +26,7 @@ a2a-server = { package = "a2a-server-lf", path = "a2a-server", version = "0.2.6"
a2a-pb = { package = "a2a-pb", path = "a2a-pb", version = "0.1.6" }
a2a-grpc = { package = "a2a-grpc", path = "a2a-grpc", version = "0.1.11" }
a2a-slimrpc = { package = "a2a-slimrpc", path = "a2a-slimrpc", version = "0.1.8" }
a2a-stdio = { package = "agntcy-a2a-stdio", path = "a2a-stdio", version = "0.1.0" }

# Serialization
serde = { version = "1", features = ["derive"] }
Expand Down
26 changes: 26 additions & 0 deletions a2a-stdio/Cargo.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,26 @@
[package]
name = "agntcy-a2a-stdio"
version = "0.1.0"
description = "A2A v1 STDIO transport binding for client and server"
readme = "README.md"
Comment thread
Ketankhunti marked this conversation as resolved.
edition.workspace = true
license.workspace = true
repository.workspace = true
rust-version.workspace = true

[lib]
name = "a2a_stdio"

[dependencies]
a2a = { workspace = true }
a2a-client = { workspace = true }
a2a-server = { workspace = true }
tokio = { workspace = true }
tokio-stream = { workspace = true }
futures = { workspace = true }
async-trait = { workspace = true }
serde = { workspace = true }
serde_json = { workspace = true }
thiserror = { workspace = true }
tracing = { workspace = true }
uuid = { workspace = true }
Loading
Loading