postgresql

Documentation

Index

• Constants
• type Client
  • func New(opts ...ClientOption) (*Client, error)
  • func (c *Client) Close()
  • func (c *Client) GetInstancePool(ctx context.Context, urlOpts UrlOpts) (*pgxpool.Pool, error)
  • func (c *Client) GetInstanceSqlDB(opts UrlOpts) (*sql.DB, error)
• type ClientOption
  • func WithConnAttempts(att int) ClientOption
  • func WithConnTimeout(t time.Duration) ClientOption
  • func WithMaxPoolSize(pz int) ClientOption
• type UrlOpts
  • func (opt UrlOpts) URL() string

Constants

const (
	DEFAULT_MAX_POOL_SIZE          = 1
	DEFAULT_POOL_CREATION_ATTEMPTS = 10
	DEFAULT_POOL_CREATION_TIMEOUT  = time.Millisecond * 200
)

Types

type Client

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

func New

func New(opts ...ClientOption) (*Client, error)

func (*Client) Close

func (c *Client) Close()

func (*Client) GetInstancePool

func (c *Client) GetInstancePool(ctx context.Context, urlOpts UrlOpts) (*pgxpool.Pool, error)

func (*Client) GetInstanceSqlDB

func (c *Client) GetInstanceSqlDB(opts UrlOpts) (*sql.DB, error)

type ClientOption

type ClientOption func(*Client)

func WithConnAttempts

func WithConnAttempts(att int) ClientOption

func WithConnTimeout

func WithConnTimeout(t time.Duration) ClientOption

func WithMaxPoolSize

func WithMaxPoolSize(pz int) ClientOption

type UrlOpts

type UrlOpts struct {
	DBName string
	Host   string
	Pass   string
	Port   int
	User   string
}

func (UrlOpts) URL

func (opt UrlOpts) URL() string

TODO: add validation fro mandatory fields