Enum kf_protocol::api::AllKfApiKey

#[repr(u16)]pub enum AllKfApiKey {
    Produce,
    Fetch,
    ListOffsets,
    Metadata,
    LeaderAndIsr,
    StopReplica,
    UpdateMetadata,
    ControlShutdown,
    OffsetCommit,
    OffsetFetch,
    FindCoordinator,
    JoinGroup,
    Heartbeat,
    LeaveGroup,
    SyncGroup,
    DescribeGroup,
    ListGroups,
    SaslHandshake,
    ApiVersion,
    CreateTopics,
    DeleteTopics,
    DeleteRecords,
    InitProducerId,
    OffsetForLeaderEpoch,
    AddPartitionsToTxn,
    AddOffsetsToTxn,
    EndTxn,
    WriteTxnMarkers,
    TxnOffsetCommit,
    DescribeAcls,
    CreateAcls,
    DeleteAcls,
    DescribeConfigs,
    AlterConfigs,
    AlterReplicaLogDirs,
    DescribeLogDirs,
    SaslAuthenticate,
    CreatePartitions,
    CreateDelegationToken,
    RenewDelegationToken,
    ExpireDelegationToken,
    DescribeDelegationToken,
    DeleteGroups,
}

Variants

Produce

Fetch

ListOffsets

Metadata

LeaderAndIsr

StopReplica

UpdateMetadata

ControlShutdown

OffsetCommit

OffsetFetch

FindCoordinator

JoinGroup

Heartbeat

LeaveGroup

SyncGroup

DescribeGroup

ListGroups

SaslHandshake

ApiVersion

CreateTopics

DeleteTopics

DeleteRecords

InitProducerId

OffsetForLeaderEpoch

AddPartitionsToTxn

AddOffsetsToTxn

EndTxn

WriteTxnMarkers

TxnOffsetCommit

DescribeAcls

CreateAcls

DeleteAcls

DescribeConfigs

AlterConfigs

AlterReplicaLogDirs

DescribeLogDirs

SaslAuthenticate

CreatePartitions

CreateDelegationToken

RenewDelegationToken

ExpireDelegationToken

DescribeDelegationToken

DeleteGroups

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 Copy for AllKfApiKey

impl Debug for AllKfApiKey

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

Formats the value using the given formatter.

impl Decoder for AllKfApiKey

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

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

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: i16) -> Result<(), Error> where
    T: BufMut, 

encoding contents for buffer

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

size of this object in bytes

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

impl PartialEq<AllKfApiKey> for AllKfApiKey

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

This method tests for self and other values to be equal, and is used by ==.

#[must_use]fn ne(&self, other: &Rhs) -> bool

This method tests for !=.

impl TryFrom<u16> for AllKfApiKey

type Error = Error

The type returned in the event of a conversion error.

fn try_from(
    value: u16
) -> Result<AllKfApiKey, <AllKfApiKey as TryFrom<u16>>::Error>

Performs the conversion.