sqlutil

package

v0.27.0 Latest Latest Go to latest Published: May 3, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/target/goalert

Links

Documentation ¶

Index ¶

func QuoteID(parts ...string) string
type BoolArray
- func (s *BoolArray) Scan(src interface{}) error
- func (s BoolArray) Value() (driver.Value, error)
type ConfigConnector
- func (cfg ConfigConnector) Connect(ctx context.Context) (*pgx.Conn, error)
type Connector
type DBConnector
- func (db *DBConnector) Connect(context.Context) (*pgx.Conn, error)
- func (db *DBConnector) Release(conn *pgx.Conn) error
type Error
- func MapError(err error) *Error
- func (e Error) Error() string
type IntArray
- func (a *IntArray) Scan(src interface{}) error
- func (a IntArray) Value() (driver.Value, error)
type Listener
- func NewListener(ctx context.Context, db Connector, channels ...string) (*Listener, error)
- func (l *Listener) Close() error
- func (l *Listener) Errors() <-chan error
- func (l *Listener) Notifications() <-chan *pgconn.Notification
- func (l *Listener) Shutdown(context.Context) error
- func (l *Listener) Start()
- func (l *Listener) Stop()
type NullTime
- func (n *NullTime) Scan(src interface{}) error
- func (n NullTime) Value() (driver.Value, error)
type Releaser
type StringArray
- func (s *StringArray) Scan(src interface{}) error
- func (s StringArray) Value() (driver.Value, error)
type UUIDArray
- func (s *UUIDArray) Scan(src interface{}) error
- func (s UUIDArray) Value() (driver.Value, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func QuoteID ¶

func QuoteID(parts ...string) string

Types ¶

type BoolArray ¶

type BoolArray []bool

func (*BoolArray) Scan ¶

func (s *BoolArray) Scan(src interface{}) error

func (BoolArray) Value ¶

func (s BoolArray) Value() (driver.Value, error)

type ConfigConnector ¶

type ConfigConnector pgx.ConnConfig

ConfigConnector implements the Connector interface for a `pgx.ConnConfig`.

func (ConfigConnector) Connect ¶

func (cfg ConfigConnector) Connect(ctx context.Context) (*pgx.Conn, error)

Connect will get a new connection using the underlying `pgx.ConnConfig`.

type Connector ¶

type Connector interface {
	Connect(context.Context) (*pgx.Conn, error)
}

Connector will return a new *pgx.Conn.

type DBConnector ¶

type DBConnector sql.DB

DBConnector implements the Connector and Releaser interfaces for a *sql.DB.

func (*DBConnector) Connect ¶

func (db *DBConnector) Connect(context.Context) (*pgx.Conn, error)

Connect will return a *pgx.Conn from the underlying *sql.DB pool.

func (*DBConnector) Release ¶

func (db *DBConnector) Release(conn *pgx.Conn) error

Release will release a *pgx.Conn to the underlying *sql.DB pool.

type Error ¶

type Error struct {
	Code           string
	Message        string
	Detail         string
	Hint           string
	TableName      string
	ConstraintName string
	Where          string
	ColumnName     string
	Position       int
	// contains filtered or unexported fields
}

Error represents a driver-agnostic SQL error.

func MapError ¶

func MapError(err error) *Error

MapError will return a Error from the given err object or nil otherwise.

func (Error) Error ¶

func (e Error) Error() string

type IntArray ¶

type IntArray []int

func (*IntArray) Scan ¶

func (a *IntArray) Scan(src interface{}) error

func (IntArray) Value ¶

func (a IntArray) Value() (driver.Value, error)

type Listener ¶

type Listener struct {
	// contains filtered or unexported fields
}

Listener will listen for NOTIFY commands on a set of channels.

func NewListener ¶

func NewListener(ctx context.Context, db Connector, channels ...string) (*Listener, error)

NewListener will create and initialize a Listener which will automatically reconnect and listen to the provided channels.

func (*Listener) Close ¶

func (l *Listener) Close() error

Close performs a shutdown with a background context.

func (*Listener) Errors ¶

func (l *Listener) Errors() <-chan error

Errors will return a channel that will be fed errors from this listener.

func (*Listener) Notifications ¶

func (l *Listener) Notifications() <-chan *pgconn.Notification

Notifications returns the notification channel for this listener. Nil values will not be returned until the listener is closed.

func (*Listener) Shutdown ¶ added in v0.25.0

func (l *Listener) Shutdown(context.Context) error

Shutdown will shut down the listener and returns after all connections have been completed. It is not necessary to call Stop() before Close().

func (*Listener) Start ¶

func (l *Listener) Start()

Start will enable reconnections and messages.

func (*Listener) Stop ¶

func (l *Listener) Stop()

Stop will end all current connections and stop reconnecting.

type NullTime ¶

type NullTime struct {
	Time  time.Time
	Valid bool // Valid is true if Time is not null
}

func (*NullTime) Scan ¶

func (n *NullTime) Scan(src interface{}) error

func (NullTime) Value ¶

func (n NullTime) Value() (driver.Value, error)

type Releaser ¶

type Releaser interface {
	Release(*pgx.Conn) error
}

Releaser is an optional interface with a Release method to be called after a connection is closed.

type StringArray ¶

type StringArray []string

func (*StringArray) Scan ¶

func (s *StringArray) Scan(src interface{}) error

func (StringArray) Value ¶

func (s StringArray) Value() (driver.Value, error)

type UUIDArray ¶

type UUIDArray []string

func (*UUIDArray) Scan ¶

func (s *UUIDArray) Scan(src interface{}) error

func (UUIDArray) Value ¶

func (s UUIDArray) Value() (driver.Value, error)

Source Files ¶

View all Source files

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