Skip to main content

Decode

Trait Decode 

Source
pub trait Decode<'de>: Sized {
    // Required method
    fn decode<B: Buf>(buf: &mut B, version: i16) -> Result<Self, ProtocolError>;
}
Expand description

Decode a Kafka wire-protocol value from a buffer at the given protocol version.

The 'de lifetime is the lifetime the decoded value may borrow from the input. Owned-flavor types implement Decode<'de> for any 'de (their output is 'static). Borrowed-flavor types implement Decode<'de> where Self: 'de.

Required Methods§

Source

fn decode<B: Buf>(buf: &mut B, version: i16) -> Result<Self, ProtocolError>

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§

Source§

impl Decode<'_> for RecordsPayload

Source§

impl Decode<'_> for RecordBatch

Source§

impl<'de> Decode<'de> for crabka_protocol::kafka_3_6_2::owned::fetch_request::FetchPartition

Source§

impl<'de> Decode<'de> for crabka_protocol::kafka_3_6_2::owned::fetch_request::FetchRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::kafka_3_6_2::owned::fetch_request::FetchTopic

Source§

impl<'de> Decode<'de> for crabka_protocol::kafka_3_6_2::owned::fetch_request::ForgottenTopic

Source§

impl<'de> Decode<'de> for crabka_protocol::kafka_3_6_2::owned::fetch_request::ReplicaState

Source§

impl<'de> Decode<'de> for crabka_protocol::kafka_3_6_2::owned::fetch_response::AbortedTransaction

Source§

impl<'de> Decode<'de> for crabka_protocol::kafka_3_6_2::owned::fetch_response::EpochEndOffset

Source§

impl<'de> Decode<'de> for crabka_protocol::kafka_3_6_2::owned::fetch_response::FetchResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::kafka_3_6_2::owned::fetch_response::FetchableTopicResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::kafka_3_6_2::owned::fetch_response::LeaderIdAndEpoch

Source§

impl<'de> Decode<'de> for crabka_protocol::kafka_3_6_2::owned::fetch_response::PartitionData

Source§

impl<'de> Decode<'de> for crabka_protocol::kafka_3_6_2::owned::fetch_response::SnapshotId

Source§

impl<'de> Decode<'de> for crabka_protocol::kafka_3_6_2::owned::produce_request::PartitionProduceData

Source§

impl<'de> Decode<'de> for crabka_protocol::kafka_3_6_2::owned::produce_request::ProduceRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::kafka_3_6_2::owned::produce_request::TopicProduceData

Source§

impl<'de> Decode<'de> for crabka_protocol::kafka_3_6_2::owned::produce_response::BatchIndexAndErrorMessage

Source§

impl<'de> Decode<'de> for crabka_protocol::kafka_3_6_2::owned::produce_response::PartitionProduceResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::kafka_3_6_2::owned::produce_response::ProduceResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::kafka_3_6_2::owned::produce_response::TopicProduceResponse

Source§

impl<'de> Decode<'de> for AddOffsetsToTxnRequest

Source§

impl<'de> Decode<'de> for AddOffsetsToTxnResponse

Source§

impl<'de> Decode<'de> for AddPartitionsToTxnRequest

Source§

impl<'de> Decode<'de> for AddPartitionsToTxnTransaction

Source§

impl<'de> Decode<'de> for AddPartitionsToTxnResponse

Source§

impl<'de> Decode<'de> for AddPartitionsToTxnResult

Source§

impl<'de> Decode<'de> for AddRaftVoterRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::add_raft_voter_request::Listener

Source§

impl<'de> Decode<'de> for AddRaftVoterResponse

Source§

impl<'de> Decode<'de> for AllocateProducerIdsRequest

Source§

impl<'de> Decode<'de> for AllocateProducerIdsResponse

Source§

impl<'de> Decode<'de> for AlterClientQuotasRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::alter_client_quotas_request::EntityData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::alter_client_quotas_request::EntryData

Source§

impl<'de> Decode<'de> for OpData

Source§

impl<'de> Decode<'de> for AlterClientQuotasResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::alter_client_quotas_response::EntityData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::alter_client_quotas_response::EntryData

Source§

impl<'de> Decode<'de> for AlterConfigsRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::alter_configs_request::AlterConfigsResource

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::alter_configs_request::AlterableConfig

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::alter_configs_response::AlterConfigsResourceResponse

Source§

impl<'de> Decode<'de> for AlterConfigsResponse

Source§

impl<'de> Decode<'de> for AlterPartitionReassignmentsRequest

Source§

impl<'de> Decode<'de> for ReassignablePartition

Source§

impl<'de> Decode<'de> for ReassignableTopic

Source§

impl<'de> Decode<'de> for AlterPartitionReassignmentsResponse

Source§

impl<'de> Decode<'de> for ReassignablePartitionResponse

Source§

impl<'de> Decode<'de> for ReassignableTopicResponse

Source§

impl<'de> Decode<'de> for AlterPartitionRequest

Source§

impl<'de> Decode<'de> for BrokerState

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::alter_partition_request::PartitionData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::alter_partition_request::TopicData

Source§

impl<'de> Decode<'de> for AlterPartitionResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::alter_partition_response::PartitionData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::alter_partition_response::TopicData

Source§

impl<'de> Decode<'de> for AlterReplicaLogDir

Source§

impl<'de> Decode<'de> for AlterReplicaLogDirTopic

Source§

impl<'de> Decode<'de> for AlterReplicaLogDirsRequest

Source§

impl<'de> Decode<'de> for AlterReplicaLogDirPartitionResult

Source§

impl<'de> Decode<'de> for AlterReplicaLogDirTopicResult

Source§

impl<'de> Decode<'de> for AlterReplicaLogDirsResponse

Source§

impl<'de> Decode<'de> for AlterShareGroupOffsetsRequest

Source§

impl<'de> Decode<'de> for AlterShareGroupOffsetsRequestPartition

Source§

impl<'de> Decode<'de> for AlterShareGroupOffsetsRequestTopic

Source§

impl<'de> Decode<'de> for AlterShareGroupOffsetsResponse

Source§

impl<'de> Decode<'de> for AlterShareGroupOffsetsResponsePartition

Source§

impl<'de> Decode<'de> for AlterShareGroupOffsetsResponseTopic

Source§

impl<'de> Decode<'de> for AlterUserScramCredentialsRequest

Source§

impl<'de> Decode<'de> for ScramCredentialDeletion

Source§

impl<'de> Decode<'de> for ScramCredentialUpsertion

Source§

impl<'de> Decode<'de> for AlterUserScramCredentialsResponse

Source§

impl<'de> Decode<'de> for AlterUserScramCredentialsResult

Source§

impl<'de> Decode<'de> for ApiVersionsRequest

Source§

impl<'de> Decode<'de> for ApiVersion

Source§

impl<'de> Decode<'de> for ApiVersionsResponse

Source§

impl<'de> Decode<'de> for FinalizedFeatureKey

Source§

impl<'de> Decode<'de> for SupportedFeatureKey

Source§

impl<'de> Decode<'de> for AssignReplicasToDirsRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::assign_replicas_to_dirs_request::DirectoryData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::assign_replicas_to_dirs_request::PartitionData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::assign_replicas_to_dirs_request::TopicData

Source§

impl<'de> Decode<'de> for AssignReplicasToDirsResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::assign_replicas_to_dirs_response::DirectoryData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::assign_replicas_to_dirs_response::PartitionData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::assign_replicas_to_dirs_response::TopicData

Source§

impl<'de> Decode<'de> for BeginQuorumEpochRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::begin_quorum_epoch_request::LeaderEndpoint

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::begin_quorum_epoch_request::PartitionData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::begin_quorum_epoch_request::TopicData

Source§

impl<'de> Decode<'de> for BeginQuorumEpochResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::begin_quorum_epoch_response::NodeEndpoint

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::begin_quorum_epoch_response::PartitionData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::begin_quorum_epoch_response::TopicData

Source§

impl<'de> Decode<'de> for BrokerHeartbeatRequest

Source§

impl<'de> Decode<'de> for BrokerHeartbeatResponse

Source§

impl<'de> Decode<'de> for BrokerRegistrationRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::broker_registration_request::Feature

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::broker_registration_request::Listener

Source§

impl<'de> Decode<'de> for BrokerRegistrationResponse

Source§

impl<'de> Decode<'de> for AddPartitionsToTxnPartitionResult

Source§

impl<'de> Decode<'de> for AddPartitionsToTxnTopic

Source§

impl<'de> Decode<'de> for AddPartitionsToTxnTopicResult

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::common::assignment::Assignment

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::common::endpoint::Endpoint

Source§

impl<'de> Decode<'de> for KeyValue

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::common::replica_state::ReplicaState

Source§

impl<'de> Decode<'de> for Status

Source§

impl<'de> Decode<'de> for TaskIds

Source§

impl<'de> Decode<'de> for TaskOffset

Source§

impl<'de> Decode<'de> for TopicInfo

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::common::topic_partition::TopicPartition

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::common::topic_partitions::TopicPartitions

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::common::voter::Voter

Source§

impl<'de> Decode<'de> for ConsumerGroupDescribeRequest

Source§

impl<'de> Decode<'de> for ConsumerGroupDescribeResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::consumer_group_describe_response::DescribedGroup

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::consumer_group_describe_response::Member

Source§

impl<'de> Decode<'de> for ConsumerGroupHeartbeatRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::consumer_group_heartbeat_request::TopicPartitions

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::consumer_group_heartbeat_response::Assignment

Source§

impl<'de> Decode<'de> for ConsumerGroupHeartbeatResponse

Source§

impl<'de> Decode<'de> for ConsumerProtocolAssignment

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::consumer_protocol_assignment::TopicPartition

Source§

impl<'de> Decode<'de> for ConsumerProtocolSubscription

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::consumer_protocol_subscription::TopicPartition

Source§

impl<'de> Decode<'de> for ControlRecordTypeSchema

Source§

impl<'de> Decode<'de> for ControllerRegistrationRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::controller_registration_request::Feature

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::controller_registration_request::Listener

Source§

impl<'de> Decode<'de> for ControllerRegistrationResponse

Source§

impl<'de> Decode<'de> for AclCreation

Source§

impl<'de> Decode<'de> for CreateAclsRequest

Source§

impl<'de> Decode<'de> for AclCreationResult

Source§

impl<'de> Decode<'de> for CreateAclsResponse

Source§

impl<'de> Decode<'de> for CreatableRenewers

Source§

impl<'de> Decode<'de> for CreateDelegationTokenRequest

Source§

impl<'de> Decode<'de> for CreateDelegationTokenResponse

Source§

impl<'de> Decode<'de> for CreatePartitionsAssignment

Source§

impl<'de> Decode<'de> for CreatePartitionsRequest

Source§

impl<'de> Decode<'de> for CreatePartitionsTopic

Source§

impl<'de> Decode<'de> for CreatePartitionsResponse

Source§

impl<'de> Decode<'de> for CreatePartitionsTopicResult

Source§

impl<'de> Decode<'de> for CreatableReplicaAssignment

Source§

impl<'de> Decode<'de> for CreatableTopic

Source§

impl<'de> Decode<'de> for CreatableTopicConfig

Source§

impl<'de> Decode<'de> for CreateTopicsRequest

Source§

impl<'de> Decode<'de> for CreatableTopicConfigs

Source§

impl<'de> Decode<'de> for CreatableTopicResult

Source§

impl<'de> Decode<'de> for CreateTopicsResponse

Source§

impl<'de> Decode<'de> for DefaultPrincipalData

Source§

impl<'de> Decode<'de> for DeleteAclsFilter

Source§

impl<'de> Decode<'de> for DeleteAclsRequest

Source§

impl<'de> Decode<'de> for DeleteAclsFilterResult

Source§

impl<'de> Decode<'de> for DeleteAclsMatchingAcl

Source§

impl<'de> Decode<'de> for DeleteAclsResponse

Source§

impl<'de> Decode<'de> for DeleteGroupsRequest

Source§

impl<'de> Decode<'de> for DeletableGroupResult

Source§

impl<'de> Decode<'de> for DeleteGroupsResponse

Source§

impl<'de> Decode<'de> for DeleteRecordsPartition

Source§

impl<'de> Decode<'de> for DeleteRecordsRequest

Source§

impl<'de> Decode<'de> for DeleteRecordsTopic

Source§

impl<'de> Decode<'de> for DeleteRecordsPartitionResult

Source§

impl<'de> Decode<'de> for DeleteRecordsResponse

Source§

impl<'de> Decode<'de> for DeleteRecordsTopicResult

Source§

impl<'de> Decode<'de> for DeleteShareGroupOffsetsRequest

Source§

impl<'de> Decode<'de> for DeleteShareGroupOffsetsRequestTopic

Source§

impl<'de> Decode<'de> for DeleteShareGroupOffsetsResponse

Source§

impl<'de> Decode<'de> for DeleteShareGroupOffsetsResponseTopic

Source§

impl<'de> Decode<'de> for DeleteShareGroupStateRequest

Source§

impl<'de> Decode<'de> for DeleteStateData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::delete_share_group_state_request::PartitionData

Source§

impl<'de> Decode<'de> for DeleteShareGroupStateResponse

Source§

impl<'de> Decode<'de> for DeleteStateResult

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::delete_share_group_state_response::PartitionResult

Source§

impl<'de> Decode<'de> for DeleteTopicState

Source§

impl<'de> Decode<'de> for DeleteTopicsRequest

Source§

impl<'de> Decode<'de> for DeletableTopicResult

Source§

impl<'de> Decode<'de> for DeleteTopicsResponse

Source§

impl<'de> Decode<'de> for DescribeAclsRequest

Source§

impl<'de> Decode<'de> for AclDescription

Source§

impl<'de> Decode<'de> for DescribeAclsResource

Source§

impl<'de> Decode<'de> for DescribeAclsResponse

Source§

impl<'de> Decode<'de> for ComponentData

Source§

impl<'de> Decode<'de> for DescribeClientQuotasRequest

Source§

impl<'de> Decode<'de> for DescribeClientQuotasResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::describe_client_quotas_response::EntityData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::describe_client_quotas_response::EntryData

Source§

impl<'de> Decode<'de> for ValueData

Source§

impl<'de> Decode<'de> for DescribeClusterRequest

Source§

impl<'de> Decode<'de> for DescribeClusterBroker

Source§

impl<'de> Decode<'de> for DescribeClusterResponse

Source§

impl<'de> Decode<'de> for DescribeConfigsRequest

Source§

impl<'de> Decode<'de> for DescribeConfigsResource

Source§

impl<'de> Decode<'de> for DescribeConfigsResourceResult

Source§

impl<'de> Decode<'de> for DescribeConfigsResponse

Source§

impl<'de> Decode<'de> for DescribeConfigsResult

Source§

impl<'de> Decode<'de> for DescribeConfigsSynonym

Source§

impl<'de> Decode<'de> for DescribeDelegationTokenOwner

Source§

impl<'de> Decode<'de> for DescribeDelegationTokenRequest

Source§

impl<'de> Decode<'de> for DescribeDelegationTokenResponse

Source§

impl<'de> Decode<'de> for DescribedDelegationToken

Source§

impl<'de> Decode<'de> for DescribedDelegationTokenRenewer

Source§

impl<'de> Decode<'de> for DescribeGroupsRequest

Source§

impl<'de> Decode<'de> for DescribeGroupsResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::describe_groups_response::DescribedGroup

Source§

impl<'de> Decode<'de> for DescribedGroupMember

Source§

impl<'de> Decode<'de> for DescribableLogDirTopic

Source§

impl<'de> Decode<'de> for DescribeLogDirsRequest

Source§

impl<'de> Decode<'de> for DescribeLogDirsPartition

Source§

impl<'de> Decode<'de> for DescribeLogDirsResponse

Source§

impl<'de> Decode<'de> for DescribeLogDirsResult

Source§

impl<'de> Decode<'de> for DescribeLogDirsTopic

Source§

impl<'de> Decode<'de> for DescribeProducersRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::describe_producers_request::TopicRequest

Source§

impl<'de> Decode<'de> for DescribeProducersResponse

Source§

impl<'de> Decode<'de> for PartitionResponse

Source§

impl<'de> Decode<'de> for ProducerState

Source§

impl<'de> Decode<'de> for TopicResponse

Source§

impl<'de> Decode<'de> for DescribeQuorumRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::describe_quorum_request::PartitionData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::describe_quorum_request::TopicData

Source§

impl<'de> Decode<'de> for DescribeQuorumResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::describe_quorum_response::Listener

Source§

impl<'de> Decode<'de> for Node

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::describe_quorum_response::PartitionData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::describe_quorum_response::TopicData

Source§

impl<'de> Decode<'de> for DescribeShareGroupOffsetsRequest

Source§

impl<'de> Decode<'de> for DescribeShareGroupOffsetsRequestGroup

Source§

impl<'de> Decode<'de> for DescribeShareGroupOffsetsRequestTopic

Source§

impl<'de> Decode<'de> for DescribeShareGroupOffsetsResponse

Source§

impl<'de> Decode<'de> for DescribeShareGroupOffsetsResponseGroup

Source§

impl<'de> Decode<'de> for DescribeShareGroupOffsetsResponsePartition

Source§

impl<'de> Decode<'de> for DescribeShareGroupOffsetsResponseTopic

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::describe_topic_partitions_request::Cursor

Source§

impl<'de> Decode<'de> for DescribeTopicPartitionsRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::describe_topic_partitions_request::TopicRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::describe_topic_partitions_response::Cursor

Source§

impl<'de> Decode<'de> for DescribeTopicPartitionsResponse

Source§

impl<'de> Decode<'de> for DescribeTopicPartitionsResponsePartition

Source§

impl<'de> Decode<'de> for DescribeTopicPartitionsResponseTopic

Source§

impl<'de> Decode<'de> for DescribeTransactionsRequest

Source§

impl<'de> Decode<'de> for DescribeTransactionsResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::describe_transactions_response::TopicData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::describe_transactions_response::TransactionState

Source§

impl<'de> Decode<'de> for DescribeUserScramCredentialsRequest

Source§

impl<'de> Decode<'de> for UserName

Source§

impl<'de> Decode<'de> for CredentialInfo

Source§

impl<'de> Decode<'de> for DescribeUserScramCredentialsResponse

Source§

impl<'de> Decode<'de> for DescribeUserScramCredentialsResult

Source§

impl<'de> Decode<'de> for ElectLeadersRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::elect_leaders_request::TopicPartitions

Source§

impl<'de> Decode<'de> for ElectLeadersResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::elect_leaders_response::PartitionResult

Source§

impl<'de> Decode<'de> for ReplicaElectionResult

Source§

impl<'de> Decode<'de> for EndQuorumEpochRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::end_quorum_epoch_request::LeaderEndpoint

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::end_quorum_epoch_request::PartitionData

Source§

impl<'de> Decode<'de> for ReplicaInfo

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::end_quorum_epoch_request::TopicData

Source§

impl<'de> Decode<'de> for EndQuorumEpochResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::end_quorum_epoch_response::NodeEndpoint

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::end_quorum_epoch_response::PartitionData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::end_quorum_epoch_response::TopicData

Source§

impl<'de> Decode<'de> for EndTxnMarker

Source§

impl<'de> Decode<'de> for EndTxnRequest

Source§

impl<'de> Decode<'de> for EndTxnResponse

Source§

impl<'de> Decode<'de> for EnvelopeRequest

Source§

impl<'de> Decode<'de> for EnvelopeResponse

Source§

impl<'de> Decode<'de> for ExpireDelegationTokenRequest

Source§

impl<'de> Decode<'de> for ExpireDelegationTokenResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_request::FetchPartition

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_request::FetchRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_request::FetchTopic

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_request::ForgottenTopic

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_request::ReplicaState

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_response::AbortedTransaction

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_response::EpochEndOffset

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_response::FetchResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_response::FetchableTopicResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_response::LeaderIdAndEpoch

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_response::NodeEndpoint

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_response::PartitionData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_response::SnapshotId

Source§

impl<'de> Decode<'de> for FetchSnapshotRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_snapshot_request::PartitionSnapshot

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_snapshot_request::SnapshotId

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_snapshot_request::TopicSnapshot

Source§

impl<'de> Decode<'de> for FetchSnapshotResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_snapshot_response::LeaderIdAndEpoch

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_snapshot_response::NodeEndpoint

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_snapshot_response::PartitionSnapshot

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_snapshot_response::SnapshotId

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::fetch_snapshot_response::TopicSnapshot

Source§

impl<'de> Decode<'de> for FindCoordinatorRequest

Source§

impl<'de> Decode<'de> for Coordinator

Source§

impl<'de> Decode<'de> for FindCoordinatorResponse

Source§

impl<'de> Decode<'de> for GetReplicaLogInfoRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::get_replica_log_info_request::TopicPartitions

Source§

impl<'de> Decode<'de> for GetReplicaLogInfoResponse

Source§

impl<'de> Decode<'de> for PartitionLogInfo

Source§

impl<'de> Decode<'de> for TopicPartitionLogInfo

Source§

impl<'de> Decode<'de> for GetTelemetrySubscriptionsRequest

Source§

impl<'de> Decode<'de> for GetTelemetrySubscriptionsResponse

Source§

impl<'de> Decode<'de> for HeartbeatRequest

Source§

impl<'de> Decode<'de> for HeartbeatResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::incremental_alter_configs_request::AlterConfigsResource

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::incremental_alter_configs_request::AlterableConfig

Source§

impl<'de> Decode<'de> for IncrementalAlterConfigsRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::incremental_alter_configs_response::AlterConfigsResourceResponse

Source§

impl<'de> Decode<'de> for IncrementalAlterConfigsResponse

Source§

impl<'de> Decode<'de> for InitProducerIdRequest

Source§

impl<'de> Decode<'de> for InitProducerIdResponse

Source§

impl<'de> Decode<'de> for InitializeShareGroupStateRequest

Source§

impl<'de> Decode<'de> for InitializeStateData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::initialize_share_group_state_request::PartitionData

Source§

impl<'de> Decode<'de> for InitializeShareGroupStateResponse

Source§

impl<'de> Decode<'de> for InitializeStateResult

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::initialize_share_group_state_response::PartitionResult

Source§

impl<'de> Decode<'de> for JoinGroupRequest

Source§

impl<'de> Decode<'de> for JoinGroupRequestProtocol

Source§

impl<'de> Decode<'de> for JoinGroupResponse

Source§

impl<'de> Decode<'de> for JoinGroupResponseMember

Source§

impl<'de> Decode<'de> for KRaftVersionRecord

Source§

impl<'de> Decode<'de> for LeaderChangeMessage

Source§

impl<'de> Decode<'de> for LeaveGroupRequest

Source§

impl<'de> Decode<'de> for MemberIdentity

Source§

impl<'de> Decode<'de> for LeaveGroupResponse

Source§

impl<'de> Decode<'de> for MemberResponse

Source§

impl<'de> Decode<'de> for ListConfigResourcesRequest

Source§

impl<'de> Decode<'de> for ConfigResource

Source§

impl<'de> Decode<'de> for ListConfigResourcesResponse

Source§

impl<'de> Decode<'de> for ListGroupsRequest

Source§

impl<'de> Decode<'de> for ListGroupsResponse

Source§

impl<'de> Decode<'de> for ListedGroup

Source§

impl<'de> Decode<'de> for ListOffsetsPartition

Source§

impl<'de> Decode<'de> for ListOffsetsRequest

Source§

impl<'de> Decode<'de> for ListOffsetsTopic

Source§

impl<'de> Decode<'de> for ListOffsetsPartitionResponse

Source§

impl<'de> Decode<'de> for ListOffsetsResponse

Source§

impl<'de> Decode<'de> for ListOffsetsTopicResponse

Source§

impl<'de> Decode<'de> for ListPartitionReassignmentsRequest

Source§

impl<'de> Decode<'de> for ListPartitionReassignmentsTopics

Source§

impl<'de> Decode<'de> for ListPartitionReassignmentsResponse

Source§

impl<'de> Decode<'de> for OngoingPartitionReassignment

Source§

impl<'de> Decode<'de> for OngoingTopicReassignment

Source§

impl<'de> Decode<'de> for ListTransactionsRequest

Source§

impl<'de> Decode<'de> for ListTransactionsResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::list_transactions_response::TransactionState

Source§

impl<'de> Decode<'de> for MetadataRequest

Source§

impl<'de> Decode<'de> for MetadataRequestTopic

Source§

impl<'de> Decode<'de> for MetadataResponse

Source§

impl<'de> Decode<'de> for MetadataResponseBroker

Source§

impl<'de> Decode<'de> for MetadataResponsePartition

Source§

impl<'de> Decode<'de> for MetadataResponseTopic

Source§

impl<'de> Decode<'de> for OffsetCommitRequest

Source§

impl<'de> Decode<'de> for OffsetCommitRequestPartition

Source§

impl<'de> Decode<'de> for OffsetCommitRequestTopic

Source§

impl<'de> Decode<'de> for OffsetCommitResponse

Source§

impl<'de> Decode<'de> for OffsetCommitResponsePartition

Source§

impl<'de> Decode<'de> for OffsetCommitResponseTopic

Source§

impl<'de> Decode<'de> for OffsetDeleteRequest

Source§

impl<'de> Decode<'de> for OffsetDeleteRequestPartition

Source§

impl<'de> Decode<'de> for OffsetDeleteRequestTopic

Source§

impl<'de> Decode<'de> for OffsetDeleteResponse

Source§

impl<'de> Decode<'de> for OffsetDeleteResponsePartition

Source§

impl<'de> Decode<'de> for OffsetDeleteResponseTopic

Source§

impl<'de> Decode<'de> for OffsetFetchRequest

Source§

impl<'de> Decode<'de> for OffsetFetchRequestGroup

Source§

impl<'de> Decode<'de> for OffsetFetchRequestTopic

Source§

impl<'de> Decode<'de> for OffsetFetchRequestTopics

Source§

impl<'de> Decode<'de> for OffsetFetchResponse

Source§

impl<'de> Decode<'de> for OffsetFetchResponseGroup

Source§

impl<'de> Decode<'de> for OffsetFetchResponsePartition

Source§

impl<'de> Decode<'de> for OffsetFetchResponsePartitions

Source§

impl<'de> Decode<'de> for OffsetFetchResponseTopic

Source§

impl<'de> Decode<'de> for OffsetFetchResponseTopics

Source§

impl<'de> Decode<'de> for OffsetForLeaderEpochRequest

Source§

impl<'de> Decode<'de> for OffsetForLeaderPartition

Source§

impl<'de> Decode<'de> for OffsetForLeaderTopic

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::offset_for_leader_epoch_response::EpochEndOffset

Source§

impl<'de> Decode<'de> for OffsetForLeaderEpochResponse

Source§

impl<'de> Decode<'de> for OffsetForLeaderTopicResult

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::produce_request::PartitionProduceData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::produce_request::ProduceRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::produce_request::TopicProduceData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::produce_response::BatchIndexAndErrorMessage

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::produce_response::LeaderIdAndEpoch

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::produce_response::NodeEndpoint

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::produce_response::PartitionProduceResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::produce_response::ProduceResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::produce_response::TopicProduceResponse

Source§

impl<'de> Decode<'de> for PushTelemetryRequest

Source§

impl<'de> Decode<'de> for PushTelemetryResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::read_share_group_state_request::PartitionData

Source§

impl<'de> Decode<'de> for ReadShareGroupStateRequest

Source§

impl<'de> Decode<'de> for ReadStateData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::read_share_group_state_response::PartitionResult

Source§

impl<'de> Decode<'de> for ReadShareGroupStateResponse

Source§

impl<'de> Decode<'de> for ReadStateResult

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::read_share_group_state_response::StateBatch

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::read_share_group_state_summary_request::PartitionData

Source§

impl<'de> Decode<'de> for ReadShareGroupStateSummaryRequest

Source§

impl<'de> Decode<'de> for ReadStateSummaryData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::read_share_group_state_summary_response::PartitionResult

Source§

impl<'de> Decode<'de> for ReadShareGroupStateSummaryResponse

Source§

impl<'de> Decode<'de> for ReadStateSummaryResult

Source§

impl<'de> Decode<'de> for RemoveRaftVoterRequest

Source§

impl<'de> Decode<'de> for RemoveRaftVoterResponse

Source§

impl<'de> Decode<'de> for RenewDelegationTokenRequest

Source§

impl<'de> Decode<'de> for RenewDelegationTokenResponse

Source§

impl<'de> Decode<'de> for RequestHeader

Source§

impl<'de> Decode<'de> for ResponseHeader

Source§

impl<'de> Decode<'de> for SaslAuthenticateRequest

Source§

impl<'de> Decode<'de> for SaslAuthenticateResponse

Source§

impl<'de> Decode<'de> for SaslHandshakeRequest

Source§

impl<'de> Decode<'de> for SaslHandshakeResponse

Source§

impl<'de> Decode<'de> for AcknowledgePartition

Source§

impl<'de> Decode<'de> for AcknowledgeTopic

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::share_acknowledge_request::AcknowledgementBatch

Source§

impl<'de> Decode<'de> for ShareAcknowledgeRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::share_acknowledge_response::LeaderIdAndEpoch

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::share_acknowledge_response::NodeEndpoint

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::share_acknowledge_response::PartitionData

Source§

impl<'de> Decode<'de> for ShareAcknowledgeResponse

Source§

impl<'de> Decode<'de> for ShareAcknowledgeTopicResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::share_fetch_request::AcknowledgementBatch

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::share_fetch_request::FetchPartition

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::share_fetch_request::FetchTopic

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::share_fetch_request::ForgottenTopic

Source§

impl<'de> Decode<'de> for ShareFetchRequest

Source§

impl<'de> Decode<'de> for AcquiredRecords

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::share_fetch_response::LeaderIdAndEpoch

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::share_fetch_response::NodeEndpoint

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::share_fetch_response::PartitionData

Source§

impl<'de> Decode<'de> for ShareFetchResponse

Source§

impl<'de> Decode<'de> for ShareFetchableTopicResponse

Source§

impl<'de> Decode<'de> for ShareGroupDescribeRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::share_group_describe_response::DescribedGroup

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::share_group_describe_response::Member

Source§

impl<'de> Decode<'de> for ShareGroupDescribeResponse

Source§

impl<'de> Decode<'de> for ShareGroupHeartbeatRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::share_group_heartbeat_response::Assignment

Source§

impl<'de> Decode<'de> for ShareGroupHeartbeatResponse

Source§

impl<'de> Decode<'de> for SnapshotFooterRecord

Source§

impl<'de> Decode<'de> for SnapshotHeaderRecord

Source§

impl<'de> Decode<'de> for StreamsGroupDescribeRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::streams_group_describe_response::DescribedGroup

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::streams_group_describe_response::Member

Source§

impl<'de> Decode<'de> for StreamsGroupDescribeResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::streams_group_describe_response::Subtopology

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::streams_group_describe_response::Topology

Source§

impl<'de> Decode<'de> for CopartitionGroup

Source§

impl<'de> Decode<'de> for StreamsGroupHeartbeatRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::streams_group_heartbeat_request::Subtopology

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::streams_group_heartbeat_request::Topology

Source§

impl<'de> Decode<'de> for EndpointToPartitions

Source§

impl<'de> Decode<'de> for StreamsGroupHeartbeatResponse

Source§

impl<'de> Decode<'de> for SyncGroupRequest

Source§

impl<'de> Decode<'de> for SyncGroupRequestAssignment

Source§

impl<'de> Decode<'de> for SyncGroupResponse

Source§

impl<'de> Decode<'de> for TxnOffsetCommitRequest

Source§

impl<'de> Decode<'de> for TxnOffsetCommitRequestPartition

Source§

impl<'de> Decode<'de> for TxnOffsetCommitRequestTopic

Source§

impl<'de> Decode<'de> for TxnOffsetCommitResponse

Source§

impl<'de> Decode<'de> for TxnOffsetCommitResponsePartition

Source§

impl<'de> Decode<'de> for TxnOffsetCommitResponseTopic

Source§

impl<'de> Decode<'de> for UnregisterBrokerRequest

Source§

impl<'de> Decode<'de> for UnregisterBrokerResponse

Source§

impl<'de> Decode<'de> for FeatureUpdateKey

Source§

impl<'de> Decode<'de> for UpdateFeaturesRequest

Source§

impl<'de> Decode<'de> for UpdatableFeatureResult

Source§

impl<'de> Decode<'de> for UpdateFeaturesResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::update_raft_voter_request::KRaftVersionFeature

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::update_raft_voter_request::Listener

Source§

impl<'de> Decode<'de> for UpdateRaftVoterRequest

Source§

impl<'de> Decode<'de> for CurrentLeader

Source§

impl<'de> Decode<'de> for UpdateRaftVoterResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::vote_request::PartitionData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::vote_request::TopicData

Source§

impl<'de> Decode<'de> for VoteRequest

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::vote_response::NodeEndpoint

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::vote_response::PartitionData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::vote_response::TopicData

Source§

impl<'de> Decode<'de> for VoteResponse

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::voters_record::Endpoint

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::voters_record::KRaftVersionFeature

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::voters_record::Voter

Source§

impl<'de> Decode<'de> for VotersRecord

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::write_share_group_state_request::PartitionData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::write_share_group_state_request::StateBatch

Source§

impl<'de> Decode<'de> for WriteShareGroupStateRequest

Source§

impl<'de> Decode<'de> for WriteStateData

Source§

impl<'de> Decode<'de> for crabka_protocol::owned::write_share_group_state_response::PartitionResult

Source§

impl<'de> Decode<'de> for WriteShareGroupStateResponse

Source§

impl<'de> Decode<'de> for WriteStateResult

Source§

impl<'de> Decode<'de> for WritableTxnMarker

Source§

impl<'de> Decode<'de> for WritableTxnMarkerTopic

Source§

impl<'de> Decode<'de> for WriteTxnMarkersRequest

Source§

impl<'de> Decode<'de> for WritableTxnMarkerPartitionResult

Source§

impl<'de> Decode<'de> for WritableTxnMarkerResult

Source§

impl<'de> Decode<'de> for WritableTxnMarkerTopicResult

Source§

impl<'de> Decode<'de> for WriteTxnMarkersResponse