diff --git a/Cargo.toml b/Cargo.toml
index 9f1dac8..a7ee367 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -12,9 +12,10 @@ publish = false
 [dependencies]
 # The version requirements of these must match the version requirement of protoc-rs used to
 # generate the code
-tonic = "0.13"
-prost = "0.13"
-prost-types = "0.13"
+tonic = "0.14"
+prost = "0.14"
+tonic-prost = "0.14"
+prost-types = "0.14"
 
 [lib]
 path = "rust/lib.rs"
diff --git a/Makefile b/Makefile
index 301a638..dbb8ba1 100644
--- a/Makefile
+++ b/Makefile
@@ -57,7 +57,7 @@ clean:
 PROTOC_VERSION := 29.2
 PROTOC_GEN_GO_VERSION := 1.36.2
 PROTOC_GEN_GO_GRPC_VERSION := 1.5.1
-PROTOC_RS_VERSION := 0.5.0
+PROTOC_RS_VERSION := 0.6.0
 
 # Checks the versions of the installed tools, making sure they are what we expect
 .PHONY: check-tools
diff --git a/rust/beegfs.rs b/rust/beegfs.rs
index b7c9408..816b1ee 100644
--- a/rust/beegfs.rs
+++ b/rust/beegfs.rs
@@ -2,7 +2,7 @@
 /// The "legacy" BeeGFS numeric Id-NodeType combination that can be used to identify an entity like
 /// a node or target. Because each entity type has its own id space (meaning a combination is not
 /// globally unique), the entity type must be known in addition to uniquely identify an entity.
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct LegacyId {
     /// BeeGFS numeric id.
     /// Required, 0 is invalid.
@@ -17,12 +17,13 @@ pub struct LegacyId {
 /// Contains all identifiers used to uniquely identify an entity like a node or a target. Mainly
 /// meant for communication with management as management has access to all the information. This
 /// message should be used in two ways:
-/// 1) In a request message (to the management),  only _one_ of the fields needs to be set (each is
-/// enough to identify an entity (legacy_id with extra knowledge).
-/// 2) In a response message (from the management), _all_ fields should be set. The request processor
-/// should have all info about an entity available. If that isn't the case, leaving fields empty is
-/// allowed.
-#[derive(Clone, PartialEq, ::prost::Message)]
+///
+/// 1. In a request message (to the management),  only *one* of the fields needs to be set (each is
+///    enough to identify an entity (legacy_id with extra knowledge).
+/// 1. In a response message (from the management), *all* fields should be set. The request processor
+///    should have all info about an entity available. If that isn't the case, leaving fields empty is
+///    allowed.
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct EntityIdSet {
     /// The global, unique entity id. Identifies an entity from all types without any additional
     /// context.
@@ -32,7 +33,7 @@ pub struct EntityIdSet {
     /// The user definable globally unique alias of an entity. Identifies an entity from all types
     /// without any additional context.
     /// Optional or Required, depending on the use case. Aliases must start with letter and contain
-    /// only \[a-zA-Z0-9_-.\].
+    /// only \[a-zA-Z0-9\_-.\].
     #[prost(string, optional, tag = "2")]
     pub alias: ::core::option::Option<::prost::alloc::string::String>,
     /// The "legacy" style numeric Id-NodeType combination. The entity type must be known in addition
diff --git a/rust/beeremote.rs b/rust/beeremote.rs
index 7fcbd10..a1533d4 100644
--- a/rust/beeremote.rs
+++ b/rust/beeremote.rs
@@ -106,7 +106,7 @@ pub struct JobRequest {
 }
 /// Nested message and enum types in `JobRequest`.
 pub mod job_request {
-    #[derive(Clone, PartialEq, ::prost::Message)]
+    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
     pub struct GenerationStatus {
         #[prost(enumeration = "generation_status::State", tag = "1")]
         pub state: i32,
@@ -224,7 +224,7 @@ pub struct Job {
 }
 /// Nested message and enum types in `Job`.
 pub mod job {
-    #[derive(Clone, PartialEq, ::prost::Message)]
+    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
     pub struct Status {
         #[prost(enumeration = "State", tag = "1")]
         pub state: i32,
@@ -472,7 +472,7 @@ pub struct UpdateJobsResponse {
 /// With the MapStore used as a wrapper around the BadgerDB k/v store we don't
 /// have to duplicate all information and can use the Metadata field of the
 /// MapStore to create references to data stored in other MapStores.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct GetJobsRequest {
     #[prost(bool, tag = "4")]
     pub include_work_requests: bool,
@@ -493,14 +493,14 @@ pub struct GetJobsRequest {
 }
 /// Nested message and enum types in `GetJobsRequest`.
 pub mod get_jobs_request {
-    #[derive(Clone, PartialEq, ::prost::Message)]
+    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
     pub struct QueryIdAndPath {
         #[prost(string, tag = "1")]
         pub job_id: ::prost::alloc::string::String,
         #[prost(string, tag = "2")]
         pub path: ::prost::alloc::string::String,
     }
-    #[derive(Clone, PartialEq, ::prost::Oneof)]
+    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
     pub enum Query {
         /// Returns at most one Job.
         #[prost(message, tag = "1")]
@@ -528,21 +528,21 @@ pub struct UpdateWorkRequest {
 }
 /// We use our own empty message instead of google.protobuf.Empty to ensure backwards
 /// compatibility should we need to add fields in the future.
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct UpdateWorkResponse {}
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct GetRstConfigRequest {}
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct GetRstConfigResponse {
     #[prost(message, repeated, tag = "1")]
     pub rsts: ::prost::alloc::vec::Vec<super::flex::RemoteStorageTarget>,
 }
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct GetStubContentsRequest {
     #[prost(string, tag = "1")]
     pub path: ::prost::alloc::string::String,
 }
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct GetStubContentsResponse {
     #[prost(uint32, optional, tag = "1")]
     pub rst_id: ::core::option::Option<u32>,
@@ -657,7 +657,7 @@ pub mod bee_remote_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/beeremote.BeeRemote/SubmitJob",
             );
@@ -681,7 +681,7 @@ pub mod bee_remote_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/beeremote.BeeRemote/UpdatePaths",
             );
@@ -705,7 +705,7 @@ pub mod bee_remote_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/beeremote.BeeRemote/UpdateJobs",
             );
@@ -729,7 +729,7 @@ pub mod bee_remote_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/beeremote.BeeRemote/GetJobs",
             );
@@ -762,7 +762,7 @@ pub mod bee_remote_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/beeremote.BeeRemote/UpdateWork",
             );
@@ -786,7 +786,7 @@ pub mod bee_remote_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/beeremote.BeeRemote/GetRSTConfig",
             );
@@ -810,7 +810,7 @@ pub mod bee_remote_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/beeremote.BeeRemote/GetStubContents",
             );
@@ -834,7 +834,7 @@ pub mod bee_remote_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/beeremote.BeeRemote/GetCapabilities",
             );
@@ -1041,7 +1041,7 @@ pub mod bee_remote_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = SubmitJobSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1087,7 +1087,7 @@ pub mod bee_remote_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = UpdatePathsSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1132,7 +1132,7 @@ pub mod bee_remote_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = UpdateJobsSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1178,7 +1178,7 @@ pub mod bee_remote_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = GetJobsSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1223,7 +1223,7 @@ pub mod bee_remote_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = UpdateWorkSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1268,7 +1268,7 @@ pub mod bee_remote_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = GetRSTConfigSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1313,7 +1313,7 @@ pub mod bee_remote_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = GetStubContentsSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1361,7 +1361,7 @@ pub mod bee_remote_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = GetCapabilitiesSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
diff --git a/rust/beewatch.rs b/rust/beewatch.rs
index a52904a..442bd95 100644
--- a/rust/beewatch.rs
+++ b/rust/beewatch.rs
@@ -4,7 +4,7 @@
 /// API. Those should only affect the serialization format between the meta and watch services, and
 /// should adhere to standard protocol buffer best practices. Notably minor updates should be
 /// additive and not remove or change the meaning of existing fields.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct Event {
     #[prost(uint64, tag = "1")]
     pub seq_id: u64,
@@ -20,7 +20,7 @@ pub struct Event {
 }
 /// Nested message and enum types in `Event`.
 pub mod event {
-    #[derive(Clone, PartialEq, ::prost::Oneof)]
+    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
     pub enum EventData {
         #[prost(message, tag = "11")]
         V1(super::V1Event),
@@ -29,7 +29,7 @@ pub mod event {
     }
 }
 /// The v1 event format is the legacy format from BeeGFS v7.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct V1Event {
     #[prost(enumeration = "v1_event::Type", tag = "1")]
     pub r#type: i32,
@@ -121,7 +121,7 @@ pub mod v1_event {
     }
 }
 /// The v2 event format was introduced in BeeGFS v8.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct V2Event {
     #[prost(enumeration = "v2_event::Type", tag = "1")]
     pub r#type: i32,
@@ -236,7 +236,7 @@ pub mod v2_event {
     }
 }
 /// Response messages allow the subscribers to acknowledge events they have processed and request a graceful shutdown.
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct Response {
     #[prost(uint64, tag = "1")]
     pub completed_seq: u64,
@@ -349,7 +349,7 @@ pub mod subscriber_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/beewatch.Subscriber/ReceiveEvents",
             );
@@ -492,7 +492,7 @@ pub mod subscriber_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = ReceiveEventsSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
diff --git a/rust/flex.rs b/rust/flex.rs
index c428e26..d3b34dc 100644
--- a/rust/flex.rs
+++ b/rust/flex.rs
@@ -1,17 +1,17 @@
 // This file is @generated by prost-build.
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct HeartbeatRequest {
     #[prost(bool, tag = "1")]
     pub include_stats: bool,
 }
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct HeartbeatResponse {
     #[prost(bool, tag = "1")]
     pub is_ready: bool,
     #[prost(message, optional, tag = "2")]
     pub node_stats: ::core::option::Option<NodeStats>,
 }
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct NodeStats {
     #[prost(message, optional, tag = "1")]
     pub timestamp: ::core::option::Option<::prost_types::Timestamp>,
@@ -30,7 +30,7 @@ pub struct SubmitWorkResponse {
 }
 /// Used to change the state of a single work request.
 /// The server will respond with a RequestStatus.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct UpdateWorkRequest {
     #[prost(string, tag = "1")]
     pub job_id: ::prost::alloc::string::String,
@@ -89,7 +89,7 @@ pub struct UpdateWorkResponse {
 /// Used to change the state of all work assigned to a particular node. This is typically only used
 /// when initially connecting to a node, or if we want to drain the work assigned to a node if it is
 /// being removed.
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct BulkUpdateWorkRequest {
     #[prost(enumeration = "bulk_update_work_request::NewState", tag = "1")]
     pub new_state: i32,
@@ -139,7 +139,7 @@ pub mod bulk_update_work_request {
 }
 /// This is a bulk operation details about individual work entries is not returned. Instead the
 /// response reflects if all outstanding work was successfully moved to the new state.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct BulkUpdateWorkResponse {
     #[prost(bool, tag = "1")]
     pub success: bool,
@@ -149,7 +149,7 @@ pub struct BulkUpdateWorkResponse {
 /// JobLockedInfo contains require information that must be determined prior to calling a job request for
 /// file. This will be produced by sync's job builder but can be produced anywhere it makes sense such as
 /// in ctl.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct JobLockedInfo {
     /// Indicates the file read-write lock has already been obtained.
     #[prost(bool, tag = "1")]
@@ -251,7 +251,7 @@ pub mod work_request {
     /// A segment indicates what portion of the file a particular worker node should
     /// work on. Segments can be divided into one or more parts, which can be used to
     /// execute the requested operation in parallel if supported by the RST type.
-    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
+    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
     pub struct Segment {
         #[prost(int64, tag = "1")]
         pub offset_start: i64,
@@ -416,7 +416,7 @@ pub struct Work {
 }
 /// Nested message and enum types in `Work`.
 pub mod work {
-    #[derive(Clone, PartialEq, ::prost::Message)]
+    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
     pub struct Status {
         #[prost(enumeration = "State", tag = "1")]
         pub state: i32,
@@ -429,7 +429,7 @@ pub mod work {
     /// divided into one or more parts allowing operations to be executed in
     /// parallel on a worker node. We use a standard part definition for all RST
     /// types. The use of the fields in Part will vary depending on the type.
-    #[derive(Clone, PartialEq, ::prost::Message)]
+    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
     pub struct Part {
         #[prost(int32, tag = "1")]
         pub part_number: i32,
@@ -553,7 +553,7 @@ pub struct UpdateConfigRequest {
     #[prost(message, repeated, tag = "2")]
     pub rsts: ::prost::alloc::vec::Vec<RemoteStorageTarget>,
 }
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct UpdateConfigResponse {
     #[prost(enumeration = "update_config_response::Result", tag = "1")]
     pub result: i32,
@@ -610,7 +610,7 @@ pub mod update_config_response {
         }
     }
 }
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct BeeRemoteNode {
     #[prost(string, tag = "1")]
     pub id: ::prost::alloc::string::String,
@@ -664,7 +664,7 @@ pub struct RemoteStorageTarget {
 }
 /// Nested message and enum types in `RemoteStorageTarget`.
 pub mod remote_storage_target {
-    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
+    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
     pub struct Policies {
         /// If the file size is larger than this, BeeRemote handles creating/finishing the multipart
         /// upload (if applicable) and will assign the job to multiple worker nodes. If the file size
@@ -726,7 +726,7 @@ pub mod remote_storage_target {
     }
     /// Nested message and enum types in `S3`.
     pub mod s3 {
-        #[derive(Clone, PartialEq, ::prost::Message)]
+        #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
         pub struct StorageClass {
             /// Name of the storage class
             #[prost(string, tag = "1")]
@@ -737,7 +737,7 @@ pub mod remote_storage_target {
         }
         /// Nested message and enum types in `StorageClass`.
         pub mod storage_class {
-            #[derive(Clone, PartialEq, ::prost::Message)]
+            #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
             pub struct Archival {
                 #[prost(string, tag = "1")]
                 pub retrieval_tier: ::prost::alloc::string::String,
@@ -765,7 +765,7 @@ pub mod remote_storage_target {
         #[prost(string, tag = "2")]
         pub account: ::prost::alloc::string::String,
     }
-    #[derive(Clone, PartialEq, ::prost::Message)]
+    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
     pub struct Posix {
         #[prost(string, tag = "1")]
         pub path: ::prost::alloc::string::String,
@@ -790,7 +790,7 @@ pub mod remote_storage_target {
         Mock(::prost::alloc::string::String),
     }
 }
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct GetCapabilitiesRequest {}
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct GetCapabilitiesResponse {
@@ -817,7 +817,7 @@ pub struct Feature {
         Feature,
     >,
 }
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct BuildInfo {
     #[prost(string, tag = "1")]
     pub binary_name: ::prost::alloc::string::String,
@@ -935,7 +935,7 @@ pub mod worker_node_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/flex.WorkerNode/UpdateConfig",
             );
@@ -959,7 +959,7 @@ pub mod worker_node_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/flex.WorkerNode/Heartbeat",
             );
@@ -982,7 +982,7 @@ pub mod worker_node_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/flex.WorkerNode/SubmitWork",
             );
@@ -1008,7 +1008,7 @@ pub mod worker_node_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/flex.WorkerNode/UpdateWork",
             );
@@ -1035,7 +1035,7 @@ pub mod worker_node_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/flex.WorkerNode/BulkUpdateWork",
             );
@@ -1059,7 +1059,7 @@ pub mod worker_node_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/flex.WorkerNode/GetCapabilities",
             );
@@ -1238,7 +1238,7 @@ pub mod worker_node_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = UpdateConfigSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1283,7 +1283,7 @@ pub mod worker_node_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = HeartbeatSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1328,7 +1328,7 @@ pub mod worker_node_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = SubmitWorkSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1373,7 +1373,7 @@ pub mod worker_node_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = UpdateWorkSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1418,7 +1418,7 @@ pub mod worker_node_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = BulkUpdateWorkSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1463,7 +1463,7 @@ pub mod worker_node_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = GetCapabilitiesSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
diff --git a/rust/license.rs b/rust/license.rs
index 7bda05a..9e82f8b 100644
--- a/rust/license.rs
+++ b/rust/license.rs
@@ -1,6 +1,6 @@
 // This file is @generated by prost-build.
 /// The result of a certificate verfication operation.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct VerifyCertResult {
     #[prost(enumeration = "VerifyResult", tag = "1")]
     pub result: i32,
@@ -13,7 +13,7 @@ pub struct VerifyCertResult {
     pub message: ::prost::alloc::string::String,
 }
 /// The result of a feature verification operation.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct VerifyFeatureResult {
     #[prost(enumeration = "VerifyResult", tag = "1")]
     pub result: i32,
diff --git a/rust/management.rs b/rust/management.rs
index a0c56f7..05a0a43 100644
--- a/rust/management.rs
+++ b/rust/management.rs
@@ -1,6 +1,6 @@
 // This file is @generated by prost-build.
 /// Sets an entity alias.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct SetAliasRequest {
     /// The entity to set the alias for.
     /// Required, one identifier is sufficient.
@@ -15,10 +15,10 @@ pub struct SetAliasRequest {
     #[prost(string, tag = "3")]
     pub new_alias: ::prost::alloc::string::String,
 }
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct SetAliasResponse {}
 /// Gets the full list of nodes.
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct GetNodesRequest {
     /// Should the nic list should be included for each node?
     /// Required.
@@ -68,7 +68,7 @@ pub mod get_nodes_response {
     /// Nested message and enum types in `Node`.
     pub mod node {
         /// An entry in a nodes nic list.
-        #[derive(Clone, PartialEq, ::prost::Message)]
+        #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
         pub struct Nic {
             /// The nics IPv4 address in the form aaa.bbb.ccc.ddd:port.
             /// Required.
@@ -86,7 +86,7 @@ pub mod get_nodes_response {
     }
 }
 /// Deletes a node from the system.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct DeleteNodeRequest {
     /// The node to delete.
     /// Required, one identifier is sufficient.
@@ -97,7 +97,7 @@ pub struct DeleteNodeRequest {
     #[prost(bool, optional, tag = "2")]
     pub execute: ::core::option::Option<bool>,
 }
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct DeleteNodeResponse {
     /// The identifier set of the deleted node.
     /// Required, should be completely populated.
@@ -105,7 +105,7 @@ pub struct DeleteNodeResponse {
     pub node: ::core::option::Option<super::beegfs::EntityIdSet>,
 }
 /// Gets the full list of targets.
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct GetTargetsRequest {}
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct GetTargetsResponse {
@@ -116,7 +116,7 @@ pub struct GetTargetsResponse {
 /// Nested message and enum types in `GetTargetsResponse`.
 pub mod get_targets_response {
     /// An entry in the target list.
-    #[derive(Clone, PartialEq, ::prost::Message)]
+    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
     pub struct Target {
         /// The targets identifier set.
         /// Required, should be completely populated.
@@ -171,7 +171,7 @@ pub mod get_targets_response {
     }
 }
 /// Deletes a target from the system.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct DeleteTargetRequest {
     /// The target to delete.
     /// Required, one identifier is sufficient.
@@ -182,7 +182,7 @@ pub struct DeleteTargetRequest {
     #[prost(bool, optional, tag = "2")]
     pub execute: ::core::option::Option<bool>,
 }
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct DeleteTargetResponse {
     /// The identifier set of the deleted target.
     /// Required, should be completely populated.
@@ -190,7 +190,7 @@ pub struct DeleteTargetResponse {
     pub target: ::core::option::Option<super::beegfs::EntityIdSet>,
 }
 /// Sets a targets consistency state.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct SetTargetStateRequest {
     /// The target to set the state for.
     /// Required, one identifier is sufficient.
@@ -201,10 +201,10 @@ pub struct SetTargetStateRequest {
     #[prost(enumeration = "super::beegfs::ConsistencyState", optional, tag = "2")]
     pub consistency_state: ::core::option::Option<i32>,
 }
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct SetTargetStateResponse {}
 /// Gets the full list of storage pools.
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct GetPoolsRequest {
     /// Should the quota limits be included for each pool?
     /// Required.
@@ -280,7 +280,7 @@ pub struct CreatePoolRequest {
     #[prost(message, repeated, tag = "5")]
     pub buddy_groups: ::prost::alloc::vec::Vec<super::beegfs::EntityIdSet>,
 }
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct CreatePoolResponse {
     /// The identifier set of the new pool.
     /// Required, should be completely populated.
@@ -303,7 +303,7 @@ pub struct AssignPoolRequest {
     #[prost(message, repeated, tag = "3")]
     pub buddy_groups: ::prost::alloc::vec::Vec<super::beegfs::EntityIdSet>,
 }
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct AssignPoolResponse {
     /// The identifier set of the pool assigned to.
     /// Required, should be completely populated.
@@ -311,7 +311,7 @@ pub struct AssignPoolResponse {
     pub pool: ::core::option::Option<super::beegfs::EntityIdSet>,
 }
 /// Deletes a pool from the system.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct DeletePoolRequest {
     /// The pool to delete.
     /// Required, one identifier is sufficient.
@@ -323,7 +323,7 @@ pub struct DeletePoolRequest {
     #[prost(bool, optional, tag = "2")]
     pub execute: ::core::option::Option<bool>,
 }
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct DeletePoolResponse {
     /// The identifier set of the deleted pool.
     /// Required, should be completely populated.
@@ -331,7 +331,7 @@ pub struct DeletePoolResponse {
     pub pool: ::core::option::Option<super::beegfs::EntityIdSet>,
 }
 /// Gets the list of buddy groups.
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct GetBuddyGroupsRequest {}
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct GetBuddyGroupsResponse {
@@ -342,7 +342,7 @@ pub struct GetBuddyGroupsResponse {
 /// Nested message and enum types in `GetBuddyGroupsResponse`.
 pub mod get_buddy_groups_response {
     /// An entry in the buddy groups list.
-    #[derive(Clone, PartialEq, ::prost::Message)]
+    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
     pub struct BuddyGroup {
         /// The buddy groups identifier set.
         /// Required, should be completely populated.
@@ -376,7 +376,7 @@ pub mod get_buddy_groups_response {
     }
 }
 /// Creates a new buddy group.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct CreateBuddyGroupRequest {
     /// The node type of the new buddy group.
     /// Required, must be META or STORAGE.
@@ -399,7 +399,7 @@ pub struct CreateBuddyGroupRequest {
     #[prost(message, optional, tag = "5")]
     pub secondary_target: ::core::option::Option<super::beegfs::EntityIdSet>,
 }
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct CreateBuddyGroupResponse {
     /// The identifier set of the new buddy group.
     /// Required, should be completely populated.
@@ -407,7 +407,7 @@ pub struct CreateBuddyGroupResponse {
     pub group: ::core::option::Option<super::beegfs::EntityIdSet>,
 }
 /// Deletes a buddy group from the system.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct DeleteBuddyGroupRequest {
     /// The buddy group to delete.
     /// Required, one identifier is sufficient.
@@ -419,7 +419,7 @@ pub struct DeleteBuddyGroupRequest {
     #[prost(bool, optional, tag = "2")]
     pub execute: ::core::option::Option<bool>,
 }
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct DeleteBuddyGroupResponse {
     /// The identifier set of the deleted buddy group.
     /// Required, should be completely populated.
@@ -427,12 +427,12 @@ pub struct DeleteBuddyGroupResponse {
     pub group: ::core::option::Option<super::beegfs::EntityIdSet>,
 }
 /// Enable metadata mirroring for the root directory.
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct MirrorRootInodeRequest {}
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct MirrorRootInodeResponse {}
 /// Manually start a resync.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct StartResyncRequest {
     /// The buddy group whose secondary target will be resynced from its primary target.
     /// Required, one identifier is sufficient.
@@ -447,11 +447,11 @@ pub struct StartResyncRequest {
     #[prost(bool, optional, tag = "3")]
     pub restart: ::core::option::Option<bool>,
 }
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct StartResyncResponse {}
 /// Contains info belonging to a quota_id + id_type + pool entry (e.g. user 1000 on storage pool 1).
 /// Depending on the message, some fields are unused.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct QuotaInfo {
     /// The system user/group id the info belongs to.
     /// Required.
@@ -487,7 +487,7 @@ pub struct QuotaInfo {
     pub inode_used: ::core::option::Option<i64>,
 }
 /// Sets the default quota limits for a pool.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct SetDefaultQuotaLimitsRequest {
     /// The storage pool to set the limits for.
     /// Required, one identifier is sufficient.
@@ -510,21 +510,21 @@ pub struct SetDefaultQuotaLimitsRequest {
     #[prost(int64, optional, tag = "5")]
     pub group_inode_limit: ::core::option::Option<i64>,
 }
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct SetDefaultQuotaLimitsResponse {}
 /// Sets the individually set per-id-and-pool quota limits.
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct SetQuotaLimitsRequest {
-    /// The explicit quota limit entries to set on the management. The _used fields should be unset.
+    /// The explicit quota limit entries to set on the management. The \_used fields should be unset.
     #[prost(message, repeated, tag = "1")]
     pub limits: ::prost::alloc::vec::Vec<QuotaInfo>,
 }
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct SetQuotaLimitsResponse {}
 /// Gets the individually set per-id-and-pool quota limits. Retrieves all explicitly set entries.
-/// By default, nothing shall be returned. Set at least one user_id_* / group_id_* field to enable
+/// By default, nothing shall be returned. Set at least one user_id\_\* / group_id\_\* field to enable
 /// querying (e.g. set user_id_min to 0 to return user entries for all user ids).
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct GetQuotaLimitsRequest {
     /// The minimum user id to return.
     /// Optional.
@@ -554,19 +554,19 @@ pub struct GetQuotaLimitsRequest {
     pub pool: ::core::option::Option<super::beegfs::EntityIdSet>,
 }
 /// One entry in the quota per-id-and-pool limits list. Meant to be streamed.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct GetQuotaLimitsResponse {
     /// One per-id-and-pool quota limit entry.
     /// This is a single (non-repeated) field because the response is meant to be streamed.
-    /// Required. The _used fields are unused.
+    /// Required. The \_used fields are unused.
     #[prost(message, optional, tag = "1")]
     pub limits: ::core::option::Option<QuotaInfo>,
 }
 /// Gets the quota usage info for all the ids the management knows about. In addition, contains
 /// the effective limits for each entry.
-/// By default, nothing shall be returned. Set at least one user_id_* / group_id_* field to enable
+/// By default, nothing shall be returned. Set at least one user_id\_\* / group_id\_\* field to enable
 /// querying (e.g. set user_id_min to 0 to return user entries for all user ids).
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct GetQuotaUsageRequest {
     /// The minimum user id to return.
     /// Optional.
@@ -600,7 +600,7 @@ pub struct GetQuotaUsageRequest {
     pub exceeded: ::core::option::Option<bool>,
 }
 /// One entry in the quota per-id-and-pool limits list. Meant to be streamed.
-#[derive(Clone, PartialEq, ::prost::Message)]
+#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct GetQuotaUsageResponse {
     /// One per-id-and-pool quota usage entry.
     /// This is a single (non-repeated) field because the response is meant to be streamed.
@@ -613,7 +613,7 @@ pub struct GetQuotaUsageResponse {
     pub refresh_period_s: ::core::option::Option<u64>,
 }
 /// Gets license information.
-#[derive(Clone, Copy, PartialEq, ::prost::Message)]
+#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct GetLicenseRequest {
     /// Reload and re-verify the license before returning it?
     /// Required.
@@ -733,7 +733,7 @@ pub mod management_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/management.Management/SetAlias",
             );
@@ -758,7 +758,7 @@ pub mod management_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/management.Management/GetNodes",
             );
@@ -782,7 +782,7 @@ pub mod management_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/management.Management/DeleteNode",
             );
@@ -807,7 +807,7 @@ pub mod management_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/management.Management/GetTargets",
             );
@@ -831,7 +831,7 @@ pub mod management_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/management.Management/DeleteTarget",
             );
@@ -856,7 +856,7 @@ pub mod management_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/management.Management/SetTargetState",
             );
@@ -881,7 +881,7 @@ pub mod management_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/management.Management/GetPools",
             );
@@ -905,7 +905,7 @@ pub mod management_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/management.Management/CreatePool",
             );
@@ -929,7 +929,7 @@ pub mod management_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/management.Management/AssignPool",
             );
@@ -953,7 +953,7 @@ pub mod management_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/management.Management/DeletePool",
             );
@@ -978,7 +978,7 @@ pub mod management_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/management.Management/GetBuddyGroups",
             );
@@ -1002,7 +1002,7 @@ pub mod management_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/management.Management/CreateBuddyGroup",
             );
@@ -1026,7 +1026,7 @@ pub mod management_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/management.Management/DeleteBuddyGroup",
             );
@@ -1050,7 +1050,7 @@ pub mod management_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/management.Management/MirrorRootInode",
             );
@@ -1074,7 +1074,7 @@ pub mod management_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/management.Management/StartResync",
             );
@@ -1099,7 +1099,7 @@ pub mod management_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/management.Management/SetDefaultQuotaLimits",
             );
@@ -1125,7 +1125,7 @@ pub mod management_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/management.Management/SetQuotaLimits",
             );
@@ -1149,7 +1149,7 @@ pub mod management_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/management.Management/GetQuotaLimits",
             );
@@ -1173,7 +1173,7 @@ pub mod management_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/management.Management/GetQuotaUsage",
             );
@@ -1198,7 +1198,7 @@ pub mod management_client {
                         format!("Service was not ready: {}", e.into()),
                     )
                 })?;
-            let codec = tonic::codec::ProstCodec::default();
+            let codec = tonic_prost::ProstCodec::default();
             let path = http::uri::PathAndQuery::from_static(
                 "/management.Management/GetLicense",
             );
@@ -1488,7 +1488,7 @@ pub mod management_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = SetAliasSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1533,7 +1533,7 @@ pub mod management_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = GetNodesSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1578,7 +1578,7 @@ pub mod management_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = DeleteNodeSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1623,7 +1623,7 @@ pub mod management_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = GetTargetsSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1668,7 +1668,7 @@ pub mod management_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = DeleteTargetSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1713,7 +1713,7 @@ pub mod management_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = SetTargetStateSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1758,7 +1758,7 @@ pub mod management_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = GetPoolsSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1803,7 +1803,7 @@ pub mod management_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = CreatePoolSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1848,7 +1848,7 @@ pub mod management_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = AssignPoolSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1893,7 +1893,7 @@ pub mod management_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = DeletePoolSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1938,7 +1938,7 @@ pub mod management_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = GetBuddyGroupsSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -1983,7 +1983,7 @@ pub mod management_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = CreateBuddyGroupSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -2028,7 +2028,7 @@ pub mod management_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = DeleteBuddyGroupSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -2073,7 +2073,7 @@ pub mod management_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = MirrorRootInodeSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -2118,7 +2118,7 @@ pub mod management_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = StartResyncSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -2164,7 +2164,7 @@ pub mod management_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = SetDefaultQuotaLimitsSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -2209,7 +2209,7 @@ pub mod management_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = SetQuotaLimitsSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -2255,7 +2255,7 @@ pub mod management_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = GetQuotaLimitsSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -2301,7 +2301,7 @@ pub mod management_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = GetQuotaUsageSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,
@@ -2346,7 +2346,7 @@ pub mod management_server {
                     let inner = self.inner.clone();
                     let fut = async move {
                         let method = GetLicenseSvc(inner);
-                        let codec = tonic::codec::ProstCodec::default();
+                        let codec = tonic_prost::ProstCodec::default();
                         let mut grpc = tonic::server::Grpc::new(codec)
                             .apply_compression_config(
                                 accept_compression_encodings,