client

Documentation

Index

• Constants
• func TryWithAttempts(f func() error, attempts uint, delay time.Duration) (err error)
• func TryWithAttemptsCtx(ctx context.Context, f func(context.Context) error, attempts uint, ...) (err error)
• type Client
  • func BadCli(t testing.TB) *Client
  • func New(uri string, log *zap.Logger) (*Client, error)
  • func NewTest(t testing.TB) (*Client, func())
  • func (cli *Client) L() *zap.Logger
  • func (cli *Client) P() *pgxpool.Pool

Constants

const (
	RetryAttempts = 4
	RetryDelay    = 2 * time.Second
)

Functions

func TryWithAttempts

func TryWithAttempts(f func() error, attempts uint, delay time.Duration) (err error)

TryWithAttempts tries to get non-error result of calling function f with delay.

func TryWithAttemptsCtx

func TryWithAttemptsCtx(ctx context.Context, f func(context.Context) error, attempts uint, delay time.Duration) (err error)

TryWithAttemptsCtx is helper function that calls TryWithAttempts with function f transformed to closure that does not require ctx as necessary argument.

Types

type Client

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

func BadCli

func BadCli(t testing.TB) *Client

func New

func New(uri string, log *zap.Logger) (*Client, error)

New opens new postgres connection, configures it and return prepared client.

func NewTest

func NewTest(t testing.TB) (*Client, func())

NewTest prepares test client.

If error occurred while creating connection then test will be skipped. Second argument cleanup function to close connection and rollback all changes.

func (*Client) L

func (cli *Client) L() *zap.Logger

L return global client logger.

If client is nil object then global logger will be returned.

func (*Client) P

func (cli *Client) P() *pgxpool.Pool

P returns client's configured logger.

If client is nil object then will be returned nil pool.