Trait kf_protocol::Encoder

pub trait Encoder {
    fn write_size(&self, version: i16) -> usize;
    fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error>
    where
        T: BufMut;

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

Required methods

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

size of this object in bytes

fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
    T: BufMut, 

encoding contents for buffer

Loading content...

Provided methods

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

Loading content...

Implementations on Foreign Types

impl<M> Encoder for Vec<M> where
    M: Encoder, 

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

fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
    T: BufMut, 

impl Encoder for Option<u16>

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

fn encode<T>(&self, dest: &mut T, _version: i16) -> Result<(), Error> where
    T: BufMut, 

impl Encoder for bool

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

fn encode<T>(&self, dest: &mut T, _version: i16) -> Result<(), Error> where
    T: BufMut, 

impl Encoder for i64

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

fn encode<T>(&self, dest: &mut T, _version: i16) -> Result<(), Error> where
    T: BufMut, 

impl Encoder for String

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

fn encode<T>(&self, dest: &mut T, _version: i16) -> Result<(), Error> where
    T: BufMut, 

impl<M> Encoder for Option<M> where
    M: Encoder, 

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

default fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
    T: BufMut, 

impl Encoder for u32

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

fn encode<T>(&self, dest: &mut T, _version: i16) -> Result<(), Error> where
    T: BufMut, 

impl<M> Encoder for Option<Vec<M>> where
    M: Encoder, 

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

fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
    T: BufMut, 

impl Encoder for Option<String>

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

fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
    T: BufMut, 

impl Encoder for i8

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

fn encode<T>(&self, dest: &mut T, _version: i16) -> Result<(), Error> where
    T: BufMut, 

impl<M> Encoder for PhantomData<M> where
    M: Encoder, 

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

fn encode<T>(&self, _dest: &mut T, _version: i16) -> Result<(), Error> where
    T: BufMut, 

impl Encoder for i16

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

fn encode<T>(&self, dest: &mut T, _version: i16) -> Result<(), Error> where
    T: BufMut, 

impl Encoder for u16

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

fn encode<T>(&self, dest: &mut T, _version: i16) -> Result<(), Error> where
    T: BufMut, 

impl Encoder for u8

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

fn encode<T>(&self, dest: &mut T, _version: i16) -> Result<(), Error> where
    T: BufMut, 

impl<K, V> Encoder for BTreeMap<K, V> where
    K: Encoder,
    V: Encoder, 

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

fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
    T: BufMut, 

impl Encoder for i32

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

fn encode<T>(&self, dest: &mut T, _version: i16) -> Result<(), Error> where
    T: BufMut, 

Loading content...

Implementors

impl Encoder for AllKfApiKey

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

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

impl Encoder for ErrorCode

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

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

impl Encoder for FlvErrorCode

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

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

impl Encoder for Isolation

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

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

impl Encoder for DefaultRecords

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

fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
    T: BufMut, 

impl Encoder for GroupAssignment

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

fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
    T: BufMut, 

impl Encoder for ProtocolMetadata

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

fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
    T: BufMut, 

impl Encoder for RecordHeader

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

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

impl Encoder for RequestHeader

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

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

impl Encoder for KfFileRecordSet

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

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

impl Encoder for ApiVersionsResponseKey

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

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

impl Encoder for KfApiVersionsRequest

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

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

impl Encoder for KfApiVersionsResponse

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

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

impl Encoder for AbortedTransaction

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

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

impl Encoder for FetchPartition

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

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

impl Encoder for FetchableTopic

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

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

impl Encoder for ForgottenTopic

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

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

impl Encoder for DeletableGroupResult

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

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

impl Encoder for DescribedGroup

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

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

impl Encoder for DescribedGroupMember

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

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

impl Encoder for JoinGroupRequestProtocol

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

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

impl Encoder for JoinGroupResponseMember

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

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

impl Encoder for KfDeleteGroupsRequest

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

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

impl Encoder for KfDeleteGroupsResponse

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

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

impl Encoder for KfDescribeGroupsRequest

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

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

impl Encoder for KfDescribeGroupsResponse

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

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

impl Encoder for KfFindCoordinatorRequest

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

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

impl Encoder for KfFindCoordinatorResponse

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

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

impl Encoder for KfHeartbeatRequest

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

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

impl Encoder for KfHeartbeatResponse

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

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

impl Encoder for KfJoinGroupRequest

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

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

impl Encoder for KfJoinGroupResponse

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

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

impl Encoder for KfLeaveGroupRequest

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

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

impl Encoder for KfLeaveGroupResponse

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

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

impl Encoder for KfListGroupsRequest

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

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

impl Encoder for KfListGroupsResponse

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

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

impl Encoder for KfSyncGroupRequest

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

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

impl Encoder for KfSyncGroupResponse

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

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

impl Encoder for ListedGroup

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

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

impl Encoder for SyncGroupRequestAssignment

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

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

impl Encoder for KfLeaderAndIsrRequest

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

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

impl Encoder for KfLeaderAndIsrResponse

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

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

impl Encoder for LeaderAndIsrLiveLeader

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

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

impl Encoder for LeaderAndIsrRequestPartitionState

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

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

impl Encoder for LeaderAndIsrRequestPartitionStateV0

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

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

impl Encoder for LeaderAndIsrRequestTopicState

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

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

impl Encoder for LeaderAndIsrResponsePartition

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

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

impl Encoder for KfMetadataRequest

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

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

impl Encoder for KfMetadataResponse

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

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

impl Encoder for KfUpdateMetadataRequest

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

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

impl Encoder for KfUpdateMetadataResponse

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

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

impl Encoder for MetadataRequestTopic

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

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

impl Encoder for MetadataResponseBroker

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

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

impl Encoder for MetadataResponsePartition

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

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

impl Encoder for MetadataResponseTopic

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

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

impl Encoder for UpdateMetadataPartitionState

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

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

impl Encoder for UpdateMetadataRequestBroker

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

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

impl Encoder for UpdateMetadataRequestEndpoint

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

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

impl Encoder for UpdateMetadataRequestPartitionStateV0

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

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

impl Encoder for UpdateMetadataRequestTopicState

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

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

impl Encoder for KfListOffsetRequest

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

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

impl Encoder for KfListOffsetResponse

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

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

impl Encoder for KfOffsetFetchRequest

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

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

impl Encoder for KfOffsetFetchResponse

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

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

impl Encoder for ListOffsetPartition

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

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

impl Encoder for ListOffsetPartitionResponse

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

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

impl Encoder for ListOffsetTopic

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

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

impl Encoder for ListOffsetTopicResponse

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

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

impl Encoder for OffsetFetchRequestTopic

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

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

impl Encoder for OffsetFetchResponsePartition

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

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

impl Encoder for OffsetFetchResponseTopic

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

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

impl Encoder for KfProduceResponse

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

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

impl Encoder for PartitionProduceResponse

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

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

impl Encoder for TopicProduceResponse

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

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

impl Encoder for CreatableReplicaAssignment

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

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

impl Encoder for CreatableTopic

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

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

impl Encoder for CreatableTopicResult

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

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

impl Encoder for CreateableTopicConfig

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

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

impl Encoder for DeletableTopicResult

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

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

impl Encoder for KfCreateTopicsRequest

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

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

impl Encoder for KfCreateTopicsResponse

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

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

impl Encoder for KfDeleteTopicsRequest

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

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

impl Encoder for KfDeleteTopicsResponse

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

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

impl<B> Encoder for Record<B> where
    B: Encoder + Default, 

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

fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
    T: BufMut, 

impl<P> Encoder for ResponseMessage<P> where
    P: Encoder + Default, 

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

fn encode<T>(&self, out: &mut T, version: i16) -> Result<(), Error> where
    T: BufMut, 

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

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

fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
    T: BufMut, 

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

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

fn encode<T>(&self, out: &mut T, version: i16) -> Result<(), Error> where
    T: BufMut, 

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Loading content...