implement bidirectional_stream (#2872)

* implement bidirectional_stream

* fix

* add network test

* add network test with duration

* add CI

* fix test command

Author: kmrmt

.github/workflows/unit-test-rust.yaml

@@ -46,6 +46,9 @@ jobs:
       - name: Set Git config
         run: |
           git config --global --add safe.directory ${GITHUB_WORKSPACE}
-      - name: Run tests for Rust / gotestfmt
+      - name: Run tests for qbg / gotestfmt
         run: |
           TEST_RESULT_DIR=${GITHUB_WORKSPACE} make test/rust/qbg
+      - name: Run tests for agent / gotestfmt
+        run: |
+          TEST_RESULT_DIR=${GITHUB_WORKSPACE} make test/rust/agent

Makefile.d/test.mk

@@ -290,6 +290,12 @@ test/cmd:
 	CGO_LDFLAGS="$(TEST_LDFLAGS)" \
 	go test -short -shuffle=on -race -mod=readonly -cover $(ROOTDIR)/cmd/...
 
+.PHONY: test/rust
+## run tests for rust
+test/rust: \
+	test/rust/qbg \
+	test/rust/agent
+
 .PHONY: test/rust/qbg
 ## run tests for qbg
 test/rust/qbg:
@@ -300,6 +306,11 @@ test/rust/qbg:
 	cargo test --manifest-path rust/Cargo.toml --package qbg --lib -- tests::test_index --exact --show-output
 	rm -rf rust/libs/algorithms/qbg/index/
 
+.PHONY: test/rust/agent
+## run tests for agent
+test/rust/agent:
+	cargo test --manifest-path rust/Cargo.toml --package agent -- handler::common::tests --show-output
+
 .PHONY: test/hack
 ## run tests for hack
 test/hack:

rust/Cargo.lock

@@ -27,6 +27,7 @@ anyhow = "1.0.95"
 cargo = "0.81.0"
 config = "0.14.0"
 flexi_logger = "0.29"
+futures = "0.3.31"
 log = "0.4"
 prost = "0.13.4"
 prost-types = "0.13.4"
@@ -35,3 +36,7 @@ tokio = { version = "1.43.0", features = ["full"] }
 tokio-stream = { version = "0.1.17", features = ["full"] }
 tonic = "0.12.3"
 tonic-types = "0.12.3"
+
+[dev-dependencies]
+bytes = "1.10.0"
+http-body = "1.0.1"