update

infinyon · Oct 29, 2024 · a95a8ab · a95a8ab
1 parent 2385330
commit a95a8ab
Show file tree

Hide file tree

Showing 3 changed files with 237 additions and 41 deletions.
diff --git a/crates/fluvio-spu/src/mirroring/home/home_api.rs b/crates/fluvio-spu/src/mirroring/home/home_api.rs
@@ -4,7 +4,7 @@ use std::convert::TryInto;
 use tracing::trace;
 
 use fluvio_protocol::bytes::Buf;
-use fluvio_protocol::{Encoder, Decoder};
+use fluvio_protocol::Decoder;
 use fluvio_protocol::api::{RequestMessage, ApiMessage, RequestHeader};
 
 use crate::mirroring::remote::sync::DefaultPartitionSyncRequest;
@@ -13,11 +13,9 @@ use super::api_key::MirrorHomeApiEnum;
 use super::update_offsets::UpdateHomeOffsetRequest;
 
 /// Requests from home to remote
-#[derive(Debug, Encoder)]
+#[derive(Debug)]
 pub enum HomeMirrorRequest {
-    #[fluvio(tag = 0)]
     UpdateHomeOffset(RequestMessage<UpdateHomeOffsetRequest>),
-    #[fluvio(tag = 1)]
     SyncRecords(RequestMessage<DefaultPartitionSyncRequest>),
 }