pub struct DefaultMQAdminExtImpl { /* private fields */ }Implementations§
Source§impl DefaultMQAdminExtImpl
impl DefaultMQAdminExtImpl
pub fn new( rpc_hook: Option<Arc<dyn RPCHook>>, timeout_millis: Duration, client_config: ArcMut<ClientConfig>, admin_ext_group: CheetahString, ) -> Self
pub fn set_inner(&mut self, inner: ArcMut<DefaultMQAdminExtImpl>)
pub fn has_inner(&self) -> 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§
Source§impl MQAdminExt for DefaultMQAdminExtImpl
impl MQAdminExt for DefaultMQAdminExtImpl
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_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( &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 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 clean_expired_consumer_queue( &self, cluster: Option<CheetahString>, addr: Option<CheetahString>, ) -> RocketMQResult<bool>
async fn delete_expired_commit_log( &self, cluster: Option<CheetahString>, addr: Option<CheetahString>, ) -> RocketMQResult<bool>
async fn clean_unused_topic( &self, cluster: Option<CheetahString>, addr: Option<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 clone_group_offset( &self, src_group: CheetahString, dest_group: CheetahString, topic: CheetahString, is_offline: bool, ) -> RocketMQResult<()>
async fn get_cluster_list( &self, topic: String, ) -> RocketMQResult<HashSet<CheetahString>>
async fn get_topic_cluster_list( &self, topic: String, ) -> RocketMQResult<HashSet<CheetahString>>
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 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 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 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 update_user( &self, broker_addr: CheetahString, username: CheetahString, password: CheetahString, user_type: CheetahString, user_status: CheetahString, ) -> RocketMQResult<()>
async fn delete_user( &self, broker_addr: CheetahString, username: CheetahString, ) -> RocketMQResult<()>
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 update_acl( &self, broker_addr: CheetahString, subject: CheetahString, resources: Vec<CheetahString>, actions: Vec<CheetahString>, source_ips: Vec<CheetahString>, decision: CheetahString, ) -> RocketMQResult<()>
async fn delete_acl( &self, broker_addr: CheetahString, subject: CheetahString, resource: CheetahString, ) -> RocketMQResult<()>
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 trigger_lite_dispatch( &self, _broker_addr: CheetahString, _group: CheetahString, _client_id: CheetahString, ) -> RocketMQResult<()>
async fn delete_topic_in_broker_concurrent( &self, _addrs: HashSet<CheetahString>, _topic: CheetahString, ) -> AdminToolResult<BrokerOperatorResult>
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_new_concurrent( &self, _group: CheetahString, _topic: CheetahString, _timestamp: u64, ) -> AdminToolResult<BrokerOperatorResult>
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 message_track_detail( &self, msg: MessageExt, ) -> RocketMQResult<Vec<MessageTrack>>
async fn message_track_detail_concurrent( &self, msg: MessageExt, ) -> AdminToolResult<Vec<MessageTrack>>
async fn view_broker_stats_data( &self, broker_addr: CheetahString, stats_name: CheetahString, stats_key: CheetahString, ) -> RocketMQResult<BrokerStatsData>
async fn fetch_consume_stats_in_broker( &self, _broker_addr: CheetahString, _is_order: bool, _timeout_millis: u64, ) -> RocketMQResult<ConsumeStatsList>
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 query_consume_queue( &self, broker_addr: CheetahString, topic: CheetahString, queue_id: i32, index: u64, count: i32, consumer_group: CheetahString, ) -> RocketMQResult<QueryConsumeQueueResponseBody>
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 elect_master( &self, _controller_addr: CheetahString, _cluster_name: CheetahString, _broker_name: CheetahString, _broker_id: Option<u64>, ) -> RocketMQResult<(ElectMasterResponseHeader, BrokerMemberGroup)>
async fn create_user_with_info( &self, _broker_addr: CheetahString, _username: CheetahString, _password: CheetahString, ) -> RocketMQResult<()>
async fn update_user_with_info( &self, _broker_addr: CheetahString, _username: CheetahString, _password: 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_with_info( &self, _broker_addr: CheetahString, _subject: CheetahString, ) -> RocketMQResult<()>
async fn update_acl_with_info( &self, _broker_addr: CheetahString, _subject: 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 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 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>
Auto Trait Implementations§
impl !Freeze for DefaultMQAdminExtImpl
impl !RefUnwindSafe for DefaultMQAdminExtImpl
impl Send for DefaultMQAdminExtImpl
impl Sync for DefaultMQAdminExtImpl
impl Unpin for DefaultMQAdminExtImpl
impl UnsafeUnpin for DefaultMQAdminExtImpl
impl !UnwindSafe for DefaultMQAdminExtImpl
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> FmtForward for T
impl<T> FmtForward for T
Source§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
Causes
self to use its Binary implementation when Debug-formatted.Source§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
Causes
self to use its Display implementation when
Debug-formatted.Source§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
Causes
self to use its LowerExp implementation when
Debug-formatted.Source§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
Causes
self to use its LowerHex implementation when
Debug-formatted.Source§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
Causes
self to use its Octal implementation when Debug-formatted.Source§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
Causes
self to use its Pointer implementation when
Debug-formatted.Source§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
Causes
self to use its UpperExp implementation when
Debug-formatted.Source§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
Causes
self to use its UpperHex implementation when
Debug-formatted.Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
Source§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
Pipes by value. This is generally the method you want to use. Read more
Source§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
Borrows
self and passes that borrow into the pipe function. Read moreSource§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
Mutably borrows
self and passes that borrow into the pipe function. Read moreSource§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
Source§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
Source§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
Borrows
self, then passes self.as_ref() into the pipe function.Source§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
Mutably borrows
self, then passes self.as_mut() into the pipe
function.Source§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
Borrows
self, then passes self.deref() into the pipe function.Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<T> Tap for T
impl<T> Tap for T
Source§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Immutable access to the
Borrow<B> of a value. Read moreSource§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
Mutable access to the
BorrowMut<B> of a value. Read moreSource§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
Immutable access to the
AsRef<R> view of a value. Read moreSource§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
Mutable access to the
AsMut<R> view of a value. Read moreSource§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Immutable access to the
Deref::Target of a value. Read moreSource§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Mutable access to the
Deref::Target of a value. Read moreSource§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
Calls
.tap() only in debug builds, and is erased in release builds.Source§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
Calls
.tap_mut() only in debug builds, and is erased in release
builds.Source§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
Calls
.tap_borrow() only in debug builds, and is erased in release
builds.Source§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
Calls
.tap_borrow_mut() only in debug builds, and is erased in release
builds.Source§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
Calls
.tap_ref() only in debug builds, and is erased in release
builds.Source§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
Calls
.tap_ref_mut() only in debug builds, and is erased in release
builds.Source§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
Calls
.tap_deref() only in debug builds, and is erased in release
builds.