Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pq

package module

Go to main page

Versions in this module

v0

v0.0.4

Mar 14, 2021

v0.0.3

Dec 25, 2020

v0.0.2

Dec 25, 2020

Changes in this version

+ const HL_ServerAddr

+ const LF_ServerAddr

v0.0.1

Dec 25, 2020

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 RegisterGSSProvider(newGssArg NewGSSFunc)

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

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

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