db

Documentation

Overview

Package db provides a wrapper around pgxpool.Pool that retries the queries

Index

• type Client
  • func NewClient(ctxWithTimeout context.Context, credentials *model.DBCredentials, ...) (*Client, error)
  • func (c *Client) Close()

Types

type Client

type Client struct {
	DBConnection *dbretrier.Pool
}

Client is the type that can perform database-related queries.

func NewClient

func NewClient(ctxWithTimeout context.Context, credentials *model.DBCredentials, retrier retry.Retry, maxConns int) (*Client, error)

NewClient returns a new postgres connection. The connection established will be shared throughout this application.

func (*Client) Close

func (c *Client) Close()

Close the connections.