duroxide-cdb 0.1.10

A CosmosDB-based provider implementation for Duroxide, a durable task orchestration framework
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

use duroxide::providers::ProviderError;

/// Map an HTTP status code and message from CosmosDB into a ProviderError.
pub fn map_cosmosdb_error(operation: &str, status: u16, message: &str) -> ProviderError {
    match status {
        // Conflict — ETag mismatch or duplicate ID
        409 => ProviderError::retryable(operation, format!("CosmosDB conflict (409): {message}")),
        // Too many requests — rate limited
        429 => {
            ProviderError::retryable(operation, format!("CosmosDB rate limited (429): {message}"))
        }
        // Request timeout
        408 => ProviderError::retryable(
            operation,
            format!("CosmosDB request timeout (408): {message}"),
        ),
        // Precondition failed — ETag mismatch on conditional write
        412 => ProviderError::retryable(
            operation,
            format!("CosmosDB precondition failed (412): {message}"),
        ),
        // Service unavailable
        503 => ProviderError::retryable(
            operation,
            format!("CosmosDB service unavailable (503): {message}"),
        ),
        // Not found
        404 => ProviderError::permanent(operation, format!("CosmosDB not found (404): {message}")),
        // Bad request
        400 => {
            ProviderError::permanent(operation, format!("CosmosDB bad request (400): {message}"))
        }
        // Request entity too large
        413 => ProviderError::permanent(
            operation,
            format!("CosmosDB request too large (413): {message}"),
        ),
        // Other errors: assume transient for 5xx, permanent for 4xx
        s if s >= 500 => {
            ProviderError::retryable(operation, format!("CosmosDB server error ({s}): {message}"))
        }
        s => ProviderError::permanent(operation, format!("CosmosDB client error ({s}): {message}")),
    }
}

/// Check if an HTTP status represents a conflict (409).
pub fn is_conflict(status: u16) -> bool {
    status == 409
}

/// Check if an HTTP status represents not found (404).
pub fn is_not_found(status: u16) -> bool {
    status == 404
}

/// Check if an HTTP status represents precondition failed (412).
pub fn is_precondition_failed(status: u16) -> bool {
    status == 412
}