postgres

Documentation

Index

• Variables
• type Client
  • func NewClient(ctx context.Context, dbUser, dbPass, dbHost string, dbPort int, dbName string, ...) (Client, error)
• type Execer
• type JSONObject
  • func (o *JSONObject) Scan(src interface{}) error
  • func (o JSONObject) Value() (driver.Value, error)
• type Option
  • func WithConnMaxLifetime(cml time.Duration) Option
  • func WithLogger(logger *zap.Logger) Option
  • func WithMaxIdleConns(mic int) Option
  • func WithMaxOpenConns(moc int) Option
• type Result

Variables

var (
	ErrDuplicateEntry = errors.New("postgres: duplicate entry")
)

Types

type Client

type Client interface {
	Execer
	Close() error
}

func NewClient

func NewClient(
	ctx context.Context,
	dbUser, dbPass, dbHost string,
	dbPort int,
	dbName string,
	opts ...Option,
) (Client, error)

type Execer

type Execer interface {
	ExecContext(ctx context.Context, query string, args ...interface{}) (Result, error)
}

type JSONObject

type JSONObject struct {
	Val interface{}
}

func (*JSONObject) Scan

func (o *JSONObject) Scan(src interface{}) error

func (JSONObject) Value

func (o JSONObject) Value() (driver.Value, error)

type Option

type Option func(*options)

func WithConnMaxLifetime

func WithConnMaxLifetime(cml time.Duration) Option

func WithLogger

func WithLogger(logger *zap.Logger) Option

func WithMaxIdleConns

func WithMaxIdleConns(mic int) Option

func WithMaxOpenConns

func WithMaxOpenConns(moc int) Option

type Result

type Result interface {
	LastInsertId() (int64, error)
	RowsAffected() (int64, error)
}