List of all items

Structs

• async_io::AsyncFile
• async_io::AsyncIo
• async_io::AsyncIoConfig
• async_io::AsyncIoStats
• async_io::AsyncIoStatsSnapshot
• async_io::AsyncSegment
• async_io::BatchBuilder
• auth::AclEntry
• auth::AuthConfig
• auth::AuthManager
• auth::AuthSession
• auth::PasswordHash
• auth::Principal
• auth::Role
• auth::SaslPlainAuth
• auth::SaslScramAuth
• backpressure::AdaptiveRateLimiter
• backpressure::AdaptiveRateLimiterConfig
• backpressure::AdaptiveStatsSnapshot
• backpressure::BackpressureChannel
• backpressure::ChannelStatsSnapshot
• backpressure::CircuitBreaker
• backpressure::CircuitBreakerConfig
• backpressure::CircuitBreakerStatsSnapshot
• backpressure::CreditFlowControl
• backpressure::CreditStatsSnapshot
• backpressure::TokenBucket
• backpressure::TokenBucketStatsSnapshot
• backpressure::WindowedRateTracker
• bloom::AdaptiveBatcher
• bloom::BatchConfig
• bloom::BatcherStats
• bloom::BloomFilter
• bloom::CountingBloomFilter
• bloom::HyperLogLog
• bloom::OffsetBloomFilter
• buffer_pool::AlignedBuffer
• buffer_pool::BufferChain
• buffer_pool::BufferPool
• buffer_pool::BufferPoolConfig
• buffer_pool::PoolStats
• buffer_pool::PooledBuffer
• cedar_authz::AuthzContext
• cedar_authz::AuthzDecision
• cedar_authz::CedarAuthorizer
• compression::BatchCompressor
• compression::BatchIterator
• compression::CompressedBatch
• compression::CompressionConfig
• compression::CompressionStats
• compression::Compressor
• compression::StreamingCompressor
• compression::StreamingDecompressor
• concurrent::AppendLogConfig
• concurrent::AppendOnlyLog
• concurrent::CacheAligned
• concurrent::ConcurrentHashMap
• concurrent::ConcurrentSkipList
• concurrent::LockFreeQueue
• concurrent::QueueStats
• config::Config
• consumer_group::ConsumerGroup
• consumer_group::GroupMember
• consumer_group::PartitionAssignment
• encryption::DisabledEncryption
• encryption::EncryptedHeader
• encryption::EncryptionConfig
• encryption::EncryptionManager
• encryption::MasterKey
• idempotent::IdempotentProducerManager
• idempotent::IdempotentProducerStats
• idempotent::PartitionProducerState
• idempotent::ProducerMetadata
• message::Message
• metrics::CoreMetrics
• metrics::Timer
• offset::OffsetManager
• partition::Partition
• quota::EntityQuotaStats
• quota::QuotaConfig
• quota::QuotaEntity
• quota::QuotaManager
• quota::QuotaStats
• quota::QuotaStatsSnapshot
• schema_registry::EmbeddedSchemaRegistry
• schema_registry::MemorySchemaRegistry
• schema_registry::SchemaRegistration
• service_auth::ApiKey
• service_auth::ServiceAccount
• service_auth::ServiceAccountConfig
• service_auth::ServiceAuthConfig
• service_auth::ServiceAuthManager
• service_auth::ServiceSession
• storage::log_manager::LogManager
• storage::memory::MemoryStorage
• storage::segment::Segment
• storage::tiered::DisabledColdStorage
• storage::tiered::HotTier
• storage::tiered::HotTierStats
• storage::tiered::LocalFsColdStorage
• storage::tiered::SegmentMetadata
• storage::tiered::TieredStorage
• storage::tiered::TieredStorageConfig
• storage::tiered::TieredStorageStats
• storage::tiered::TieredStorageStatsSnapshot
• storage::tiered::WarmTier
• storage::tiered::WarmTierStats
• tls::CertificateDer
• tls::CertificateWatcher
• tls::ClientConfig
• tls::PrivatePkcs8KeyDer
• tls::ServerConfig
• tls::TlsAcceptor
• tls::TlsClientStream
• tls::TlsConfig
• tls::TlsConfigBuilder
• tls::TlsConnector
• tls::TlsIdentity
• tls::TlsSecurityAudit
• tls::TlsServerStream
• topic::Topic
• topic::TopicManager
• topic_config::ConfigValue
• topic_config::TopicConfig
• topic_config::TopicConfigManager
• transaction::PendingWrite
• transaction::Transaction
• transaction::TransactionCoordinator
• transaction::TransactionOffsetCommit
• transaction::TransactionPartition
• transaction::TransactionStats
• transaction::TransactionStatsSnapshot
• validation::Validator
• vectorized::BatchDecoder
• vectorized::BatchEncoder
• vectorized::BatchMessage
• vectorized::BatchProcessor
• vectorized::DecodedMessage
• vectorized::DecoderStatsSnapshot
• vectorized::EncoderStatsSnapshot
• vectorized::ProcessorStatsSnapshot
• vectorized::RecordBatch
• vectorized::RecordBatchIter
• wal::GroupCommitWal
• wal::RecordFlags
• wal::WalConfig
• wal::WalReader
• wal::WalRecord
• wal::WalStatsSnapshot
• wal::WriteResult
• zero_copy::BufferPoolStats
• zero_copy::BufferSlice
• zero_copy::ConsumedMessage
• zero_copy::ConsumerStatsSnapshot
• zero_copy::ProducerStatsSnapshot
• zero_copy::SmallVec
• zero_copy::ZeroCopyBuffer
• zero_copy::ZeroCopyBufferPool
• zero_copy::ZeroCopyConsumer
• zero_copy::ZeroCopyMessage
• zero_copy::ZeroCopyProducer

Enums

• async_io::BatchResult
• auth::AuthError
• auth::Permission
• auth::PrincipalType
• auth::ResourceType
• auth::ScramState
• backpressure::CircuitState
• buffer_pool::SizeClass
• cedar_authz::CedarError
• cedar_authz::RivvenAction
• cedar_authz::RivvenResource
• compression::CompressionAlgorithm
• compression::CompressionError
• compression::CompressionLevel
• consumer_group::AssignmentStrategy
• consumer_group::GroupState
• consumer_group::RebalanceProtocol
• consumer_group::RebalanceResult
• encryption::Algorithm
• encryption::EncryptionError
• encryption::KeyProvider
• error::Error
• idempotent::SequenceResult
• quota::QuotaEntityType
• quota::QuotaResult
• quota::QuotaType
• schema_registry::SchemaLogEvent
• service_auth::AuthMethod
• service_auth::ServiceAuthError
• service_auth::ServiceAuthRequest
• service_auth::ServiceAuthResponse
• storage::tiered::ColdStorageConfig
• storage::tiered::StorageTier
• tls::CertificateSource
• tls::MtlsMode
• tls::PrivateKeyDer
• tls::PrivateKeySource
• tls::TlsError
• tls::TlsVersion
• topic_config::CleanupPolicy
• topic_config::CompressionType
• transaction::TransactionMarker
• transaction::TransactionResult
• transaction::TransactionState
• validation::ValidationError
• wal::RecordType
• wal::SyncMode
• zero_copy::BufferRef

Traits

• encryption::Encryptor
• schema_registry::SchemaRegistry
• storage::tiered::ColdStorageBackend
• storage::traits::StorageBackend

Macros

• metrics::counter
• metrics::gauge
• metrics::histogram

Functions

• consumer_group::assignment::range_assignment
• consumer_group::assignment::round_robin_assignment
• consumer_group::assignment::sticky_assignment
• encryption::generate_key_file
• metrics::init_metrics
• metrics::init_metrics_recorder
• serde_utils::bytes_serde::deserialize
• serde_utils::bytes_serde::serialize
• serde_utils::duration::deserialize
• serde_utils::duration::serialize
• serde_utils::option_bytes_serde::deserialize
• serde_utils::option_bytes_serde::serialize
• serde_utils::system_time::deserialize
• serde_utils::system_time::serialize
• tls::certificate_fingerprint
• tls::generate_self_signed
• tls::load_certificates
• tls::load_private_key
• tls::verify_certificate_chain
• vectorized::crc32_batch
• vectorized::crc32_fast
• vectorized::memchr_fast
• vectorized::memcmp_fast
• vectorized::memmem_fast

Type Aliases

• auth::AuthResult
• cedar_authz::CedarResult
• compression::Result
• consumer_group::GroupId
• consumer_group::GroupInstanceId
• consumer_group::MemberId
• encryption::Result
• error::Result
• idempotent::ProducerEpoch
• idempotent::ProducerId
• idempotent::SequenceNumber
• service_auth::ServiceAuthResult
• tls::TlsResult
• transaction::TransactionId

Constants

• idempotent::NO_SEQUENCE
• quota::DEFAULT_CONSUME_BYTES_RATE
• quota::DEFAULT_PRODUCE_BYTES_RATE
• quota::DEFAULT_REQUEST_RATE
• quota::UNLIMITED
• topic_config::DEFAULT_MAX_MESSAGE_BYTES
• topic_config::DEFAULT_RETENTION_BYTES
• topic_config::DEFAULT_RETENTION_MS
• topic_config::DEFAULT_SEGMENT_BYTES
• topic_config::DEFAULT_SEGMENT_MS
• transaction::DEFAULT_TRANSACTION_TIMEOUT
• transaction::MAX_PENDING_TRANSACTIONS
• validation::DEFAULT_MAX_MESSAGE_SIZE
• validation::MAX_IDENTIFIER_LENGTH
• validation::MAX_TOPIC_NAME_LENGTH
• validation::MIN_TOPIC_NAME_LENGTH