pq

package module

Go to main page

Versions in this module

v1

v1.0.7

Nov 12, 2024

v1.0.6

Feb 21, 2024

v1.0.5

Jun 13, 2023

v1.0.4

Aug 8, 2022

Changes in this version

+ const ClientEncoding

+ const DefaultClientEncoding

+ const ServerEncoding

+ const ServerVersion

+ const TimeZone

+ var ErrSSLKeyUnknownOwnership = errors.New(...)

+ func ParseURLToMap(connString string) (map[string]string, error)

type Error

+ func (err *Error) SQLState() string

v1.0.3

Feb 25, 2022

Changes in this version

+ const AUTH_REQ_CRYPT

+ const AUTH_REQ_KRB4

+ const AUTH_REQ_KRB5

+ const AUTH_REQ_SCM

+ const AUTH_REQ_SSPI

+ const AuthReqGss

+ const AuthReqGssContinue

+ const AuthReqMd5

+ const AuthReqMd5Sha256

+ const AuthReqOk

+ const AuthReqPassword

+ const AuthReqSha256

+ const AuthReqSm3

+ const Md5Password

+ const PlainPassword

+ const Sha256Password

+ const Sm3Password

+ func DeregisterTLSConfig(key string)

+ func RegisterTLSConfig(key string, config *tls.Config) error

+ func ValidateConnectTargetSessionAttrsPrimary(cn *conn) error

+ func ValidateConnectTargetSessionAttrsReadOnly(cn *conn) error

+ func ValidateConnectTargetSessionAttrsReadWrite(cn *conn) error

+ func ValidateConnectTargetSessionAttrsStandby(cn *conn) error

type Config

+ ValidateConnect ValidateConnectFunc

type Connector

+ func NewConnectorConfig(config *Config) (*Connector, error)

+ type ValidateConnectFunc func(conn *conn) error

v1.0.2

Aug 25, 2021

v1.0.1

Aug 25, 2021

Changes in this version

+ const LogLevelDebug

+ const LogLevelError

+ const LogLevelInfo

+ const LogLevelNone

+ const LogLevelTrace

+ const LogLevelWarn

+ func Md5Sha256encode(password, random64code string, salt []byte) []byte

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

+ func XorBetweenPassword(password1 []byte, password2 []byte, length int) []byte

+ type Config struct

+ ConnectTimeout time.Duration

+ Database string

+ DialFunc DialFunc

+ Fallbacks []*FallbackConfig

+ GssAPIParams map[string]string

+ Host string

+ LogLevel LogLevel

+ Logger Logger

+ LookupFunc LookupFunc

+ Password string

+ Port uint16

+ RuntimeParams map[string]string

+ TLSConfig *tls.Config

+ User string

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

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

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

type ErrorCode

+ func (ec ErrorCode) String() string

+ type FallbackConfig struct

+ Host string

+ Port uint16

+ TLSConfig *tls.Config

+ type LogLevel int

+ func LogLevelFromString(s string) (LogLevel, error)

+ func (ll LogLevel) String() string

+ type Logger interface

+ Log func(ctx context.Context, level LogLevel, msg string, data map[string]interface{})

+ var DefaultLogger Logger = NewPrintfLogger(LogLevelDebug)

+ func NewPrintfLogger(level LogLevel) Logger

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

v1.0.0

Mar 20, 2021

Changes in this version

+ const Edebug

+ const Efatal

+ const Einfo

+ const Elog

+ const Enotice

+ const Epanic

+ const Ewarning

+ var ErrChannelAlreadyOpen = errors.New("pq: channel is already open")

+ var ErrChannelNotOpen = errors.New("pq: channel is not open")

+ var ErrCouldNotDetectUsername = errors.New("pq: Could not detect default username. Please provide one explicitly")

+ var ErrInFailedTransaction = errors.New("pq: Could not complete operation in a failed transaction")

+ var ErrNotSupported = errors.New("pq: Unsupported command")

+ var ErrSSLKeyHasWorldPermissions = errors.New(...)

+ var ErrSSLNotSupported = errors.New("pq: SSL is not enabled on the server")

+ func Array(a interface{}) interface

+ func ConnectorNoticeHandler(c driver.Connector) func(*Error)

+ func ConnectorNotificationHandler(c driver.Connector) func(*Notification)

+ func CopyIn(table string, columns ...string) string

+ func CopyInSchema(schema, table string, columns ...string) string

+ func DialOpen(d Dialer, dsn string) (_ driver.Conn, err error)

+ func EnableInfinityTs(negative time.Time, positive time.Time)

+ func FormatTimestamp(t time.Time) []byte

+ func NoticeHandler(c driver.Conn) func(*Error)

+ func Open(dsn string) (_ driver.Conn, err error)

+ func ParseTimestamp(currentLocation *time.Location, str string) (time.Time, error)

+ func ParseURL(url string) (string, error)

+ func QuoteIdentifier(name string) string

+ func QuoteLiteral(literal string) string

+ func RFC5802Algorithm(password string, random64code string, token string, server_signature string, ...) []byte

+ func RegisterGSSProvider(newGssArg NewGSSFunc)

+ func SetNoticeHandler(c driver.Conn, handler func(*Error))

+ func SetNotificationHandler(c driver.Conn, handler func(*Notification))

+ func TestRFC5802Algorithm(t *testing.T)

+ func XOR_between_password(password1 []byte, password2 []byte, length int) []byte

+ type ArrayDelimiter interface

+ ArrayDelimiter func() string

+ type BoolArray []bool

+ func (a *BoolArray) Scan(src interface{}) error

+ func (a BoolArray) Value() (driver.Value, error)

+ type ByteaArray [][]byte

+ func (a *ByteaArray) Scan(src interface{}) error

+ func (a ByteaArray) Value() (driver.Value, error)

+ type Connector struct

+ func NewConnector(dsn string) (*Connector, error)

+ func (c *Connector) Connect(ctx context.Context) (driver.Conn, error)

+ func (c *Connector) Driver() driver.Driver

+ type Dialer interface

+ Dial func(network, address string) (net.Conn, error)

+ DialTimeout func(network, address string, timeout time.Duration) (net.Conn, error)

+ type DialerContext interface

+ DialContext func(ctx context.Context, network, address string) (net.Conn, error)

+ type Driver struct

+ func (d Driver) Open(name string) (driver.Conn, error)

+ type Error struct

+ Code ErrorCode

+ Column string

+ Constraint string

+ DataTypeName string

+ Detail string

+ File string

+ Hint string

+ InternalPosition string

+ InternalQuery string

+ Line string

+ Message string

+ Position string

+ Routine string

+ Schema string

+ Severity string

+ Table string

+ Where string

+ func (err *Error) Fatal() bool

+ func (err *Error) Get(k byte) (v string)

+ func (err Error) Error() string

+ type ErrorClass string

+ func (ec ErrorClass) Name() string

+ type ErrorCode string

+ func (ec ErrorCode) Class() ErrorClass

+ func (ec ErrorCode) Name() string

+ type EventCallbackType func(event ListenerEventType, err error)

+ type Float32Array []float32

+ func (a *Float32Array) Scan(src interface{}) error

+ func (a Float32Array) Value() (driver.Value, error)

+ type Float64Array []float64

+ func (a *Float64Array) Scan(src interface{}) error

+ func (a Float64Array) Value() (driver.Value, error)

+ 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 GenericArray struct

+ A interface{}

+ func (a GenericArray) Scan(src interface{}) error

+ func (a GenericArray) Value() (driver.Value, error)

+ type Int32Array []int32

+ func (a *Int32Array) Scan(src interface{}) error

+ func (a Int32Array) Value() (driver.Value, error)

+ type Int64Array []int64

+ func (a *Int64Array) Scan(src interface{}) error

+ func (a Int64Array) Value() (driver.Value, error)

+ type Listener struct

+ Notify chan *Notification

+ func NewDialListener(d Dialer, name string, minReconnectInterval time.Duration, ...) *Listener

+ func NewListener(name string, minReconnectInterval time.Duration, ...) *Listener

+ func (l *Listener) Close() error

+ func (l *Listener) Listen(channel string) error

+ func (l *Listener) NotificationChannel() <-chan *Notification

+ func (l *Listener) Ping() error

+ func (l *Listener) Unlisten(channel string) error

+ func (l *Listener) UnlistenAll() error

+ type ListenerConn struct

+ func NewListenerConn(name string, notificationChan chan<- *Notification) (*ListenerConn, error)

+ func (l *ListenerConn) Close() error

+ func (l *ListenerConn) Err() error

+ func (l *ListenerConn) ExecSimpleQuery(q string) (executed bool, err error)

+ func (l *ListenerConn) Listen(channel string) (bool, error)

+ func (l *ListenerConn) Ping() error

+ func (l *ListenerConn) Unlisten(channel string) (bool, error)

+ func (l *ListenerConn) UnlistenAll() (bool, error)

+ type ListenerEventType int

+ const ListenerEventConnected

+ const ListenerEventConnectionAttemptFailed

+ const ListenerEventDisconnected

+ const ListenerEventReconnected

+ type NewGSSFunc func() (GSS, error)

+ type NoticeHandlerConnector struct

+ func ConnectorWithNoticeHandler(c driver.Connector, handler func(*Error)) *NoticeHandlerConnector

+ func (n *NoticeHandlerConnector) Connect(ctx context.Context) (driver.Conn, error)

+ type Notification struct

+ BePid int

+ Channel string

+ Extra string

+ type NotificationHandlerConnector struct

+ func ConnectorWithNotificationHandler(c driver.Connector, handler func(*Notification)) *NotificationHandlerConnector

+ func (n *NotificationHandlerConnector) Connect(ctx context.Context) (driver.Conn, error)

+ type NullTime struct

+ Time time.Time

+ Valid bool

+ func (nt *NullTime) Scan(value interface{}) error

+ func (nt NullTime) Value() (driver.Value, error)

+ type PGError interface

+ Error func() string

+ Fatal func() bool

+ Get func(k byte) (v string)

+ type StringArray []string

+ func (a *StringArray) Scan(src interface{}) error

+ func (a StringArray) Value() (driver.Value, error)

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