type github.com/jackc/pgx/v5/pgconn.PgConn
79 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#L27: AfterConnectFunc func(ctx context.Context, pgconn *PgConn) error
config.go#L28: ValidateConnectFunc func(ctx context.Context, pgconn *PgConn) error
config.go#L48: BuildContextWatcherHandler func(*PgConn) ctxwatch.Handler
config.go#L373: BuildContextWatcherHandler: func(pgConn *PgConn) ctxwatch.Handler {
config.go#L376: OnPgError: func(_ *PgConn, pgErr *PgError) bool {
config.go#L1006: func ValidateConnectTargetSessionAttrsReadWrite(ctx context.Context, pgConn *PgConn) error {
config.go#L1021: func ValidateConnectTargetSessionAttrsReadOnly(ctx context.Context, pgConn *PgConn) error {
config.go#L1036: func ValidateConnectTargetSessionAttrsStandby(ctx context.Context, pgConn *PgConn) error {
config.go#L1051: func ValidateConnectTargetSessionAttrsPrimary(ctx context.Context, pgConn *PgConn) error {
config.go#L1066: 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#L115: func Connect(ctx context.Context, connString string) (*PgConn, error) {
pgconn.go#L127: func ConnectWithOptions(ctx context.Context, connString string, parseConfigOptions ParseConfigOptions) (*PgConn, error) {
pgconn.go#L142: func ConnectConfig(ctx context.Context, config *Config) (*PgConn, error) {
pgconn.go#L247: func connectPreferred(ctx context.Context, config *Config, connectOneConfigs []*connectOneConfig) (*PgConn, []error) {
pgconn.go#L315: ) (*PgConn, error) {
pgconn.go#L316: pgConn := new(PgConn)
pgconn.go#L424: requireAuthFail := func(err error) (*PgConn, error) {
pgconn.go#L561: func (pgConn *PgConn) txPasswordMessage(password string) (err error) {
pgconn.go#L572: func (pgConn *PgConn) signalMessage() chan struct{} {
pgconn.go#L597: func (pgConn *PgConn) ReceiveMessage(ctx context.Context) (pgproto3.BackendMessage, error) {
pgconn.go#L625: func (pgConn *PgConn) peekMessage() (pgproto3.BackendMessage, error) {
pgconn.go#L664: func (pgConn *PgConn) receiveMessage() (pgproto3.BackendMessage, error) {
pgconn.go#L703: func (pgConn *PgConn) Conn() net.Conn {
pgconn.go#L708: func (pgConn *PgConn) PID() uint32 {
pgconn.go#L721: func (pgConn *PgConn) TxStatus() byte {
pgconn.go#L726: func (pgConn *PgConn) SecretKey() []byte {
pgconn.go#L731: func (pgConn *PgConn) Frontend() *pgproto3.Frontend {
pgconn.go#L738: func (pgConn *PgConn) Close(ctx context.Context) error {
pgconn.go#L772: func (pgConn *PgConn) asyncClose() {
pgconn.go#L804: func (pgConn *PgConn) CleanupDone() chan (struct{}) {
pgconn.go#L811: func (pgConn *PgConn) IsClosed() bool {
pgconn.go#L816: func (pgConn *PgConn) IsBusy() bool {
pgconn.go#L821: func (pgConn *PgConn) lock() error {
pgconn.go#L834: func (pgConn *PgConn) unlock() {
pgconn.go#L846: func (pgConn *PgConn) ParameterStatus(key string) string {
pgconn.go#L914: func (pgConn *PgConn) getFieldDescriptionSlice(n int) []FieldDescription {
pgconn.go#L950: func (pgConn *PgConn) Prepare(ctx context.Context, name, sql string, paramOIDs []uint32) (*StatementDescription, error) {
pgconn.go#L1016: func (pgConn *PgConn) Deallocate(ctx context.Context, name string) error {
pgconn.go#L1089: func (pgConn *PgConn) CancelRequest(ctx context.Context) error {
pgconn.go#L1163: func (pgConn *PgConn) WaitForNotification(ctx context.Context) error {
pgconn.go#L1197: func (pgConn *PgConn) Exec(ctx context.Context, sql string) *MultiResultReader {
pgconn.go#L1255: func (pgConn *PgConn) ExecParams(ctx context.Context, sql string, paramValues [][]byte, paramOIDs []uint32, paramFormats, resultFormats []int16) *ResultReader {
pgconn.go#L1281: func (pgConn *PgConn) ExecPrepared(ctx context.Context, stmtName string, paramValues [][]byte, paramFormats, resultFormats []int16) *ResultReader {
pgconn.go#L1310: func (pgConn *PgConn) ExecStatement(ctx context.Context, statementDescription *StatementDescription, paramValues [][]byte, paramFormats, resultFormats []int16) *ResultReader {
pgconn.go#L1323: func (pgConn *PgConn) execExtendedPrefix(ctx context.Context, paramValues [][]byte) *ResultReader {
pgconn.go#L1358: func (pgConn *PgConn) execExtendedSuffix(result *ResultReader, statementDescription *StatementDescription, resultFormats []int16) {
pgconn.go#L1379: func (pgConn *PgConn) CopyTo(ctx context.Context, w io.Writer, sql string) (CommandTag, error) {
pgconn.go#L1438: func (pgConn *PgConn) CopyFrom(ctx context.Context, r io.Reader, sql string) (CommandTag, error) {
pgconn.go#L1570: pgConn *PgConn
pgconn.go#L1710: pgConn *PgConn
pgconn.go#L1994: func (pgConn *PgConn) ExecBatch(ctx context.Context, batch *Batch) *MultiResultReader {
pgconn.go#L2059: func (pgConn *PgConn) EscapeString(s string) (string, error) {
pgconn.go#L2079: func (pgConn *PgConn) CheckConn() error {
pgconn.go#L2096: func (pgConn *PgConn) Ping(ctx context.Context) error {
pgconn.go#L2101: func (pgConn *PgConn) makeCommandTag(buf []byte) CommandTag {
pgconn.go#L2107: func (pgConn *PgConn) enterPotentialWriteReadDeadlock() {
pgconn.go#L2120: func (pgConn *PgConn) exitPotentialWriteReadDeadlock() {
pgconn.go#L2133: func (pgConn *PgConn) flushWithPotentialWriteReadDeadlock() error {
pgconn.go#L2147: func (pgConn *PgConn) SyncConn(ctx context.Context) error {
pgconn.go#L2165: func (pgConn *PgConn) CustomData() map[string]any {
pgconn.go#L2191: func (pgConn *PgConn) Hijack() (*HijackedConn, error) {
pgconn.go#L2217: func Construct(hc *HijackedConn) (*PgConn, error) {
pgconn.go#L2218: pgConn := &PgConn{
pgconn.go#L2262: conn *PgConn
pgconn.go#L2426: func (pgConn *PgConn) StartPipeline(ctx context.Context) *Pipeline {
pgconn.go#L2966: 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 }