type github.com/jackc/pgx/v5/pgconn.PgConn
78 uses
github.com/jackc/pgx/v5/pgconn (current package)
auth_oauth.go#L12: func (c *PgConn) oauthAuth(ctx context.Context) error {
auth_scram.go#L43: func (c *PgConn) scramAuth(serverAuthMechanisms []string) error {
auth_scram.go#L114: func (c *PgConn) rxSASLContinue() (*pgproto3.AuthenticationSASLContinue, error) {
auth_scram.go#L129: func (c *PgConn) rxSASLFinal() (*pgproto3.AuthenticationSASLFinal, error) {
config.go#L28: AfterConnectFunc func(ctx context.Context, pgconn *PgConn) error
config.go#L29: ValidateConnectFunc func(ctx context.Context, pgconn *PgConn) error
config.go#L49: BuildContextWatcherHandler func(*PgConn) ctxwatch.Handler
config.go#L314: BuildContextWatcherHandler: func(pgConn *PgConn) ctxwatch.Handler {
config.go#L317: OnPgError: func(_ *PgConn, pgErr *PgError) bool {
config.go#L947: func ValidateConnectTargetSessionAttrsReadWrite(ctx context.Context, pgConn *PgConn) error {
config.go#L962: func ValidateConnectTargetSessionAttrsReadOnly(ctx context.Context, pgConn *PgConn) error {
config.go#L977: func ValidateConnectTargetSessionAttrsStandby(ctx context.Context, pgConn *PgConn) error {
config.go#L992: func ValidateConnectTargetSessionAttrsPrimary(ctx context.Context, pgConn *PgConn) error {
config.go#L1007: func ValidateConnectTargetSessionAttrsPreferStandby(ctx context.Context, pgConn *PgConn) error {
krb5.go#L36: func (c *PgConn) gssAuth() error {
krb5.go#L86: func (c *PgConn) rxGSSContinue() (*pgproto3.AuthenticationGSSContinue, error) {
pgconn.go#L62: type PgErrorHandler func(*PgConn, *PgError) bool
pgconn.go#L68: type NoticeHandler func(*PgConn, *Notice)
pgconn.go#L74: type NotificationHandler func(*PgConn, *Notification)
pgconn.go#L77: type PgConn struct {
pgconn.go#L114: func Connect(ctx context.Context, connString string) (*PgConn, error) {
pgconn.go#L126: func ConnectWithOptions(ctx context.Context, connString string, parseConfigOptions ParseConfigOptions) (*PgConn, error) {
pgconn.go#L141: func ConnectConfig(ctx context.Context, config *Config) (*PgConn, error) {
pgconn.go#L246: func connectPreferred(ctx context.Context, config *Config, connectOneConfigs []*connectOneConfig) (*PgConn, []error) {
pgconn.go#L308: ) (*PgConn, error) {
pgconn.go#L309: pgConn := new(PgConn)
pgconn.go#L511: func (pgConn *PgConn) txPasswordMessage(password string) (err error) {
pgconn.go#L522: func (pgConn *PgConn) signalMessage() chan struct{} {
pgconn.go#L547: func (pgConn *PgConn) ReceiveMessage(ctx context.Context) (pgproto3.BackendMessage, error) {
pgconn.go#L575: func (pgConn *PgConn) peekMessage() (pgproto3.BackendMessage, error) {
pgconn.go#L614: func (pgConn *PgConn) receiveMessage() (pgproto3.BackendMessage, error) {
pgconn.go#L653: func (pgConn *PgConn) Conn() net.Conn {
pgconn.go#L658: func (pgConn *PgConn) PID() uint32 {
pgconn.go#L671: func (pgConn *PgConn) TxStatus() byte {
pgconn.go#L676: func (pgConn *PgConn) SecretKey() []byte {
pgconn.go#L681: func (pgConn *PgConn) Frontend() *pgproto3.Frontend {
pgconn.go#L688: func (pgConn *PgConn) Close(ctx context.Context) error {
pgconn.go#L722: func (pgConn *PgConn) asyncClose() {
pgconn.go#L754: func (pgConn *PgConn) CleanupDone() chan (struct{}) {
pgconn.go#L761: func (pgConn *PgConn) IsClosed() bool {
pgconn.go#L766: func (pgConn *PgConn) IsBusy() bool {
pgconn.go#L771: func (pgConn *PgConn) lock() error {
pgconn.go#L784: func (pgConn *PgConn) unlock() {
pgconn.go#L796: func (pgConn *PgConn) ParameterStatus(key string) string {
pgconn.go#L864: func (pgConn *PgConn) getFieldDescriptionSlice(n int) []FieldDescription {
pgconn.go#L900: func (pgConn *PgConn) Prepare(ctx context.Context, name, sql string, paramOIDs []uint32) (*StatementDescription, error) {
pgconn.go#L966: func (pgConn *PgConn) Deallocate(ctx context.Context, name string) error {
pgconn.go#L1039: func (pgConn *PgConn) CancelRequest(ctx context.Context) error {
pgconn.go#L1094: func (pgConn *PgConn) WaitForNotification(ctx context.Context) error {
pgconn.go#L1129: func (pgConn *PgConn) Exec(ctx context.Context, sql string) *MultiResultReader {
pgconn.go#L1187: func (pgConn *PgConn) ExecParams(ctx context.Context, sql string, paramValues [][]byte, paramOIDs []uint32, paramFormats, resultFormats []int16) *ResultReader {
pgconn.go#L1213: func (pgConn *PgConn) ExecPrepared(ctx context.Context, stmtName string, paramValues [][]byte, paramFormats, resultFormats []int16) *ResultReader {
pgconn.go#L1242: func (pgConn *PgConn) ExecStatement(ctx context.Context, statementDescription *StatementDescription, paramValues [][]byte, paramFormats, resultFormats []int16) *ResultReader {
pgconn.go#L1255: func (pgConn *PgConn) execExtendedPrefix(ctx context.Context, paramValues [][]byte) *ResultReader {
pgconn.go#L1290: func (pgConn *PgConn) execExtendedSuffix(result *ResultReader, statementDescription *StatementDescription, resultFormats []int16) {
pgconn.go#L1311: func (pgConn *PgConn) CopyTo(ctx context.Context, w io.Writer, sql string) (CommandTag, error) {
pgconn.go#L1370: func (pgConn *PgConn) CopyFrom(ctx context.Context, r io.Reader, sql string) (CommandTag, error) {
pgconn.go#L1502: pgConn *PgConn
pgconn.go#L1642: pgConn *PgConn
pgconn.go#L1927: func (pgConn *PgConn) ExecBatch(ctx context.Context, batch *Batch) *MultiResultReader {
pgconn.go#L1992: func (pgConn *PgConn) EscapeString(s string) (string, error) {
pgconn.go#L2012: func (pgConn *PgConn) CheckConn() error {
pgconn.go#L2029: func (pgConn *PgConn) Ping(ctx context.Context) error {
pgconn.go#L2034: func (pgConn *PgConn) makeCommandTag(buf []byte) CommandTag {
pgconn.go#L2040: func (pgConn *PgConn) enterPotentialWriteReadDeadlock() {
pgconn.go#L2053: func (pgConn *PgConn) exitPotentialWriteReadDeadlock() {
pgconn.go#L2066: func (pgConn *PgConn) flushWithPotentialWriteReadDeadlock() error {
pgconn.go#L2080: func (pgConn *PgConn) SyncConn(ctx context.Context) error {
pgconn.go#L2098: func (pgConn *PgConn) CustomData() map[string]any {
pgconn.go#L2123: func (pgConn *PgConn) Hijack() (*HijackedConn, error) {
pgconn.go#L2148: func Construct(hc *HijackedConn) (*PgConn, error) {
pgconn.go#L2149: pgConn := &PgConn{
pgconn.go#L2192: conn *PgConn
pgconn.go#L2356: func (pgConn *PgConn) StartPipeline(ctx context.Context) *Pipeline {
pgconn.go#L2896: Conn *PgConn
github.com/jackc/pgx/v5
conn.go#L68: pgConn *pgconn.PgConn
conn.go#L409: func (c *Conn) bufferNotifications(_ *pgconn.PgConn, n *pgconn.Notification) {
conn.go#L462: func (c *Conn) PgConn() *pgconn.PgConn { return c.pgConn }