List of all items
Structs
- Error
- Record
- RecordData
- SmartModuleRecord
- 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::SmartModuleLookbackRuntimeError
- 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::core::record::SchemaId
- 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::record::SchemaId
- dataplane::smartmodule::Lookback
- dataplane::smartmodule::SmartModuleAggregateInput
- dataplane::smartmodule::SmartModuleAggregateOutput
- dataplane::smartmodule::SmartModuleExtraParams
- dataplane::smartmodule::SmartModuleInitInput
- dataplane::smartmodule::SmartModuleInitOutput
- dataplane::smartmodule::SmartModuleInitRuntimeError
- dataplane::smartmodule::SmartModuleInput
- dataplane::smartmodule::SmartModuleLookbackOutput
- dataplane::smartmodule::SmartModuleLookbackRuntimeError
- 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::core::types::PartitionError
- dataplane::core::types::partition::PartitionError
- dataplane::record::PartitionError
- dataplane::smartmodule::LegacySmartModuleError
- dataplane::smartmodule::SmartModuleInitError
- dataplane::smartmodule::SmartModuleInitErrorStatus
- dataplane::smartmodule::SmartModuleKind
- dataplane::smartmodule::SmartModuleLookbackErrorStatus
- 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
- dataplane::core::api::api_decode
- dataplane::core::api_decode
- dataplane::core::derive::fluvio_api
- dataplane::core::types::log_actions
- dataplane::core::types::log_on_err
- dataplane::core::types::print_cli_err
- dataplane::core::types::print_cli_ok
- dataplane::core::types::print_ok_msg
- eyre
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::core::types::partition::create_partition_name
- dataplane::core::types::partition::decompose_partition_name
- dataplane::record::create_partition_name
- dataplane::record::decompose_partition_name
- memory::alloc
- memory::dealloc
Type Aliases
- Offset
- 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::core::types::IgnoreRackAssignment
- dataplane::core::types::IsOk
- dataplane::core::types::IsOnline
- dataplane::core::types::Name
- dataplane::core::types::PartitionCount
- dataplane::core::types::PartitionId
- dataplane::core::types::Reason
- dataplane::core::types::ReplicaMap
- dataplane::core::types::ReplicationFactor
- dataplane::core::types::SmartModuleName
- dataplane::core::types::SpuId
- dataplane::core::types::SpuName
- dataplane::core::types::Timestamp
- dataplane::core::types::TokenName
- dataplane::core::types::TokenSecret
- dataplane::core::types::TopicName
- dataplane::record::MemoryRecords
- dataplane::record::Offset
- dataplane::record::Size
- dataplane::record::Size64
Constants
- ENCODING_ERROR
- SMARTMODULE_TIMESTAMPS_VERSION
- 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::NO_TIMESTAMP
- dataplane::core::types::defaults::CLI_CONFIG_PATH
- dataplane::core::types::defaults::CLI_DEFAULT_PROFILE
- dataplane::core::types::defaults::CLI_PROFILES_DIR
- dataplane::core::types::defaults::CONFIG_FILE_EXTENSION
- dataplane::core::types::defaults::CONFIG_FILE_EXTENTION
- dataplane::core::types::defaults::FLUVIO_CLIENT_MAX_FETCH_BYTES
- dataplane::core::types::defaults::FLUVIO_MAX_SIZE_TOPIC_NAME
- dataplane::core::types::defaults::FLV_FLUVIO_HOME
- dataplane::core::types::defaults::FLV_LOG_BASE_DIR
- dataplane::core::types::defaults::FLV_LOG_INDEX_MAX_BYTES
- dataplane::core::types::defaults::FLV_LOG_INDEX_MAX_INTERVAL_BYTES
- dataplane::core::types::defaults::FLV_LOG_SEGMENT_MAX_BYTES
- dataplane::core::types::defaults::FLV_LOG_SIZE
- dataplane::core::types::defaults::FLV_RACK
- dataplane::core::types::defaults::FLV_REPLICA_IN_SYNC_REPLICA_MIN
- dataplane::core::types::defaults::FLV_SC_PRIVATE_HOST
- dataplane::core::types::defaults::FLV_SC_PRIVATE_PORT
- dataplane::core::types::defaults::FLV_SC_RETRY_TIMEOUT_MS
- dataplane::core::types::defaults::FLV_SPU_ID
- dataplane::core::types::defaults::FLV_SPU_PRIVATE_HOST
- dataplane::core::types::defaults::FLV_SPU_PRIVATE_PORT
- dataplane::core::types::defaults::FLV_SPU_PUBLIC_HOST
- dataplane::core::types::defaults::FLV_SPU_PUBLIC_PORT
- dataplane::core::types::defaults::FLV_SPU_TYPE
- dataplane::core::types::defaults::FLV_TOKEN_SECRET_FILE
- dataplane::core::types::defaults::HC_SPU_PING_INTERVAL_SEC
- dataplane::core::types::defaults::HC_SPU_TRIGGER_INTERVAL_SEC
- dataplane::core::types::defaults::K8_TOKEN_SECRET_KEY
- dataplane::core::types::defaults::KF_REQUEST_TIMEOUT_MS
- dataplane::core::types::defaults::PRODUCT_NAME
- dataplane::core::types::defaults::SC_CONFIG_FILE
- dataplane::core::types::defaults::SC_DEFAULT_ID
- dataplane::core::types::defaults::SC_HOSTNAME
- dataplane::core::types::defaults::SC_PRIVATE_PORT
- dataplane::core::types::defaults::SC_PUBLIC_PORT
- dataplane::core::types::defaults::SC_RECONCILIATION_INTERVAL_SEC
- dataplane::core::types::defaults::SERVER_CONFIG_BASE_PATH
- dataplane::core::types::defaults::SERVER_CONFIG_DIR
- dataplane::core::types::defaults::SPU_CONFIG_FILE
- dataplane::core::types::defaults::SPU_CREDENTIALS_FILE
- dataplane::core::types::defaults::SPU_DEFAULT_NAME
- dataplane::core::types::defaults::SPU_LOG_BASE_DIR
- dataplane::core::types::defaults::SPU_LOG_INDEX_MAX_BYTES
- dataplane::core::types::defaults::SPU_LOG_INDEX_MAX_INTERVAL_BYTES
- dataplane::core::types::defaults::SPU_LOG_LOG_SEGMENT_MAX_BYTE_MIN
- dataplane::core::types::defaults::SPU_LOG_SEGMENT_MAX_BYTES
- dataplane::core::types::defaults::SPU_LOG_SIZE
- dataplane::core::types::defaults::SPU_MIN_IN_SYNC_REPLICAS
- dataplane::core::types::defaults::SPU_MONITORING_UNIX_SOCKET
- dataplane::core::types::defaults::SPU_PARTITION_MAX_BYTES
- dataplane::core::types::defaults::SPU_PARTITION_MAX_BYTES_MIN
- dataplane::core::types::defaults::SPU_PRIVATE_HOSTNAME
- dataplane::core::types::defaults::SPU_PRIVATE_PORT
- dataplane::core::types::defaults::SPU_PUBLIC_HOSTNAME
- dataplane::core::types::defaults::SPU_PUBLIC_PORT
- dataplane::core::types::defaults::SPU_RETRY_SC_TIMEOUT_MS
- dataplane::core::types::defaults::SPU_SMARTENGINE_STORE_MAX_BYTES
- dataplane::core::types::defaults::STORAGE_FLUSH_IDLE_MSEC
- dataplane::core::types::defaults::STORAGE_FLUSH_WRITE_COUNT
- dataplane::core::types::defaults::STORAGE_MAX_BATCH_SIZE
- dataplane::core::types::defaults::STORAGE_RETENTION_SECONDS
- dataplane::core::types::defaults::STORAGE_RETENTION_SECONDS_MIN
- dataplane::core::types::defaults::TLS_CLIENT_SECRET_NAME
- dataplane::core::types::defaults::TLS_SERVER_SECRET_NAME
- dataplane::record::BATCH_FILE_HEADER_SIZE
- dataplane::record::BATCH_HEADER_SIZE
- dataplane::record::BATCH_PREAMBLE_SIZE
- dataplane::record::NO_TIMESTAMP
- dataplane::smartmodule::SMARTMODULE_TIMESTAMPS_VERSION