mrpostgres

Documentation

Index

• type ConnAdapter
  • func New() *ConnAdapter
  • func (c *ConnAdapter) Cli() *pgxpool.Pool
  • func (c *ConnAdapter) Close() error
  • func (c *ConnAdapter) Connect(ctx context.Context, opts Options) error
  • func (c *ConnAdapter) Exec(ctx context.Context, sql string, args ...any) error
  • func (c *ConnAdapter) Ping(ctx context.Context) error
  • func (c *ConnAdapter) Query(ctx context.Context, sql string, args ...any) (mrstorage.DBQueryRows, error)
  • func (c *ConnAdapter) QueryRow(ctx context.Context, sql string, args ...any) mrstorage.DBQueryRow
• type ConnManager
  • func NewConnManager(conn *ConnAdapter) *ConnManager
  • func (m *ConnManager) Conn(ctx context.Context) mrstorage.DBConn
  • func (m *ConnManager) ConnAdapter() *ConnAdapter
  • func (m *ConnManager) Do(ctx context.Context, job func(ctx context.Context) error) error
• type Options
• type TxManagerStub
  • func NewTxManagerStub() *TxManagerStub
  • func (m *TxManagerStub) Do(ctx context.Context, job func(ctx context.Context) error) error

Types

type ConnAdapter

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

ConnAdapter - адаптер для работы с Postgres клиентом.

func New

func New() *ConnAdapter

New - создаёт объект ConnAdapter.

func (*ConnAdapter) Cli

func (c *ConnAdapter) Cli() *pgxpool.Pool

Cli - возвращается нативный объект, с которым работает данный адаптер.

func (*ConnAdapter) Close

func (c *ConnAdapter) Close() error

Close - закрывает текущее соединение.

func (*ConnAdapter) Connect

func (c *ConnAdapter) Connect(ctx context.Context, opts Options) error

Connect - создаёт соединение с указанными опциями.

func (*ConnAdapter) Exec

func (c *ConnAdapter) Exec(ctx context.Context, sql string, args ...any) error

Exec - comment method.

func (*ConnAdapter) Ping

func (c *ConnAdapter) Ping(ctx context.Context) error

Ping - проверяет работоспособность соединения.

func (*ConnAdapter) Query

func (c *ConnAdapter) Query(ctx context.Context, sql string, args ...any) (mrstorage.DBQueryRows, error)

Query - comment method.

func (*ConnAdapter) QueryRow

func (c *ConnAdapter) QueryRow(ctx context.Context, sql string, args ...any) mrstorage.DBQueryRow

QueryRow - comment method.

type ConnManager

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

ConnManager - менеджер транзакций.

func NewConnManager

func NewConnManager(conn *ConnAdapter) *ConnManager

NewConnManager - создаёт объект ConnManager.

func (*ConnManager) Conn

func (m *ConnManager) Conn(ctx context.Context) mrstorage.DBConn

Conn - возвращает соединение с PostgreSQL или транзакцию, если она была открыта.

func (*ConnManager) ConnAdapter

func (m *ConnManager) ConnAdapter() *ConnAdapter

ConnAdapter - возвращает соединение с PostgreSQL.

func (*ConnManager) Do

func (m *ConnManager) Do(ctx context.Context, job func(ctx context.Context) error) error

Do - запускает задачу с запросом в транзакции. Пытается запустить в текущей транзакции, если ее нет, создает новую транзакцию.

type Options

type Options struct {
	DSN             string // если указано, то Host, Port, Database, Username не используются, но Password более приоритетен если явно указан
	Host            string
	Port            string
	Database        string
	Username        string
	Password        string
	MaxPoolSize     int
	MaxConnLifetime time.Duration
	MaxConnIdleTime time.Duration
	ConnAttempts    int
	ConnTimeout     time.Duration
	QueryTracer     pgx.QueryTracer
	AfterConnect    func(ctx context.Context, conn *pgx.Conn) error
}

Options - опции для создания соединения для ConnAdapter.

type TxManagerStub

type TxManagerStub struct{}

TxManagerStub - фиктивный менеджер транзакций, который запускает только переданную работу без открытия транзакции.

func NewTxManagerStub

func NewTxManagerStub() *TxManagerStub

NewTxManagerStub - создаёт объект TxManagerStub.

func (*TxManagerStub) Do

func (m *TxManagerStub) Do(ctx context.Context, job func(ctx context.Context) error) error

Do - запускает работу без использования транзакции.