slsPgx

Documentation

Index

• func Bool(value bool) *bool
• func Float32(value float32) *float32
• func Int(value int) *int
• type Logger
• type SlsConn
  • func New(config SlsConnConfigParams) *SlsConn
  • func (s *SlsConn) Clean(ctx context.Context) (int, error)
  • func (s SlsConn) Close(ctx context.Context) error
  • func (s *SlsConn) Connect(ctx context.Context, connectionString string) error
  • func (s *SlsConn) ConnectConfig(ctx context.Context, connConfig *pgx.ConnConfig) error
  • func (s SlsConn) Exec(ctx context.Context, sql string, args ...interface{}) (pgconn.CommandTag, error)
  • func (s SlsConn) GetConnection() *pgx.Conn
  • func (s SlsConn) Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)
• type SlsConnConfigParams

Functions

func Bool

func Bool(value bool) *bool

func Float32

func Float32(value float32) *float32

func Int

func Int(value int) *int

Types

type Logger

type Logger interface {
	Info(message interface{})
	Failure(err error)
}

type SlsConn

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

func New

func New(config SlsConnConfigParams) *SlsConn

func (*SlsConn) Clean

func (s *SlsConn) Clean(ctx context.Context) (int, error)

func (SlsConn) Close

func (s SlsConn) Close(ctx context.Context) error

func (*SlsConn) Connect

func (s *SlsConn) Connect(ctx context.Context, connectionString string) error

func (*SlsConn) ConnectConfig

func (s *SlsConn) ConnectConfig(ctx context.Context, connConfig *pgx.ConnConfig) error

func (SlsConn) Exec

func (s SlsConn) Exec(ctx context.Context, sql string, args ...interface{}) (pgconn.CommandTag, error)

func (SlsConn) GetConnection

func (s SlsConn) GetConnection() *pgx.Conn

func (SlsConn) Query

func (s SlsConn) Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)

type SlsConnConfigParams

type SlsConnConfigParams struct {
	MaxConnectionsFreqMs     *float32
	ManualMaxConnections     *bool
	MaxConnections           *int
	MinConnectionIdleTimeSec *float32
	MaxIdleConnectionsToKill *int
	ConnUtilization          *float32
	Debug                    *bool
	BackoffCapMs             *float32
	BackoffBaseMs            *float32
	BackoffDelayMs           *float32
	BackoffMaxRetries        *int
}