postgres

May 13, 2024

Changes in this version

type Postgres

+ func NewWithSeparateURIs(writerUri, readerUri string, opts ...Option) (*Postgres, error)

May 4, 2024

Changes in this version

type Postgres

+ ReadPool *pgxpool.Pool

+ WritePool *pgxpool.Pool

Mar 27, 2024

Changes in this version

type Option

+ func MaxDataPerWrite(max int) Option

+ func MaxRetries(max int) Option

+ func WatchBufferSize(max int) Option

type Postgres

+ func (p *Postgres) GetMaxDataPerWrite() int

+ func (p *Postgres) GetMaxRetries() int

+ func (p *Postgres) GetWatchBufferSize() int

Apr 15, 2023

Changes in this version

+ type MockPQDatabase struct

+ func (m *MockPQDatabase) Close() error

+ func (m *MockPQDatabase) GetEngineType() string

+ func (m *MockPQDatabase) IsReady(ctx context.Context) (bool, error)

Jan 20, 2023

Changes in this version

type Option

+ func MaxConnectionIdleTime(d time.Duration) Option

+ func MaxConnectionLifeTime(d time.Duration) Option

+ func MaxIdleConnections(c int) Option

type Postgres

+ DB *sql.DB

Dec 24, 2022

Changes in this version

type Option

+ func ConnectionTimeout(timeout time.Duration) Option

+ func MaxOpenConnections(size int) Option

Dec 17, 2022

Changes in this version

+ type Option func(*Postgres)

+ func ConnAttempts(attempts int) Option

+ func ConnTimeout(timeout time.Duration) Option

+ func MaxPoolSize(size int) Option

+ type Postgres struct

+ Builder squirrel.StatementBuilderType

+ Pool *pgxpool.Pool

+ func New(uri, database string, opts ...Option) (*Postgres, error)

+ func (p *Postgres) Close() error

+ func (p *Postgres) GetEngineType() string

+ func (p *Postgres) IsReady(ctx context.Context) (bool, error)

+ func (p *Postgres) Migrate(statements []string) (err error)