[Invoker] Wire up ReservedResource to replace the old Permit

Cargo.toml

@@ -60,7 +60,6 @@ restate-futures-util = { path = "crates/futures-util" }
 restate-hyper-uds = { path = "crates/hyper-uds" }
 restate-ingress-http = { path = "crates/ingress-http" }
 restate-ingress-kafka = { path = "crates/ingress-kafka" }
-restate-invoker-api = { path = "crates/invoker-api" }
 restate-invoker-impl = { path = "crates/invoker-impl" }
 restate-local-cluster-runner = { path = "crates/local-cluster-runner" }
 restate-log-server = { path = "crates/log-server" }

crates/bifrost/Cargo.toml

@@ -67,7 +67,7 @@ restate-storage-api = { workspace = true }
 restate-test-util = { workspace = true }
 restate-types = { workspace = true, features = ["test-util"] }
 restate-wal-protocol = { workspace = true }
-restate-invoker-api = { workspace = true }
+restate-worker-api = { workspace = true }
 
 bytestring = { workspace = true }
 criterion = { workspace = true, features = ["async_tokio"] }

crates/bifrost/benches/replicated_loglet_serde.rs

@@ -25,7 +25,6 @@ use rand::{Rng, RngCore, random};
 use restate_bifrost::InputRecord;
 use restate_core::network::protobuf::network::message::Body;
 use restate_core::network::protobuf::network::{Datagram, Message, datagram};
-use restate_invoker_api::{Effect, EffectKind};
 use restate_storage_api::deduplication_table::{DedupInformation, EpochSequenceNumber, ProducerId};
 use restate_types::identifiers::{InvocationId, LeaderEpoch, PartitionProcessorRpcRequestId};
 use restate_types::invocation::{
@@ -41,6 +40,7 @@ use restate_types::net::{RpcRequest, Service};
 use restate_types::time::MillisSinceEpoch;
 use restate_types::{GenerationalNodeId, RestateVersion};
 use restate_wal_protocol::{Command, Destination, Envelope};
+use restate_worker_api::invoker::{Effect, EffectKind};
 
 #[cfg(not(target_env = "msvc"))]
 #[global_allocator]