List of all items[−]
Structs
- Fluvio
- FluvioAdmin
- FluvioConfig
- Offset
- TopicProducer
- config::Config
- config::ConfigFile
- config::FluvioConfig
- config::Profile
- config::Replica
- config::TlsCerts
- config::TlsPaths
- config::Topic
- consumer::ConsumerConfig
- consumer::PartitionConsumer
- consumer::Record
- dataplane::ReplicaKey
- dataplane::batch::Batch
- dataplane::batch::BatchHeader
- dataplane::core::api::RequestHeader
- dataplane::core::api::RequestMessage
- dataplane::core::api::ResponseMessage
- dataplane::core::api::core::bytes::Bytes
- dataplane::core::api::core::bytes::BytesMut
- dataplane::core::bytes::Bytes
- dataplane::core::bytes::BytesMut
- dataplane::core::codec::FluvioCodec
- dataplane::fetch::AbortedTransaction
- dataplane::fetch::FetchPartition
- dataplane::fetch::FetchRequest
- dataplane::fetch::FetchResponse
- dataplane::fetch::FetchablePartitionResponse
- dataplane::fetch::FetchableTopic
- dataplane::fetch::FetchableTopicResponse
- dataplane::fetch::ForgottenTopic
- dataplane::produce::PartitionProduceData
- dataplane::produce::PartitionProduceResponse
- dataplane::produce::ProduceRequest
- dataplane::produce::ProduceResponse
- dataplane::produce::TopicProduceData
- dataplane::produce::TopicProduceResponse
- dataplane::record::DefaultAsyncBuffer
- dataplane::record::FileRecordSet
- dataplane::record::Record
- dataplane::record::RecordHeader
- dataplane::record::RecordSet
- dataplane::versions::ApiVersionKey
- dataplane::versions::ApiVersionsRequest
- dataplane::versions::ApiVersionsResponse
- dataplane::versions::PlatformVersion
- metadata::core::MetadataContext
- metadata::core::MetadataObj
- metadata::objects::CreateRequest
- metadata::objects::Metadata
- metadata::objects::MetadataUpdate
- metadata::partition::PartitionSpec
- metadata::partition::PartitionStatus
- metadata::partition::Replica
- metadata::partition::ReplicaKey
- metadata::partition::ReplicaLeader
- metadata::partition::ReplicaStatus
- metadata::spg::EnvVar
- metadata::spg::RealStorageConfig
- metadata::spg::ReplicationConfig
- metadata::spg::SpuConfig
- metadata::spg::SpuGroupSpec
- metadata::spg::SpuGroupStatus
- metadata::spg::StorageConfig
- metadata::spu::CustomSpuSpec
- metadata::spu::Endpoint
- metadata::spu::IngressAddr
- metadata::spu::IngressPort
- metadata::spu::SpuSpec
- metadata::spu::SpuStatus
- metadata::store::ChangeFlag
- metadata::store::ChangeListener
- metadata::store::DualEpochCounter
- metadata::store::DualEpochMap
- metadata::store::EpochChanges
- metadata::store::EpochCounter
- metadata::store::EpochMap
- metadata::store::LocalStore
- metadata::store::MetadataStoreObject
- metadata::store::SimpleConcurrentBTreeMap
- metadata::store::SimpleConcurrentHashMap
- metadata::store::SyncStatus
- metadata::store::event::EventPublisher
- metadata::store::event::SimpleEvent
- metadata::topic::PartitionMap
- metadata::topic::PartitionMaps
- metadata::topic::TopicReplicaParam
- metadata::topic::TopicStatus
Enums
- FluvioError
- config::ConfigError
- config::TlsConfig
- config::TlsPolicy
- dataplane::ErrorCode
- dataplane::Isolation
- dataplane::PartitionError
- dataplane::core::store::StoreValue
- metadata::objects::AllCreatableSpec
- metadata::objects::DeleteRequest
- metadata::objects::ListRequest
- metadata::objects::ListResponse
- metadata::objects::WatchRequest
- metadata::objects::WatchResponse
- metadata::partition::ElectionScoring
- metadata::partition::PartitionResolution
- metadata::spg::SpuGroupStatusResolution
- metadata::spu::CustomSpu
- metadata::spu::CustomSpuKey
- metadata::spu::EncryptionEnum
- metadata::spu::SpuStatusResolution
- metadata::spu::SpuType
- metadata::store::EpochDeltaChanges
- metadata::store::actions::LSChange
- metadata::store::actions::LSUpdate
- metadata::store::actions::SpecChange
- metadata::topic::TopicResolution
- metadata::topic::TopicSpec
Traits
- dataplane::PartitionOffset
- dataplane::batch::BatchRecords
- 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::api::core::Decoder
- dataplane::core::api::core::DecoderVarInt
- dataplane::core::api::core::Encoder
- dataplane::core::api::core::EncoderVarInt
- dataplane::core::api::core::bytes::Buf
- dataplane::core::api::core::bytes::BufMut
- dataplane::core::bytes::Buf
- dataplane::core::bytes::BufMut
- dataplane::core::store::FileWrite
- dataplane::record::AsyncBuffer
- dataplane::record::Records
- metadata::core::Creatable
- metadata::core::MetadataItem
- metadata::core::MetadataRevExtension
- metadata::core::MetadataStoreDriver
- metadata::core::Removable
- metadata::core::Spec
- metadata::core::Status
- metadata::objects::DeleteSpec
- metadata::objects::ListFilter
- metadata::objects::ListSpec
- metadata::objects::WatchSpec
- metadata::partition::ElectionPolicy
- metadata::partition::store::PartitionLocalStorePolicy
- metadata::partition::store::PartitionMd
- metadata::spu::store::SpuLocalStorePolicy
- metadata::spu::store::SpuMd
- metadata::store::DualDiff
- metadata::store::KeyFilter
- metadata::topic::store::TopicLocalStorePolicy
- metadata::topic::store::TopicMd
Macros
- dataplane::core::api::api_decode
- dataplane::core::api::derive::fluvio_api
- dataplane::core::derive::fluvio_api
Derive Macros
- dataplane::core::api::derive::Decode
- dataplane::core::api::derive::Encode
- dataplane::core::api::derive::FluvioDefault
- dataplane::core::api::derive::RequestApi
- dataplane::core::derive::Decode
- dataplane::core::derive::Encode
- dataplane::core::derive::FluvioDefault
- dataplane::core::derive::RequestApi
Functions
Typedefs
- dataplane::Offset
- dataplane::Size
- dataplane::batch::DefaultBatch
- dataplane::batch::DefaultBatchRecords
- dataplane::core::Version
- dataplane::core::api::core::Version
- dataplane::fetch::DefaultFetchRequest
- dataplane::fetch::DefaultFetchResponse
- dataplane::fetch::FileFetchRequest
- dataplane::fetch::FileFetchResponse
- dataplane::fetch::FilePartitionResponse
- dataplane::fetch::FileTopicResponse
- dataplane::produce::DefaultPartitionRequest
- dataplane::produce::DefaultProduceRequest
- dataplane::produce::DefaultTopicRequest
- dataplane::produce::FilePartitionRequest
- dataplane::produce::FileProduceRequest
- dataplane::produce::FileTopicRequest
- dataplane::record::DefaultRecord
- dataplane::versions::ApiVersions
- metadata::core::DefaultMetadataContext
- metadata::objects::NameFilter
- metadata::partition::store::DefaultPartitionMd
- metadata::partition::store::DefaultPartitionStore
- metadata::partition::store::PartitionLocalStore
- metadata::partition::store::PartitionMetadata
- metadata::partition::store::SharedPartitionStore
- metadata::spg::store::SpuGroupLocalStore
- metadata::spg::store::SpuGroupMetadata
- metadata::spu::store::DefaultSpuMd
- metadata::spu::store::DefaultSpuStore
- metadata::spu::store::SharedSpuLocalStore
- metadata::spu::store::SpuLocalStore
- metadata::spu::store::SpuMetadata
- metadata::store::DefaultMetadataObject
- metadata::store::Epoch
- metadata::store::MetadataChanges
- metadata::topic::store::DefaultTopicLocalStore
- metadata::topic::store::DefaultTopicMd
- metadata::topic::store::TopicLocalStore
- metadata::topic::store::TopicMetadata
Statics
- metadata::store::FULL_FILTER
- metadata::store::META_FILTER
- metadata::store::SPEC_FILTER
- metadata::store::STATUS_FILTER