sentinel_driver/connection/
mod.rs

1pub mod startup;
2pub mod stream;
3
4mod client;
5mod copy_impl;
6mod notify_impl;
7mod pipeline_impl;
8mod portal_impl;
9mod prepare;
10mod query;
11mod stream_impl;
12mod transaction_impl;
13
14use std::time::Duration;
15
16use crate::cache::{CacheMetrics, StatementCache};
17use crate::cancel::CancelToken;
18use crate::config::Config;
19use crate::copy;
20use crate::error::{Error, Result};
21use crate::notify::{self, Notification};
22use crate::pipeline::{self, batch::PipelineBatch};
23use crate::protocol::backend::{BackendMessage, TransactionStatus};
24use crate::protocol::frontend;
25use crate::row::{Row, RowDescription};
26use crate::statement::Statement;
27use crate::transaction::TransactionConfig;
28use crate::types::{Oid, ToSql};
29
30use bytes::BytesMut;
31use stream::PgConnection;
32
33/// A high-level connection to PostgreSQL.
34///
35/// Wraps the low-level `PgConnection` with statement caching,
36/// convenient query methods, and transaction support.
37pub struct Connection {
38    pub(crate) conn: PgConnection,
39    pub(crate) config: Config,
40    pub(crate) connected_host: String,
41    pub(crate) connected_port: u16,
42    pub(crate) process_id: i32,
43    pub(crate) secret_key: i32,
44    pub(crate) transaction_status: TransactionStatus,
45    pub(crate) stmt_cache: StatementCache,
46    pub(crate) query_timeout: Option<Duration>,
47    pub(crate) is_broken: bool,
48}
sentinel_driver/connection/mod.rs

sentinel_driver/connection/
mod.rs
