List of all items

Structs

• base::request_task::RequestTask
• base::response_future::ResponseFuture
• base::tokio_event::TokioEvent
• clients::BlockingClient
• clients::Client
• clients::connection_pool::ConnectionMetrics
• clients::connection_pool::ConnectionPool
• clients::connection_pool::PoolStats
• clients::connection_pool::PooledConnection
• clients::reconnect::CircuitBreaker
• clients::reconnect::ExponentialBackoff
• clients::rocketmq_tokio_client::RocketmqDefaultClient
• codec::remoting_command_codec::CompositeCodec
• codec::remoting_command_codec::RemotingCommandCodec
• common::remoting_helper::RemotingHelper
• connection::Connection
• connection_v2::ConcurrentConnection
• connection_v2::RefactoredConnection
• net::channel::Channel
• net::channel::ChannelInner
• protocol::DataVersion
• protocol::admin::consume_stats::ConsumeStats
• protocol::admin::consume_stats_list::ConsumeStatsList
• protocol::admin::offset_wrapper::OffsetWrapper
• protocol::admin::rollback_stats::RollbackStats
• protocol::admin::topic_offset::TopicOffset
• protocol::admin::topic_stats_table::TopicStatsTable
• protocol::body::acl_info::AclInfo
• protocol::body::acl_info::PolicyEntryInfo
• protocol::body::acl_info::PolicyInfo
• protocol::body::batch_ack::BatchAck
• protocol::body::batch_ack::SerializableBitVec
• protocol::body::batch_ack_message_request_body::BatchAckMessageRequestBody
• protocol::body::broker_body::broker_member_group::BrokerMemberGroup
• protocol::body::broker_body::broker_member_group::GetBrokerMemberGroupResponseBody
• protocol::body::broker_body::cluster_info::ClusterInfo
• protocol::body::broker_body::register_broker_body::RegisterBrokerBody
• protocol::body::broker_item::BrokerStatsItem
• protocol::body::broker_replicas_info::BrokerReplicasInfo
• protocol::body::broker_replicas_info::ReplicaIdentity
• protocol::body::broker_replicas_info::ReplicasInfo
• protocol::body::check_client_request_body::CheckClientRequestBody
• protocol::body::check_rocksdb_cqwrite_progress_response_body::ClusterAclVersionInfo
• protocol::body::cluster_acl_version_info::ClusterAclVersionInfo
• protocol::body::connection::Connection
• protocol::body::consume_message_directly_result::ConsumeMessageDirectlyResult
• protocol::body::consume_queue_data::ConsumeQueueData
• protocol::body::consume_status::ConsumeStatus
• protocol::body::consumer_connection::ConsumerConnection
• protocol::body::consumer_offset_serialize_wrapper::ConsumerOffsetSerializeWrapper
• protocol::body::consumer_running_info::ConsumerRunningInfo
• protocol::body::create_topic_list_request_body::CreateTopicListRequestBody
• protocol::body::epoch_entry_cache::EpochEntry
• protocol::body::epoch_entry_cache::EpochEntryCache
• protocol::body::get_consumer_listby_group_response_body::GetConsumerListByGroupResponseBody
• protocol::body::group_list::GroupList
• protocol::body::ha_client_runtime_info::HAClientRuntimeInfo
• protocol::body::ha_connection_runtime_info::HAConnectionRuntimeInfo
• protocol::body::ha_runtime_info::HARuntimeInfo
• protocol::body::kv_table::KVTable
• protocol::body::message_request_mode_serialize_wrapper::MessageRequestModeSerializeWrapper
• protocol::body::pop_process_queue_info::PopProcessQueueInfo
• protocol::body::process_queue_info::ProcessQueueInfo
• protocol::body::producer_connection::ProducerConnection
• protocol::body::producer_info::ProducerInfo
• protocol::body::producer_table_info::ProducerTableInfo
• protocol::body::query_assignment_request_body::QueryAssignmentRequestBody
• protocol::body::query_assignment_response_body::QueryAssignmentResponseBody
• protocol::body::query_consume_queue_response_body::QueryConsumeQueueResponseBody
• protocol::body::queue_time_span::QueueTimeSpan
• protocol::body::request::lock_batch_request_body::LockBatchRequestBody
• protocol::body::response::lock_batch_response_body::LockBatchResponseBody
• protocol::body::set_message_request_mode_request_body::SetMessageRequestModeRequestBody
• protocol::body::subscription_group_wrapper::SubscriptionGroupWrapper
• protocol::body::sync_state_set_body::SyncStateSet
• protocol::body::timer_metrics_serialize_wrapper::Metric
• protocol::body::timer_metrics_serialize_wrapper::TimerMetricsSerializeWrapper
• protocol::body::topic::topic_list::TopicList
• protocol::body::topic_info_wrapper::TopicConfigSerializeWrapper
• protocol::body::topic_info_wrapper::topic_config_wrapper::TopicConfigAndMappingSerializeWrapper
• protocol::body::topic_info_wrapper::topic_config_wrapper::TopicConfigSerializeWrapper
• protocol::body::topic_info_wrapper::topic_queue_wrapper::TopicQueueMappingSerializeWrapper
• protocol::body::unlock_batch_request_body::UnlockBatchRequestBody
• protocol::body::user_info::UserInfo
• protocol::broker_sync_info::BrokerSyncInfo
• protocol::filter::filter_api::FilterAPI
• protocol::forbidden_type::ForbiddenType
• protocol::header::ack_message_request_header::AckMessageRequestHeader
• protocol::header::broker::broker_heartbeat_request_header::BrokerHeartbeatRequestHeader
• protocol::header::change_invisible_time_request_header::ChangeInvisibleTimeRequestHeader
• protocol::header::change_invisible_time_response_header::ChangeInvisibleTimeResponseHeader
• protocol::header::check_transaction_state_request_header::CheckTransactionStateRequestHeader
• protocol::header::client_request_header::GetRouteInfoRequestHeader
• protocol::header::consume_message_directly_result_request_header::ConsumeMessageDirectlyResultRequestHeader
• protocol::header::consumer_send_msg_back_request_header::ConsumerSendMsgBackRequestHeader
• protocol::header::create_topic_request_header::CreateTopicRequestHeader
• protocol::header::delete_subscription_group_request_header::DeleteSubscriptionGroupRequestHeader
• protocol::header::delete_topic_request_header::DeleteTopicRequestHeader
• protocol::header::elect_master_response_header::ElectMasterResponseHeader
• protocol::header::empty_header::EmptyHeader
• protocol::header::end_transaction_request_header::EndTransactionRequestHeader
• protocol::header::exchange_ha_info_request_header::ExchangeHAInfoRequestHeader
• protocol::header::exchange_ha_info_response_header::ExchangeHaInfoResponseHeader
• protocol::header::extra_info_util::ExtraInfoUtil
• protocol::header::get_all_topic_config_response_header::GetAllTopicConfigResponseHeader
• protocol::header::get_consume_stats_request_header::GetConsumeStatsRequestHeader
• protocol::header::get_consumer_connection_list_request_header::GetConsumerConnectionListRequestHeader
• protocol::header::get_consumer_listby_group_request_header::GetConsumerListByGroupRequestHeader
• protocol::header::get_consumer_listby_group_response_header::GetConsumerListByGroupResponseHeader
• protocol::header::get_consumer_running_info_request_header::GetConsumerRunningInfoRequestHeader
• protocol::header::get_earliest_msg_storetime_response_header::GetEarliestMsgStoretimeResponseHeader
• protocol::header::get_max_offset_request_header::GetMaxOffsetRequestHeader
• protocol::header::get_max_offset_response_header::GetMaxOffsetResponseHeader
• protocol::header::get_meta_data_response_header::GetMetaDataResponseHeader
• protocol::header::get_min_offset_request_header::GetMinOffsetRequestHeader
• protocol::header::get_min_offset_response_header::GetMinOffsetResponseHeader
• protocol::header::get_topic_config_request_header::GetTopicConfigRequestHeader
• protocol::header::get_topic_stats_info_request_header::GetTopicStatsInfoRequestHeader
• protocol::header::get_topic_stats_request_header::GetTopicStatsRequestHeader
• protocol::header::heartbeat_request_header::HeartbeatRequestHeader
• protocol::header::lock_batch_mq_request_header::LockBatchMqRequestHeader
• protocol::header::message_operation_header::send_message_request_header::SendMessageRequestHeader
• protocol::header::message_operation_header::send_message_request_header_v2::SendMessageRequestHeaderV2
• protocol::header::message_operation_header::send_message_response_header::SendMessageResponseHeader
• protocol::header::namesrv::broker_request::BrokerHeartbeatRequestHeader
• protocol::header::namesrv::broker_request::GetBrokerMemberGroupRequestHeader
• protocol::header::namesrv::broker_request::UnRegisterBrokerRequestHeader
• protocol::header::namesrv::brokerid_change_request_header::NotifyMinBrokerIdChangeRequestHeader
• protocol::header::namesrv::kv_config_header::DeleteKVConfigRequestHeader
• protocol::header::namesrv::kv_config_header::GetKVConfigRequestHeader
• protocol::header::namesrv::kv_config_header::GetKVConfigResponseHeader
• protocol::header::namesrv::kv_config_header::GetKVListByNamespaceRequestHeader
• protocol::header::namesrv::kv_config_header::PutKVConfigRequestHeader
• protocol::header::namesrv::perm_broker_header::AddWritePermOfBrokerRequestHeader
• protocol::header::namesrv::perm_broker_header::AddWritePermOfBrokerResponseHeader
• protocol::header::namesrv::perm_broker_header::WipeWritePermOfBrokerRequestHeader
• protocol::header::namesrv::perm_broker_header::WipeWritePermOfBrokerResponseHeader
• protocol::header::namesrv::query_data_version_header::QueryDataVersionRequestHeader
• protocol::header::namesrv::query_data_version_header::QueryDataVersionResponseHeader
• protocol::header::namesrv::register_broker_header::RegisterBrokerRequestHeader
• protocol::header::namesrv::register_broker_header::RegisterBrokerResponseHeader
• protocol::header::namesrv::topic_operation_header::DeleteTopicFromNamesrvRequestHeader
• protocol::header::namesrv::topic_operation_header::GetTopicsByClusterRequestHeader
• protocol::header::namesrv::topic_operation_header::RegisterTopicRequestHeader
• protocol::header::namesrv::topic_operation_header::TopicRequestHeader
• protocol::header::notification_request_header::NotificationRequestHeader
• protocol::header::notification_response_header::NotificationResponseHeader
• protocol::header::notify_broker_role_change_request_header::NotifyBrokerRoleChangedRequestHeader
• protocol::header::notify_consumer_ids_changed_request_header::NotifyConsumerIdsChangedRequestHeader
• protocol::header::pop_message_request_header::PopMessageRequestHeader
• protocol::header::pop_message_response_header::PopMessageResponseHeader
• protocol::header::pull_message_request_header::PullMessageRequestHeader
• protocol::header::pull_message_response_header::PullMessageResponseHeader
• protocol::header::query_consume_time_span_request_header::QueryConsumeTimeSpanRequestHeader
• protocol::header::query_consumer_offset_request_header::QueryConsumerOffsetRequestHeader
• protocol::header::query_consumer_offset_response_header::QueryConsumerOffsetResponseHeader
• protocol::header::query_message_request_header::QueryMessageRequestHeader
• protocol::header::query_message_response_header::QueryMessageResponseHeader
• protocol::header::query_subscription_by_consumer_request_header::QuerySubscriptionByConsumerRequestHeader
• protocol::header::query_topic_consume_by_who_request_header::QueryTopicConsumeByWhoRequestHeader
• protocol::header::query_topics_by_consumer_request_header::QueryTopicsByConsumerRequestHeader
• protocol::header::reply_message_request_header::ReplyMessageRequestHeader
• protocol::header::reset_master_flush_offset_header::ResetMasterFlushOffsetHeader
• protocol::header::reset_offset_request_header::ResetOffsetRequestHeader
• protocol::header::search_offset_response_header::SearchOffsetResponseHeader
• protocol::header::unlock_batch_mq_request_header::UnlockBatchMqRequestHeader
• protocol::header::unregister_client_request_header::UnregisterClientRequestHeader
• protocol::header::update_consumer_offset_header::UpdateConsumerOffsetRequestHeader
• protocol::header::update_consumer_offset_header::UpdateConsumerOffsetResponseHeader
• protocol::header::view_message_request_header::ViewMessageRequestHeader
• protocol::header::view_message_response_header::ViewMessageResponseHeader
• protocol::heartbeat::consumer_data::ConsumerData
• protocol::heartbeat::heartbeat_data::HeartbeatData
• protocol::heartbeat::producer_data::ProducerData
• protocol::heartbeat::subscription_data::SubscriptionData
• protocol::namespace_util::NamespaceUtil
• protocol::namesrv::RegisterBrokerResult
• protocol::remoting_command::RemotingCommand
• protocol::remoting_command::SERIALIZE_TYPE_CONFIG_IN_THIS_SERVER
• protocol::rocketmq_serializable::RocketMQSerializable
• protocol::route::route_data_view::BrokerData
• protocol::route::route_data_view::QueueData
• protocol::route::topic_route_data::TopicRouteData
• protocol::static_topic::logic_queue_mapping_item::LogicQueueMappingItem
• protocol::static_topic::topic_config_and_queue_mapping::TopicConfigAndQueueMapping
• protocol::static_topic::topic_queue_info::TopicQueueMappingInfo
• protocol::static_topic::topic_queue_mapping_context::TopicQueueMappingContext
• protocol::static_topic::topic_queue_mapping_detail::TopicQueueMappingDetail
• protocol::static_topic::topic_queue_mapping_one::TopicQueueMappingOne
• protocol::static_topic::topic_queue_mapping_utils::MappingAllocator
• protocol::static_topic::topic_queue_mapping_utils::TopicQueueMappingUtils
• protocol::static_topic::topic_remapping_detail_wrapper::TopicRemappingDetailWrapper
• protocol::subscription::broker_stats_data::BrokerStatsData
• protocol::subscription::customized_retry_policy::CustomizedRetryPolicy
• protocol::subscription::exponential_retry_policy::ExponentialRetryPolicy
• protocol::subscription::group_forbidden::GroupForbidden
• protocol::subscription::group_retry_policy::GroupRetryPolicy
• protocol::subscription::simple_subscription_data::SimpleSubscriptionData
• protocol::subscription::subscription_group_config::SubscriptionGroupConfig
• protocol::topic::OffsetMovedEvent
• remoting_server::rocketmq_tokio_server::ConnectionHandler
• remoting_server::rocketmq_tokio_server::RocketMQServer
• request_processor::default_request_processor::DefaultRemotingRequestProcessor
• rpc::client_metadata::ClientMetadata
• rpc::rpc_client_impl::RpcClientImpl
• rpc::rpc_client_utils::RpcClientUtils
• rpc::rpc_request::RpcRequest
• rpc::rpc_request_header::RpcRequestHeader
• rpc::rpc_response::RpcResponse
• rpc::topic_request_header::TopicRequestHeader
• runtime::config::client_config::TokioClientConfig
• runtime::connection_handler_context::ConnectionHandlerContextWrapper
• smart_encode_buffer::BufferStats
• smart_encode_buffer::EncodeBuffer
• smart_encode_buffer::EncodeBufferConfig

Enums

• base::connection_net_event::ConnectionNetEvent
• clients::reconnect::CircuitState
• code::broker_request_code::BrokerRequestCode
• code::request_code::RequestCode
• code::response_code::RemotingSysResponseCode
• code::response_code::ResponseCode
• connection::ConnectionState
• connection_v2::ConnectionState
• protocol::LanguageCode
• protocol::RemotingCommandType
• protocol::SerializeType
• protocol::body::cm_result::CMResult
• protocol::heartbeat::consume_type::ConsumeType
• protocol::heartbeat::message_model::MessageModel
• protocol::request_source::RequestSource
• protocol::request_type::RequestType
• protocol::subscription::group_retry_policy_type::GroupRetryPolicyType

Traits

• base::channel_event_listener::ChannelEventListener
• clients::RemotingClient
• protocol::FastCodesHeader
• protocol::JsonSerializable
• protocol::RemotingDeserializable
• protocol::RemotingSerializable
• protocol::command_custom_header::AsAny
• protocol::command_custom_header::CommandCustomHeader
• protocol::command_custom_header::FromMap
• protocol::header::message_operation_header::TopicRequestHeaderTrait
• protocol::subscription::retry_policy::RetryPolicy
• remoting::InvokeCallback
• remoting::RemotingService
• remoting_server::RemotingServer
• rpc::rpc_client::RpcClient
• rpc::rpc_client::RpcClientLocal
• rpc::rpc_client_hook::RpcClientHook
• runtime::RPCHook
• runtime::processor::LocalRequestProcessor
• runtime::processor::RequestProcessor

Functions

• error_helpers::abort_process_error
• error_helpers::channel_recv_failed
• error_helpers::channel_send_failed
• error_helpers::connection_invalid
• error_helpers::decoder_error
• error_helpers::decoding_error
• error_helpers::deserialize_header_error
• error_helpers::encoder_error
• error_helpers::illegal_argument
• error_helpers::io_error
• error_helpers::remote_error
• error_helpers::unsupported_serialize_type
• protocol::header::message_operation_header::send_message_request_header::parse_request_header
• protocol::remoting_command::mark_protocol_type
• protocol::remoting_command::parse_header_length
• protocol::remoting_command::parse_serialize_type
• remoting_server::rocketmq_tokio_server::run

Type Aliases

• base::remoting_fn::ConnectedListener
• connection::ConnectionId
• net::channel::ArcChannel
• net::channel::ChannelId
• protocol::body::message_request_mode_serialize_wrapper::MessageRequestModeMap
• rpc::rpc_client_hook::RpcClientHookFn
• runtime::connection_handler_context::ConnectionHandlerContext
• runtime::processor::RejectRequestResponse

Constants

• protocol::remoting_command::REMOTING_VERSION_KEY
• protocol::remoting_command::SERIALIZE_TYPE_ENV
• protocol::remoting_command::SERIALIZE_TYPE_PROPERTY
• protocol::static_topic::topic_remapping_detail_wrapper::SUFFIX_AFTER
• protocol::static_topic::topic_remapping_detail_wrapper::SUFFIX_BEFORE
• protocol::static_topic::topic_remapping_detail_wrapper::TYPE_CREATE_OR_UPDATE
• protocol::static_topic::topic_remapping_detail_wrapper::TYPE_REMAPPING