Rebase

restatedev · May 16, 2024 · bfcecc5 · bfcecc5
1 parent 4dc237a
commit bfcecc5
Show file tree

Hide file tree

Showing 3 changed files with 1 addition and 4 deletions.
diff --git a/crates/ingress-dispatcher/src/dispatcher.rs b/crates/ingress-dispatcher/src/dispatcher.rs
@@ -20,8 +20,7 @@ use restate_bifrost::Bifrost;
 use restate_core::metadata;
 use restate_core::network::MessageHandler;
 use restate_node_protocol::codec::Targeted;
-use restate_node_protocol::ingress::{IngressCorrelationId, IngressMessage};
-use restate_node_protocol::RpcMessage;
+use restate_node_protocol::ingress::IngressMessage;
 use restate_storage_api::deduplication_table::DedupInformation;
 use restate_types::identifiers::{InvocationId, PartitionKey, WithPartitionKey};
 use restate_types::ingress::InvocationResponseCorrelationIds;

diff --git a/crates/ingress-dispatcher/src/lib.rs b/crates/ingress-dispatcher/src/lib.rs
@@ -11,7 +11,6 @@
 use bytes::Bytes;
 use bytestring::ByteString;
 use restate_core::metadata;
-pub use restate_node_protocol::ingress::IngressCorrelationId;
 use restate_schema_api::subscription::{EventReceiverServiceType, Sink, Subscription};
 use restate_types::identifiers::{
     partitioner, IdempotencyId, InvocationId, PartitionKey, ServiceId, WithPartitionKey,

diff --git a/crates/node-protocol/src/ingress.rs b/crates/node-protocol/src/ingress.rs
@@ -13,7 +13,6 @@ use serde::{Deserialize, Serialize};
 
 use crate::common::TargetName;
 use crate::define_message;
-use crate::RpcMessage;
 
 #[derive(
     Debug,