1 2 3 4 5 6 7 8 9 10 11 12 13 14 15
use dataplane::core::{Encoder, Decoder}; /// Api Key for Spu Client API (from server to client) #[repr(u16)] #[derive(PartialEq, Debug, Encoder, Decoder, Clone, Copy)] #[fluvio(encode_discriminant)] pub enum SpuClientApiKey { ReplicaOffsetUpdate = 1001, } impl Default for SpuClientApiKey { fn default() -> Self { Self::ReplicaOffsetUpdate } }