datahub 0.1.1

Simple Alibaba Cloud DataHub Client in Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

use crate::models::err_msg::ErrorInfo;
use serde::{Deserialize, Serialize};
use std::fmt::{Display, Formatter};
use thiserror::Error;

pub type DHResult<T> = Result<T, DHError>;

#[derive(Debug, Error)]
pub enum DHError {
    #[error("{0}")]
    ErrorInfo(#[from] ErrorInfo),
    #[error("{0}")]
    UrlParseError(#[from] url::ParseError),
    #[error("{0}")]
    RequestError(#[from] reqwest::Error),
}

#[derive(Debug, Deserialize, Serialize)]
pub enum ErrorCode {
    InvalidUriSpec,
    ProjectAlreadyExist,
    InvalidParameter,
    InvalidSubscription,
    InvalidCursor,

    ResourceNotFound,
    NoSuchTopic,
    NoSuchProject,
    NoSuchSubscription,
    NoSuchShard,
    NoSuchConnector,
    NoSuchMeterInfo,
    NoSuchAlarmRule,

    ResourceAlreadyExist,
    TopicAlreadyExist,
    ConnectorAlreadyExist,
    UserAlreadyExist,
    AlarmRuleAlreadyExist,

    ResourceLimit,
    SeekOutOfRange,
    Unauthorized,
    NoPermission,
    InvalidShardOperation,
    OperatorDenied,
    LimitExceed,
    InternalServerError,
    SubscriptionOffline,
    OffsetReseted,
    OffsetSessionClosed,
    OffsetSessionChanged,
    MalformedRecord,
    NoSuchConsumer,
    ConsumerGroupInProcess,
    ExpiredAccessToken,
    TopicOffline,
}

impl Display for ErrorCode {
    fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
        write!(f, "{:?}", self)
    }
}