steps

package

v0.2.0 Latest Latest Go to latest Published: Apr 23, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation ¶

Overview ¶

Package steps provides pipeline step implementations for database migrations.

Index ¶

func NewMigrateDownStep(name string, raw map[string]any) sdk.StepInstance
func NewMigrateStatusStep(name string, raw map[string]any) sdk.StepInstance
func NewMigrateToStep(name string, raw map[string]any) sdk.StepInstance
func NewMigrateUpStep(name string, raw map[string]any) sdk.StepInstance
type MigrateDownStep
- func (s *MigrateDownStep) Execute(ctx context.Context, _ map[string]any, _ map[string]map[string]any, ...) (*sdk.StepResult, error)
type MigrateStatusStep
- func (s *MigrateStatusStep) Execute(ctx context.Context, _ map[string]any, _ map[string]map[string]any, ...) (*sdk.StepResult, error)
type MigrateToStep
- func (s *MigrateToStep) Execute(ctx context.Context, _ map[string]any, _ map[string]map[string]any, ...) (*sdk.StepResult, error)
type MigrateUpStep
- func (s *MigrateUpStep) Execute(ctx context.Context, _ map[string]any, _ map[string]map[string]any, ...) (*sdk.StepResult, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewMigrateDownStep ¶

func NewMigrateDownStep(name string, raw map[string]any) sdk.StepInstance

NewMigrateDownStep returns a new step.migrate_down step.

func NewMigrateStatusStep ¶

func NewMigrateStatusStep(name string, raw map[string]any) sdk.StepInstance

NewMigrateStatusStep returns a new step.migrate_status step.

func NewMigrateToStep ¶

func NewMigrateToStep(name string, raw map[string]any) sdk.StepInstance

NewMigrateToStep returns a new step.migrate_to step.

func NewMigrateUpStep ¶

func NewMigrateUpStep(name string, raw map[string]any) sdk.StepInstance

NewMigrateUpStep returns a new step.migrate_up step.

Types ¶

type MigrateDownStep ¶

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

MigrateDownStep rolls back N migrations (down).

func (*MigrateDownStep) Execute ¶

func (s *MigrateDownStep) Execute(ctx context.Context, _ map[string]any, _ map[string]map[string]any, _ map[string]any, _ map[string]any, _ map[string]any) (*sdk.StepResult, error)

Execute rolls back N migrations.

type MigrateStatusStep ¶

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

MigrateStatusStep returns the current migration status.

func (*MigrateStatusStep) Execute ¶

func (s *MigrateStatusStep) Execute(ctx context.Context, _ map[string]any, _ map[string]map[string]any, _ map[string]any, _ map[string]any, _ map[string]any) (*sdk.StepResult, error)

Execute returns the migration status.

type MigrateToStep ¶

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

MigrateToStep migrates to a specific version.

func (*MigrateToStep) Execute ¶

func (s *MigrateToStep) Execute(ctx context.Context, _ map[string]any, _ map[string]map[string]any, _ map[string]any, _ map[string]any, _ map[string]any) (*sdk.StepResult, error)

Execute migrates the database to the given target version.

type MigrateUpStep ¶

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

MigrateUpStep executes all pending migrations (up).

func (*MigrateUpStep) Execute ¶

func (s *MigrateUpStep) Execute(ctx context.Context, _ map[string]any, _ map[string]map[string]any, _ map[string]any, _ map[string]any, raw map[string]any) (*sdk.StepResult, error)

Execute applies all pending migrations.

Source Files ¶

View all Source files

base.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL