postgres

Documentation

Index

• Variables
• type Client
  • func NewClient(ctx context.Context, config ConnectionConfig, opts ...Option) (*Client, error)
  • func (c *Client) Close()
  • func (c *Client) Exec(ctx context.Context, sql string, args ...interface{}) (pgconn.CommandTag, error)
  • func (c *Client) Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)
  • func (c *Client) QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row
  • func (c *Client) WithTx(ctx context.Context, txFunc func(ctx context.Context) error) error
• type ConnectionConfig
  • func NewConnectionConfig(host, port, dbname, username, password, sslmode string) ConnectionConfig
• type Option
  • func WithConnAttempts(connAttempts int) Option
  • func WithConnTimeout(connTimeout time.Duration) Option
  • func WithMaxPoolSize(maxPoolSize int) Option
• type Transactor
  • func NewTransactor(db *Client) *Transactor
  • func (t *Transactor) WithTx(ctx context.Context, txFunc func(ctx context.Context) error) error

Variables

var ErrUnableToConnect = errors.New("all attempts are exceeded. Unable to connect to instance")

Types

type Client

type Client struct {
	Builder sq.StatementBuilderType
	Pool    *pgxpool.Pool
	// contains filtered or unexported fields
}

func NewClient

func NewClient(ctx context.Context, config ConnectionConfig, opts ...Option) (*Client, error)

func (*Client) Close

func (c *Client) Close()

func (*Client) Exec

func (c *Client) Exec(ctx context.Context, sql string, args ...interface{}) (pgconn.CommandTag, error)

func (*Client) Query

func (c *Client) Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)

func (*Client) QueryRow

func (c *Client) QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row

func (*Client) WithTx

func (c *Client) WithTx(ctx context.Context, txFunc func(ctx context.Context) error) error

type ConnectionConfig

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

func NewConnectionConfig

func NewConnectionConfig(host, port, dbname, username, password, sslmode string) ConnectionConfig

type Option

type Option func(*Client)

func WithConnAttempts

func WithConnAttempts(connAttempts int) Option

func WithConnTimeout

func WithConnTimeout(connTimeout time.Duration) Option

func WithMaxPoolSize

func WithMaxPoolSize(maxPoolSize int) Option

type Transactor

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

func NewTransactor

func NewTransactor(db *Client) *Transactor

func (*Transactor) WithTx

func (t *Transactor) WithTx(ctx context.Context, txFunc func(ctx context.Context) error) error