postgresql

Documentation

Index

• Variables
• type Builder
  • func NewBuilder() *Builder
  • func (b *Builder) Build() (*PostgreSQL, error)
  • func (b *Builder) Config(config *Config) *Builder
  • func (b *Builder) Logger(logger Logger) *Builder
• type Config
• type Logger
• type PostgreSQL
  • func (pg *PostgreSQL) ConnPool() *pgxpool.Pool
  • func (pg *PostgreSQL) Start(ctx context.Context) error
  • func (pg *PostgreSQL) Stop(ctx context.Context) error

Variables

var (
	ErrConfigIsRequired = errors.NewError("SYS", "PostgreSQL config is required")
	ErrLoggerIsRequired = errors.NewError("SYS", "Logger is required")
)

Types

type Builder

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

func NewBuilder

func NewBuilder() *Builder

func (*Builder) Build

func (b *Builder) Build() (*PostgreSQL, error)

func (*Builder) Config

func (b *Builder) Config(config *Config) *Builder

func (*Builder) Logger

func (b *Builder) Logger(logger Logger) *Builder

type Config

type Config struct {
	Url             string
	MaxConnIdleTime time.Duration
	MaxConns        int32
	MinConns        int32
}

type Logger

type Logger interface {
	LogError(ctx context.Context, errs ...error)
	LogInfo(ctx context.Context, messages ...string)
}

type PostgreSQL

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

func (*PostgreSQL) ConnPool

func (pg *PostgreSQL) ConnPool() *pgxpool.Pool

func (*PostgreSQL) Start

func (pg *PostgreSQL) Start(ctx context.Context) error

func (*PostgreSQL) Stop

func (pg *PostgreSQL) Stop(ctx context.Context) error