fluvio_spu_schema/client/
api_key.rs

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