Replace usages of proxy connector with new location

src/invoker/Cargo.toml

@@ -15,6 +15,7 @@ options_schema = ["dep:schemars", "restate_common/options_schema"]
 bytes = { workspace = true }
 bytes-utils = { workspace = true }
 restate_common = { workspace = true, features = ["serde"] }
+restate_hyper_util = { workspace = true }
 drain = { workspace = true }
 futures = { workspace = true }
 hyper = { workspace = true, features = ["http1", "http2", "client", "tcp", "stream", "runtime"] }

src/invoker/src/invoker.rs

@@ -7,8 +7,8 @@ use std::{cmp, panic};
 
 use futures::stream;
 use futures::stream::{PollNext, StreamExt};
-use restate_common::proxy_connector::{Proxy, ProxyConnector};
 use restate_common::types::PartitionLeaderEpoch;
+use restate_hyper_util::proxy_connector::{Proxy, ProxyConnector};
 use restate_journal::raw::{PlainRawEntry, RawEntryCodec};
 use restate_service_metadata::ServiceEndpointRegistry;
 use restate_timer_queue::TimerQueue;

src/meta/Cargo.toml

@@ -33,6 +33,7 @@ schemars = { workspace = true }
 
 # Service discovery and metadata
 restate_common = { workspace = true, features = ["serde"] }
+restate_hyper_util = { workspace = true }
 restate_service_key_extractor = { workspace = true, features = ["json"] }
 restate_service_metadata = { workspace = true, features = ["serde", "serde_schema"] }
 restate_service_protocol = { workspace = true, features = ["discovery"] }

src/meta/src/lib.rs

@@ -4,9 +4,9 @@ mod storage;
 
 use codederror::CodedError;
 use rest_api::MetaRestEndpoint;
-use restate_common::proxy_connector::Proxy;
 use restate_common::retry_policy::RetryPolicy;
 use restate_common::worker_command::WorkerCommandSender;
+use restate_hyper_util::proxy_connector::Proxy;
 use restate_ingress_grpc::ReflectionRegistry;
 use restate_service_key_extractor::KeyExtractorsRegistry;
 use restate_service_metadata::{InMemoryMethodDescriptorRegistry, InMemoryServiceEndpointRegistry};

src/meta/src/service.rs

@@ -7,10 +7,10 @@ use std::future::Future;
 use hyper::http::{HeaderName, HeaderValue};
 use hyper::Uri;
 use prost_reflect::DescriptorPool;
-use restate_common::proxy_connector::Proxy;
 use restate_common::retry_policy::RetryPolicy;
 use restate_errors::{error_it, warn_it};
 use restate_futures_util::command::{Command, UnboundedCommandReceiver, UnboundedCommandSender};
+use restate_hyper_util::proxy_connector::Proxy;
 use restate_ingress_grpc::{ReflectionRegistry, RegistrationError};
 use restate_service_key_extractor::KeyExtractorsRegistry;
 use restate_service_metadata::{

src/service_protocol/Cargo.toml

@@ -12,7 +12,7 @@ default = []
 protocol = []
 message = ["protocol", "dep:restate_common", "dep:bytes-utils", "dep:codederror", "dep:restate_errors", "dep:size", "dep:tracing"]
 codec = ["protocol", "dep:restate_common", "dep:thiserror", "dep:restate_journal", "dep:paste"]
-discovery = ["dep:thiserror", "dep:codederror", "dep:restate_errors", "dep:restate_service_key_extractor", "dep:hyper", "dep:hyper-rustls", "dep:prost-reflect", "dep:restate_common", "dep:restate_service_metadata"]
+discovery = ["dep:thiserror", "dep:codederror", "dep:restate_errors", "dep:restate_service_key_extractor", "dep:hyper", "dep:hyper-rustls", "dep:prost-reflect", "dep:restate_common", "dep:restate_hyper_util", "dep:restate_service_metadata"]
 
 [dependencies]
 bytes = { workspace = true }
@@ -34,6 +34,7 @@ prost-reflect = { workspace = true, optional = true }
 restate_service_metadata = { workspace = true, optional = true }
 codederror = { workspace = true, optional = true }
 restate_errors = { workspace = true, optional = true }
+restate_hyper_util = { workspace = true, optional = true }
 
 size = { version = "0.4.1", optional = true }
 

src/service_protocol/src/discovery.rs

@@ -11,9 +11,9 @@ use prost_reflect::{
     DescriptorError, DescriptorPool, ExtensionDescriptor, FieldDescriptor, Kind, MethodDescriptor,
     ServiceDescriptor,
 };
-use restate_common::proxy_connector::{Proxy, ProxyConnector};
 use restate_common::retry_policy::RetryPolicy;
 use restate_errors::{META0001, META0002, META0003};
+use restate_hyper_util::proxy_connector::{Proxy, ProxyConnector};
 use restate_service_key_extractor::{KeyStructure, ServiceInstanceType};
 use restate_service_metadata::ProtocolType;