Trait kf_protocol::Decoder

pub trait Decoder: Default {
    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,
    { ... }
}

Required methods

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

Loading content...

Provided methods

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

decode Kafka compliant protocol values from buf

Loading content...

Implementations on Foreign Types

impl Decoder for String

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

impl<M> Decoder for Vec<M> where
    M: Default + Decoder, 

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

impl Decoder for i64

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

impl Decoder for bool

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

impl Decoder for u8

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

impl<K, V> Decoder for BTreeMap<K, V> where
    K: Decoder + Ord,
    V: Decoder, 

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

impl<M> Decoder for Option<M> where
    M: Default + Decoder, 

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

impl<M> Decoder for PhantomData<M> where
    M: Default + Decoder, 

default fn decode<T>(
    &mut self,
    _src: &mut T,
    _version: i16
) -> Result<(), Error> where
    T: Buf, 

impl Decoder for u16

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

impl Decoder for i16

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

impl<M> Decoder for Option<Vec<M>> where
    M: Default + Decoder, 

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

impl Decoder for u32

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

impl Decoder for i8

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

impl Decoder for i32

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

impl Decoder for Option<String>

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

impl Decoder for Vec<u8>

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

impl Decoder for Option<u16>

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

Loading content...

Implementors

impl Decoder for AllKfApiKey

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

impl Decoder for ErrorCode

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

impl Decoder for FlvErrorCode

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

impl Decoder for Isolation

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

impl Decoder for DefaultRecords

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

impl Decoder for GroupAssignment

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

impl Decoder for ProtocolMetadata

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

impl Decoder for RecordHeader

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

impl Decoder for RequestHeader

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

impl Decoder for KfFileRecordSet

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

impl Decoder for ApiVersionsResponseKey

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

impl Decoder for KfApiVersionsRequest

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

impl Decoder for KfApiVersionsResponse

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

impl Decoder for AbortedTransaction

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

impl Decoder for FetchPartition

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

impl Decoder for FetchableTopic

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

impl Decoder for ForgottenTopic

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

impl Decoder for DeletableGroupResult

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

impl Decoder for DescribedGroup

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

impl Decoder for DescribedGroupMember

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

impl Decoder for JoinGroupRequestProtocol

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

impl Decoder for JoinGroupResponseMember

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

impl Decoder for KfDeleteGroupsRequest

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

impl Decoder for KfDeleteGroupsResponse

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

impl Decoder for KfDescribeGroupsRequest

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

impl Decoder for KfDescribeGroupsResponse

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

impl Decoder for KfFindCoordinatorRequest

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

impl Decoder for KfFindCoordinatorResponse

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

impl Decoder for KfHeartbeatRequest

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

impl Decoder for KfHeartbeatResponse

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

impl Decoder for KfJoinGroupRequest

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

impl Decoder for KfJoinGroupResponse

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

impl Decoder for KfLeaveGroupRequest

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

impl Decoder for KfLeaveGroupResponse

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

impl Decoder for KfListGroupsRequest

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

impl Decoder for KfListGroupsResponse

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

impl Decoder for KfSyncGroupRequest

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

impl Decoder for KfSyncGroupResponse

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

impl Decoder for ListedGroup

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

impl Decoder for SyncGroupRequestAssignment

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

impl Decoder for KfLeaderAndIsrRequest

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

impl Decoder for KfLeaderAndIsrResponse

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

impl Decoder for LeaderAndIsrLiveLeader

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

impl Decoder for LeaderAndIsrRequestPartitionState

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

impl Decoder for LeaderAndIsrRequestPartitionStateV0

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

impl Decoder for LeaderAndIsrRequestTopicState

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

impl Decoder for LeaderAndIsrResponsePartition

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

impl Decoder for KfMetadataRequest

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

impl Decoder for KfMetadataResponse

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

impl Decoder for KfUpdateMetadataRequest

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

impl Decoder for KfUpdateMetadataResponse

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

impl Decoder for MetadataRequestTopic

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

impl Decoder for MetadataResponseBroker

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

impl Decoder for MetadataResponsePartition

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

impl Decoder for MetadataResponseTopic

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

impl Decoder for UpdateMetadataPartitionState

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

impl Decoder for UpdateMetadataRequestBroker

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

impl Decoder for UpdateMetadataRequestEndpoint

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

impl Decoder for UpdateMetadataRequestPartitionStateV0

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

impl Decoder for UpdateMetadataRequestTopicState

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

impl Decoder for KfListOffsetRequest

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

impl Decoder for KfListOffsetResponse

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

impl Decoder for KfOffsetFetchRequest

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

impl Decoder for KfOffsetFetchResponse

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

impl Decoder for ListOffsetPartition

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

impl Decoder for ListOffsetPartitionResponse

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

impl Decoder for ListOffsetTopic

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

impl Decoder for ListOffsetTopicResponse

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

impl Decoder for OffsetFetchRequestTopic

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

impl Decoder for OffsetFetchResponsePartition

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

impl Decoder for OffsetFetchResponseTopic

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

impl Decoder for KfProduceResponse

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

impl Decoder for PartitionProduceResponse

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

impl Decoder for TopicProduceResponse

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

impl Decoder for CreatableReplicaAssignment

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

impl Decoder for CreatableTopic

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

impl Decoder for CreatableTopicResult

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

impl Decoder for CreateableTopicConfig

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

impl Decoder for DeletableTopicResult

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

impl Decoder for KfCreateTopicsRequest

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

impl Decoder for KfCreateTopicsResponse

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

impl Decoder for KfDeleteTopicsRequest

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

impl Decoder for KfDeleteTopicsResponse

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

impl<B> Decoder for Record<B> where
    B: Decoder, 

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

impl<R> Decoder for Batch<R> where
    R: BatchRecords, 

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

impl<R> Decoder for RequestMessage<R> where
    R: Request, 

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

impl<R> Decoder for FetchablePartitionResponse<R> where
    R: Encoder + Decoder + Default + Debug, 

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

impl<R> Decoder for FetchableTopicResponse<R> where
    R: Encoder + Decoder + Default + Debug, 

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

impl<R> Decoder for KfFetchRequest<R> where
    R: Encoder + Decoder + Default + Debug, 

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

impl<R> Decoder for KfFetchResponse<R> where
    R: Encoder + Decoder + Default + Debug, 

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

impl<R> Decoder for KfProduceRequest<R> where
    R: Encoder + Decoder + Default + Debug, 

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

impl<R> Decoder for PartitionProduceData<R> where
    R: Encoder + Decoder + Default + Debug, 

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

impl<R> Decoder for TopicProduceData<R> where
    R: Encoder + Decoder + Default + Debug, 

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

Loading content...