Trait fluvio::dataplane::core::Encoder

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

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

Required methods

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

size of this object in bytes

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

encoding contents for buffer

Loading content...

Provided methods

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

Loading content...

Implementations on Foreign Types

impl Encoder for u8

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

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

impl Encoder for i16

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

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

impl Encoder for i32

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

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

impl Encoder for i64

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

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

impl Encoder for u32

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

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

impl Encoder for u16

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

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

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

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

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

impl Encoder for bool

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

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

impl Encoder for i8

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

pub 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, 

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

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

impl Encoder for String

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

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

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

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

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

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

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

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

impl Encoder for Status

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

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

impl Encoder for AdminPublicApiKey

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

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

impl Encoder for AdminPublicRequest

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

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

impl<C> Encoder for Message<C> where
    C: Encoder + Decoder + Debug, 

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

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

impl Encoder for ReplicaMsgs

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

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

impl Encoder for MsgType

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

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

impl Encoder for FetchOffsetsResponse

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

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

impl Encoder for ReplicaOffsetUpdateResponse

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

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

impl Encoder for SpuServerRequest

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

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

impl Encoder for FetchOffsetPartition

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

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

impl Encoder for FetchOffsetPartitionResponse

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

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

impl Encoder for FetchOffsetsRequest

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

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

impl Encoder for SpuClientRequest

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

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

impl Encoder for SpuServerApiKey

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

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

impl Encoder for UpdateOffsetsRequest

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

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

impl Encoder for UpdateOffsetsResponse

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

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

impl Encoder for OffsetUpdateStatus

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

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

impl Encoder for FetchOffsetTopic

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

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

impl Encoder for ReplicaOffsetUpdateRequest

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

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

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

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

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

impl Encoder for ReplicaOffsetUpdate

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

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

impl Encoder for FetchOffsetTopicResponse

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

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

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

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

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

impl Encoder for OffsetUpdate

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

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

impl Encoder for SpuClientApiKey

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

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

Loading content...

Implementors

impl Encoder for ErrorCode

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

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

impl Encoder for Isolation

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

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

impl Encoder for AllCreatableSpec

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

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

impl Encoder for DeleteRequest

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

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

impl Encoder for ListRequest

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

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

impl Encoder for ListResponse

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

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

impl Encoder for WatchRequest

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

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

impl Encoder for WatchResponse

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

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

impl Encoder for PartitionResolution

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

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

impl Encoder for SpuGroupStatusResolution

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

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

impl Encoder for CustomSpu

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

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

impl Encoder for CustomSpuKey

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

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

impl Encoder for EncryptionEnum

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

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

impl Encoder for SpuStatusResolution

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

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

impl Encoder for SpuType

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

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

impl Encoder for TopicResolution

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

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

impl Encoder for TopicSpec

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

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

impl Encoder for BatchHeader

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

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

impl Encoder for RequestHeader

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

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

impl Encoder for AbortedTransaction

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

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

impl Encoder for FetchPartition

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

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

impl Encoder for FetchableTopic

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

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

impl Encoder for ForgottenTopic

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

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

impl Encoder for PartitionProduceResponse

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

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

impl Encoder for ProduceResponse

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

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

impl Encoder for TopicProduceResponse

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

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

impl Encoder for DefaultAsyncBuffer

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

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

impl Encoder for FileRecordSet

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

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

impl Encoder for RecordHeader

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

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

impl Encoder for RecordSet

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

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

impl Encoder for ReplicaKey

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

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

impl Encoder for ApiVersionKey

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

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

impl Encoder for ApiVersionsRequest

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

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

impl Encoder for ApiVersionsResponse

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

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

impl Encoder for PlatformVersion

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

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

impl Encoder for CreateRequest

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

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

impl Encoder for PartitionSpec

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

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

impl Encoder for PartitionStatus

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

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

impl Encoder for Replica

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

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

impl Encoder for ReplicaLeader

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

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

impl Encoder for ReplicaStatus

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

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

impl Encoder for EnvVar

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

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

impl Encoder for ReplicationConfig

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

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

impl Encoder for SpuConfig

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

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

impl Encoder for SpuGroupSpec

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

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

impl Encoder for SpuGroupStatus

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

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

impl Encoder for StorageConfig

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

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

impl Encoder for CustomSpuSpec

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

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

impl Encoder for Endpoint

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

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

impl Encoder for IngressAddr

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

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

impl Encoder for IngressPort

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

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

impl Encoder for SpuSpec

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

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

impl Encoder for SpuStatus

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

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

impl Encoder for PartitionMap

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

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

impl Encoder for PartitionMaps

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

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

impl Encoder for TopicReplicaParam

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

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

impl Encoder for TopicStatus

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

impl<S> Encoder for Metadata<S> where
    S: Spec + Debug + Encoder + Decoder,
    <S as Spec>::Status: Debug,
    <S as Spec>::Status: Encoder,
    <S as Spec>::Status: Decoder, 

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

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

impl<S> Encoder for MetadataUpdate<S> where
    S: Spec + Debug + Encoder + Decoder,
    <S as Spec>::Status: Debug,
    <S as Spec>::Status: Encoder,
    <S as Spec>::Status: Decoder, 

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

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

Loading content...