Struct DefaultMQ Admin Ext &nbsp; Copy item path

pub fn with_rpc_hook_and_timeout( rpc_hook: Arc<dyn RPCHook>, timeout_millis: Duration, ) -> Self

pub fn with_admin_ext_group(admin_ext_group: impl Into<CheetahString>) -> Self

pub fn with_admin_ext_group_and_timeout( admin_ext_group: impl Into<CheetahString>, timeout_millis: Duration, ) -> Self

pub fn with_admin_ext_group_and_rpc_hook( admin_ext_group: impl Into<CheetahString>, rpc_hook: Arc<dyn RPCHook>, ) -> Self

pub fn set_namesrv_addr(&mut self, name_serv_addr: impl Into<CheetahString>)

pub fn is_use_tls(&self) -> bool

pub fn set_use_tls(&mut self, use_tls: bool)

pub fn client_config(&self) -> &ArcMut<ClientConfig>

pub fn client_config_mut(&mut self) -> &mut ArcMut<ClientConfig>

pub fn inner(&self) -> &ArcMut<DefaultMQAdminExtImpl>

pub fn inner_mut(&mut self) -> &mut ArcMut<DefaultMQAdminExtImpl>

pub fn has_inner(&self) -> bool

pub async fn start(&mut self) -> RocketMQResult<()>

pub async fn shutdown(&mut self)

Methods from Deref<Target = DefaultMQAdminExtImpl>§

pub fn set_inner(&mut self, inner: ArcMut<DefaultMQAdminExtImpl>)

pub fn has_inner(&self) -> bool

pub fn is_use_tls(&self) -> bool

pub fn set_use_tls(&mut self, use_tls: bool)

pub async fn create_acl_with_acl_info( &self, broker_addr: CheetahString, acl_info: AclInfo, ) -> RocketMQResult<()>

pub async fn update_acl_with_acl_info( &self, broker_addr: CheetahString, acl_info: AclInfo, ) -> RocketMQResult<()>

pub async fn create_user_with_user_info( &self, broker_addr: CheetahString, user_info: UserInfo, ) -> RocketMQResult<()>

pub async fn update_user_with_user_info( &self, broker_addr: CheetahString, user_info: UserInfo, ) -> RocketMQResult<()>

pub async fn pull_message_from_queue( &self, broker_addr: &str, mq: &MessageQueue, sub_expression: &str, offset: i64, max_nums: i32, timeout_millis: u64, ) -> RocketMQResult<PullResult>

pub async fn query_message_by_key( &self, cluster_name: Option<CheetahString>, topic: CheetahString, key: CheetahString, max_num: i32, begin_timestamp: i64, end_timestamp: i64, _key_type: CheetahString, _last_key: Option<CheetahString>, ) -> RocketMQResult<QueryResult>

pub async fn query_message_by_unique_key( &self, cluster_name: Option<CheetahString>, topic: CheetahString, unique_key: CheetahString, max_num: i32, begin_timestamp: i64, end_timestamp: i64, ) -> RocketMQResult<QueryResult>

Trait Implementations§

impl AsMut<DefaultMQAdminExtImpl> for DefaultMQAdminExt

fn as_mut(&mut self) -> &mut DefaultMQAdminExtImpl

Converts this type into a mutable reference of the (usually inferred) input type.

impl AsRef<DefaultMQAdminExtImpl> for DefaultMQAdminExt

fn as_ref(&self) -> &DefaultMQAdminExtImpl

Converts this type into a shared reference of the (usually inferred) input type.

impl Default for DefaultMQAdminExt

fn default() -> Self

Returns the “default value” for a type. Read more

impl Deref for DefaultMQAdminExt

type Target = DefaultMQAdminExtImpl

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for DefaultMQAdminExt

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl MQAdminExt for DefaultMQAdminExt

async fn start(&mut self) -> RocketMQResult<()>

async fn shutdown(&mut self)

async fn add_broker_to_container( &self, broker_container_addr: CheetahString, broker_config: CheetahString, ) -> RocketMQResult<()>

async fn remove_broker_from_container( &self, broker_container_addr: CheetahString, cluster_name: CheetahString, broker_name: CheetahString, broker_id: u64, ) -> RocketMQResult<()>

async fn update_broker_config( &self, broker_addr: CheetahString, properties: HashMap<CheetahString, CheetahString>, ) -> RocketMQResult<()>

async fn get_broker_config( &self, broker_addr: CheetahString, ) -> RocketMQResult<HashMap<CheetahString, CheetahString>>

async fn create_and_update_topic_config( &self, addr: CheetahString, config: TopicConfig, ) -> RocketMQResult<()>

async fn create_and_update_topic_config_list( &self, addr: CheetahString, topic_config_list: Vec<TopicConfig>, ) -> RocketMQResult<()>

async fn create_and_update_plain_access_config( &self, addr: CheetahString, config: PlainAccessConfig, ) -> RocketMQResult<()>

async fn delete_plain_access_config( &self, addr: CheetahString, access_key: CheetahString, ) -> RocketMQResult<()>

async fn update_global_white_addr_config( &self, addr: CheetahString, global_white_addrs: CheetahString, acl_file_full_path: Option<CheetahString>, ) -> RocketMQResult<()>

async fn examine_broker_cluster_acl_version_info( &self, addr: CheetahString, ) -> RocketMQResult<CheetahString>

async fn create_and_update_subscription_group_config( &self, addr: CheetahString, config: SubscriptionGroupConfig, ) -> RocketMQResult<()>

async fn create_and_update_subscription_group_config_list( &self, broker_addr: CheetahString, configs: Vec<SubscriptionGroupConfig>, ) -> RocketMQResult<()>

async fn examine_subscription_group_config( &self, addr: CheetahString, group: CheetahString, ) -> RocketMQResult<SubscriptionGroupConfig>

async fn examine_topic_stats( &self, topic: CheetahString, broker_addr: Option<CheetahString>, ) -> RocketMQResult<TopicStatsTable>

async fn examine_topic_stats_concurrent( &self, topic: CheetahString, ) -> AdminToolResult<TopicStatsTable>

async fn fetch_all_topic_list(&self) -> RocketMQResult<TopicList>

async fn fetch_topics_by_cluster( &self, cluster_name: CheetahString, ) -> RocketMQResult<TopicList>

async fn fetch_broker_runtime_stats( &self, broker_addr: CheetahString, ) -> RocketMQResult<KVTable>

async fn examine_consume_stats( &self, consumer_group: CheetahString, topic: Option<CheetahString>, cluster_name: Option<CheetahString>, broker_addr: Option<CheetahString>, timeout_millis: Option<u64>, ) -> RocketMQResult<ConsumeStats>

async fn check_rocksdb_cq_write_progress( &self, broker_addr: CheetahString, topic: CheetahString, check_store_time: i64, ) -> RocketMQResult<CheckRocksdbCqWriteResult>

async fn examine_broker_cluster_info(&self) -> RocketMQResult<ClusterInfo>

async fn examine_topic_route_info( &self, topic: CheetahString, ) -> RocketMQResult<Option<TopicRouteData>>

async fn examine_consumer_connection_info( &self, consumer_group: CheetahString, broker_addr: Option<CheetahString>, ) -> RocketMQResult<ConsumerConnection>

async fn examine_producer_connection_info( &self, producer_group: CheetahString, topic: CheetahString, ) -> RocketMQResult<ProducerConnection>

async fn get_all_producer_info( &self, broker_addr: CheetahString, ) -> RocketMQResult<ProducerTableInfo>

async fn get_name_server_address_list(&self) -> Vec<CheetahString>

async fn wipe_write_perm_of_broker( &self, namesrv_addr: CheetahString, broker_name: CheetahString, ) -> RocketMQResult<i32>

async fn add_write_perm_of_broker( &self, namesrv_addr: CheetahString, broker_name: CheetahString, ) -> RocketMQResult<i32>

async fn put_kv_config( &self, namespace: CheetahString, key: CheetahString, value: CheetahString, )

async fn get_kv_config( &self, namespace: CheetahString, key: CheetahString, ) -> RocketMQResult<CheetahString>

async fn get_kv_list_by_namespace( &self, namespace: CheetahString, ) -> RocketMQResult<KVTable>

async fn delete_topic( &self, topic_name: CheetahString, cluster_name: CheetahString, ) -> RocketMQResult<()>

async fn delete_topic_in_broker( &self, addrs: HashSet<CheetahString>, topic: CheetahString, ) -> RocketMQResult<()>

async fn delete_topic_in_broker_concurrent( &self, addrs: HashSet<CheetahString>, topic: CheetahString, ) -> AdminToolResult<BrokerOperatorResult>

async fn delete_topic_in_name_server( &self, addrs: HashSet<CheetahString>, cluster_name: Option<CheetahString>, topic: CheetahString, ) -> RocketMQResult<()>

async fn delete_subscription_group( &self, addr: CheetahString, group_name: CheetahString, remove_offset: Option<bool>, ) -> RocketMQResult<()>

async fn create_and_update_kv_config( &self, namespace: CheetahString, key: CheetahString, value: CheetahString, ) -> RocketMQResult<()>

async fn delete_kv_config( &self, namespace: CheetahString, key: CheetahString, ) -> RocketMQResult<()>

async fn reset_offset_by_timestamp_old( &self, cluster_name: Option<CheetahString>, consumer_group: CheetahString, topic: CheetahString, timestamp: u64, force: bool, ) -> RocketMQResult<Vec<RollbackStats>>

async fn reset_offset_by_timestamp( &self, cluster_name: Option<CheetahString>, topic: CheetahString, group: CheetahString, timestamp: u64, is_force: bool, ) -> RocketMQResult<HashMap<MessageQueue, u64>>

async fn reset_offset_new( &self, consumer_group: CheetahString, topic: CheetahString, timestamp: u64, ) -> RocketMQResult<()>

async fn reset_offset_new_concurrent( &self, group: CheetahString, topic: CheetahString, timestamp: u64, ) -> AdminToolResult<BrokerOperatorResult>

async fn get_consume_status( &self, topic: CheetahString, group: CheetahString, client_addr: CheetahString, ) -> RocketMQResult<HashMap<CheetahString, HashMap<MessageQueue, u64>>>

async fn create_or_update_order_conf( &self, key: CheetahString, value: CheetahString, is_cluster: bool, ) -> RocketMQResult<()>

async fn query_topic_consume_by_who( &self, topic: CheetahString, ) -> RocketMQResult<GroupList>

async fn query_topics_by_consumer( &self, group: CheetahString, ) -> RocketMQResult<TopicList>

async fn query_topics_by_consumer_concurrent( &self, group: CheetahString, ) -> AdminToolResult<TopicList>

async fn query_subscription( &self, group: CheetahString, topic: CheetahString, ) -> RocketMQResult<SubscriptionData>

async fn query_consume_time_span( &self, topic: CheetahString, group: CheetahString, ) -> RocketMQResult<Vec<QueueTimeSpan>>

async fn query_consume_time_span_concurrent( &self, topic: CheetahString, group: CheetahString, ) -> AdminToolResult<Vec<QueueTimeSpan>>

async fn clean_expired_consumer_queue( &self, cluster: Option<CheetahString>, addr: Option<CheetahString>, ) -> RocketMQResult<bool>

async fn clean_expired_consumer_queue_by_addr( &self, addr: CheetahString, ) -> RocketMQResult<bool>

async fn delete_expired_commit_log( &self, cluster: Option<CheetahString>, addr: Option<CheetahString>, ) -> RocketMQResult<bool>

async fn delete_expired_commit_log_by_addr( &self, addr: CheetahString, ) -> RocketMQResult<bool>

async fn clean_unused_topic( &self, cluster: Option<CheetahString>, addr: Option<CheetahString>, ) -> RocketMQResult<bool>

async fn clean_unused_topic_by_addr( &self, addr: CheetahString, ) -> RocketMQResult<bool>

async fn get_consumer_running_info( &self, consumer_group: CheetahString, client_id: CheetahString, jstack: bool, metrics: Option<bool>, ) -> RocketMQResult<ConsumerRunningInfo>

async fn consume_message_directly( &self, consumer_group: CheetahString, client_id: CheetahString, topic: CheetahString, msg_id: CheetahString, ) -> RocketMQResult<ConsumeMessageDirectlyResult>

async fn consume_message_directly_ext( &self, cluster_name: CheetahString, consumer_group: CheetahString, client_id: CheetahString, topic: CheetahString, msg_id: CheetahString, ) -> RocketMQResult<ConsumeMessageDirectlyResult>

async fn message_track_detail( &self, msg: MessageExt, ) -> RocketMQResult<Vec<MessageTrack>>

async fn message_track_detail_concurrent( &self, msg: MessageExt, ) -> AdminToolResult<Vec<MessageTrack>>

async fn clone_group_offset( &self, src_group: CheetahString, dest_group: CheetahString, topic: CheetahString, is_offline: bool, ) -> RocketMQResult<()>

async fn view_broker_stats_data( &self, broker_addr: CheetahString, stats_name: CheetahString, stats_key: CheetahString, ) -> RocketMQResult<BrokerStatsData>

async fn get_cluster_list( &self, topic: String, ) -> RocketMQResult<HashSet<CheetahString>>

async fn fetch_consume_stats_in_broker( &self, broker_addr: CheetahString, is_order: bool, timeout_millis: u64, ) -> RocketMQResult<ConsumeStatsList>

async fn get_topic_cluster_list( &self, topic: String, ) -> RocketMQResult<HashSet<CheetahString>>

async fn get_all_subscription_group( &self, broker_addr: CheetahString, timeout_millis: u64, ) -> RocketMQResult<SubscriptionGroupWrapper>

async fn get_user_subscription_group( &self, broker_addr: CheetahString, timeout_millis: u64, ) -> RocketMQResult<SubscriptionGroupWrapper>

async fn get_all_topic_config( &self, broker_addr: CheetahString, timeout_millis: u64, ) -> RocketMQResult<TopicConfigSerializeWrapper>

async fn get_user_topic_config( &self, broker_addr: CheetahString, special_topic: bool, timeout_millis: u64, ) -> RocketMQResult<TopicConfigSerializeWrapper>

async fn update_consume_offset( &self, broker_addr: CheetahString, consume_group: CheetahString, mq: MessageQueue, offset: u64, ) -> RocketMQResult<()>

async fn update_name_server_config( &self, properties: HashMap<CheetahString, CheetahString>, name_servers: Option<Vec<CheetahString>>, ) -> RocketMQResult<()>

async fn get_name_server_config( &self, name_servers: Vec<CheetahString>, ) -> RocketMQResult<HashMap<CheetahString, HashMap<CheetahString, CheetahString>>>

async fn probe_name_server( &self, name_server: CheetahString, ) -> RocketMQResult<()>

async fn query_consume_queue( &self, broker_addr: CheetahString, topic: CheetahString, queue_id: i32, index: u64, count: i32, consumer_group: CheetahString, ) -> RocketMQResult<QueryConsumeQueueResponseBody>

async fn resume_check_half_message( &self, topic: CheetahString, msg_id: CheetahString, ) -> RocketMQResult<bool>

async fn set_message_request_mode( &self, broker_addr: CheetahString, topic: CheetahString, consumer_group: CheetahString, mode: MessageRequestMode, pop_work_group_size: i32, timeout_millis: u64, ) -> RocketMQResult<()>

async fn reset_offset_by_queue_id( &self, broker_addr: CheetahString, consumer_group: CheetahString, topic_name: CheetahString, queue_id: i32, reset_offset: u64, ) -> RocketMQResult<()>

async fn examine_topic_config( &self, addr: CheetahString, topic: CheetahString, ) -> RocketMQResult<TopicConfig>

async fn create_static_topic( &self, addr: CheetahString, default_topic: CheetahString, topic_config: TopicConfig, mapping_detail: TopicQueueMappingDetail, force: bool, ) -> RocketMQResult<()>

async fn update_and_get_group_read_forbidden( &self, broker_addr: CheetahString, group_name: CheetahString, topic_name: CheetahString, readable: Option<bool>, ) -> RocketMQResult<GroupForbidden>

async fn query_message( &self, cluster_name: CheetahString, topic: CheetahString, msg_id: CheetahString, ) -> RocketMQResult<MessageExt>

async fn get_broker_ha_status( &self, broker_addr: CheetahString, ) -> RocketMQResult<HARuntimeInfo>

async fn get_in_sync_state_data( &self, controller_address: CheetahString, brokers: Vec<CheetahString>, ) -> RocketMQResult<BrokerReplicasInfo>

async fn get_broker_epoch_cache( &self, broker_addr: CheetahString, ) -> RocketMQResult<EpochEntryCache>

async fn get_controller_meta_data( &self, controller_addr: CheetahString, ) -> RocketMQResult<GetMetaDataResponseHeader>

async fn reset_master_flush_offset( &self, broker_addr: CheetahString, master_flush_offset: u64, ) -> RocketMQResult<()>

async fn get_controller_config( &self, controller_servers: Vec<CheetahString>, ) -> RocketMQResult<HashMap<CheetahString, HashMap<CheetahString, CheetahString>>>

async fn update_controller_config( &self, properties: HashMap<CheetahString, CheetahString>, controllers: Vec<CheetahString>, ) -> RocketMQResult<()>

async fn elect_master( &self, controller_addr: CheetahString, cluster_name: CheetahString, broker_name: CheetahString, broker_id: Option<u64>, ) -> RocketMQResult<(ElectMasterResponseHeader, BrokerMemberGroup)>

async fn clean_controller_broker_data( &self, controller_addr: CheetahString, cluster_name: CheetahString, broker_name: CheetahString, broker_controller_ids_to_clean: Option<CheetahString>, is_clean_living_broker: bool, ) -> RocketMQResult<()>

async fn update_cold_data_flow_ctr_group_config( &self, broker_addr: CheetahString, properties: HashMap<CheetahString, CheetahString>, ) -> RocketMQResult<()>

async fn remove_cold_data_flow_ctr_group_config( &self, broker_addr: CheetahString, consumer_group: CheetahString, ) -> RocketMQResult<()>

async fn get_cold_data_flow_ctr_info( &self, broker_addr: CheetahString, ) -> RocketMQResult<CheetahString>

async fn set_commit_log_read_ahead_mode( &self, broker_addr: CheetahString, mode: CheetahString, ) -> RocketMQResult<CheetahString>

async fn create_user( &self, broker_addr: CheetahString, username: CheetahString, password: CheetahString, user_type: CheetahString, ) -> RocketMQResult<()>

async fn create_user_with_info( &self, broker_addr: CheetahString, username: CheetahString, password: CheetahString, ) -> RocketMQResult<()>

async fn update_user( &self, broker_addr: CheetahString, username: CheetahString, password: CheetahString, user_type: CheetahString, user_status: CheetahString, ) -> RocketMQResult<()>

async fn update_user_with_info( &self, broker_addr: CheetahString, username: CheetahString, password: CheetahString, ) -> RocketMQResult<()>

async fn delete_user( &self, broker_addr: CheetahString, username: CheetahString, ) -> RocketMQResult<()>

async fn get_user( &self, broker_addr: CheetahString, username: CheetahString, ) -> RocketMQResult<Option<UserInfo>>

async fn list_users( &self, broker_addr: CheetahString, filter: CheetahString, ) -> RocketMQResult<Vec<UserInfo>>

async fn create_acl( &self, broker_addr: CheetahString, subject: CheetahString, resources: Vec<CheetahString>, actions: Vec<CheetahString>, source_ips: Vec<CheetahString>, decision: CheetahString, ) -> RocketMQResult<()>

async fn create_acl_with_info( &self, broker_addr: CheetahString, subject: CheetahString, ) -> RocketMQResult<()>

async fn update_acl( &self, broker_addr: CheetahString, subject: CheetahString, resources: Vec<CheetahString>, actions: Vec<CheetahString>, source_ips: Vec<CheetahString>, decision: CheetahString, ) -> RocketMQResult<()>

async fn update_acl_with_info( &self, broker_addr: CheetahString, subject: CheetahString, ) -> RocketMQResult<()>

async fn delete_acl( &self, broker_addr: CheetahString, subject: CheetahString, resource: CheetahString, ) -> RocketMQResult<()>

async fn get_acl( &self, broker_addr: CheetahString, subject: CheetahString, ) -> RocketMQResult<AclInfo>

async fn list_acl( &self, broker_addr: CheetahString, subject_filter: CheetahString, resource_filter: CheetahString, ) -> RocketMQResult<Vec<AclInfo>>

async fn create_lite_pull_topic( &self, addr: CheetahString, topic: CheetahString, queue_num: i32, topic_sys_flag: i32, read_queue_nums: i32, write_queue_nums: i32, ) -> RocketMQResult<()>

async fn update_lite_pull_topic( &self, addr: CheetahString, topic: CheetahString, read_queue_nums: i32, write_queue_nums: i32, ) -> RocketMQResult<()>

async fn get_lite_pull_topic( &self, addr: CheetahString, topic: CheetahString, ) -> RocketMQResult<TopicConfig>

async fn delete_lite_pull_topic( &self, addr: CheetahString, cluster_name: CheetahString, topic: CheetahString, ) -> RocketMQResult<()>

async fn query_lite_pull_topic_list( &self, addr: CheetahString, ) -> RocketMQResult<TopicList>

async fn query_lite_pull_topic_by_cluster( &self, cluster_name: CheetahString, ) -> RocketMQResult<TopicList>

async fn query_lite_pull_subscription_list( &self, addr: CheetahString, topic: CheetahString, ) -> RocketMQResult<GroupList>

async fn update_lite_pull_consumer_offset( &self, addr: CheetahString, topic: CheetahString, group: CheetahString, queue_id: i32, offset: u64, ) -> RocketMQResult<()>

async fn examine_consume_stats_with_queue( &self, consumer_group: CheetahString, topic: Option<CheetahString>, queue_id: Option<i32>, ) -> RocketMQResult<ConsumeStats>

async fn examine_consume_stats_concurrent( &self, consumer_group: CheetahString, topic: Option<CheetahString>, ) -> AdminToolResult<ConsumeStats>

async fn examine_consume_stats_concurrent_with_cluster( &self, consumer_group: CheetahString, topic: Option<CheetahString>, cluster_name: Option<CheetahString>, ) -> AdminToolResult<ConsumeStats>

async fn export_rocksdb_consumer_offset_to_json( &self, broker_addr: CheetahString, file_path: CheetahString, ) -> RocketMQResult<()>

async fn export_rocksdb_consumer_offset_from_memory( &self, broker_addr: CheetahString, ) -> RocketMQResult<CheetahString>

async fn sync_broker_member_group( &self, controller_addr: CheetahString, cluster_name: CheetahString, broker_name: CheetahString, ) -> RocketMQResult<()>

async fn get_topic_config_by_topic_name( &self, broker_addr: CheetahString, topic_name: CheetahString, ) -> RocketMQResult<TopicConfig>

async fn notify_min_broker_id_changed( &self, cluster_name: CheetahString, broker_name: CheetahString, min_broker_id: u64, min_broker_addr: CheetahString, offline_broker_addr: Option<CheetahString>, ha_broker_addr: Option<CheetahString>, ) -> RocketMQResult<()>

async fn get_topic_stats_info( &self, broker_addr: CheetahString, topic: CheetahString, ) -> RocketMQResult<TopicStatsTable>

async fn query_broker_has_topic( &self, broker_addr: CheetahString, topic: CheetahString, ) -> RocketMQResult<bool>

async fn get_system_topic_list_from_broker( &self, broker_addr: CheetahString, ) -> RocketMQResult<TopicList>

async fn examine_topic_route_info_with_timeout( &self, topic: CheetahString, timeout_millis: u64, ) -> RocketMQResult<Option<TopicRouteData>>

async fn export_pop_records( &self, broker_addr: CheetahString, timeout: u64, ) -> RocketMQResult<()>

async fn switch_timer_engine( &self, broker_addr: CheetahString, des_timer_engine: CheetahString, ) -> RocketMQResult<()>

async fn get_broker_lite_info( &self, broker_addr: CheetahString, ) -> RocketMQResult<GetBrokerLiteInfoResponseBody>

async fn get_parent_topic_info( &self, broker_addr: CheetahString, topic: CheetahString, ) -> RocketMQResult<GetParentTopicInfoResponseBody>

async fn get_lite_topic_info( &self, broker_addr: CheetahString, parent_topic: CheetahString, lite_topic: CheetahString, ) -> RocketMQResult<GetLiteTopicInfoResponseBody>

async fn get_lite_client_info( &self, broker_addr: CheetahString, parent_topic: CheetahString, group: CheetahString, client_id: CheetahString, ) -> RocketMQResult<GetLiteClientInfoResponseBody>

async fn get_lite_group_info( &self, broker_addr: CheetahString, group: CheetahString, lite_topic: CheetahString, top_k: i32, ) -> RocketMQResult<GetLiteGroupInfoResponseBody>

async fn trigger_lite_dispatch( &self, broker_addr: CheetahString, group: CheetahString, client_id: CheetahString, ) -> RocketMQResult<()>

async fn export_rocksdb_config_to_json( &self, broker_addr: CheetahString, config_types: Vec<CheetahString>, ) -> RocketMQResult<()>

async fn search_offset( &self, broker_addr: CheetahString, topic_name: CheetahString, queue_id: i32, timestamp: u64, timeout_millis: u64, ) -> RocketMQResult<u64>

async fn min_offset( &self, broker_addr: CheetahString, message_queue: MessageQueue, timeout_millis: u64, ) -> RocketMQResult<i64>

async fn max_offset( &self, broker_addr: CheetahString, message_queue: MessageQueue, timeout_millis: u64, ) -> RocketMQResult<i64>

async fn list_user( &self, broker_addr: CheetahString, filter: CheetahString, ) -> RocketMQResult<Vec<UserInfo>>

Auto Trait Implementations§

impl !RefUnwindSafe for DefaultMQAdminExt

impl !UnwindSafe for DefaultMQAdminExt

impl Freeze for DefaultMQAdminExt

impl Send for DefaultMQAdminExt

impl Sync for DefaultMQAdminExt

impl Unpin for DefaultMQAdminExt

impl UnsafeUnpin for DefaultMQAdminExt

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> Conv for T

fn conv<T>(self) -> T
where Self: Into<T>,

Converts self into T using Into<T>. Read more

impl<T> FmtForward for T

fn fmt_binary(self) -> FmtBinary<Self>
where Self: Binary,

Causes self to use its Binary implementation when Debug-formatted.

fn fmt_display(self) -> FmtDisplay<Self>
where Self: Display,

Causes self to use its Display implementation when Debug-formatted.

fn fmt_lower_exp(self) -> FmtLowerExp<Self>
where Self: LowerExp,

Causes self to use its LowerExp implementation when Debug-formatted.

fn fmt_lower_hex(self) -> FmtLowerHex<Self>
where Self: LowerHex,

Causes self to use its LowerHex implementation when Debug-formatted.

fn fmt_octal(self) -> FmtOctal<Self>
where Self: Octal,

Causes self to use its Octal implementation when Debug-formatted.

fn fmt_pointer(self) -> FmtPointer<Self>
where Self: Pointer,

Causes self to use its Pointer implementation when Debug-formatted.

fn fmt_upper_exp(self) -> FmtUpperExp<Self>
where Self: UpperExp,

Causes self to use its UpperExp implementation when Debug-formatted.

fn fmt_upper_hex(self) -> FmtUpperHex<Self>
where Self: UpperHex,

Causes self to use its UpperHex implementation when Debug-formatted.

fn fmt_list(self) -> FmtList<Self>
where &'a Self: for<'a> IntoIterator,

Formats each item in a sequence. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ

Attaches the provided Context to this type, returning a WithContext wrapper. Read more

fn with_current_context(self) -> WithContext<Self> ⓘ

Attaches the current Context to this type, returning a WithContext wrapper. Read more

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> Pipe for T
where T: ?Sized,

fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R
where Self: Sized,

Pipes by value. This is generally the method you want to use. Read more

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R
where R: 'a,

Borrows self and passes that borrow into the pipe function. Read more

fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R
where R: 'a,

Mutably borrows self and passes that borrow into the pipe function. Read more

fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
where Self: Borrow, B: 'a + ?Sized, R: 'a,

Borrows self, then passes self.borrow() into the pipe function. Read more

fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
where Self: BorrowMut, B: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.borrow_mut() into the pipe function. Read more

fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
where Self: AsRef, U: 'a + ?Sized, R: 'a,

Borrows self, then passes self.as_ref() into the pipe function.

fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
where Self: AsMut, U: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.as_mut() into the pipe function.

fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
where Self: Deref<Target = T>, T: 'a + ?Sized, R: 'a,

Borrows self, then passes self.deref() into the pipe function.

fn pipe_deref_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R, ) -> R
where Self: DerefMut<Target = T> + Deref, T: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.deref_mut() into the pipe function.

impl<T> Pointable for T

const ALIGN: usize

The alignment of pointer.

type Init = T

The type for initializers.

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more

impl<P, T> Receiver for P
where P: Deref<Target = T> + ?Sized, T: ?Sized,

type Target = T

🔬This is a nightly-only experimental API. (arbitrary_self_types)

The target type on which the method may be called.

impl<T> Same for T

type Output = T

Should always be Self

impl<T> Tap for T

fn tap(self, func: impl FnOnce(&Self)) -> Self

Immutable access to a value. Read more

fn tap_mut(self, func: impl FnOnce(&mut Self)) -> Self

Mutable access to a value. Read more

fn tap_borrow(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow, B: ?Sized,

Immutable access to the Borrow of a value. Read more

fn tap_borrow_mut(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut, B: ?Sized,

Mutable access to the BorrowMut of a value. Read more

fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

Immutable access to the AsRef<R> view of a value. Read more

fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

Mutable access to the AsMut<R> view of a value. Read more

fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

Immutable access to the Deref::Target of a value. Read more

fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

Mutable access to the Deref::Target of a value. Read more

fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self

Calls .tap() only in debug builds, and is erased in release builds.

fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self

Calls .tap_mut() only in debug builds, and is erased in release builds.

fn tap_borrow_dbg(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow, B: ?Sized,

Calls .tap_borrow() only in debug builds, and is erased in release builds.

fn tap_borrow_mut_dbg(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut, B: ?Sized,

Calls .tap_borrow_mut() only in debug builds, and is erased in release builds.

fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

Calls .tap_ref() only in debug builds, and is erased in release builds.

fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

Calls .tap_ref_mut() only in debug builds, and is erased in release builds.

fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

Calls .tap_deref() only in debug builds, and is erased in release builds.

fn tap_deref_mut_dbg<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

Calls .tap_deref_mut() only in debug builds, and is erased in release builds.

impl<T> TryConv for T

fn try_conv<T>(self) -> Result<T, Self::Error>
where Self: TryInto<T>,

Attempts to convert self into T using TryInto<T>. Read more

impl<T, U> TryFrom for T
where U: Into<T>,

type Error = !

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, !>

Performs the conversion.

impl<T, U> TryInto for T
where U: TryFrom<T>,

type Error = >::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more