pq

Apr 14, 2023

Changes in this version

+ func BufferQuoteIdentifier(name string, buffer *bytes.Buffer)

May 16, 2022

Changes in this version

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

type Connector

+ func (c *Connector) Dialer(dialer Dialer)

type Error

+ func (err *Error) SQLState() string

Dec 1, 2020

Changes in this version

+ type Float32Array []float32

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

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

+ type Int32Array []int32

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

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

Jun 8, 2020

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)

May 26, 2020

Changes in this version

+ 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)

+ func NewGSS() (Gss, error)

May 3, 2020

Changes in this version

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

+ type NotificationHandlerConnector struct

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

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

May 3, 2020

Changes in this version

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

Apr 21, 2020

Changes in this version

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

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

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

+ type NoticeHandlerConnector struct

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

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

Jul 16, 2019

Changes in this version

+ func QuoteLiteral(literal string) string

Apr 15, 2019

Changes in this version

+ type Connector struct

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

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

+ type DialerContext interface

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

Aug 23, 2018

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 CopyIn(table string, columns ...string) string

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

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

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

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

+ func NewConnector(name string) (driver.Connector, error)

+ func Open(name 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

+ 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 Dialer interface

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

+ DialTimeout func(network, address string, timeout time.Duration) (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 Float64Array []float64

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

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

+ type GenericArray struct

+ A interface{}

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

+ func (a GenericArray) 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 Notification struct

+ BePid int

+ Channel string

+ Extra string

+ 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)