Trait fluvio::dataplane::Decoder

pub trait Decoder: Sized + Default {
    // Required method
    fn decode<T>(&mut self, src: &mut T, version: i16) -> Result<(), Error>
       where T: Buf;

    // Provided method
    fn decode_from<T>(src: &mut T, version: i16) -> Result<Self, Error>
       where T: Buf { ... }
}

Required Methods

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

where T: Buf,

Provided Methods

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

where T: Buf,

decode Fluvio compliant protocol values from buf

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl Decoder for MsgType

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

where T: Buf,

impl Decoder for MirrorType

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

where T: Buf,

impl Decoder for ConnectionStatus

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

where T: Buf,

impl Decoder for MirrorPairStatus

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

where T: Buf,

impl Decoder for MirroringApiKey

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

where T: Buf,

impl Decoder for CustomSpu

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

where T: Buf,

impl Decoder for EncryptionEnum

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

where T: Buf,

impl Decoder for SpuType

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

where T: Buf,

impl Decoder for SpuStatusResolution

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

where T: Buf,

impl Decoder for AdminPublicApiKey

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

where T: Buf,

impl Decoder for SmartModuleInitErrorStatus

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

where T: Buf,

impl Decoder for SmartModuleLookbackErrorStatus

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

where T: Buf,

impl Decoder for SmartModuleTransformErrorStatus

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

where T: Buf,

impl Decoder for SpuClientApiKey

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

where T: Buf,

impl Decoder for SpuServerApiKey

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

where T: Buf,

impl Decoder for SmartModuleWasmCompressed

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 f32

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

where T: Buf,

impl Decoder for f64

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 i16

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 i64

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 Decoder for u16

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 u64

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

where T: Buf,

impl Decoder for String

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

where T: Buf,

impl Decoder for Duration

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

where T: Buf,

impl Decoder for Home

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

where T: Buf,

impl Decoder for MirrorSpec

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

where T: Buf,

impl Decoder for Remote

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

where T: Buf,

impl Decoder for ConnectionStat

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

where T: Buf,

impl Decoder for MirrorStatus

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

where T: Buf,

impl Decoder for MirrorConnect

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

where T: Buf,

impl Decoder for MirroringStatus

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

where T: Buf,

impl Decoder for MirroringStatusResponse

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

where T: Buf,

impl Decoder for Endpoint

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

where T: Buf,

impl Decoder for IngressAddr

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

where T: Buf,

impl Decoder for IngressPort

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

where T: Buf,

impl Decoder for SpuStatus

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

where T: Buf,

impl Decoder for ObjectMirroringRequest

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

where T: Buf,

impl Decoder for Status

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

where T: Buf,

impl Decoder for Lookback

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

where T: Buf,

impl Decoder for SmartModuleAggregateInput

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

where T: Buf,

impl Decoder for SmartModuleInitInput

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

where T: Buf,

impl Decoder for SmartModuleInput

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

where T: Buf,

impl Decoder for SmartModuleAggregateOutput

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

where T: Buf,

impl Decoder for SmartModuleInitOutput

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

where T: Buf,

impl Decoder for SmartModuleLookbackOutput

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

where T: Buf,

impl Decoder for SmartModuleOutput

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

where T: Buf,

impl Decoder for ReplicaOffsetUpdate

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

where T: Buf,

impl Decoder for ReplicaOffsetUpdateRequest

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

where T: Buf,

impl Decoder for ReplicaOffsetUpdateResponse

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 AbortedTransaction

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

where T: Buf,

impl Decoder for FileRecordSet

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 ProduceResponse

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 ConsumerOffset

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

where T: Buf,

impl Decoder for DeleteConsumerOffsetRequest

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

where T: Buf,

impl Decoder for DeleteConsumerOffsetResponse

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

where T: Buf,

impl Decoder for FetchConsumerOffsetsRequest

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

where T: Buf,

impl Decoder for FetchConsumerOffsetsResponse

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

where T: Buf,

impl Decoder for UpdateConsumerOffsetRequest

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

where T: Buf,

impl Decoder for UpdateConsumerOffsetResponse

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

where T: Buf,

impl Decoder for FetchOffsetPartition

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

where T: Buf,

impl Decoder for FetchOffsetPartitionResponse

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

where T: Buf,

impl Decoder for FetchOffsetTopic

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

where T: Buf,

impl Decoder for FetchOffsetTopicResponse

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

where T: Buf,

impl Decoder for FetchOffsetsRequest

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

where T: Buf,

impl Decoder for FetchOffsetsResponse

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

where T: Buf,

impl Decoder for StartMirrorRequest

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

where T: Buf,

impl Decoder for StartMirrorResponse

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

where T: Buf,

impl Decoder for OffsetUpdate

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

where T: Buf,

impl Decoder for OffsetUpdateStatus

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

where T: Buf,

impl Decoder for UpdateOffsetsRequest

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

where T: Buf,

impl Decoder for UpdateOffsetsResponse

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

where T: Buf,

impl<C> Decoder for Message<C>

where C: Decoder,

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: Decoder,

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

where T: Buf,

impl<M> Decoder for Vec<M>

where M: Decoder,

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

where T: Buf,

impl<M> Decoder for PhantomData<M>

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

where T: Buf,

impl<R> Decoder for FetchRequest<R>

where R: Decoder,

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

where T: Buf,

impl<R> Decoder for FetchResponse<R>

where R: Decoder,

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

where T: Buf,

impl<R> Decoder for FetchablePartitionResponse<R>

where R: Decoder,

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

where T: Buf,

impl<R> Decoder for FetchableTopicResponse<R>

where R: Decoder,

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

where T: Buf,

impl<R> Decoder for PartitionProduceData<R>

where R: Decoder,

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

where T: Buf,

impl<R> Decoder for ProduceRequest<R>

where R: Decoder + Encoder + 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: Decoder,

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

where T: Buf,

impl<R> Decoder for StreamFetchRequest<R>

where R: Decoder,

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

where T: Buf,

impl<R> Decoder for StreamFetchResponse<R>

where R: Decoder,

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

where T: Buf,

impl<S> Decoder for Messages<S>

where S: Decoder,

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

where T: Buf,

impl<S> Decoder for MirroringRemoteClusterRequest<S>

where S: Decoder,

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

where T: Buf,

impl<S> Decoder for MirroringSpecWrapper<S>

where S: Decoder,

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

where T: Buf,

Implementors

impl Decoder for Isolation

impl Decoder for SmartModuleContextData

impl Decoder for SmartModuleInvocationWasm

impl Decoder for fluvio::SmartModuleKind

impl Decoder for CustomSpuKey

impl Decoder for ClassicDeleteApiDeleteRequest

impl Decoder for ClassicObjectApiListRequest

impl Decoder for ClassicObjectApiListResponse

impl Decoder for ClassicObjectApiWatchRequest

impl Decoder for ClassicObjectApiWatchResponse

impl Decoder for PartitionMirrorConfig

impl Decoder for PartitionResolution

impl Decoder for SmartModuleVisibility

impl Decoder for SmartModuleWasmFormat

impl Decoder for SpuGroupStatusResolution

impl Decoder for Color

impl Decoder for DataFormat

impl Decoder for TableFormatAlignment

impl Decoder for TableFormatStatusResolution

impl Decoder for CleanupPolicy

impl Decoder for CompressionAlgorithm

impl Decoder for MirrorConfig

impl Decoder for ReplicaSpec

impl Decoder for TopicResolution

impl Decoder for RequestKind

impl Decoder for ErrorCode

impl Decoder for LegacySmartModuleError

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

impl Decoder for CustomSpuSpec

impl Decoder for CommonCreateRequest

impl Decoder for ListFilter

impl Decoder for ListFilters

impl Decoder for ObjectApiCreateRequest

impl Decoder for ObjectApiDeleteRequest

impl Decoder for ObjectApiListRequest

impl Decoder for ObjectApiListResponse

impl Decoder for ObjectApiWatchRequest

impl Decoder for ObjectApiWatchResponse

impl Decoder for TypeBuffer

impl Decoder for HomePartitionConfig

impl Decoder for PartitionConfig

impl Decoder for PartitionSpec

impl Decoder for PartitionStatus

impl Decoder for RemotePartitionConfig

impl Decoder for ReplicaStatus

impl Decoder for FluvioSemVersion

impl Decoder for SmartModuleMetadata

impl Decoder for SmartModulePackage

impl Decoder for SmartModuleSpec

impl Decoder for SmartModuleStatus

impl Decoder for SmartModuleWasm

impl Decoder for SmartModuleWasmSummary

impl Decoder for EnvVar

impl Decoder for ReplicationConfig

impl Decoder for SpuConfig

impl Decoder for SpuGroupSpec

impl Decoder for SpuGroupStatus

impl Decoder for StorageConfig

impl Decoder for SpuSpec

impl Decoder for TableFormatColumnConfig

impl Decoder for TableFormatSpec

impl Decoder for TableFormatStatus

impl Decoder for Bounds

impl Decoder for Deduplication

impl Decoder for Filter

impl Decoder for HomeMirrorConfig

impl Decoder for HomeMirrorPartition

impl Decoder for PartitionMap

impl Decoder for PartitionMaps

impl Decoder for RemoteMirrorConfig

impl Decoder for SegmentBasedPolicy

impl Decoder for SpuMirrorConfig

impl Decoder for TopicReplicaParam

impl Decoder for TopicSpec

impl Decoder for TopicStatus

impl Decoder for TopicStorageConfig

impl Decoder for Transform

impl Decoder for SmartModuleExtraParams

impl Decoder for SmartModuleInvocation

impl Decoder for RequestHeader

impl Decoder for SmartModuleInitRuntimeError

impl Decoder for SmartModuleLookbackRuntimeError

impl Decoder for SmartModuleTransformRuntimeError

impl Decoder for ApiVersionKey

impl Decoder for ApiVersionsRequest

impl Decoder for ApiVersionsResponse

impl Decoder for PlatformVersion

impl Decoder for BatchHeader

impl Decoder for RawRecords

impl Decoder for RecordData

impl Decoder for RecordHeader

impl Decoder for ReplicaKey

impl Decoder for SchemaId

impl Decoder for ByteBuf

impl<B> Decoder for Record<B>

where B: Decoder,

impl<R> Decoder for RequestMessage<R>

where R: Request,

impl<R> Decoder for Batch<R>

where R: BatchRecords,

impl<R> Decoder for RecordSet<R>

where R: BatchRecords,

impl<S> Decoder for CreateRequest<S>

where S: Decoder,

impl<S> Decoder for DeleteRequest<S>

where S: DeletableAdminSpec + Decoder,

impl<S> Decoder for ListRequest<S>

where S: Decoder,

impl<S> Decoder for ListResponse<S>

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

impl<S> Decoder for Metadata<S>

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

impl<S> Decoder for MetadataUpdate<S>

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

impl<S> Decoder for WatchRequest<S>

where S: AdminSpec + Decoder,

impl<S> Decoder for WatchResponse<S>

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