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::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
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::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