external

Documentation

Index

• func BackOffRetry(ctx context.Context, l zerolog.Logger, maxTime time.Duration, ...) error
• func CallWithTimeout[T any](ctx context.Context, timeout time.Duration, fn func() (T, error)) (T, error)
• type ConnectionStatus
  • func (s ConnectionStatus) String() string

Functions

func BackOffRetry

func BackOffRetry(ctx context.Context, l zerolog.Logger, maxTime time.Duration, retryFn func() error) error

func CallWithTimeout

func CallWithTimeout[T any](ctx context.Context, timeout time.Duration, fn func() (T, error)) (T, error)

CallWithTimeout executes a function with a timeout and returns the result or an error if it times out

Types

type ConnectionStatus

type ConnectionStatus int

const (
	// Connection is connected
	StatusConnected ConnectionStatus = iota
	// Connection is disconnected and not trying to reconnect
	StatusDisconnected
	// Connection is attempting to reconnect
	StatusReconnecting
	// Connection cannot authentified itself to the db
	StatusNotAuthenticated
	// Connection is purposfully closed
	StatusClosed
)

func (ConnectionStatus) String

func (s ConnectionStatus) String() string