rocketmq_client_rust/common/
admin_tools_result_code_enum.rs

1/*
2 * Licensed to the Apache Software Foundation (ASF) under one or more
3 * contributor license agreements.  See the NOTICE file distributed with
4 * this work for additional information regarding copyright ownership.
5 * The ASF licenses this file to You under the Apache License, Version 2.0
6 * (the "License"); you may not use this file except in compliance with
7 * the License.  You may obtain a copy of the License at
8 *
9 *     http://www.apache.org/licenses/LICENSE-2.0
10 *
11 * Unless required by applicable law or agreed to in writing, software
12 * distributed under the License is distributed on an "AS IS" BASIS,
13 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 * See the License for the specific language governing permissions and
15 * limitations under the License.
16 */
17#[allow(dead_code)]
18#[derive(Debug, Clone, Copy, PartialEq, Eq)]
19pub enum AdminToolsResultCodeEnum {
20    Success = 200,
21    RemotingError = -1001,
22    MQBrokerError = -1002,
23    MQClientError = -1003,
24    InterruptError = -1004,
25    TopicRouteInfoNotExist = -2001,
26    ConsumerNotOnline = -2002,
27    BroadcastConsumption = -2003,
28}
29
30#[allow(dead_code)]
31impl AdminToolsResultCodeEnum {
32    pub fn get_code(&self) -> i32 {
33        *self as i32
34    }
35}
36
37#[cfg(test)]
38mod tests {
39    use super::*;
40
41    #[test]
42    fn get_code_returns_correct_value_for_success() {
43        let code = AdminToolsResultCodeEnum::Success;
44        assert_eq!(code.get_code(), 200);
45    }
46
47    #[test]
48    fn get_code_returns_correct_value_for_remoting_error() {
49        let code = AdminToolsResultCodeEnum::RemotingError;
50        assert_eq!(code.get_code(), -1001);
51    }
52
53    #[test]
54    fn get_code_returns_correct_value_for_mq_broker_error() {
55        let code = AdminToolsResultCodeEnum::MQBrokerError;
56        assert_eq!(code.get_code(), -1002);
57    }
58
59    #[test]
60    fn get_code_returns_correct_value_for_mq_client_error() {
61        let code = AdminToolsResultCodeEnum::MQClientError;
62        assert_eq!(code.get_code(), -1003);
63    }
64
65    #[test]
66    fn get_code_returns_correct_value_for_interrupt_error() {
67        let code = AdminToolsResultCodeEnum::InterruptError;
68        assert_eq!(code.get_code(), -1004);
69    }
70
71    #[test]
72    fn get_code_returns_correct_value_for_topic_route_info_not_exist() {
73        let code = AdminToolsResultCodeEnum::TopicRouteInfoNotExist;
74        assert_eq!(code.get_code(), -2001);
75    }
76
77    #[test]
78    fn get_code_returns_correct_value_for_consumer_not_online() {
79        let code = AdminToolsResultCodeEnum::ConsumerNotOnline;
80        assert_eq!(code.get_code(), -2002);
81    }
82
83    #[test]
84    fn get_code_returns_correct_value_for_broadcast_consumption() {
85        let code = AdminToolsResultCodeEnum::BroadcastConsumption;
86        assert_eq!(code.get_code(), -2003);
87    }
88}
rocketmq_client_rust/common/admin_tools_result_code_enum.rs

rocketmq_client_rust/common/
admin_tools_result_code_enum.rs
