migrate

Documentation

Index

• type Plan
  • func NewPlan1(logger *zap.Logger, service sinks.SinkService, sinkRepo sinks.SinkRepository, ...) Plan
• type Plan1UpdateConfiguration
  • func (p *Plan1UpdateConfiguration) Up(ctx context.Context) (mainErr error)
  • func (p *Plan1UpdateConfiguration) Version() string
• type Service
  • func NewService(logger *zap.Logger, sinkRepository sinks.SinkRepository) Service

Types

type Plan

type Plan interface {
	Version() string
	Up(ctx context.Context) error
}

func NewPlan1

func NewPlan1(logger *zap.Logger, service sinks.SinkService, sinkRepo sinks.SinkRepository, passwordService authentication_type.PasswordService) Plan

type Plan1UpdateConfiguration

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

func (*Plan1UpdateConfiguration) Up

func (p *Plan1UpdateConfiguration) Up(ctx context.Context) (mainErr error)

func (*Plan1UpdateConfiguration) Version

func (p *Plan1UpdateConfiguration) Version() string

type Service

type Service interface {
	Migrate(plans ...Plan) error
}

func NewService

func NewService(logger *zap.Logger, sinkRepository sinks.SinkRepository) Service