qail-pg 0.27.7

Rust PostgreSQL driver for typed AST queries with direct wire-protocol execution
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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81

//! PostgreSQL Driver Module (Layer 3: Async I/O)
//!
//! Auto-detects the best I/O backend:
//! - Linux 5.1+: io_uring (fastest)
//! - Linux < 5.1 / macOS / Windows: tokio
//!
//! Submodules:
//! - `types` — Core types (PgError, PgRow, ColumnInfo, ResultFormat)
//! - `auth_types` — Auth/security types (AuthSettings, TlsMode, GssEncMode)
//! - `pg_driver` — High-level async driver (connect, fetch, execute, txn)
//! - `pg_driver_builder` — Builder pattern for PgDriver
//! - `connection` — Low-level PgConnection
//! - `pool` — Connection pool (PgPool, PoolConfig, PooledConnection)

// ── Internal submodules ─────────────────────────────────────────────
mod auth_types;
mod auto_mode;
pub mod branch_sql;
mod builder;
mod cancel;
mod connection;
mod copy;
mod core;
mod cursor;
#[cfg(test)]
mod driver_tests;
pub mod explain;
pub(crate) mod extended_flow;
mod fetch;
#[cfg(all(feature = "enterprise-gssapi", target_os = "linux"))]
pub mod gss;
mod io;
pub mod io_backend;
pub mod notification;
mod ops;
mod pipeline;
mod pool;
mod prepared;
mod query;
mod replication;
pub mod rls;
mod row;
mod stream;
mod transaction;
mod types;
#[cfg(all(target_os = "linux", feature = "io_uring"))]
mod uring;

// ── Public API ──────────────────────────────────────────────────────
pub use auth_types::{
    AuthSettings, ConnectOptions, EnterpriseAuthMechanism, GssEncMode, GssTokenProvider,
    GssTokenProviderEx, GssTokenRequest, ScramChannelBindingMode, TlsMode,
};
pub use auto_mode::{AutoCountPath, AutoCountPlan};
pub use builder::PgDriverBuilder;
pub use cancel::CancelToken;
pub use connection::{PgConnection, TlsConfig};
pub use core::PgDriver;
pub use notification::Notification;
pub use pipeline::AstPipelineMode;
pub use pool::{
    PgPool, PoolConfig, PoolStats, PooledConnection, ScopedPoolFuture, scope,
    spawn_pool_maintenance,
};
pub use prepared::{PreparedAstQuery, PreparedStatement};
pub use replication::{
    IdentifySystem, ReplicationKeepalive, ReplicationOption, ReplicationSlotInfo,
    ReplicationStreamMessage, ReplicationStreamStart, ReplicationXLogData,
};
pub use rls::RlsContext;
pub use row::QailRow;
pub use types::{
    ColumnInfo, PgBytesRow, PgError, PgResult, PgRow, PgServerError, QueryResult, ResultFormat,
};

// ── Crate-internal re-exports ───────────────────────────────────────
pub(crate) use connection::{CANCEL_REQUEST_CODE, parse_affected_rows};
pub(crate) use types::{
    is_ignorable_session_message, is_ignorable_session_msg_type, unexpected_backend_message,
    unexpected_backend_msg_type,
};