rocketmq_client_rust/
admin.rs

1// Copyright 2023 The RocketMQ Rust Authors
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7//     http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15#[cfg(feature = "admin-full")]
16mod capability;
17pub mod default_mq_admin_ext;
18pub mod default_mq_admin_ext_impl;
19#[cfg(feature = "admin-read")]
20mod mq_admin_consumer_observation_read_ext;
21#[cfg(feature = "admin-read")]
22mod mq_admin_infrastructure_observation_read_ext;
23#[cfg(feature = "admin-mutation")]
24mod mq_admin_mutation_ext;
25#[cfg(feature = "admin-read")]
26mod mq_admin_read_ext;
27#[cfg(feature = "admin-read")]
28mod mq_admin_topic_stats_read_ext;
29
30#[cfg(feature = "admin-full")]
31pub use capability::AuthAdmin;
32#[cfg(feature = "admin-full")]
33pub use capability::BrokerAdmin;
34#[cfg(feature = "admin-full")]
35pub use capability::ConsumerAdmin;
36#[cfg(feature = "admin-full")]
37pub use capability::OffsetAdmin;
38#[cfg(feature = "admin-full")]
39pub use capability::RouteAdmin;
40#[cfg(feature = "admin-full")]
41pub use capability::TopicAdmin;
42pub use default_mq_admin_ext::DefaultMQAdminExt;
43pub use default_mq_admin_ext_impl::DefaultMQAdminExtImpl;
44#[cfg(feature = "admin-read")]
45pub use mq_admin_consumer_observation_read_ext::ConsumerConnectionRead;
46#[cfg(feature = "admin-read")]
47pub use mq_admin_consumer_observation_read_ext::ConsumerGroupConfigRead;
48#[cfg(feature = "admin-read")]
49pub use mq_admin_consumer_observation_read_ext::ConsumerProgressRead;
50#[cfg(feature = "admin-read")]
51pub use mq_admin_consumer_observation_read_ext::MQAdminConsumerObservationReadExt;
52#[cfg(feature = "admin-read")]
53pub use mq_admin_infrastructure_observation_read_ext::InfrastructureObservationReadError;
54#[cfg(feature = "admin-read")]
55pub use mq_admin_infrastructure_observation_read_ext::InfrastructureObservationReadErrorCode;
56#[cfg(feature = "admin-read")]
57pub use mq_admin_infrastructure_observation_read_ext::MQAdminInfrastructureObservationReadExt;
58#[cfg(feature = "admin-mutation")]
59pub use mq_admin_mutation_ext::BrokerConfigPatchOutcome;
60#[cfg(feature = "admin-mutation")]
61pub use mq_admin_mutation_ext::BrokerMutationConfigState;
62#[cfg(feature = "admin-mutation")]
63pub use mq_admin_mutation_ext::ConditionalConsumerOffsetOutcome;
64#[cfg(feature = "admin-mutation")]
65pub use mq_admin_mutation_ext::MQAdminMutationExt;
66#[cfg(feature = "admin-mutation")]
67pub use mq_admin_mutation_ext::MutationConsumerOffsetPreview;
68#[cfg(feature = "admin-mutation")]
69pub use mq_admin_mutation_ext::MutationExpectedMessageRequestMode;
70#[cfg(feature = "admin-mutation")]
71pub use mq_admin_mutation_ext::MutationExpectedState;
72#[cfg(feature = "admin-mutation")]
73pub use mq_admin_mutation_ext::MutationMessageRequestMode;
74#[cfg(feature = "admin-mutation")]
75pub use mq_admin_mutation_ext::MutationMessageRequestModeOutcome;
76#[cfg(feature = "admin-mutation")]
77pub use mq_admin_mutation_ext::MutationPersistenceState;
78#[cfg(feature = "admin-mutation")]
79pub use mq_admin_mutation_ext::MutationStateCasOutcome;
80#[cfg(feature = "admin-mutation")]
81pub use mq_admin_mutation_ext::MutationSubscriptionGroupConfig;
82#[cfg(feature = "admin-mutation")]
83pub use mq_admin_mutation_ext::MutationSubscriptionGroupConfigState;
84#[cfg(feature = "admin-mutation")]
85pub use mq_admin_mutation_ext::MutationTopicConfig;
86#[cfg(feature = "admin-mutation")]
87pub use mq_admin_mutation_ext::MutationTopicConfigState;
88#[cfg(feature = "admin-mutation")]
89pub use mq_admin_mutation_ext::MutationTopicConfigVersioned;
90#[cfg(feature = "admin-mutation")]
91pub use mq_admin_mutation_ext::MutationTopicMessageType;
92#[cfg(feature = "admin-mutation")]
93pub use mq_admin_mutation_ext::SubscriptionGroupConfigPatch;
94#[cfg(feature = "admin-mutation")]
95pub use mq_admin_mutation_ext::SubscriptionGroupConfigPatchOutcome;
96#[cfg(feature = "admin-mutation")]
97pub use mq_admin_mutation_ext::TopicConfigPatch;
98#[cfg(feature = "admin-mutation")]
99pub use mq_admin_mutation_ext::TopicConfigPatchOutcome;
100#[cfg(feature = "admin-mutation")]
101pub use mq_admin_mutation_ext::TopicOffsetMutationFailureCode;
102#[cfg(feature = "admin-mutation")]
103pub use mq_admin_mutation_ext::TopicOffsetMutationOutcome;
104#[cfg(feature = "admin-mutation")]
105pub use mq_admin_mutation_ext::TopicOffsetMutationTargetOutcome;
106#[cfg(feature = "admin-read")]
107pub use mq_admin_read_ext::BrokerConfigAllowlisted;
108#[cfg(feature = "admin-read")]
109pub use mq_admin_read_ext::BrokerReadFailure;
110#[cfg(feature = "admin-read")]
111pub use mq_admin_read_ext::ConsumeStatsReadResult;
112#[cfg(feature = "admin-read")]
113pub use mq_admin_read_ext::MQAdminMessageReadExt;
114#[cfg(feature = "admin-read")]
115pub use mq_admin_read_ext::MQAdminReadExt;
116#[cfg(feature = "admin-read")]
117pub use mq_admin_read_ext::MQAdminTopicInventoryReadExt;
118#[cfg(feature = "admin-read")]
119pub use mq_admin_read_ext::MessageMetadataRead;
120#[cfg(feature = "admin-read")]
121pub use mq_admin_read_ext::ReadFailureCode;
122#[cfg(feature = "admin-read")]
123pub use mq_admin_read_ext::SubscriptionGroupConfigVersioned;
124#[cfg(feature = "admin-read")]
125pub use mq_admin_read_ext::TopicConfigVersioned;
126#[cfg(feature = "admin-read")]
127pub use mq_admin_topic_stats_read_ext::MQAdminTopicStatsReadExt;
rocketmq_client_rust/admin.rs

rocketmq_client_rust/
admin.rs
