List of all items
Structs
- Fluvio
- FluvioAdmin
- FutureRecordMetadata
- Offset
- PartitionerConfig
- ProduceOutput
- RecordKey
- RecordMetadata
- RetryPolicy
- SmartModuleExtraParams
- SmartModuleInvocation
- TopicProducer
- TopicProducerConfig
- TopicProducerConfigBuilder
- config::Config
- config::ConfigFile
- config::FluvioConfig
- config::Profile
- config::Replica
- config::TlsCerts
- config::TlsPaths
- config::Topic
- consumer::ConsumerConfig
- consumer::ConsumerConfigBuilder
- consumer::ConsumerConfigExt
- consumer::ConsumerConfigExtBuilder
- consumer::ConsumerOffset
- consumer::MultiplePartitionConsumer
- consumer::MultiplePartitionConsumerStream
- consumer::PartitionConsumer
- consumer::Record
- consumer::SinglePartitionConsumerStream
- consumer::SmartModuleExtraParams
- consumer::SmartModuleInvocation
- dataplane::ByteBuf
- dataplane::api::RequestHeader
- dataplane::api::RequestMessage
- dataplane::api::ResponseMessage
- dataplane::bytes::Bytes
- dataplane::bytes::BytesMut
- dataplane::bytes::buf::Chain
- dataplane::bytes::buf::IntoIter
- dataplane::bytes::buf::Limit
- dataplane::bytes::buf::Reader
- dataplane::bytes::buf::Take
- dataplane::bytes::buf::UninitSlice
- dataplane::bytes::buf::Writer
- dataplane::codec::FluvioCodec
- dataplane::core::ByteBuf
- dataplane::link::smartmodule::SmartModuleInitRuntimeError
- dataplane::link::smartmodule::SmartModuleLookbackRuntimeError
- dataplane::link::smartmodule::SmartModuleTransformRuntimeError
- dataplane::link::versions::ApiVersionKey
- dataplane::link::versions::ApiVersionsRequest
- dataplane::link::versions::ApiVersionsResponse
- dataplane::link::versions::PlatformVersion
- 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::types::event::SimpleEvent
- dataplane::types::event::StickyEvent
- dataplane::types::event::offsets::OffsetChangeListener
- dataplane::types::event::offsets::OffsetPublisher
- metadata::core::MetadataContext
- metadata::core::MetadataObj
- metadata::customspu::CustomSpuSpec
- metadata::objects::CommonCreateRequest
- metadata::objects::CreateRequest
- metadata::objects::DeleteRequest
- metadata::objects::ListFilter
- metadata::objects::ListFilters
- metadata::objects::ListRequest
- metadata::objects::ListResponse
- metadata::objects::Metadata
- metadata::objects::MetadataUpdate
- metadata::objects::ObjectApiCreateRequest
- metadata::objects::ObjectApiDeleteRequest
- metadata::objects::ObjectApiListRequest
- metadata::objects::ObjectApiListResponse
- metadata::objects::ObjectApiWatchRequest
- metadata::objects::ObjectApiWatchResponse
- metadata::objects::TypeBuffer
- metadata::objects::WatchRequest
- metadata::objects::WatchResponse
- metadata::partition::HomePartitionConfig
- metadata::partition::PartitionConfig
- metadata::partition::PartitionSpec
- metadata::partition::PartitionStatus
- metadata::partition::RemotePartitionConfig
- metadata::partition::ReplicaKey
- metadata::partition::ReplicaStatus
- metadata::smartmodule::ClientConfig
- metadata::smartmodule::FluvioSemVersion
- metadata::smartmodule::SmartModuleApiClient
- metadata::smartmodule::SmartModuleMetadata
- metadata::smartmodule::SmartModulePackage
- metadata::smartmodule::SmartModulePackageKey
- metadata::smartmodule::SmartModuleSpec
- metadata::smartmodule::SmartModuleStatus
- metadata::smartmodule::SmartModuleV1Wrapper
- metadata::smartmodule::SmartModuleWasm
- metadata::smartmodule::SmartModuleWasmSummary
- metadata::spg::ControllerEndPoint
- metadata::spg::EnvVar
- metadata::spg::K8ReplicationConfig
- metadata::spg::K8SpuGroupSpec
- metadata::spg::K8StorageConfig
- metadata::spg::RealStorageConfig
- metadata::spg::ReplicationConfig
- metadata::spg::SpuConfig
- metadata::spg::SpuEndpointTemplate
- metadata::spg::SpuGroupSpec
- metadata::spg::SpuGroupStatus
- metadata::spg::SpuTemplate
- 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::MetadataStoreList
- metadata::store::MetadataStoreObject
- metadata::store::SimpleConcurrentBTreeMap
- metadata::store::SimpleConcurrentHashMap
- metadata::store::SyncStatus
- metadata::store::event::EventPublisher
- metadata::store::event::SimpleEvent
- metadata::store::k8::K8MetaItem
- metadata::store::memory::MemoryMeta
- metadata::tableformat::TableFormatColumnConfig
- metadata::tableformat::TableFormatSpec
- metadata::tableformat::TableFormatStatus
- metadata::topic::Bounds
- metadata::topic::BoundsBuilder
- metadata::topic::Deduplication
- metadata::topic::DeduplicationBuilder
- metadata::topic::Filter
- metadata::topic::FilterBuilder
- metadata::topic::HomeMirrorConfig
- metadata::topic::HomeMirrorPartition
- metadata::topic::InvalidCompressionAlgorithm
- metadata::topic::PartitionMap
- metadata::topic::PartitionMaps
- metadata::topic::RemoteMirrorConfig
- metadata::topic::SegmentBasedPolicy
- metadata::topic::SpuMirrorConfig
- metadata::topic::TopicReplicaParam
- metadata::topic::TopicSpec
- metadata::topic::TopicStatus
- metadata::topic::TopicStorageConfig
- metadata::topic::Transform
- metadata::topic::TransformBuilder
- metadata::topic::config::CompressionConfig
- metadata::topic::config::CompressionConfigBuilder
- metadata::topic::config::MetaConfig
- metadata::topic::config::MetaConfigBuilder
- metadata::topic::config::PartitionConfig
- metadata::topic::config::PartitionConfigBuilder
- metadata::topic::config::RetentionConfig
- metadata::topic::config::RetentionConfigBuilder
- metadata::topic::config::TopicConfig
- metadata::topic::config::TopicConfigBuilder
- metrics::ClientMetrics
- metrics::RecordCounter
- spu::SpuPool
Enums
- Compression
- DeliverySemantic
- FluvioError
- Isolation
- ProducerError
- RetryStrategy
- SmartModuleContextData
- SmartModuleInvocationWasm
- SmartModuleKind
- config::ConfigError
- config::TlsConfig
- config::TlsPolicy
- consumer::OffsetManagementStrategy
- consumer::PartitionSelectionStrategy
- consumer::SmartModuleContextData
- consumer::SmartModuleInvocationWasm
- consumer::SmartModuleKind
- dataplane::api::RequestKind
- dataplane::link::ErrorCode
- dataplane::link::smartmodule::LegacySmartModuleError
- dataplane::link::smartmodule::SmartModuleKind
- dataplane::record::PartitionError
- dataplane::store::StoreValue
- dataplane::types::PartitionError
- dataplane::types::config_file::LoadConfigError
- dataplane::types::partition::PartitionError
- metadata::customspu::CustomSpuKey
- metadata::objects::ClassicDeleteApiDeleteRequest
- metadata::objects::ClassicObjectApiListRequest
- metadata::objects::ClassicObjectApiListResponse
- metadata::objects::ClassicObjectApiWatchRequest
- metadata::objects::ClassicObjectApiWatchResponse
- metadata::partition::PartitionMirrorConfig
- metadata::partition::PartitionResolution
- metadata::smartmodule::SmartModuleKeyError
- metadata::smartmodule::SmartModuleVisibility
- metadata::smartmodule::SmartModuleWasmFormat
- metadata::smartmodule::SocketError
- metadata::spg::SpuGroupStatusResolution
- metadata::store::EpochDeltaChanges
- metadata::store::NameSpace
- metadata::store::actions::LSChange
- metadata::store::actions::LSUpdate
- metadata::store::actions::SpecChange
- metadata::store::k8::K8ConvertError
- metadata::tableformat::Color
- metadata::tableformat::DataFormat
- metadata::tableformat::TableFormatAlignment
- metadata::tableformat::TableFormatStatusResolution
- metadata::topic::BoundsBuilderError
- metadata::topic::CleanupPolicy
- metadata::topic::CompressionAlgorithm
- metadata::topic::DeduplicationBuilderError
- metadata::topic::FilterBuilderError
- metadata::topic::MirrorConfig
- metadata::topic::ReplicaSpec
- metadata::topic::TopicResolution
- metadata::topic::TransformBuilderError
- metadata::topic::config::CompressionConfigBuilderError
- metadata::topic::config::MetaConfigBuilderError
- metadata::topic::config::PartitionConfigBuilderError
- metadata::topic::config::RetentionConfigBuilderError
- metadata::topic::config::TopicConfigBuilderError
Traits
- Partitioner
- consumer::ConsumerStream
- dataplane::Decoder
- dataplane::DecoderVarInt
- dataplane::Encoder
- dataplane::EncoderVarInt
- dataplane::api::ApiKey
- dataplane::api::ApiMessage
- dataplane::api::Request
- dataplane::bytes::Buf
- dataplane::bytes::BufMut
- dataplane::bytes::buf::Buf
- dataplane::bytes::buf::BufMut
- dataplane::core::Decoder
- dataplane::core::DecoderVarInt
- dataplane::core::Encoder
- dataplane::core::EncoderVarInt
- dataplane::record::BatchRecords
- dataplane::record::PartitionOffset
- dataplane::record::ProducerBatchHeader
- dataplane::store::FileWrite
- dataplane::types::config_file::SaveLoadConfig
- metadata::AdminSpec
- metadata::core::Creatable
- metadata::core::MetadataItem
- metadata::core::MetadataRevExtension
- metadata::core::MetadataStoreDriver
- metadata::core::Removable
- metadata::core::Spec
- metadata::core::Status
- metadata::store::DualDiff
- metadata::store::KeyFilter
- metadata::store::k8::K8ExtendedSpec
- spu::SpuDirectory
Macros
- dataplane::api::api_decode
- dataplane::api_decode
- dataplane::derive::fluvio_api
- dataplane::types::log_actions
- dataplane::types::log_on_err
- dataplane::types::print_cli_err
- dataplane::types::print_cli_ok
- dataplane::types::print_ok_msg
Derive Macros
- dataplane::Decoder
- dataplane::Encoder
- dataplane::FluvioDefault
- dataplane::RequestApi
- dataplane::derive::Decoder
- dataplane::derive::Encoder
- dataplane::derive::FluvioDefault
- dataplane::derive::RequestApi
Functions
- consumer
- dataplane::record::create_partition_name
- dataplane::record::decompose_partition_name
- dataplane::types::partition::create_partition_name
- dataplane::types::partition::decompose_partition_name
- metadata::store::k8::default_convert_from_k8
- metadata::topic::validate::valid_topic_name
- producer
Type Aliases
- dataplane::Version
- dataplane::codec::FluvioCodecData
- dataplane::core::Version
- dataplane::link::versions::ApiVersions
- dataplane::record::MemoryRecords
- dataplane::record::Offset
- dataplane::record::Size
- dataplane::record::Size64
- dataplane::types::IgnoreRackAssignment
- dataplane::types::IsOk
- dataplane::types::IsOnline
- dataplane::types::Name
- dataplane::types::PartitionCount
- dataplane::types::PartitionId
- dataplane::types::Reason
- dataplane::types::ReplicaMap
- dataplane::types::ReplicationFactor
- dataplane::types::SmartModuleName
- dataplane::types::SpuId
- dataplane::types::SpuName
- dataplane::types::Timestamp
- dataplane::types::TokenName
- dataplane::types::TokenSecret
- dataplane::types::TopicName
- dataplane::types::event::offsets::SharedOffsetPublisher
- dataplane::types::event::offsets::WeakSharedOffsetPublisher
- metadata::core::DefaultMetadataContext
- metadata::spg::store::SpuGroupLocalStore
- metadata::spg::store::SpuGroupMetadata
- metadata::store::DefaultMetadataObject
- metadata::store::Epoch
- metadata::store::MetadataChanges
- metadata::store::k8::K8MetadataContext
- metadata::topic::MirrorMap
Statics
- metadata::store::FULL_FILTER
- metadata::store::META_FILTER
- metadata::store::SPEC_FILTER
- metadata::store::STATUS_FILTER
Constants
- config::LOCAL_PROFILE
- dataplane::api::MAX_BYTES
- dataplane::link::versions::V10_PLATFORM
- dataplane::link::versions::VERSIONS_API_KEY
- dataplane::record::BATCH_FILE_HEADER_SIZE
- dataplane::record::BATCH_HEADER_SIZE
- dataplane::record::BATCH_PREAMBLE_SIZE
- dataplane::record::NO_TIMESTAMP
- dataplane::types::defaults::CLI_CONFIG_PATH
- dataplane::types::defaults::CLI_DEFAULT_PROFILE
- dataplane::types::defaults::CLI_PROFILES_DIR
- dataplane::types::defaults::CONFIG_FILE_EXTENSION
- dataplane::types::defaults::CONFIG_FILE_EXTENTION
- dataplane::types::defaults::CONSUMER_STORAGE_TOPIC
- dataplane::types::defaults::FLUVIO_CLIENT_MAX_FETCH_BYTES
- dataplane::types::defaults::FLUVIO_MAX_SIZE_TOPIC_NAME
- dataplane::types::defaults::FLV_FLUVIO_HOME
- dataplane::types::defaults::FLV_LOG_BASE_DIR
- dataplane::types::defaults::FLV_LOG_INDEX_MAX_BYTES
- dataplane::types::defaults::FLV_LOG_INDEX_MAX_INTERVAL_BYTES
- dataplane::types::defaults::FLV_LOG_SEGMENT_MAX_BYTES
- dataplane::types::defaults::FLV_LOG_SIZE
- dataplane::types::defaults::FLV_RACK
- dataplane::types::defaults::FLV_REPLICA_IN_SYNC_REPLICA_MIN
- dataplane::types::defaults::FLV_SC_PRIVATE_HOST
- dataplane::types::defaults::FLV_SC_PRIVATE_PORT
- dataplane::types::defaults::FLV_SC_RETRY_TIMEOUT_MS
- dataplane::types::defaults::FLV_SPU_ID
- dataplane::types::defaults::FLV_SPU_PRIVATE_HOST
- dataplane::types::defaults::FLV_SPU_PRIVATE_PORT
- dataplane::types::defaults::FLV_SPU_PUBLIC_HOST
- dataplane::types::defaults::FLV_SPU_PUBLIC_PORT
- dataplane::types::defaults::FLV_SPU_TYPE
- dataplane::types::defaults::FLV_TOKEN_SECRET_FILE
- dataplane::types::defaults::HC_SPU_PING_INTERVAL_SEC
- dataplane::types::defaults::HC_SPU_TRIGGER_INTERVAL_SEC
- dataplane::types::defaults::K8_TOKEN_SECRET_KEY
- dataplane::types::defaults::KF_REQUEST_TIMEOUT_MS
- dataplane::types::defaults::PRODUCT_NAME
- dataplane::types::defaults::SC_CONFIG_FILE
- dataplane::types::defaults::SC_DEFAULT_ID
- dataplane::types::defaults::SC_HOSTNAME
- dataplane::types::defaults::SC_PRIVATE_PORT
- dataplane::types::defaults::SC_PUBLIC_PORT
- dataplane::types::defaults::SC_RECONCILIATION_INTERVAL_SEC
- dataplane::types::defaults::SERVER_CONFIG_BASE_PATH
- dataplane::types::defaults::SERVER_CONFIG_DIR
- dataplane::types::defaults::SPU_CONFIG_FILE
- dataplane::types::defaults::SPU_CREDENTIALS_FILE
- dataplane::types::defaults::SPU_DEFAULT_NAME
- dataplane::types::defaults::SPU_LOG_BASE_DIR
- dataplane::types::defaults::SPU_LOG_INDEX_MAX_BYTES
- dataplane::types::defaults::SPU_LOG_INDEX_MAX_INTERVAL_BYTES
- dataplane::types::defaults::SPU_LOG_LOG_SEGMENT_MAX_BYTE_MIN
- dataplane::types::defaults::SPU_LOG_SEGMENT_MAX_BYTES
- dataplane::types::defaults::SPU_LOG_SIZE
- dataplane::types::defaults::SPU_MIN_IN_SYNC_REPLICAS
- dataplane::types::defaults::SPU_MONITORING_UNIX_SOCKET
- dataplane::types::defaults::SPU_PARTITION_MAX_BYTES
- dataplane::types::defaults::SPU_PARTITION_MAX_BYTES_MIN
- dataplane::types::defaults::SPU_PRIVATE_HOSTNAME
- dataplane::types::defaults::SPU_PRIVATE_PORT
- dataplane::types::defaults::SPU_PUBLIC_HOSTNAME
- dataplane::types::defaults::SPU_PUBLIC_PORT
- dataplane::types::defaults::SPU_RETRY_SC_TIMEOUT_MS
- dataplane::types::defaults::SPU_SMARTENGINE_STORE_MAX_BYTES
- dataplane::types::defaults::STORAGE_FLUSH_IDLE_MSEC
- dataplane::types::defaults::STORAGE_FLUSH_WRITE_COUNT
- dataplane::types::defaults::STORAGE_MAX_BATCH_SIZE
- dataplane::types::defaults::STORAGE_RETENTION_SECONDS
- dataplane::types::defaults::STORAGE_RETENTION_SECONDS_MIN
- dataplane::types::defaults::TLS_CLIENT_SECRET_NAME
- dataplane::types::defaults::TLS_SERVER_SECRET_NAME
- dataplane::types::event::offsets::INIT_OFFSET
- dataplane::types::event::offsets::TOPIC_DELETED
- metadata::topic::PENDING_REASON