pgc

Documentation

Index

• Variables
• func CheckError(err error) error
• type Client
  • func NewClient(logger log.Logger, cfg db.Config) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) Commit(ctx context.Context) error
  • func (c *Client) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
  • func (c *Client) GetContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error
  • func (c *Client) GetDB(ctx context.Context) sqlx.ExtContext
  • func (c *Client) GetSaltDB(ctx context.Context) *db.Client
  • func (c *Client) NamedExecContext(ctx context.Context, query string, arg interface{}) (sql.Result, error)
  • func (c *Client) NamedQueryContext(ctx context.Context, query string, arg interface{}) (*sqlx.Rows, error)
  • func (c *Client) QueryRowxContext(ctx context.Context, query string, args ...interface{}) *sqlx.Row
  • func (c *Client) QueryxContext(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error)
  • func (c *Client) Rollback(ctx context.Context) error
  • func (c *Client) WithTransaction(ctx context.Context, opts *sql.TxOptions) context.Context
• type ListString
  • func (m *ListString) Scan(value interface{}) error
  • func (a ListString) Value() (driver.Value, error)
• type ListStringAnyMap
  • func (m *ListStringAnyMap) Scan(value interface{}) error
  • func (a ListStringAnyMap) Value() (driver.Value, error)
• type StringAnyMap
  • func (m *StringAnyMap) Scan(value any) error
  • func (a StringAnyMap) Value() (driver.Value, error)
• type StringStringMap
  • func (m *StringStringMap) Scan(value interface{}) error
  • func (a StringStringMap) Value() (driver.Value, error)
• type TimeDuration
  • func (t *TimeDuration) Scan(value interface{}) error
  • func (t TimeDuration) Value() (driver.Value, error)

Variables

var (
	ErrDuplicateKey        = errors.New("duplicate key")
	ErrCheckViolation      = errors.New("check constraint violation")
	ErrForeignKeyViolation = errors.New("foreign key violation")
)

Functions

func CheckError

func CheckError(err error) error

Types

type Client

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

func NewClient

func NewClient(logger log.Logger, cfg db.Config) (*Client, error)

NewClient wraps salt/db client

func (*Client) Close

func (c *Client) Close() error

Close closes the database connection

func (*Client) Commit

func (c *Client) Commit(ctx context.Context) error

func (*Client) ExecContext

func (c *Client) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

func (*Client) GetContext

func (c *Client) GetContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error

func (*Client) GetDB

func (c *Client) GetDB(ctx context.Context) sqlx.ExtContext

func (*Client) GetSaltDB

func (c *Client) GetSaltDB(ctx context.Context) *db.Client

func (*Client) NamedExecContext

func (c *Client) NamedExecContext(ctx context.Context, query string, arg interface{}) (sql.Result, error)

func (*Client) NamedQueryContext

func (c *Client) NamedQueryContext(ctx context.Context, query string, arg interface{}) (*sqlx.Rows, error)

func (*Client) QueryRowxContext

func (c *Client) QueryRowxContext(ctx context.Context, query string, args ...interface{}) *sqlx.Row

func (*Client) QueryxContext

func (c *Client) QueryxContext(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error)

func (*Client) Rollback

func (c *Client) Rollback(ctx context.Context) error

func (*Client) WithTransaction

func (c *Client) WithTransaction(ctx context.Context, opts *sql.TxOptions) context.Context

type ListString

type ListString []string

func (*ListString) Scan

func (m *ListString) Scan(value interface{}) error

func (ListString) Value

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

type ListStringAnyMap

type ListStringAnyMap []map[string]any

func (*ListStringAnyMap) Scan

func (m *ListStringAnyMap) Scan(value interface{}) error

func (ListStringAnyMap) Value

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

type StringAnyMap

type StringAnyMap map[string]any

func (*StringAnyMap) Scan

func (m *StringAnyMap) Scan(value any) error

func (StringAnyMap) Value

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

type StringStringMap

type StringStringMap map[string]string

func (*StringStringMap) Scan

func (m *StringStringMap) Scan(value interface{}) error

func (StringStringMap) Value

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

type TimeDuration

type TimeDuration time.Duration

func (*TimeDuration) Scan

func (t *TimeDuration) Scan(value interface{}) error

func (TimeDuration) Value

func (t TimeDuration) Value() (driver.Value, error)