zergrepo

May 19, 2020

Changes in this version

+ type Cfg interface

+ DSN func() string

type Logger

+ Infof func(format string, args ...interface{})

May 15, 2020

Changes in this version

+ var ErrNotCorrectVersion = errors.New("version must be above 0")

+ var ErrNotSetDown = errors.New("not set down function")

+ var ErrNotSetUp = errors.New("not set up function")

+ func RegisterMetric(m ...Migrate) error

+ type Logger interface

+ Warnf func(format string, args ...interface{})

type Repo

+ func (r *Repo) DownTo(ctx context.Context, versionTo uint) error

+ func (r *Repo) Reset(ctx context.Context) error

+ func (r *Repo) TxByCfg(ctx context.Context, opts *sql.TxOptions, fn func(*sqlx.Tx) error) error

+ func (r *Repo) UpOne(ctx context.Context) error

+ func (r *Repo) UpTo(ctx context.Context, versionTo uint) error

May 11, 2020

Changes in this version

+ var ErrDuplicateVersion = errors.New("duplicate version")

+ type ErrMapFunc func(error) error

+ func NewConvert(target error, variables ...error) ErrMapFunc

+ func PQConstraint(target error, constraint string) ErrMapFunc

+ type Mapper struct

+ func NewMapper(converters ...ErrMapFunc) *Mapper

+ func (m *Mapper) Map(err error) error

+ type Mapperer interface

+ Map func(err error) error

+ type Migrate struct

+ Down MigrateFunc

+ Up MigrateFunc

+ Version uint

+ type MigrateFunc func(context.Context, *sql.Tx) error

+ func Query(query string) MigrateFunc

type Repo

+ func (r *Repo) Down(ctx context.Context, migrates ...Migrate) error

+ func (r *Repo) Up(ctx context.Context, migrates ...Migrate) error

May 7, 2020

Changes in this version

+ const DBHost

+ const DBName

+ const DBPassword

+ const DBPort

+ const DBSSLMode

+ const DBUser

+ var ErrNotValidateArg = errors.New("no migration command or args")

+ func Connect(ctx context.Context, driver string, options ...Option) (*sql.DB, error)

+ func ConnectByCfg(ctx context.Context, driver string, cfg DSN) (*sql.DB, error)

+ type Config struct

+ DBName string

+ Host string

+ Password string

+ Port int

+ SSLMode string

+ User string

+ func DefaultConfig() *Config

+ func (c Config) DSN() string

+ type DSN interface

+ DSN func() string

+ type Metric struct

+ func MustMetric(namespace, subsystem string) *Metric

+ func NewMetric(namespace, subsystem string, reg prometheus.Registerer) (*Metric, error)

+ type Option func(*Config)

+ func Host(host string) Option

+ func Name(name string) Option

+ func Pass(pass string) Option

+ func Port(port int) Option

+ func SSLMode(sslMode string) Option

+ func User(user string) Option

+ type Repo struct

+ func New(db *sql.DB, log *zap.Logger, m *Metric) *Repo

+ func (r *Repo) Close()

+ func (r *Repo) Do(fn func(*sql.DB) error) error

+ func (r *Repo) Migrate(dir string, cmd string) error

+ func (r *Repo) Tx(ctx context.Context, fn func(*sql.Tx) error, opts ...TxOption) error

+ func (r *Repo) WarnIfFail(fn func() error, fields ...zap.Field)

+ type TxOption func(options *sql.TxOptions)

+ func IsolationLevel(level sql.IsolationLevel) TxOption

+ func ReadOnly() TxOption