cartel-pg 0.1.1

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

pub trait Sink {
    fn push(&mut self, byte: u8);
    fn extend_from_slice(&mut self, src: &[u8]);
    fn len(&self) -> usize;
    fn is_empty(&self) -> bool {
        self.len() == 0
    }
    fn as_mut_slice(&mut self) -> &mut [u8];
}

impl Sink for o3::buffer::Owned {
    fn push(&mut self, byte: u8) {
        o3::buffer::Owned::push(self, byte);
    }
    fn extend_from_slice(&mut self, src: &[u8]) {
        o3::buffer::Owned::extend_from_slice(self, src);
    }
    fn len(&self) -> usize {
        o3::buffer::Owned::len(self)
    }
    fn as_mut_slice(&mut self) -> &mut [u8] {
        o3::buffer::Owned::as_mut_slice(self)
    }
}

impl Sink for dope::manifold::connector::session::Stage<'_> {
    fn push(&mut self, byte: u8) {
        dope::manifold::connector::session::Stage::push(self, byte);
    }
    fn extend_from_slice(&mut self, src: &[u8]) {
        dope::manifold::connector::session::Stage::extend_from_slice(self, src);
    }
    fn len(&self) -> usize {
        dope::manifold::connector::session::Stage::len(self)
    }
    fn as_mut_slice(&mut self) -> &mut [u8] {
        dope::manifold::connector::session::Stage::as_mut_slice(self)
    }
}

pub(super) struct Fe;

impl Fe {
    pub(super) const STARTUP_PROTOCOL: u32 = 0x0003_0000;

    pub(super) const PARSE: u8 = b'P';
    pub(super) const BIND: u8 = b'B';
    pub(super) const EXECUTE: u8 = b'E';
    pub(super) const SYNC: u8 = b'S';
    pub(super) const PASSWORD: u8 = b'p';
    pub(super) const COPY_DATA: u8 = b'd';
    pub(super) const COPY_DONE: u8 = b'c';
}

pub(super) struct Be;

impl Be {
    pub(super) const AUTH: u8 = b'R';
    pub(super) const PARAMETER_STATUS: u8 = b'S';
    pub(super) const BACKEND_KEY_DATA: u8 = b'K';
    pub(super) const READY_FOR_QUERY: u8 = b'Z';
    pub(super) const ROW_DESCRIPTION: u8 = b'T';
    pub(super) const DATA_ROW: u8 = b'D';
    pub(super) const COMMAND_COMPLETE: u8 = b'C';
    pub(super) const PARSE_COMPLETE: u8 = b'1';
    pub(super) const BIND_COMPLETE: u8 = b'2';
    pub(super) const ERROR_RESPONSE: u8 = b'E';
    pub(super) const NOTICE_RESPONSE: u8 = b'N';
    pub(super) const NOTIFICATION_RESPONSE: u8 = b'A';
    pub(super) const NO_DATA: u8 = b'n';
    pub(super) const EMPTY_QUERY_RESPONSE: u8 = b'I';
    pub(super) const PARAMETER_DESCRIPTION: u8 = b't';
    pub(super) const PORTAL_SUSPENDED: u8 = b's';
    pub(super) const COPY_IN_RESPONSE: u8 = b'G';
    pub(super) const COPY_OUT_RESPONSE: u8 = b'H';
    pub(super) const COPY_DATA: u8 = b'd';
    pub(super) const COPY_DONE: u8 = b'c';
}

pub(super) struct Auth;

impl Auth {
    pub(super) const OK: u32 = 0;
    pub(super) const SASL: u32 = 10;
    pub(super) const SASL_CONTINUE: u32 = 11;
    pub(super) const SASL_FINAL: u32 = 12;
}