migrate

package

v1.1.2 Latest Latest Go to latest Published: Mar 5, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrMigratorFactory         = errors.New("failed to make migrators")
	ErrNoOneMigratorWasDefined = errors.New("no migrators were defined")
)

This section is empty.

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

func New(ctx context.Context, logger logger.Logger, factory storage.Factorier) (*Migrate, error)

func (m *Migrate) Down() error

Down executes each migrator in parallel wrapping them in errgroup without context.

func (m *Migrate) Force(n int, storage storage.Storager) error

func (m *Migrate) Storages() []storage.Storager

Storages returns all for self management.

func (m *Migrate) Up() error

Up executes each migrator in parallel wrapping them in errgroup without context.

func (m *Migrate) Version(storage storage.Storager) (version uint, dirty bool, err error)