List of all items

Structs

• base::ByteBuffer
• base::allocate_mapped_file_service::AllocateMappedFileService
• base::get_message_result::GetMessageResult
• base::message_result::AppendMessageResult
• base::message_result::PutMessageResult
• base::put_message_context::PutMessageContext
• base::query_message_result::QueryMessageResult
• base::select_result::SelectMappedBufferResult
• base::store_checkpoint::StoreCheckpoint
• base::store_stats_service::CallSnapshot
• base::store_stats_service::StoreStatsService
• base::transient_store_pool::TransientStorePool
• config::message_store_config::MessageStoreConfig
• consume_queue::consume_queue_ext::CqExtUnit
• consume_queue::mapped_file_queue::MappedFileQueue
• log_file::commit_log::CommitLog
• log_file::flush_manager_impl::defalut_flush_manager::DefaultFlushManager
• log_file::mapped_file::default_mapped_file_impl::DefaultMappedFile
• log_file::mapped_file::default_mapped_file_impl::ReferenceResource
• message_store::default_message_store::CommitLogDispatcherDefault
• message_store::default_message_store::DefaultMessageStore
• stats::broker_stats::BrokerStats
• stats::broker_stats_manager::BrokerStatsManager
• store::running_flags::RunningFlags
• timer::timer_message_store::TimerMessageStore

Enums

• base::message_status_enum::AppendMessageStatus
• base::message_status_enum::GetMessageStatus
• base::message_status_enum::PutMessageStatus
• base::store_enum::StoreType
• config::broker_role::BrokerRole
• config::flush_disk_type::FlushDiskType
• stats::stats_type::StatsType

Traits

• base::append_message_callback::AppendMessageCallback
• base::commit_log_dispatcher::CommitLogDispatcher
• base::compaction_append_msg_callback::CompactionAppendMsgCallback
• base::flush_manager::FlushManager
• base::flush_manager::RocketMQFlushManager
• base::message_arriving_listener::MessageArrivingListener
• base::swappable::Swappable
• filter::MessageFilter
• hook::put_message_hook::PutMessageHook
• log_file::MessageStore
• log_file::RocketMQMessageStore
• log_file::mapped_file::MappedFile

Functions

• log_file::commit_log::check_message_and_return_size
• log_file::commit_log::get_cq_type
• log_file::commit_log::get_message_num
• stats::broker_stats_manager::build_account_stat_key
• stats::broker_stats_manager::build_account_stat_key_with_flowlimit
• stats::broker_stats_manager::build_account_stats_key
• stats::broker_stats_manager::build_account_stats_key_with_flowlimit
• stats::broker_stats_manager::build_commercial_stats_key
• stats::broker_stats_manager::build_stats_key
• stats::broker_stats_manager::create_statistics_kind_meta
• stats::broker_stats_manager::split_account_stat_key
• store_path_config_helper::get_abort_file
• store_path_config_helper::get_delay_offset_store_path
• store_path_config_helper::get_lock_file
• store_path_config_helper::get_store_checkpoint
• store_path_config_helper::get_store_path_batch_consume_queue
• store_path_config_helper::get_store_path_consume_queue
• store_path_config_helper::get_store_path_consume_queue_ext
• store_path_config_helper::get_store_path_index

Type Aliases

• hook::put_message_hook::BoxedPutMessageHook

Constants

• log_file::MAX_PULL_MSG_SIZE
• log_file::commit_log::BLANK_MAGIC_CODE
• log_file::commit_log::CRC32_RESERVED_LEN
• log_file::commit_log::MESSAGE_MAGIC_CODE
• log_file::mapped_file::default_mapped_file_impl::OS_PAGE_SIZE
• timer::timer_message_store::DAY_SECS
• timer::timer_message_store::DEFAULT_CAPACITY
• timer::timer_message_store::MAGIC_DEFAULT
• timer::timer_message_store::MAGIC_DELETE
• timer::timer_message_store::MAGIC_ROLL
• timer::timer_message_store::PUT_NEED_RETRY
• timer::timer_message_store::PUT_NO_RETRY
• timer::timer_message_store::PUT_OK
• timer::timer_message_store::TIMER_BLANK_SLOTS
• timer::timer_message_store::TIMER_DELETE_UNIQUE_KEY
• timer::timer_message_store::TIMER_DEQUEUE_MS
• timer::timer_message_store::TIMER_ENQUEUE_MS
• timer::timer_message_store::TIMER_OUT_MS
• timer::timer_message_store::TIMER_ROLL_TIMES
• timer::timer_message_store::TIMER_TOPIC
• timer::timer_message_store::TIMER_WHEEL_TTL_DAY