bucketwarden-errors 0.1.0

BucketWarden S3 error catalogs and retry classification.
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

use std::sync::OnceLock;

#[derive(Clone, Copy, Debug, Eq, PartialEq)]
pub struct S3ServiceSpecificError {
    pub feature_id: &'static str,
    pub family: &'static str,
    pub code: &'static str,
    pub status: u16,
    pub message: &'static str,
}

pub fn s3_service_specific_error_catalog() -> &'static [S3ServiceSpecificError] {
    S3_SERVICE_SPECIFIC_ERRORS
        .get_or_init(|| {
            S3_SERVICE_SPECIFIC_ERROR_PARTS
                .iter()
                .flat_map(|part| part.iter().copied())
                .collect()
        })
        .as_slice()
}

pub fn s3_service_specific_error_by_family_code(
    family: &str,
    code: &str,
) -> Option<&'static S3ServiceSpecificError> {
    s3_service_specific_error_catalog()
        .iter()
        .find(|error| error.family == family && error.code == code)
}

pub fn error_response_is_retryable(status: u16) -> bool {
    matches!(status, 500 | 503)
}

static S3_SERVICE_SPECIFIC_ERRORS: OnceLock<Vec<S3ServiceSpecificError>> = OnceLock::new();

const S3_SERVICE_SPECIFIC_ERROR_PARTS: &[&[S3ServiceSpecificError]] = &[
    include!("s3_service_specific_errors/access-grants.rs"),
    include!("s3_service_specific_errors/async.rs"),
    include!("s3_service_specific_errors/fsx.rs"),
    include!("s3_service_specific_errors/general-part-01.rs"),
    include!("s3_service_specific_errors/general-part-02.rs"),
    include!("s3_service_specific_errors/general-part-03.rs"),
    include!("s3_service_specific_errors/select-part-01.rs"),
    include!("s3_service_specific_errors/select-part-02.rs"),
    include!("s3_service_specific_errors/select-part-03.rs"),
    include!("s3_service_specific_errors/storage-lens-groups.rs"),
    include!("s3_service_specific_errors/storage-lens.rs"),
    include!("s3_service_specific_errors/tables.rs"),
    include!("s3_service_specific_errors/object-lambda.rs"),
    include!("s3_service_specific_errors/outposts.rs"),
    include!("s3_service_specific_errors/replication.rs"),
    include!("s3_service_specific_errors/tagging.rs"),
];