List of all items

Structs

• error::AddEntryLogBatchSnafu
• error::BatchProduceSnafu
• error::BuildClientSnafu
• error::BuildPartitionClientSnafu
• error::CastSnafu
• error::ConsumeRecordSnafu
• error::CreateWriterSnafu
• error::DecodeJsonSnafu
• error::DiscontinuousLogIndexSnafu
• error::EncodeJsonSnafu
• error::FetchEntrySnafu
• error::GetOffsetSnafu
• error::IllegalNamespaceSnafu
• error::IllegalSequenceSnafu
• error::IllegalStateSnafu
• error::InvalidProviderSnafu
• error::IoSnafu
• error::MetaLengthExceededLimitSnafu
• error::MissingKeySnafu
• error::MissingValueSnafu
• error::NoMaxValueSnafu
• error::OrderedBatchProducerStoppedSnafu
• error::OverrideCompactedEntrySnafu
• error::ProduceRecordSnafu
• error::RaftEngineSnafu
• error::ReadIndexSnafu
• error::ResolveKafkaEndpointSnafu
• error::StartWalTaskSnafu
• error::StopWalTaskSnafu
• error::TlsConfigSnafu
• error::WaitDumpIndexSnafu
• error::WaitProduceResultReceiverSnafu
• error::WriteIndexSnafu
• kafka::EntryImpl
• kafka::GlobalIndexCollector
• kafka::NamespaceImpl
• kafka::client_manager::Client
• kafka::client_manager::ClientManager
• kafka::consumer::Consumer
• kafka::consumer::ConsumerBuilder
• kafka::consumer::FetchResult
• kafka::consumer::RecordsBuffer
• kafka::high_watermark_manager::HighWatermarkManager
• kafka::index::collector::CollectionTask
• kafka::index::collector::CollectionTaskHandle
• kafka::index::collector::GlobalIndexCollector
• kafka::index::collector::NoopCollector
• kafka::index::collector::ProviderLevelIndexCollector
• kafka::index::collector::RegionIndexes
• kafka::index::encoder::DatanodeWalIndexes
• kafka::index::encoder::DeltaEncodedRegionIndexes
• kafka::index::encoder::JsonIndexEncoder
• kafka::index::iterator::MultipleRegionWalIndexIterator
• kafka::index::iterator::NextBatchHint
• kafka::index::iterator::RegionWalRange
• kafka::index::iterator::RegionWalVecIndex
• kafka::log_store::KafkaLogStore
• kafka::producer::OrderedBatchProducer
• kafka::util::range::ConvertIndexToRange
• kafka::util::range::MergeRange
• kafka::util::record::Record
• kafka::util::record::RecordMeta
• kafka::worker::BackgroundProducerWorker
• kafka::worker::DumpIndexRequest
• kafka::worker::PendingRequest
• kafka::worker::ProduceRequest
• kafka::worker::ProduceResultHandle
• kafka::worker::ProduceResultReceiver
• kafka::worker::TruncateIndexRequest
• metrics::METRIC_KAFKA_APPEND_BATCH_BYTES_TOTAL
• metrics::METRIC_KAFKA_APPEND_BATCH_ELAPSED
• metrics::METRIC_KAFKA_CLIENT_BYTES_TOTAL
• metrics::METRIC_KAFKA_CLIENT_PRODUCE_ELAPSED
• metrics::METRIC_KAFKA_CLIENT_TRAFFIC_TOTAL
• metrics::METRIC_KAFKA_READ_BYTES_TOTAL
• metrics::METRIC_KAFKA_READ_ELAPSED
• metrics::METRIC_LOGSTORE_OP_BYTES_TOTAL
• metrics::METRIC_LOGSTORE_OP_ELAPSED
• metrics::METRIC_RAFT_ENGINE_APPEND_BATCH_BYTES_TOTAL
• metrics::METRIC_RAFT_ENGINE_APPEND_BATCH_ELAPSED
• metrics::METRIC_RAFT_ENGINE_READ_BYTES_TOTAL
• metrics::METRIC_RAFT_ENGINE_READ_ELAPSED
• raft_engine::Config
• raft_engine::RaftEngineBackend
• raft_engine::backend::RaftEngineBackend
• raft_engine::log_store::MessageType
• raft_engine::log_store::PurgeExpiredFilesFunction
• raft_engine::log_store::RaftEngineLogStore
• raft_engine::log_store::SyncWalTaskFunction
• raft_engine::protos::logstore::EntryImpl
• raft_engine::protos::logstore::LogStoreState
• raft_engine::protos::logstore::NamespaceImpl

Enums

• error::Error
• kafka::consumer::ConsumerBuilderError
• kafka::util::record::RecordType
• kafka::worker::WorkerRequest

Traits

• kafka::consumer::FetchClient
• kafka::index::collector::IndexCollector
• kafka::index::encoder::IndexEncoder
• kafka::index::iterator::RegionWalIndexIterator
• kafka::producer::ProducerClient

Functions

• error::rskafka_client_error_to_status_code
• kafka::default_index_file
• kafka::index::default_index_file
• kafka::index::iterator::build_region_wal_index_iterator
• kafka::log_store::build_entry
• kafka::log_store::check_termination
• kafka::util::range::merge
• kafka::util::record::convert_to_kafka_records
• kafka::util::record::convert_to_multiple_entry
• kafka::util::record::convert_to_naive_entry
• kafka::util::record::maybe_emit_entry
• kafka::util::record::remaining_entries
• raft_engine::backend::engine_delete
• raft_engine::backend::engine_get
• raft_engine::backend::engine_put
• raft_engine::backend::ensure_dir
• raft_engine::protos::logstore::file_descriptor_proto
• raft_engine::protos::logstore::parse_descriptor_proto
• test_util::log_store_util::create_kafka_log_store
• test_util::log_store_util::create_tmp_local_file_log_store

Type Aliases

• error::Result
• kafka::client_manager::ClientManagerRef
• kafka::producer::OrderedBatchProducerRef

Statics

• raft_engine::protos::logstore::file_descriptor_proto_data
• raft_engine::protos::logstore::file_descriptor_proto_lazy

Constants

• kafka::DEFAULT_PARTITION
• kafka::client_manager::DEFAULT_PARTITION
• kafka::consumer::AVG_RECORD_SIZE
• kafka::consumer::MAX_BATCH_SIZE
• kafka::index::iterator::MIN_BATCH_WINDOW_SIZE
• kafka::log_store::DEFAULT_HIGH_WATERMARK_UPDATE_INTERVAL
• kafka::producer::PRODUCER_CHANNEL_SIZE
• kafka::producer::REQUEST_BATCH_SIZE
• kafka::util::record::ESTIMATED_META_SIZE
• kafka::util::record::VERSION
• metrics::LOGSTORE_LABEL
• metrics::OPTYPE_LABEL
• metrics::PARTITION_LABEL
• metrics::TOPIC_LABEL
• raft_engine::backend::SYSTEM_NAMESPACE
• raft_engine::log_store::NAMESPACE_PREFIX