cartel-pg 0.29.0

Async PostgreSQL driver for the dope runtime
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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99

use cartel_core::{memory, reply::layout};
use o3::{
    alloc,
    buffer::{hold::limits, pool},
    depot::{capacity, queue::pool::fair},
};
use std::num::NonZero;

use crate::port::{config::Connection, ready};

#[derive(Clone, Debug, PartialEq, Eq)]
pub enum Error {
    Connections(Connection),
    Inflight {
        actual: usize,
        minimum: usize,
        maximum: usize,
    },
    AdmissionWaitersZero,
    RequestFrames {
        actual: usize,
        minimum: usize,
        maximum: usize,
    },
    RequestFrameBytes {
        actual: usize,
        maximum: usize,
    },
    ResponseItems {
        actual: usize,
        minimum: usize,
        maximum: usize,
    },
    ResponseBytesZero,
    ResponseFrameBytes {
        actual: usize,
        minimum: usize,
        maximum: usize,
    },
    ResponseFrameExceedsCapacity {
        frame_bytes: usize,
        payload_bytes: usize,
        available_payload_bytes: usize,
    },
    ResponseFrameExceedsLaneCapacity {
        frame_bytes: usize,
        payload_bytes: usize,
        available_payload_bytes: usize,
    },
    NotificationItems(capacity::Error),
    NotificationItemsZero,
    NotificationBytesZero,
    CancelBytesOverflow {
        connections: usize,
    },
    OwnerSlotsOverflow {
        items: usize,
        connections: usize,
    },
    OwnersOverflow {
        slots: usize,
        notifications: usize,
    },
    Owners(capacity::Error),
    FixedBaseOverflow {
        request_bytes: usize,
        cancel_bytes: usize,
    },
    FixedReadyOverflow {
        base_bytes: usize,
        ready_bytes: usize,
    },
    RequestPool(pool::LayoutError),
    RequestQueue(fair::Error),
    Ready(ready::Error),
    Arena(layout::Error),
    Memory(memory::Error),
    ResidentFixed(limits::Error),
    ResidentDiagnostic(limits::Error),
    GroupSlots(capacity::Error),
    GroupRecordsOverflow {
        groups: NonZero<usize>,
        records: NonZero<usize>,
    },
    GroupBytesOverflow {
        groups: NonZero<usize>,
        bytes: NonZero<usize>,
    },
    GroupRecordsLayout(alloc::Overflow),
    GroupPool(pool::LayoutError),
    GroupRecordsCapacity {
        requested: NonZero<usize>,
        available: usize,
    },
    GroupBytesCapacity {
        requested: NonZero<usize>,
        available: usize,
    },
}