Enum AllKfApiKey

#[repr(u16)]
pub enum AllKfApiKey {
    Produce = 0,
    Fetch = 1,
    ListOffsets = 2,
    Metadata = 3,
    LeaderAndIsr = 4,
    StopReplica = 5,
    UpdateMetadata = 6,
    ControlShutdown = 7,
    OffsetCommit = 8,
    OffsetFetch = 9,
    FindCoordinator = 10,
    JoinGroup = 11,
    Heartbeat = 12,
    LeaveGroup = 13,
    SyncGroup = 14,
    DescribeGroup = 15,
    ListGroups = 16,
    SaslHandshake = 17,
    ApiVersion = 18,
    CreateTopics = 19,
    DeleteTopics = 20,
    DeleteRecords = 21,
    InitProducerId = 22,
    OffsetForLeaderEpoch = 23,
    AddPartitionsToTxn = 24,
    AddOffsetsToTxn = 25,
    EndTxn = 26,
    WriteTxnMarkers = 27,
    TxnOffsetCommit = 28,
    DescribeAcls = 29,
    CreateAcls = 30,
    DeleteAcls = 31,
    DescribeConfigs = 32,
    AlterConfigs = 33,
    AlterReplicaLogDirs = 34,
    DescribeLogDirs = 35,
    SaslAuthenticate = 36,
    CreatePartitions = 37,
    CreateDelegationToken = 38,
    RenewDelegationToken = 39,
    ExpireDelegationToken = 40,
    DescribeDelegationToken = 41,
    DeleteGroups = 42,
}

Variants

Produce = 0

Fetch = 1

ListOffsets = 2

Metadata = 3

LeaderAndIsr = 4

StopReplica = 5

UpdateMetadata = 6

ControlShutdown = 7

OffsetCommit = 8

OffsetFetch = 9

FindCoordinator = 10

JoinGroup = 11

Heartbeat = 12

LeaveGroup = 13

SyncGroup = 14

DescribeGroup = 15

ListGroups = 16

SaslHandshake = 17

ApiVersion = 18

CreateTopics = 19

DeleteTopics = 20

DeleteRecords = 21

InitProducerId = 22

OffsetForLeaderEpoch = 23

AddPartitionsToTxn = 24

AddOffsetsToTxn = 25

EndTxn = 26

WriteTxnMarkers = 27

TxnOffsetCommit = 28

DescribeAcls = 29

CreateAcls = 30

DeleteAcls = 31

DescribeConfigs = 32

AlterConfigs = 33

AlterReplicaLogDirs = 34

DescribeLogDirs = 35

SaslAuthenticate = 36

CreatePartitions = 37

CreateDelegationToken = 38

RenewDelegationToken = 39

ExpireDelegationToken = 40

DescribeDelegationToken = 41

DeleteGroups = 42

Trait Implementations

impl Clone for AllKfApiKey

fn clone(&self) -> AllKfApiKey

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AllKfApiKey

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Decoder for AllKfApiKey

fn decode<T>(&mut self, src: &mut T, version: Version) -> Result<(), Error>

where T: Buf,

fn decode_from<T>(src: &mut T, version: i16) -> Result<Self, Error>

where T: Buf, Self: Default,

decode Kafka compliant protocol values from buf

impl Default for AllKfApiKey

fn default() -> AllKfApiKey

Returns the “default value” for a type.

impl Encoder for AllKfApiKey

fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error>

where T: BufMut,

encoding contents for buffer

fn write_size(&self, version: Version) -> usize

size of this object in bytes

fn as_bytes(&self, version: i16) -> Result<Bytes, Error>

impl PartialEq for AllKfApiKey

fn eq(&self, other: &AllKfApiKey) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl TryFrom<u16> for AllKfApiKey

type Error = Error

The type returned in the event of a conversion error.

fn try_from(value: u16) -> Result<Self, Self::Error>

Performs the conversion.

impl Copy for AllKfApiKey

impl StructuralPartialEq for AllKfApiKey