postgres

Documentation

Index

• func MustSetupDB(dsn string, maxOpenConns, maxIdleConns int, enableMigration bool, ...) *sql.DB
• type Config
• type PG
  • func MustSetupStorage(config Config) PG
  • func New(db *sql.DB) PG
  • func (p PG) Check(ctx context.Context) error
  • func (p PG) Close() error
  • func (p PG) Create(ctx context.Context, a *model.Announcement) error
  • func (p PG) Delete(ctx context.Context, id string) error
  • func (p PG) GetAll(ctx context.Context, filter model.Filter) ([]*model.Announcement, error)
  • func (p PG) InTx(ctx context.Context, action func(s storage.AnnouncementStorage) error) error

Functions

func MustSetupDB

func MustSetupDB(dsn string, maxOpenConns, maxIdleConns int, enableMigration bool, migrations string) *sql.DB

MustSetupDB opens DB connection and runs migrations.

Types

type Config

type Config struct {
	Host, Port                 string
	User, Password             string
	DBName                     string
	MaxOpenConns, MaxIdleConns int
	EnableMigration            bool
	MigrationsDir              string
}

type PG

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

func MustSetupStorage

func MustSetupStorage(config Config) PG

func New

func New(db *sql.DB) PG

New creates postgres storage.

func (PG) Check

func (p PG) Check(ctx context.Context) error

func (PG) Close

func (p PG) Close() error

func (PG) Create

func (p PG) Create(ctx context.Context, a *model.Announcement) error

func (PG) Delete

func (p PG) Delete(ctx context.Context, id string) error

func (PG) GetAll

func (p PG) GetAll(ctx context.Context, filter model.Filter) ([]*model.Announcement, error)

func (PG) InTx

func (p PG) InTx(ctx context.Context, action func(s storage.AnnouncementStorage) error) error