postgres

README

postgres

• pool_max_conns: integer greater than 0 (default 4)
• pool_min_conns: integer 0 or greater (default 0)
• pool_max_conn_lifetime: duration string (default 1 hour)
• pool_max_conn_idle_time: duration string (default 30 minutes)
• pool_health_check_period: duration string (default 1 minute)
• pool_max_conn_lifetime_jitter: duration string (default 0)

Documentation

Index

• Constants
• func Mapping[T any](rows pgx.Rows) (obj *T, err error)
• type Connector
  • func (connect *Connector) Ctx(ctx context.Context) context.Context
  • func (connect *Connector) ExecuteQuery(ctx context.Context, query string, params ...interface{}) error
  • func (connect *Connector) GetConnection(ctx context.Context) (outCtx context.Context, alreadyExist bool, err error)
  • func (connect *Connector) GetListener(ctx context.Context, channel string) (*Listener, error)
  • func (connect *Connector) GetRows(ctx context.Context, query string, processing DBRowProcessing, ...) error
  • func (connect *Connector) Setup(connectionString string) *Connector
  • func (connect *Connector) Using(ctx context.Context, query DBContextExecutorFunction) error
  • func (connect *Connector) UsingWithTransaction(ctx context.Context, query DBContextExecutorFunction) error
• type DBContextExecutorFunction
• type DBFieldMapping
• type DBRowProcessing
• type Database
  • func (cfg *Database) CopySettingsContext(src context.Context, dst context.Context) context.Context
  • func (cfg *Database) GetConnector() *Connector
  • func (cfg *Database) InitSettings(_ context.Context) error
  • func (cfg *Database) InitSettingsContext(ctx context.Context) context.Context
• type Executor
• type Listener
  • func (listener *Listener) Close()

Constants

const (
	DBContext  = "db"
	DBExecutor = "dbExecutor"
)

Functions

func Mapping

func Mapping[T any](rows pgx.Rows) (obj *T, err error)

Types

type Connector

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

func (*Connector) Ctx

func (connect *Connector) Ctx(ctx context.Context) context.Context

func (*Connector) ExecuteQuery

func (connect *Connector) ExecuteQuery(ctx context.Context, query string, params ...interface{}) error

func (*Connector) GetConnection

func (connect *Connector) GetConnection(ctx context.Context) (outCtx context.Context, alreadyExist bool, err error)

func (*Connector) GetListener

func (connect *Connector) GetListener(ctx context.Context, channel string) (*Listener, error)

GetListener - get listener

func (*Connector) GetRows

func (connect *Connector) GetRows(ctx context.Context, query string, processing DBRowProcessing, params ...interface{}) error

func (*Connector) Setup

func (connect *Connector) Setup(connectionString string) *Connector

Setup - setup Db ctx

func (*Connector) Using

func (connect *Connector) Using(ctx context.Context, query DBContextExecutorFunction) error

func (*Connector) UsingWithTransaction

func (connect *Connector) UsingWithTransaction(ctx context.Context, query DBContextExecutorFunction) error

type DBContextExecutorFunction

type DBContextExecutorFunction func(ctx context.Context) error

type DBFieldMapping

type DBFieldMapping func(pgx.Rows) (interface{}, error)

type DBRowProcessing

type DBRowProcessing func(row pgx.Rows) error

type Database

type Database struct {
	Host     *string `yaml:"host"`
	Port     int     `yaml:"port"`
	User     string  `yaml:"user"`
	Password string  `yaml:"password"`
	Db       string  `yaml:"db"`
	SslMode  *string `yaml:"sslMode"`
	PoolSize *int    `yaml:"poolSize"`
	// contains filtered or unexported fields
}

func (*Database) CopySettingsContext

func (cfg *Database) CopySettingsContext(src context.Context, dst context.Context) context.Context

func (*Database) GetConnector

func (cfg *Database) GetConnector() *Connector

func (*Database) InitSettings

func (cfg *Database) InitSettings(_ context.Context) error

func (*Database) InitSettingsContext

func (cfg *Database) InitSettingsContext(ctx context.Context) context.Context

type Executor

type Executor interface {
	Begin(ctx context.Context) (pgx.Tx, error)
	Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error)
	Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)
	QueryRow(ctx context.Context, sql string, args ...any) pgx.Row
	SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults
}

type Listener

type Listener struct {
	Data chan string
	// contains filtered or unexported fields
}

Listener - class for work with Postgres listener

func (*Listener) Close

func (listener *Listener) Close()

Close - close listener