core

type BaseMigrator struct {
	Migrations []Migration
}

type Gomiger interface {
	Up(ctx context.Context, toVersion string) error
	Down(ctx context.Context, atVersion string) error
	Connect(ctx context.Context) error
	GetSchema(ctx context.Context, version string) (*Schema, error)
	ApplyMigration(ctx context.Context, mi Migration) error
	RevertMigration(ctx context.Context, mi Migration) error
}

type GomigerConfig struct {
	// Path to the migration root folder.
	Path string `yaml:"path"`
	// The package name of the migrator & migrations.
	// Default by the folder name of the path.
	PkgName string `yaml:"pkg_name"`
	// Database connection string.
	URI string `yaml:"uri"`
	// The path to the table / collection schema store.
	SchemaStore string `yaml:"schema_store"`
}

type Migration struct {
	Version string
	Up      MutationFunc
	Down    MutationFunc
}

type MutationFunc = func(context context.Context) error

type Schema struct {
	Version   string       `json:"version" bson:"version" validate:"required"`
	Timestamp time.Time    `json:"timestamp" bson:"timestamp" validate:"required"`
	Status    SchemaStatus `json:"status" bson:"status" validate:"required"`
}

type SchemaStatus string