Invoker

Cargo.toml

@@ -18,7 +18,7 @@ anyhow = "1.0.68"
 bytes = { version = "1.3", features = ["serde"] }
 bytestring = { version = "1.2", features = ["serde"] }
 bytes-utils = "0.1.3"
-clap = { version = "4.0", features = ["derive", "env"] }
+clap = { version = "4.1", features = ["derive", "env"] }
 futures = "0.3.25"
 futures-sink = "0.3.25"
 futures-util = "0.3.25"
@@ -31,9 +31,11 @@ prost-build = "0.11"
 serde = { version = "1.0", features = ["derive"] }
 thiserror = "1.0"
 tracing = "0.1"
+tracing-subscriber = { version = "0.3", features = ["env-filter"] }
 tokio = { version = "1.24", features = ["rt-multi-thread", "signal", "macros"] }
 tokio-stream = "0.1.11"
 tokio-util = "0.7.4"
+tonic = { version = "0.8.3", default-features = false }
 opentelemetry = { version = "0.18" }
 uuid = { version = "1.3.0", features = ["v7", "serde"] }
 
@@ -49,6 +51,7 @@ service_key_extractor = { path = "src/service_key_extractor" }
 service_protocol = { path = "src/service_protocol" }
 storage_api = {path = "src/storage_api"}
 storage_rocksdb = { path = "src/storage_rocksdb" }
+test_utils = { path = "src/test_utils" }
 tracing_instrumentation = { path = "src/tracing_instrumentation" }
 worker = { path = "src/worker" }
 
@@ -61,5 +64,4 @@ panic = "abort"
 
 [profile.dev]
 # Let's be defensive and abort on every panic
-panic = "abort"
-
+panic = "abort"

deny.toml

@@ -13,6 +13,7 @@ unlicensed = "deny"
 allow = [
     "MIT",
     "Apache-2.0",
+    "BSD-2-Clause",
     "BSD-3-Clause",
     "ISC"
 ]
@@ -50,6 +51,14 @@ multiple-versions = "deny"
 wildcards = "allow"
 highlight = "all"
 allow = []
+skip = [
+    # It's ok to ignore these dependencies, as they're resolved but we never use them,
+    # since we don't target Windows, nor HermitCore. We have a couple of transitive dependencies
+    # requiring windows and hermit syscalls with conflicting version.
+    # Also see https://github.com/rust-lang/cargo/issues/1197
+    { name = "windows-sys" },
+    { name = "hermit-abi" },
+]
 deny = [
     # Each entry the name of a crate and a version range. If version is
     # not specified, all versions will be matched.

src/invoker/Cargo.toml

@@ -15,16 +15,23 @@ bytes-utils = { workspace = true }
 common = { workspace = true }
 drain = { workspace = true }
 futures = { workspace = true }
+hyper = { version = "0.14.23", features = ["http1", "http2", "client", "tcp", "stream", "runtime"] }
+hyper-tls = "0.5"
+h2 = { version = "0.3.15", features = ["unstable"] }
 paste = { workspace = true }
 prost = { workspace = true }
 thiserror = { workspace = true }
 tokio = { workspace = true }
 tokio-util = { workspace = true }
+tonic = { workspace = true }
 tracing = { workspace = true }
 opentelemetry = { workspace = true }
+opentelemetry-http = "0.7"
 
 journal = { workspace = true }
 service_protocol = { workspace = true }
 
 [dev-dependencies]
 uuid = { workspace = true }
+test_utils = { workspace = true }
+tracing-subscriber = { workspace = true }