List of all items
Structs
- Error
- Record
- RecordData
- dataplane::core::ByteBuf
- dataplane::core::api::RequestHeader
- dataplane::core::api::RequestMessage
- dataplane::core::api::ResponseMessage
- dataplane::core::bytes::Bytes
- dataplane::core::bytes::BytesMut
- dataplane::core::bytes::buf::Chain
- dataplane::core::bytes::buf::IntoIter
- dataplane::core::bytes::buf::Limit
- dataplane::core::bytes::buf::Reader
- dataplane::core::bytes::buf::Take
- dataplane::core::bytes::buf::UninitSlice
- dataplane::core::bytes::buf::Writer
- dataplane::core::core::ByteBuf
- dataplane::core::link::smartmodule::SmartModuleInitRuntimeError
- dataplane::core::link::smartmodule::SmartModuleTransformRuntimeError
- dataplane::core::link::versions::ApiVersionKey
- dataplane::core::link::versions::ApiVersionsRequest
- dataplane::core::link::versions::ApiVersionsResponse
- dataplane::core::link::versions::PlatformVersion
- dataplane::core::record::Batch
- dataplane::core::record::BatchHeader
- dataplane::core::record::ConsumerRecord
- dataplane::core::record::RawRecords
- dataplane::core::record::Record
- dataplane::core::record::RecordData
- dataplane::core::record::RecordHeader
- dataplane::core::record::RecordKey
- dataplane::core::record::RecordSet
- dataplane::core::record::ReplicaKey
- dataplane::record::Batch
- dataplane::record::BatchHeader
- dataplane::record::ConsumerRecord
- dataplane::record::RawRecords
- dataplane::record::Record
- dataplane::record::RecordData
- dataplane::record::RecordHeader
- dataplane::record::RecordKey
- dataplane::record::RecordSet
- dataplane::record::ReplicaKey
- dataplane::smartmodule::SmartModuleAggregateInput
- dataplane::smartmodule::SmartModuleAggregateOutput
- dataplane::smartmodule::SmartModuleExtraParams
- dataplane::smartmodule::SmartModuleInitInput
- dataplane::smartmodule::SmartModuleInitOutput
- dataplane::smartmodule::SmartModuleInitRuntimeError
- dataplane::smartmodule::SmartModuleInput
- dataplane::smartmodule::SmartModuleOutput
- dataplane::smartmodule::SmartModuleTransformRuntimeError
Enums
- dataplane::core::api::RequestKind
- dataplane::core::link::ErrorCode
- dataplane::core::link::smartmodule::LegacySmartModuleError
- dataplane::core::link::smartmodule::SmartModuleKind
- dataplane::core::record::PartitionError
- dataplane::record::PartitionError
- dataplane::smartmodule::LegacySmartModuleError
- dataplane::smartmodule::SmartModuleInitError
- dataplane::smartmodule::SmartModuleInitErrorStatus
- dataplane::smartmodule::SmartModuleKind
- dataplane::smartmodule::SmartModuleTransformErrorStatus
Traits
- dataplane::core::Decoder
- dataplane::core::DecoderVarInt
- dataplane::core::Encoder
- dataplane::core::EncoderVarInt
- dataplane::core::api::ApiKey
- dataplane::core::api::ApiMessage
- dataplane::core::api::Request
- dataplane::core::bytes::Buf
- dataplane::core::bytes::BufMut
- dataplane::core::bytes::buf::Buf
- dataplane::core::bytes::buf::BufMut
- dataplane::core::core::Decoder
- dataplane::core::core::DecoderVarInt
- dataplane::core::core::Encoder
- dataplane::core::core::EncoderVarInt
- dataplane::core::record::BatchRecords
- dataplane::core::record::PartitionOffset
- dataplane::core::record::ProducerBatchHeader
- dataplane::record::BatchRecords
- dataplane::record::PartitionOffset
- dataplane::record::ProducerBatchHeader
Macros
Attribute Macros
Derive Macros
- SmartOpt
- dataplane::core::Decoder
- dataplane::core::Encoder
- dataplane::core::FluvioDefault
- dataplane::core::RequestApi
- dataplane::core::derive::Decoder
- dataplane::core::derive::Encoder
- dataplane::core::derive::FluvioDefault
- dataplane::core::derive::RequestApi
Functions
- dataplane::core::record::create_partition_name
- dataplane::core::record::decompose_partition_name
- dataplane::record::create_partition_name
- dataplane::record::decompose_partition_name
- memory::alloc
- memory::dealloc
Type Definitions
- Result
- dataplane::core::Version
- dataplane::core::core::Version
- dataplane::core::link::versions::ApiVersions
- dataplane::core::record::MemoryRecords
- dataplane::core::record::Offset
- dataplane::core::record::Size
- dataplane::core::record::Size64
- dataplane::record::MemoryRecords
- dataplane::record::Offset
- dataplane::record::Size
- dataplane::record::Size64
Constants
- ENCODING_ERROR
- dataplane::core::api::MAX_BYTES
- dataplane::core::link::versions::V10_PLATFORM
- dataplane::core::link::versions::VERSIONS_API_KEY
- dataplane::core::record::BATCH_FILE_HEADER_SIZE
- dataplane::core::record::BATCH_HEADER_SIZE
- dataplane::core::record::BATCH_PREAMBLE_SIZE
- dataplane::core::record::COMPRESSION_CODEC_MASK
- dataplane::core::record::NO_TIMESTAMP
- dataplane::record::BATCH_FILE_HEADER_SIZE
- dataplane::record::BATCH_HEADER_SIZE
- dataplane::record::BATCH_PREAMBLE_SIZE
- dataplane::record::COMPRESSION_CODEC_MASK
- dataplane::record::NO_TIMESTAMP