migrator

type Connection interface {
	DSN() string
	Driver() connection.Driver
	Ping() error
	QueryContext(ctx context.Context, query string, args ...any) (sqlex.Rows, error)
	ExecContext(ctx context.Context, query string, args ...any) (sqlex.Result, error)
	Transaction(ctx context.Context, txFn func(ctx context.Context) error) error
	io.Closer
}

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

type FileNameBuilder interface {
	// Up builds a file name for migration update
	Up(version string, forceSafely bool) (fname string, safely bool)
	// Down builds a file name for migration downgrade
	Down(version string, forceSafely bool) (fname string, safely bool)
}

type Options struct {
	DSN                string
	MaxConnAttempts    int
	Directory          string
	TableName          string
	ClusterName        string
	Replicated         bool
	Compact            bool
	Interactive        bool
	MaxSQLOutputLength int
}