fx

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 New(lc fx.Lifecycle, uri string, log *zap.Logger) (*Client, error)

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 New

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

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