Enum kafka_protocol::messages::RequestKind

source ·

#[non_exhaustive]pub enum RequestKind {
Show 74 variants
    ProduceRequest(ProduceRequest),
    FetchRequest(FetchRequest),
    ListOffsetsRequest(ListOffsetsRequest),
    MetadataRequest(MetadataRequest),
    LeaderAndIsrRequest(LeaderAndIsrRequest),
    StopReplicaRequest(StopReplicaRequest),
    UpdateMetadataRequest(UpdateMetadataRequest),
    ControlledShutdownRequest(ControlledShutdownRequest),
    OffsetCommitRequest(OffsetCommitRequest),
    OffsetFetchRequest(OffsetFetchRequest),
    FindCoordinatorRequest(FindCoordinatorRequest),
    JoinGroupRequest(JoinGroupRequest),
    HeartbeatRequest(HeartbeatRequest),
    LeaveGroupRequest(LeaveGroupRequest),
    SyncGroupRequest(SyncGroupRequest),
    DescribeGroupsRequest(DescribeGroupsRequest),
    ListGroupsRequest(ListGroupsRequest),
    SaslHandshakeRequest(SaslHandshakeRequest),
    ApiVersionsRequest(ApiVersionsRequest),
    CreateTopicsRequest(CreateTopicsRequest),
    DeleteTopicsRequest(DeleteTopicsRequest),
    DeleteRecordsRequest(DeleteRecordsRequest),
    InitProducerIdRequest(InitProducerIdRequest),
    OffsetForLeaderEpochRequest(OffsetForLeaderEpochRequest),
    AddPartitionsToTxnRequest(AddPartitionsToTxnRequest),
    AddOffsetsToTxnRequest(AddOffsetsToTxnRequest),
    EndTxnRequest(EndTxnRequest),
    WriteTxnMarkersRequest(WriteTxnMarkersRequest),
    TxnOffsetCommitRequest(TxnOffsetCommitRequest),
    DescribeAclsRequest(DescribeAclsRequest),
    CreateAclsRequest(CreateAclsRequest),
    DeleteAclsRequest(DeleteAclsRequest),
    DescribeConfigsRequest(DescribeConfigsRequest),
    AlterConfigsRequest(AlterConfigsRequest),
    AlterReplicaLogDirsRequest(AlterReplicaLogDirsRequest),
    DescribeLogDirsRequest(DescribeLogDirsRequest),
    SaslAuthenticateRequest(SaslAuthenticateRequest),
    CreatePartitionsRequest(CreatePartitionsRequest),
    CreateDelegationTokenRequest(CreateDelegationTokenRequest),
    RenewDelegationTokenRequest(RenewDelegationTokenRequest),
    ExpireDelegationTokenRequest(ExpireDelegationTokenRequest),
    DescribeDelegationTokenRequest(DescribeDelegationTokenRequest),
    DeleteGroupsRequest(DeleteGroupsRequest),
    ElectLeadersRequest(ElectLeadersRequest),
    IncrementalAlterConfigsRequest(IncrementalAlterConfigsRequest),
    AlterPartitionReassignmentsRequest(AlterPartitionReassignmentsRequest),
    ListPartitionReassignmentsRequest(ListPartitionReassignmentsRequest),
    OffsetDeleteRequest(OffsetDeleteRequest),
    DescribeClientQuotasRequest(DescribeClientQuotasRequest),
    AlterClientQuotasRequest(AlterClientQuotasRequest),
    DescribeUserScramCredentialsRequest(DescribeUserScramCredentialsRequest),
    AlterUserScramCredentialsRequest(AlterUserScramCredentialsRequest),
    VoteRequest(VoteRequest),
    BeginQuorumEpochRequest(BeginQuorumEpochRequest),
    EndQuorumEpochRequest(EndQuorumEpochRequest),
    DescribeQuorumRequest(DescribeQuorumRequest),
    AlterPartitionRequest(AlterPartitionRequest),
    UpdateFeaturesRequest(UpdateFeaturesRequest),
    EnvelopeRequest(EnvelopeRequest),
    FetchSnapshotRequest(FetchSnapshotRequest),
    DescribeClusterRequest(DescribeClusterRequest),
    DescribeProducersRequest(DescribeProducersRequest),
    BrokerRegistrationRequest(BrokerRegistrationRequest),
    BrokerHeartbeatRequest(BrokerHeartbeatRequest),
    UnregisterBrokerRequest(UnregisterBrokerRequest),
    DescribeTransactionsRequest(DescribeTransactionsRequest),
    ListTransactionsRequest(ListTransactionsRequest),
    AllocateProducerIdsRequest(AllocateProducerIdsRequest),
    ConsumerGroupHeartbeatRequest(ConsumerGroupHeartbeatRequest),
    ControllerRegistrationRequest(ControllerRegistrationRequest),
    GetTelemetrySubscriptionsRequest(GetTelemetrySubscriptionsRequest),
    PushTelemetryRequest(PushTelemetryRequest),
    AssignReplicasToDirsRequest(AssignReplicasToDirsRequest),
    ListClientMetricsResourcesRequest(ListClientMetricsResourcesRequest),
}

Expand description

Wrapping enum for all requests in the Kafka protocol.

Variants (Non-exhaustive)§

This enum is marked as non-exhaustive

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

§

ProduceRequest(ProduceRequest)

ProduceRequest,

§

FetchRequest(FetchRequest)

FetchRequest,

§

ListOffsetsRequest(ListOffsetsRequest)

ListOffsetsRequest,

§

MetadataRequest(MetadataRequest)

MetadataRequest,

§

LeaderAndIsrRequest(LeaderAndIsrRequest)

LeaderAndIsrRequest,

§

StopReplicaRequest(StopReplicaRequest)

StopReplicaRequest,

§

UpdateMetadataRequest(UpdateMetadataRequest)

UpdateMetadataRequest,

§

ControlledShutdownRequest(ControlledShutdownRequest)

ControlledShutdownRequest,

§

OffsetCommitRequest(OffsetCommitRequest)

OffsetCommitRequest,

§

OffsetFetchRequest(OffsetFetchRequest)

OffsetFetchRequest,

§

FindCoordinatorRequest(FindCoordinatorRequest)

FindCoordinatorRequest,

§

JoinGroupRequest(JoinGroupRequest)

JoinGroupRequest,

§

HeartbeatRequest(HeartbeatRequest)

HeartbeatRequest,

§

LeaveGroupRequest(LeaveGroupRequest)

LeaveGroupRequest,

§

SyncGroupRequest(SyncGroupRequest)

SyncGroupRequest,

§

DescribeGroupsRequest(DescribeGroupsRequest)

DescribeGroupsRequest,

§

ListGroupsRequest(ListGroupsRequest)

ListGroupsRequest,

§

SaslHandshakeRequest(SaslHandshakeRequest)

SaslHandshakeRequest,

§

ApiVersionsRequest(ApiVersionsRequest)

ApiVersionsRequest,

§

CreateTopicsRequest(CreateTopicsRequest)

CreateTopicsRequest,

§

DeleteTopicsRequest(DeleteTopicsRequest)

DeleteTopicsRequest,

§

DeleteRecordsRequest(DeleteRecordsRequest)

DeleteRecordsRequest,

§

InitProducerIdRequest(InitProducerIdRequest)

InitProducerIdRequest,

§

OffsetForLeaderEpochRequest(OffsetForLeaderEpochRequest)

OffsetForLeaderEpochRequest,

§

AddPartitionsToTxnRequest(AddPartitionsToTxnRequest)

AddPartitionsToTxnRequest,

§

AddOffsetsToTxnRequest(AddOffsetsToTxnRequest)

AddOffsetsToTxnRequest,

§

EndTxnRequest(EndTxnRequest)

EndTxnRequest,

§

WriteTxnMarkersRequest(WriteTxnMarkersRequest)

WriteTxnMarkersRequest,

§

TxnOffsetCommitRequest(TxnOffsetCommitRequest)

TxnOffsetCommitRequest,

§

DescribeAclsRequest(DescribeAclsRequest)

DescribeAclsRequest,

§

CreateAclsRequest(CreateAclsRequest)

CreateAclsRequest,

§

DeleteAclsRequest(DeleteAclsRequest)

DeleteAclsRequest,

§

DescribeConfigsRequest(DescribeConfigsRequest)

DescribeConfigsRequest,

§

AlterConfigsRequest(AlterConfigsRequest)

AlterConfigsRequest,

§

AlterReplicaLogDirsRequest(AlterReplicaLogDirsRequest)

AlterReplicaLogDirsRequest,

§

DescribeLogDirsRequest(DescribeLogDirsRequest)

DescribeLogDirsRequest,

§

SaslAuthenticateRequest(SaslAuthenticateRequest)

SaslAuthenticateRequest,

§

CreatePartitionsRequest(CreatePartitionsRequest)

CreatePartitionsRequest,

§

CreateDelegationTokenRequest(CreateDelegationTokenRequest)

CreateDelegationTokenRequest,

§

RenewDelegationTokenRequest(RenewDelegationTokenRequest)

RenewDelegationTokenRequest,

§

ExpireDelegationTokenRequest(ExpireDelegationTokenRequest)

ExpireDelegationTokenRequest,

§

DescribeDelegationTokenRequest(DescribeDelegationTokenRequest)

DescribeDelegationTokenRequest,

§

DeleteGroupsRequest(DeleteGroupsRequest)

DeleteGroupsRequest,

§

ElectLeadersRequest(ElectLeadersRequest)

ElectLeadersRequest,

§

IncrementalAlterConfigsRequest(IncrementalAlterConfigsRequest)

IncrementalAlterConfigsRequest,

§

AlterPartitionReassignmentsRequest(AlterPartitionReassignmentsRequest)

AlterPartitionReassignmentsRequest,

§

ListPartitionReassignmentsRequest(ListPartitionReassignmentsRequest)

ListPartitionReassignmentsRequest,

§

OffsetDeleteRequest(OffsetDeleteRequest)

OffsetDeleteRequest,

§

DescribeClientQuotasRequest(DescribeClientQuotasRequest)

DescribeClientQuotasRequest,

§

AlterClientQuotasRequest(AlterClientQuotasRequest)

AlterClientQuotasRequest,

§

DescribeUserScramCredentialsRequest(DescribeUserScramCredentialsRequest)

DescribeUserScramCredentialsRequest,

§

AlterUserScramCredentialsRequest(AlterUserScramCredentialsRequest)

AlterUserScramCredentialsRequest,

§

VoteRequest(VoteRequest)

VoteRequest,

§

BeginQuorumEpochRequest(BeginQuorumEpochRequest)

BeginQuorumEpochRequest,

§

EndQuorumEpochRequest(EndQuorumEpochRequest)

EndQuorumEpochRequest,

§

DescribeQuorumRequest(DescribeQuorumRequest)

DescribeQuorumRequest,

§

AlterPartitionRequest(AlterPartitionRequest)

AlterPartitionRequest,

§

UpdateFeaturesRequest(UpdateFeaturesRequest)

UpdateFeaturesRequest,

§

EnvelopeRequest(EnvelopeRequest)

EnvelopeRequest,

§

FetchSnapshotRequest(FetchSnapshotRequest)

FetchSnapshotRequest,

§

DescribeClusterRequest(DescribeClusterRequest)

DescribeClusterRequest,

§

DescribeProducersRequest(DescribeProducersRequest)

DescribeProducersRequest,

§

BrokerRegistrationRequest(BrokerRegistrationRequest)

BrokerRegistrationRequest,

§

BrokerHeartbeatRequest(BrokerHeartbeatRequest)

BrokerHeartbeatRequest,

§

UnregisterBrokerRequest(UnregisterBrokerRequest)

UnregisterBrokerRequest,

§

DescribeTransactionsRequest(DescribeTransactionsRequest)

DescribeTransactionsRequest,

§

ListTransactionsRequest(ListTransactionsRequest)

ListTransactionsRequest,

§

AllocateProducerIdsRequest(AllocateProducerIdsRequest)

AllocateProducerIdsRequest,

§

ConsumerGroupHeartbeatRequest(ConsumerGroupHeartbeatRequest)

ConsumerGroupHeartbeatRequest,

§

ControllerRegistrationRequest(ControllerRegistrationRequest)

ControllerRegistrationRequest,

§

GetTelemetrySubscriptionsRequest(GetTelemetrySubscriptionsRequest)

GetTelemetrySubscriptionsRequest,

§

PushTelemetryRequest(PushTelemetryRequest)

PushTelemetryRequest,

§

AssignReplicasToDirsRequest(AssignReplicasToDirsRequest)

AssignReplicasToDirsRequest,

§

ListClientMetricsResourcesRequest(ListClientMetricsResourcesRequest)

ListClientMetricsResourcesRequest,

Trait Implementations§

source §

impl Clone for RequestKind

source §

fn clone(&self) -> RequestKind

Returns a copy of the value. Read more

1.0.0 · source§

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

Performs copy-assignment from source. Read more

source §

impl Debug for RequestKind

source §

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

Formats the value using the given formatter. Read more

source §

impl PartialEq for RequestKind

source §

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

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

1.0.0 · source§

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

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

source §

impl StructuralPartialEq for RequestKind

Auto Trait Implementations§

§

impl UnwindSafe for RequestKind

Blanket Implementations§

source §

impl<T> Any for T
where T: 'static + ?Sized,

source §

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

source §

impl<T> Borrow<T> for T
where T: ?Sized,

source §

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

source §

impl<T> BorrowMut<T> for T
where T: ?Sized,

source §

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

source §

impl<T> From<T> for T

source §

fn from(t: T) -> T

Returns the argument unchanged.

source §

impl<T, U> Into for T
where U: From<T>,

source §

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source §

impl<T> ToOwned for T
where T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.

source §

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more

source §

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more

source §

impl<T, U> TryFrom for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.

source §

fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

source §

impl<T, U> TryInto for T
where U: TryFrom<T>,

§

type Error = >::Error

The type returned in the event of a conversion error.

source §

fn try_into(self) -> Result<U, >::Error>

Performs the conversion.