[−][src]Trait kf_protocol::Decoder
Required methods
Loading content...Provided methods
fn decode_from<T>(src: &mut T, version: i16) -> Result<Self, Error> where
Self: Default,
T: Buf,
Self: Default,
T: Buf,
decode Kafka compliant protocol values from buf
Implementations on Foreign Types
impl Decoder for Option<u16>
[src]
impl Decoder for i32
[src]
impl<M> Decoder for PhantomData<M> where
M: Default + Decoder,
[src]
M: Default + Decoder,
default fn decode<T>(
&mut self,
_src: &mut T,
_version: i16
) -> Result<(), Error> where
T: Buf,
[src]
&mut self,
_src: &mut T,
_version: i16
) -> Result<(), Error> where
T: Buf,
impl<M> Decoder for Vec<M> where
M: Default + Decoder,
[src]
M: Default + Decoder,
impl Decoder for u8
[src]
impl Decoder for u32
[src]
impl<M> Decoder for Option<Vec<M>> where
M: Default + Decoder,
[src]
M: Default + Decoder,
impl Decoder for i64
[src]
impl Decoder for i16
[src]
impl<K, V> Decoder for BTreeMap<K, V> where
K: Decoder + Ord,
V: Decoder,
[src]
K: Decoder + Ord,
V: Decoder,
impl Decoder for Vec<u8>
[src]
impl Decoder for bool
[src]
impl<M> Decoder for Option<M> where
M: Default + Decoder,
[src]
M: Default + Decoder,
impl Decoder for String
[src]
impl Decoder for Option<String>
[src]
impl Decoder for i8
[src]
impl Decoder for u16
[src]
Loading content...Implementors
impl Decoder for AllKfApiKey
[src]
impl Decoder for ErrorCode
[src]
impl Decoder for FlvErrorCode
[src]
impl Decoder for Isolation
[src]
impl Decoder for GroupAssignment
[src]
impl Decoder for ProtocolMetadata
[src]
impl Decoder for RecordHeader
[src]
impl Decoder for RecordSet
[src]
impl Decoder for ReplicaKey
[src]
impl Decoder for RequestHeader
[src]
impl Decoder for KfFileRecordSet
[src]
impl Decoder for ApiVersionsResponseKey
[src]
impl Decoder for KfApiVersionsRequest
[src]
impl Decoder for KfApiVersionsResponse
[src]
impl Decoder for AbortedTransaction
[src]
impl Decoder for FetchPartition
[src]
impl Decoder for FetchableTopic
[src]
impl Decoder for ForgottenTopic
[src]
impl Decoder for DeletableGroupResult
[src]
impl Decoder for DescribedGroup
[src]
impl Decoder for DescribedGroupMember
[src]
impl Decoder for JoinGroupRequestProtocol
[src]
impl Decoder for JoinGroupResponseMember
[src]
impl Decoder for KfDeleteGroupsRequest
[src]
impl Decoder for KfDeleteGroupsResponse
[src]
impl Decoder for KfDescribeGroupsRequest
[src]
impl Decoder for KfDescribeGroupsResponse
[src]
impl Decoder for KfFindCoordinatorRequest
[src]
impl Decoder for KfFindCoordinatorResponse
[src]
impl Decoder for KfHeartbeatRequest
[src]
impl Decoder for KfHeartbeatResponse
[src]
impl Decoder for KfJoinGroupRequest
[src]
impl Decoder for KfJoinGroupResponse
[src]
impl Decoder for KfLeaveGroupRequest
[src]
impl Decoder for KfLeaveGroupResponse
[src]
impl Decoder for KfListGroupsRequest
[src]
impl Decoder for KfListGroupsResponse
[src]
impl Decoder for KfSyncGroupRequest
[src]
impl Decoder for KfSyncGroupResponse
[src]
impl Decoder for ListedGroup
[src]
impl Decoder for SyncGroupRequestAssignment
[src]
impl Decoder for KfLeaderAndIsrRequest
[src]
impl Decoder for KfLeaderAndIsrResponse
[src]
impl Decoder for LeaderAndIsrLiveLeader
[src]
impl Decoder for LeaderAndIsrRequestPartitionState
[src]
impl Decoder for LeaderAndIsrRequestPartitionStateV0
[src]
impl Decoder for LeaderAndIsrRequestTopicState
[src]
impl Decoder for LeaderAndIsrResponsePartition
[src]
impl Decoder for KfMetadataRequest
[src]
impl Decoder for KfMetadataResponse
[src]
impl Decoder for KfUpdateMetadataRequest
[src]
impl Decoder for KfUpdateMetadataResponse
[src]
impl Decoder for MetadataRequestTopic
[src]
impl Decoder for MetadataResponseBroker
[src]
impl Decoder for MetadataResponsePartition
[src]
impl Decoder for MetadataResponseTopic
[src]
impl Decoder for UpdateMetadataPartitionState
[src]
impl Decoder for UpdateMetadataRequestBroker
[src]
impl Decoder for UpdateMetadataRequestEndpoint
[src]
impl Decoder for UpdateMetadataRequestPartitionStateV0
[src]
impl Decoder for UpdateMetadataRequestTopicState
[src]
impl Decoder for KfListOffsetRequest
[src]
impl Decoder for KfListOffsetResponse
[src]
impl Decoder for KfOffsetFetchRequest
[src]
impl Decoder for KfOffsetFetchResponse
[src]
impl Decoder for ListOffsetPartition
[src]
impl Decoder for ListOffsetPartitionResponse
[src]
impl Decoder for ListOffsetTopic
[src]
impl Decoder for ListOffsetTopicResponse
[src]
impl Decoder for OffsetFetchRequestTopic
[src]
impl Decoder for OffsetFetchResponsePartition
[src]
impl Decoder for OffsetFetchResponseTopic
[src]
impl Decoder for KfProduceResponse
[src]
impl Decoder for PartitionProduceResponse
[src]
impl Decoder for TopicProduceResponse
[src]
impl Decoder for CreatableReplicaAssignment
[src]
impl Decoder for CreatableTopic
[src]
impl Decoder for CreatableTopicResult
[src]
impl Decoder for CreateableTopicConfig
[src]
impl Decoder for DeletableTopicResult
[src]
impl Decoder for KfCreateTopicsRequest
[src]
impl Decoder for KfCreateTopicsResponse
[src]
impl Decoder for KfDeleteTopicsRequest
[src]
impl Decoder for KfDeleteTopicsResponse
[src]
impl<B> Decoder for Record<B> where
B: Decoder,
[src]
B: Decoder,
impl<R> Decoder for Batch<R> where
R: BatchRecords,
[src]
R: BatchRecords,
impl<R> Decoder for RequestMessage<R> where
R: Request,
[src]
R: Request,
impl<R> Decoder for FetchablePartitionResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
impl<R> Decoder for FetchableTopicResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
impl<R> Decoder for KfFetchRequest<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
impl<R> Decoder for KfFetchResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
impl<R> Decoder for KfProduceRequest<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
impl<R> Decoder for PartitionProduceData<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
impl<R> Decoder for TopicProduceData<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,