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