Make a crate of grpc_stream

rust/Cargo.toml

@@ -1,7 +1,14 @@
 [workspace]
 resolver = "2"
 
-members = ["indexer-metrics", "moving-average", "processor", "server-framework"]
+members = [
+    "aptos-indexer-transaction-stream",
+    "indexer-metrics",
+    "moving-average",
+    "processor",
+    "server-framework",
+    "transaction-filter",
+]
 
 [workspace.package]
 authors = ["Aptos Labs <[email protected]>"]
@@ -16,6 +23,8 @@ rust-version = "1.75"
 processor = { path = "processor" }
 server-framework = { path = "server-framework" }
 aptos-moving-average = { path = "moving-average" }
+aptos-indexer-transaction-stream = { path = "aptos-indexer-transaction-stream" }
+transaction-filter = { path = "transaction-filter" }
 
 ahash = { version = "0.8.7", features = ["serde"] }
 anyhow = "1.0.62"

rust/aptos-indexer-transaction-stream/Cargo.toml

@@ -0,0 +1,30 @@
+[package]
+name = "aptos-indexer-transaction-stream"
+version = "0.1.0"
+
+# Workspace inherited keys
+authors = { workspace = true }
+edition = { workspace = true }
+homepage = { workspace = true }
+license = { workspace = true }
+publish = { workspace = true }
+repository = { workspace = true }
+rust-version = { workspace = true }
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+aptos-moving-average = { workspace = true }
+aptos-protos = { workspace = true }
+bigdecimal = { workspace = true }
+chrono = { workspace = true }
+futures-util = { workspace = true }
+itertools = { workspace = true }
+kanal = { workspace = true }
+once_cell = { workspace = true }
+prometheus = { workspace = true }
+prost = { workspace = true }
+tokio = { workspace = true }
+tonic = { workspace = true }
+tracing = { workspace = true }
+transaction-filter = { workspace = true }
+url = { workspace = true }

rust/aptos-indexer-transaction-stream/src/lib.rs

@@ -0,0 +1,2 @@
+pub mod transaction_stream;
+pub mod utils;