List of all items[−]
Structs
- Fluvio
- FluvioAdmin
- FluvioConfig
- Offset
- RecordKey
- TopicProducer
- config::Config
- config::ConfigFile
- config::FluvioConfig
- config::Profile
- config::Replica
- config::TlsCerts
- config::TlsPaths
- config::Topic
- consumer::ConsumerConfig
- consumer::ConsumerConfigBuilder
- consumer::DerivedStreamInvocation
- consumer::MultiplePartitionConsumer
- consumer::PartitionConsumer
- consumer::Record
- consumer::SmartModuleInvocation
- dataplane::ReplicaKey
- dataplane::batch::Batch
- dataplane::batch::BatchHeader
- 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::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::ConsumerRecord
- dataplane::record::FileRecordSet
- dataplane::record::Record
- dataplane::record::RecordData
- dataplane::record::RecordHeader
- dataplane::record::RecordKey
- dataplane::record::RecordSet
- dataplane::smartmodule::SmartModuleAggregateInput
- dataplane::smartmodule::SmartModuleAggregateOutput
- dataplane::smartmodule::SmartModuleExtraParams
- dataplane::smartmodule::SmartModuleInput
- dataplane::smartmodule::SmartModuleOutput
- dataplane::smartmodule::SmartModuleRuntimeError
- dataplane::versions::ApiVersionKey
- dataplane::versions::ApiVersionsRequest
- dataplane::versions::ApiVersionsResponse
- dataplane::versions::PlatformVersion
- metadata::connector::ManagedConnectorSpec
- metadata::connector::ManagedConnectorStatus
- metadata::core::MetadataContext
- metadata::core::MetadataObj
- metadata::customspu::CustomSpuSpec
- metadata::derivedstream::DerivedStreamJoinModule
- metadata::derivedstream::DerivedStreamModule
- metadata::derivedstream::DerivedStreamRef
- metadata::derivedstream::DerivedStreamSpec
- metadata::derivedstream::DerivedStreamStatus
- metadata::derivedstream::DerivedStreamSteps
- metadata::derivedstream::DerivedStreamValidationInput
- metadata::objects::CommonCreateRequest
- metadata::objects::CreateRequest
- metadata::objects::DeleteRequest
- metadata::objects::ListRequest
- metadata::objects::ListResponse
- metadata::objects::Metadata
- metadata::objects::MetadataUpdate
- metadata::objects::ObjectApiCreateRequest
- metadata::objects::WatchRequest
- metadata::objects::WatchResponse
- metadata::partition::PartitionSpec
- metadata::partition::PartitionStatus
- metadata::partition::Replica
- metadata::partition::ReplicaKey
- metadata::partition::ReplicaLeader
- metadata::partition::ReplicaStatus
- metadata::smartmodule::SmartModule
- metadata::smartmodule::SmartModuleParameter
- metadata::smartmodule::SmartModuleSourceCode
- metadata::smartmodule::SmartModuleSpec
- metadata::smartmodule::SmartModuleStatus
- metadata::smartmodule::SmartModuleWasm
- metadata::spg::EnvVar
- metadata::spg::RealStorageConfig
- metadata::spg::ReplicationConfig
- metadata::spg::SpuConfig
- metadata::spg::SpuGroupSpec
- metadata::spg::SpuGroupStatus
- metadata::spg::StorageConfig
- metadata::spu::SpuSpec
- 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::store::memory::MemoryMeta
- metadata::topic::PartitionMap
- metadata::topic::PartitionMaps
- metadata::topic::TopicReplicaParam
- metadata::topic::TopicStatus
- sockets::ClientConfig
- sockets::VersionedSerialSocket
- sockets::VersionedSocket
- sockets::Versions
- spu::SpuPool
- spu::SpuSocket
Enums
- FluvioError
- config::ConfigError
- config::TlsConfig
- config::TlsPolicy
- consumer::ConsumerConfigBuilderError
- consumer::PartitionSelectionStrategy
- consumer::SmartModuleInvocationWasm
- consumer::SmartModuleKind
- dataplane::ErrorCode
- dataplane::Isolation
- dataplane::LegacySmartModuleError
- dataplane::PartitionError
- dataplane::core::store::StoreValue
- dataplane::smartmodule::SmartModuleInternalError
- dataplane::smartmodule::SmartModuleKind
- metadata::connector::ManagedConnectorStatusResolution
- metadata::customspu::CustomSpuKey
- metadata::derivedstream::DerivedStreamInputRef
- metadata::derivedstream::DerivedStreamResolution
- metadata::derivedstream::DerivedStreamStep
- metadata::objects::ObjectApiDeleteRequest
- metadata::objects::ObjectApiListRequest
- metadata::objects::ObjectApiListResponse
- metadata::objects::ObjectApiWatchRequest
- metadata::objects::ObjectApiWatchResponse
- metadata::objects::ObjectCreateRequest
- metadata::partition::ElectionScoring
- metadata::partition::PartitionResolution
- metadata::smartmodule::SmartModuleInputKind
- metadata::smartmodule::SmartModuleOutputKind
- metadata::smartmodule::SmartModuleSourceCodeLanguage
- metadata::smartmodule::SmartModuleWasmFormat
- metadata::spg::SpuGroupStatusResolution
- 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::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::store::FileWrite
- metadata::AdminSpec
- metadata::core::Creatable
- metadata::core::MetadataItem
- metadata::core::MetadataRevExtension
- metadata::core::MetadataStoreDriver
- metadata::core::Removable
- metadata::core::Spec
- metadata::core::Status
- metadata::partition::ElectionPolicy
- metadata::partition::store::PartitionLocalStorePolicy
- metadata::partition::store::PartitionMd
- metadata::store::DualDiff
- metadata::store::KeyFilter
- metadata::topic::store::TopicLocalStorePolicy
- metadata::topic::store::TopicMd
- spu::SpuDirectory
Macros
Derive Macros
- 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
- consumer
- dataplane::create_partition_name
- dataplane::decompose_partition_name
- metadata::topic::validate::valid_topic_name
- producer
Typedefs
- dataplane::Offset
- dataplane::Size
- dataplane::batch::MemoryRecords
- dataplane::core::Version
- dataplane::core::codec::FluvioCodecData
- dataplane::core::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::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::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