List of all items

Structs

• PullResultExt
• TraceDataEncoder
• admin::default_mq_admin_ext_impl::DefaultMQAdminExtImpl
• admin::mq_admin_ext_async_inner::MQAdminExtInnerImpl
• base::client_config::ClientConfig
• base::client_config_builder::ClientConfigBuilder
• base::client_config_validation::ClientConfigValidator
• base::query_result::QueryResult
• base::validators::Validators
• common::admin_tool_result::AdminToolResult
• common::client_error_code::ClientErrorCode
• common::session_credentials::SessionCredentials
• common::thread_local_index::ThreadLocalIndex
• consumer::ack_result::AckResult
• consumer::consumer_impl::process_queue::ProcessQueue
• consumer::consumer_impl::pull_message_service::PullMessageService
• consumer::consumer_impl::pull_request::PullRequest
• consumer::default_lite_pull_consumer::DefaultLitePullConsumer
• consumer::default_lite_pull_consumer_builder::DefaultLitePullConsumerBuilder
• consumer::default_mq_push_consumer::ConsumerConfig
• consumer::default_mq_push_consumer::DefaultMQPushConsumer
• consumer::default_mq_push_consumer_builder::DefaultMQPushConsumerBuilder
• consumer::listener::consume_concurrently_context::ConsumeConcurrentlyContext
• consumer::listener::consume_orderly_context::ConsumeOrderlyContext
• consumer::message_selector::MessageSelector
• consumer::pop_callback::DefaultPopCallback
• consumer::pop_result::PopResult
• consumer::pull_result::PullResult
• consumer::rebalance_strategy::allocate_message_queue_averagely::AllocateMessageQueueAveragely
• consumer::rebalance_strategy::allocate_message_queue_averagely_by_circle::AllocateMessageQueueAveragelyByCircle
• consumer::rebalance_strategy::allocate_message_queue_by_config::AllocateMessageQueueByConfig
• consumer::rebalance_strategy::allocate_message_queue_by_machine_room::AllocateMessageQueueByMachineRoom
• consumer::rebalance_strategy::allocate_message_queue_by_machine_room_nearby::AllocateMessageQueueByMachineRoomNearby
• factory::mq_client_instance::MQClientInstance
• implementation::mq_client_manager::MQClientManager
• producer::default_mq_produce_builder::DefaultMQProducerBuilder
• producer::default_mq_producer::DefaultMQProducer
• producer::default_mq_producer::ProducerConfig
• producer::produce_accumulator::AggregateKey
• producer::produce_accumulator::ProduceAccumulator
• producer::producer_config_validation::ProducerConfigValidator
• producer::producer_impl::topic_publish_info::TopicPublishInfo
• producer::queue_selector::select_message_queue_by_hash::SelectMessageQueueByHash
• producer::queue_selector::select_message_queue_by_random::SelectMessageQueueByRandom
• producer::send_result::SendResult
• producer::transaction_mq_produce_builder::TransactionMQProducerBuilder
• producer::transaction_mq_producer::TransactionMQProducer
• producer::transaction_mq_producer::TransactionProducerConfig
• producer::transaction_send_result::TransactionSendResult
• stat::consumer_stats_manager::ConsumerStatsManager
• utils::message_util::MessageUtil

Enums

• base::access_channel::AccessChannel
• common::admin_tools_result_code_enum::AdminToolsResultCodeEnum
• consumer::ack_status::AckStatus
• consumer::listener::consume_concurrently_status::ConsumeConcurrentlyStatus
• consumer::listener::consume_orderly_status::ConsumeOrderlyStatus
• consumer::listener::consume_return_type::ConsumeReturnType
• consumer::pop_status::PopStatus
• consumer::pull_status::PullStatus
• producer::local_transaction_state::LocalTransactionState
• producer::send_status::SendStatus

Traits

• admin::mq_admin_ext_async::MQAdminExt
• admin::mq_admin_ext_inner::MQAdminExtInner
• base::mq_admin::MQAdmin
• base::mq_client_admin::MqClientAdmin
• base::mq_client_admin::MqClientAdminInner
• consumer::ack_callback::AckCallback
• consumer::allocate_message_queue_strategy::AllocateMessageQueueStrategy
• consumer::listener::message_listener_concurrently::MessageListenerConcurrently
• consumer::listener::message_listener_orderly::MessageListenerOrderly
• consumer::lite_pull_consumer::LitePullConsumer
• consumer::lite_pull_consumer::LitePullConsumerLocal
• consumer::message_queue_listener::MessageQueueListener
• consumer::mq_consumer::MQConsumer
• consumer::mq_push_consumer::MQPushConsumer
• consumer::pop_callback::PopCallback
• consumer::pop_callback::PopCallbackInner
• consumer::rebalance_strategy::allocate_message_queue_by_machine_room_nearby::MachineRoomResolver
• consumer::topic_message_queue_change_listener::TopicMessageQueueChangeListener
• producer::message_queue_selector::MessageQueueSelector
• producer::mq_producer::MQProducer
• producer::producer_impl::queue_filter::QueueFilter
• producer::request_callback::RequestCallback
• producer::send_callback::SendCallback
• producer::transaction_listener::TransactionListener

Macros

• client_broker_err
• mq_client_err

Functions

• consumer::rebalance_strategy::check
• factory::mq_client_instance::topic_route_data2topic_publish_info
• factory::mq_client_instance::topic_route_data2topic_subscribe_info
• producer::producer_impl::timeout_utils::with_timeout
• producer::producer_impl::timeout_utils::with_timeout_all
• producer::producer_impl::timeout_utils::with_timeout_millis
• producer::producer_impl::timeout_utils::with_timeout_named

Type Aliases

• consumer::ack_callback::AckCallbackFn
• consumer::listener::message_listener_concurrently::ArcMessageListenerConcurrently
• consumer::listener::message_listener_orderly::ArcMessageListenerOrderly
• consumer::message_queue_listener::ArcMessageQueueListener
• consumer::pop_callback::PopCallbackFn
• factory::client_tables::AdminExtTable
• factory::client_tables::BrokerAddrTable
• factory::client_tables::BrokerHeartbeatFingerprintTable
• factory::client_tables::BrokerSupportV2HeartbeatSet
• factory::client_tables::BrokerVersionTable
• factory::client_tables::ConsumerTable
• factory::client_tables::ProducerTable
• factory::client_tables::TopicEndPointsTable
• factory::client_tables::TopicRouteTable
• producer::message_queue_selector::MessageQueueSelectorFn
• producer::request_callback::RequestCallbackFn
• producer::send_callback::ArcSendCallback
• producer::send_callback::SendMessageCallback
• producer::transaction_listener::ArcTransactionListener

Statics

• consumer::consumer_impl::process_queue::REBALANCE_LOCK_INTERVAL
• consumer::consumer_impl::process_queue::REBALANCE_LOCK_MAX_LIVE_TIME

Constants

• common::session_credentials::ACCESS_KEY
• common::session_credentials::SECRET_KEY
• common::session_credentials::SECURITY_TOKEN
• common::session_credentials::SIGNATURE