pgconn

package module

Go to main page

Versions in this module

v1

v1.14.3

Mar 4, 2024

v1.14.2

Mar 4, 2024

v1.14.1

Jul 20, 2023

v1.14.0

Feb 11, 2023

v1.13.0

Aug 6, 2022

Changes in this version

+ func ValidateConnectTargetSessionAttrsPreferStandby(ctx context.Context, pgConn *PgConn) error

type Config

+ func ParseConfigWithOptions(connString string, options ParseConfigOptions) (*Config, error)

+ type GetSSLPasswordFunc func(ctx context.Context) string

+ type NotPreferredError struct

+ func (e *NotPreferredError) Error() string

+ func (e *NotPreferredError) SafeToRetry() bool

+ func (e *NotPreferredError) Unwrap() error

+ type ParseConfigOptions struct

+ GetSSLPassword GetSSLPasswordFunc

type PgConn

+ func ConnectWithOptions(ctx context.Context, connString string, parseConfigOptions ParseConfigOptions) (*PgConn, error)

v1.12.1

May 7, 2022

Changes in this version

type Config

+ KerberosSpn string

+ KerberosSrvName string

v1.12.0

Apr 22, 2022

Changes in this version

+ func RegisterGSSProvider(newGSSArg NewGSSFunc)

+ type GSS interface

+ Continue func(inToken []byte) (done bool, outToken []byte, err error)

+ GetInitToken func(host string, service string) ([]byte, error)

+ GetInitTokenFromSPN func(spn string) ([]byte, error)

+ type NewGSSFunc func() (GSS, error)

v1.11.0

Feb 7, 2022

Changes in this version

+ func ValidateConnectTargetSessionAttrsPrimary(ctx context.Context, pgConn *PgConn) error

+ func ValidateConnectTargetSessionAttrsReadOnly(ctx context.Context, pgConn *PgConn) error

+ func ValidateConnectTargetSessionAttrsStandby(ctx context.Context, pgConn *PgConn) error

v1.10.1

Nov 20, 2021

v1.10.0

Jul 24, 2021

v1.9.0

Jul 10, 2021

v1.8.1

Mar 25, 2021

v1.8.0

Dec 4, 2020

v1.7.2

Nov 4, 2020

v1.7.1

Oct 31, 2020

v1.7.0

Sep 26, 2020

Changes in this version

type PgConn

+ func (pgConn *PgConn) CleanupDone() chan (struct{})

+ func (pgConn *PgConn) ReceiveResults(ctx context.Context) *MultiResultReader

v1.6.4

Jul 30, 2020

v1.6.3

Jul 22, 2020

v1.6.2

Jul 14, 2020

v1.6.1

Jun 27, 2020

v1.6.0

Jun 6, 2020

Changes in this version

type Config

+ ConnectTimeout time.Duration

+ func (c *Config) Copy() *Config

v1.5.0

Mar 30, 2020

v1.4.0

Mar 7, 2020

v1.3.2

Feb 14, 2020

v1.3.1

Feb 5, 2020

v1.3.0

Jan 24, 2020

Changes in this version

+ type HijackedConn struct

+ Config *Config

+ Conn net.Conn

+ Frontend Frontend

+ PID uint32

+ ParameterStatuses map[string]string

+ SecretKey uint32

+ TxStatus byte

type PgConn

+ func Construct(hc *HijackedConn) (*PgConn, error)

+ func (pgConn *PgConn) Hijack() (*HijackedConn, error)

v1.2.1

Jan 13, 2020

v1.2.0

Jan 12, 2020

Changes in this version

type CommandTag

+ func (ct CommandTag) Delete() bool

+ func (ct CommandTag) Insert() bool

+ func (ct CommandTag) Select() bool

+ func (ct CommandTag) Update() bool

type PgError

+ func (pe *PgError) SQLState() string

v1.1.0

Oct 12, 2019

Changes in this version

type Config

+ LookupFunc LookupFunc

+ type LookupFunc func(ctx context.Context, host string) (addrs []string, err error)

type PgConn

+ func (pgConn *PgConn) IsBusy() bool

v1.0.1

Sep 20, 2019

v1.0.0

Sep 15, 2019

Changes in this version

+ func NetworkAddress(host string, port uint16) (network, address string)

+ func SafeToRetry(err error) bool

+ func Timeout(err error) bool

+ func ValidateConnectTargetSessionAttrsReadWrite(ctx context.Context, pgConn *PgConn) error

+ type AfterConnectFunc func(ctx context.Context, pgconn *PgConn) error

+ type Batch struct

+ func (batch *Batch) ExecParams(sql string, paramValues [][]byte, paramOIDs []uint32, paramFormats []int16, ...)

+ func (batch *Batch) ExecPrepared(stmtName string, paramValues [][]byte, paramFormats []int16, ...)

+ type BuildFrontendFunc func(r io.Reader, w io.Writer) Frontend

+ type CommandTag []byte

+ func (ct CommandTag) RowsAffected() int64

+ func (ct CommandTag) String() string

+ type Config struct

+ AfterConnect AfterConnectFunc

+ BuildFrontend BuildFrontendFunc

+ Database string

+ DialFunc DialFunc

+ Fallbacks []*FallbackConfig

+ Host string

+ OnNotice NoticeHandler

+ OnNotification NotificationHandler

+ Password string

+ Port uint16

+ RuntimeParams map[string]string

+ TLSConfig *tls.Config

+ User string

+ ValidateConnect ValidateConnectFunc

+ func ParseConfig(connString string) (*Config, error)

+ type DialFunc func(ctx context.Context, network, addr string) (net.Conn, error)

+ type FallbackConfig struct

+ Host string

+ Port uint16

+ TLSConfig *tls.Config

+ type Frontend interface

+ Receive func() (pgproto3.BackendMessage, error)

+ type MultiResultReader struct

+ func (mrr *MultiResultReader) Close() error

+ func (mrr *MultiResultReader) NextResult() bool

+ func (mrr *MultiResultReader) ReadAll() ([]*Result, error)

+ func (mrr *MultiResultReader) ResultReader() *ResultReader

+ type Notice PgError

+ type NoticeHandler func(*PgConn, *Notice)

+ type Notification struct

+ Channel string

+ PID uint32

+ Payload string

+ type NotificationHandler func(*PgConn, *Notification)

+ type PgConn struct

+ func Connect(ctx context.Context, connString string) (*PgConn, error)

+ func ConnectConfig(ctx context.Context, config *Config) (pgConn *PgConn, err error)

+ func (pgConn *PgConn) CancelRequest(ctx context.Context) error

+ func (pgConn *PgConn) Close(ctx context.Context) error

+ func (pgConn *PgConn) Conn() net.Conn

+ func (pgConn *PgConn) CopyFrom(ctx context.Context, r io.Reader, sql string) (CommandTag, error)

+ func (pgConn *PgConn) CopyTo(ctx context.Context, w io.Writer, sql string) (CommandTag, error)

+ func (pgConn *PgConn) EscapeString(s string) (string, error)

+ func (pgConn *PgConn) Exec(ctx context.Context, sql string) *MultiResultReader

+ func (pgConn *PgConn) ExecBatch(ctx context.Context, batch *Batch) *MultiResultReader

+ func (pgConn *PgConn) ExecParams(ctx context.Context, sql string, paramValues [][]byte, paramOIDs []uint32, ...) *ResultReader

+ func (pgConn *PgConn) ExecPrepared(ctx context.Context, stmtName string, paramValues [][]byte, ...) *ResultReader

+ func (pgConn *PgConn) IsClosed() bool

+ func (pgConn *PgConn) PID() uint32

+ func (pgConn *PgConn) ParameterStatus(key string) string

+ func (pgConn *PgConn) Prepare(ctx context.Context, name, sql string, paramOIDs []uint32) (*StatementDescription, error)

+ func (pgConn *PgConn) ReceiveMessage(ctx context.Context) (pgproto3.BackendMessage, error)

+ func (pgConn *PgConn) SecretKey() uint32

+ func (pgConn *PgConn) SendBytes(ctx context.Context, buf []byte) error

+ func (pgConn *PgConn) TxStatus() byte

+ func (pgConn *PgConn) WaitForNotification(ctx context.Context) error

+ type PgError struct

+ Code string

+ ColumnName string

+ ConstraintName string

+ DataTypeName string

+ Detail string

+ File string

+ Hint string

+ InternalPosition int32

+ InternalQuery string

+ Line int32

+ Message string

+ Position int32

+ Routine string

+ SchemaName string

+ Severity string

+ TableName string

+ Where string

+ func ErrorResponseToPgError(msg *pgproto3.ErrorResponse) *PgError

+ func (pe *PgError) Error() string

+ type Result struct

+ CommandTag CommandTag

+ Err error

+ FieldDescriptions []pgproto3.FieldDescription

+ Rows [][][]byte

+ type ResultReader struct

+ func (rr *ResultReader) Close() (CommandTag, error)

+ func (rr *ResultReader) FieldDescriptions() []pgproto3.FieldDescription

+ func (rr *ResultReader) NextRow() bool

+ func (rr *ResultReader) Read() *Result

+ func (rr *ResultReader) Values() [][]byte

+ type StatementDescription struct

+ Fields []pgproto3.FieldDescription

+ Name string

+ ParamOIDs []uint32

+ SQL string

+ type ValidateConnectFunc func(ctx context.Context, pgconn *PgConn) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL