Trait fluvio::dataplane::Encoder

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

    // Provided method
    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

Provided Methods

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

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl Encoder for MsgType

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

where T: BufMut,

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

impl Encoder for RemoteType

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

where T: BufMut,

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

impl Encoder for ConnectionStatus

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

where T: BufMut,

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

impl Encoder for RemotePairStatus

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

where T: BufMut,

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

impl Encoder for CustomSpu

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

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

where T: BufMut,

impl Encoder for EncryptionEnum

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

where T: BufMut,

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

impl Encoder for SpuType

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

where T: BufMut,

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

impl Encoder for SpuStatusResolution

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

where T: BufMut,

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

impl Encoder for AdminPublicApiKey

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

where T: BufMut,

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

impl Encoder for SmartModuleInitErrorStatus

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

where T: BufMut,

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

impl Encoder for SmartModuleLookbackErrorStatus

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

where T: BufMut,

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

impl Encoder for SmartModuleTransformErrorStatus

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

where T: BufMut,

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

impl Encoder for SpuClientRequest

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

where T: BufMut,

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

impl Encoder for SpuClientApiKey

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

where T: BufMut,

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

impl Encoder for SpuServerRequest

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

where T: BufMut,

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

impl Encoder for SpuServerApiKey

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

where T: BufMut,

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

impl Encoder for SmartModuleWasmCompressed

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

where T: BufMut,

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

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 f32

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

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

where T: BufMut,

impl Encoder for f64

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 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 i32

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 u8

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 u32

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

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

where T: BufMut,

impl Encoder for u64

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 Encoder for Duration

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

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

where T: BufMut,

impl Encoder for Core

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

where T: BufMut,

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

impl Encoder for Edge

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

where T: BufMut,

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

impl Encoder for RemoteSpec

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

where T: BufMut,

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

impl Encoder for ConnectionStat

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

where T: BufMut,

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

impl Encoder for RemoteStatus

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

where T: BufMut,

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

impl Encoder for Endpoint

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

where T: BufMut,

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

impl Encoder for IngressAddr

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

where T: BufMut,

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

impl Encoder for IngressPort

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

where T: BufMut,

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

impl Encoder for SpuStatus

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

where T: BufMut,

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

impl Encoder for Status

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

where T: BufMut,

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

impl Encoder for Lookback

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

where T: BufMut,

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

impl Encoder for SmartModuleAggregateInput

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

where T: BufMut,

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

impl Encoder for SmartModuleInitInput

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

where T: BufMut,

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

impl Encoder for SmartModuleInput

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

where T: BufMut,

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

impl Encoder for SmartModuleAggregateOutput

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

where T: BufMut,

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

impl Encoder for SmartModuleInitOutput

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

where T: BufMut,

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

impl Encoder for SmartModuleLookbackOutput

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

where T: BufMut,

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

impl Encoder for SmartModuleOutput

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

where T: BufMut,

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

impl Encoder for ReplicaOffsetUpdate

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

where T: BufMut,

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

impl Encoder for ReplicaOffsetUpdateRequest

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

where T: BufMut,

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

impl Encoder for ReplicaOffsetUpdateResponse

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

where T: BufMut,

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

impl Encoder for FetchPartition

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

where T: BufMut,

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

impl Encoder for FetchableTopic

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

where T: BufMut,

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

impl Encoder for ForgottenTopic

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

where T: BufMut,

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

impl Encoder for AbortedTransaction

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

where T: BufMut,

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

impl Encoder for FileRecordSet

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

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

where T: BufMut,

impl Encoder for PartitionProduceResponse

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

where T: BufMut,

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

impl Encoder for ProduceResponse

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

where T: BufMut,

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

impl Encoder for TopicProduceResponse

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

where T: BufMut,

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

impl Encoder for ConsumerOffset

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

where T: BufMut,

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

impl Encoder for DeleteConsumerOffsetRequest

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

where T: BufMut,

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

impl Encoder for DeleteConsumerOffsetResponse

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

where T: BufMut,

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

impl Encoder for FetchConsumerOffsetsRequest

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

where T: BufMut,

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

impl Encoder for FetchConsumerOffsetsResponse

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

where T: BufMut,

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

impl Encoder for UpdateConsumerOffsetRequest

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

where T: BufMut,

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

impl Encoder for UpdateConsumerOffsetResponse

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

where T: BufMut,

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

impl Encoder for FetchOffsetPartition

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

where T: BufMut,

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

impl Encoder for FetchOffsetPartitionResponse

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

where T: BufMut,

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

impl Encoder for FetchOffsetTopic

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

where T: BufMut,

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

impl Encoder for FetchOffsetTopicResponse

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

where T: BufMut,

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

impl Encoder for FetchOffsetsRequest

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

where T: BufMut,

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

impl Encoder for FetchOffsetsResponse

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

where T: BufMut,

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

impl Encoder for OffsetUpdate

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

where T: BufMut,

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

impl Encoder for OffsetUpdateStatus

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

where T: BufMut,

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

impl Encoder for UpdateOffsetsRequest

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

where T: BufMut,

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

impl Encoder for UpdateOffsetsResponse

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

where T: BufMut,

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

impl<C> Encoder for Message<C>

where C: Encoder,

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

where T: BufMut,

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

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<M> Encoder for Option<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<M> Encoder for &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<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<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<R> Encoder for FetchRequest<R>

where R: Encoder,

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

where T: BufMut,

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

impl<R> Encoder for FetchResponse<R>

where R: Encoder,

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

where T: BufMut,

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

impl<R> Encoder for FetchablePartitionResponse<R>

where R: Encoder,

fn encode<T>(&self, dest: &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,

fn encode<T>(&self, dest: &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,

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

where T: BufMut,

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

impl<R> Encoder for ProduceRequest<R>

where R: Encoder + Decoder + Default + Debug,

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 TopicProduceData<R>

where R: Encoder,

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

where T: BufMut,

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

impl<R> Encoder for StreamFetchRequest<R>

where R: Encoder,

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

where T: BufMut,

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

impl<R> Encoder for StreamFetchResponse<R>

where R: Encoder,

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

where T: BufMut,

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

impl<S> Encoder for Messages<S>

where S: Encoder,

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

where T: BufMut,

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

Implementors

impl Encoder for Isolation

impl Encoder for SmartModuleContextData

impl Encoder for SmartModuleInvocationWasm

impl Encoder for fluvio::SmartModuleKind

impl Encoder for CustomSpuKey

impl Encoder for ClassicDeleteApiDeleteRequest

impl Encoder for ClassicObjectApiListRequest

impl Encoder for ClassicObjectApiListResponse

impl Encoder for ClassicObjectApiWatchRequest

impl Encoder for ClassicObjectApiWatchResponse

impl Encoder for PartitionResolution

impl Encoder for SmartModuleVisibility

impl Encoder for SmartModuleWasmFormat

impl Encoder for SpuGroupStatusResolution

impl Encoder for Color

impl Encoder for DataFormat

impl Encoder for TableFormatAlignment

impl Encoder for TableFormatStatusResolution

impl Encoder for CleanupPolicy

impl Encoder for CompressionAlgorithm

impl Encoder for ReplicaSpec

impl Encoder for TopicResolution

impl Encoder for RequestKind

impl Encoder for ErrorCode

impl Encoder for LegacySmartModuleError

impl Encoder for fluvio::dataplane::link::smartmodule::SmartModuleKind

impl Encoder for CustomSpuSpec

impl Encoder for CommonCreateRequest

impl Encoder for ListFilter

impl Encoder for ListFilters

impl Encoder for ObjectApiCreateRequest

impl Encoder for ObjectApiDeleteRequest

impl Encoder for ObjectApiListRequest

impl Encoder for ObjectApiListResponse

impl Encoder for ObjectApiWatchRequest

impl Encoder for ObjectApiWatchResponse

impl Encoder for TypeBuffer

impl Encoder for PartitionConfig

impl Encoder for PartitionSpec

impl Encoder for PartitionStatus

impl Encoder for ReplicaStatus

impl Encoder for FluvioSemVersion

impl Encoder for SmartModuleMetadata

impl Encoder for SmartModulePackage

impl Encoder for SmartModuleSpec

impl Encoder for SmartModuleStatus

impl Encoder for SmartModuleWasm

impl Encoder for SmartModuleWasmSummary

impl Encoder for EnvVar

impl Encoder for ReplicationConfig

impl Encoder for SpuConfig

impl Encoder for SpuGroupSpec

impl Encoder for SpuGroupStatus

impl Encoder for StorageConfig

impl Encoder for SpuSpec

impl Encoder for TableFormatColumnConfig

impl Encoder for TableFormatSpec

impl Encoder for TableFormatStatus

impl Encoder for Bounds

impl Encoder for Deduplication

impl Encoder for Filter

impl Encoder for PartitionMap

impl Encoder for PartitionMaps

impl Encoder for SegmentBasedPolicy

impl Encoder for TopicReplicaParam

impl Encoder for TopicSpec

impl Encoder for TopicStatus

impl Encoder for TopicStorageConfig

impl Encoder for Transform

impl Encoder for SmartModuleExtraParams

impl Encoder for SmartModuleInvocation

impl Encoder for RequestHeader

impl Encoder for SmartModuleInitRuntimeError

impl Encoder for SmartModuleLookbackRuntimeError

impl Encoder for SmartModuleTransformRuntimeError

impl Encoder for ApiVersionKey

impl Encoder for ApiVersionsRequest

impl Encoder for ApiVersionsResponse

impl Encoder for PlatformVersion

impl Encoder for BatchHeader

impl Encoder for RawRecords

impl Encoder for RecordData

impl Encoder for RecordHeader

impl Encoder for ReplicaKey

impl Encoder for SchemaId

impl Encoder for ByteBuf

impl<B> Encoder for Record<B>

where B: Encoder + Default,

impl<P> Encoder for ResponseMessage<P>

where P: Encoder + Default,

impl<R> Encoder for RequestMessage<R>

where R: Request,

impl<R> Encoder for Batch<R>

where R: BatchRecords,

impl<R> Encoder for RecordSet<R>

where R: BatchRecords,

impl<S> Encoder for CreateRequest<S>

where S: Encoder,

impl<S> Encoder for DeleteRequest<S>

where S: DeletableAdminSpec + Encoder,

impl<S> Encoder for ListRequest<S>

where S: Encoder,

impl<S> Encoder for ListResponse<S>

where S: AdminSpec + Encoder, <S as Spec>::Status: Encoder + Decoder + Debug,

impl<S> Encoder for Metadata<S>

where S: Encoder + Spec + Decoder, <S as Spec>::Status: Encoder + Decoder,

impl<S> Encoder for MetadataUpdate<S>

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

impl<S> Encoder for WatchRequest<S>

where S: AdminSpec + Encoder,

impl<S> Encoder for WatchResponse<S>

where S: AdminSpec + Encoder, <S as Spec>::Status: Encoder + Decoder,