migration

Documentation

Index

• Constants
• func RunAllMigration(sqlDB *db.SqlDB, logger lager.Logger) error
• func RunMigrations(sqlDB *db.SqlDB, migrations []Migration, logger lager.Logger) error
• type Migration
  • func InitializeMigrations() []Migration
• type MigrationData
• type Runner
  • func NewRunner(sqlDB *db.SqlDB, logger lager.Logger) *Runner
  • func (r *Runner) Run(signals <-chan os.Signal, ready chan<- struct{}) error
• type V0InitMigration
  • func NewV0InitMigration() *V0InitMigration
  • func (v *V0InitMigration) Run(sqlDB *db.SqlDB) error
  • func (v *V0InitMigration) Version() int
• type V2UpdateRgMigration
  • func NewV2UpdateRgMigration() *V2UpdateRgMigration
  • func (v *V2UpdateRgMigration) Run(sqlDB *db.SqlDB) error
  • func (v *V2UpdateRgMigration) Version() int
• type V3UpdateTcpRouteMigration
  • func NewV3UpdateTcpRouteMigration() *V3UpdateTcpRouteMigration
  • func (v *V3UpdateTcpRouteMigration) Run(sqlDB *db.SqlDB) error
  • func (v *V3UpdateTcpRouteMigration) Version() int
• type V4AddRgUniqIdxTCPRoute
  • func NewV4AddRgUniqIdxTCPRouteMigration() *V4AddRgUniqIdxTCPRoute
  • func (v *V4AddRgUniqIdxTCPRoute) Run(sqlDB *db.SqlDB) error
  • func (v *V4AddRgUniqIdxTCPRoute) Version() int
• type V5SniHostnameMigration
  • func NewV5SniHostnameMigration() *V5SniHostnameMigration
  • func (v *V5SniHostnameMigration) Run(sqlDB *db.SqlDB) error
  • func (v *V5SniHostnameMigration) Version() int

Constants

const MigrationKey = "routing-api-migration"

Functions

func RunAllMigration

func RunAllMigration(sqlDB *db.SqlDB, logger lager.Logger) error

func RunMigrations

func RunMigrations(sqlDB *db.SqlDB, migrations []Migration, logger lager.Logger) error

Types

type Migration

type Migration interface {
	Run(*db.SqlDB) error
	Version() int
}

func InitializeMigrations

func InitializeMigrations() []Migration

type MigrationData

type MigrationData struct {
	MigrationKey   string `gorm:"primary_key"`
	CurrentVersion int
	TargetVersion  int
}

type Runner

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

func NewRunner

func NewRunner(
	sqlDB *db.SqlDB,
	logger lager.Logger,
) *Runner

func (*Runner) Run

func (r *Runner) Run(signals <-chan os.Signal, ready chan<- struct{}) error

type V0InitMigration

type V0InitMigration struct{}

func NewV0InitMigration

func NewV0InitMigration() *V0InitMigration

func (*V0InitMigration) Run

func (v *V0InitMigration) Run(sqlDB *db.SqlDB) error

func (*V0InitMigration) Version

func (v *V0InitMigration) Version() int

type V2UpdateRgMigration

type V2UpdateRgMigration struct{}

func NewV2UpdateRgMigration

func NewV2UpdateRgMigration() *V2UpdateRgMigration

func (*V2UpdateRgMigration) Run

func (v *V2UpdateRgMigration) Run(sqlDB *db.SqlDB) error

func (*V2UpdateRgMigration) Version

func (v *V2UpdateRgMigration) Version() int

type V3UpdateTcpRouteMigration

type V3UpdateTcpRouteMigration struct{}

func NewV3UpdateTcpRouteMigration

func NewV3UpdateTcpRouteMigration() *V3UpdateTcpRouteMigration

func (*V3UpdateTcpRouteMigration) Run

func (v *V3UpdateTcpRouteMigration) Run(sqlDB *db.SqlDB) error

func (*V3UpdateTcpRouteMigration) Version

func (v *V3UpdateTcpRouteMigration) Version() int

type V4AddRgUniqIdxTCPRoute

type V4AddRgUniqIdxTCPRoute struct{}

func NewV4AddRgUniqIdxTCPRouteMigration

func NewV4AddRgUniqIdxTCPRouteMigration() *V4AddRgUniqIdxTCPRoute

func (*V4AddRgUniqIdxTCPRoute) Run

func (v *V4AddRgUniqIdxTCPRoute) Run(sqlDB *db.SqlDB) error

func (*V4AddRgUniqIdxTCPRoute) Version

func (v *V4AddRgUniqIdxTCPRoute) Version() int

type V5SniHostnameMigration

type V5SniHostnameMigration struct{}

func NewV5SniHostnameMigration

func NewV5SniHostnameMigration() *V5SniHostnameMigration

func (*V5SniHostnameMigration) Run

func (v *V5SniHostnameMigration) Run(sqlDB *db.SqlDB) error

func (*V5SniHostnameMigration) Version

func (v *V5SniHostnameMigration) Version() int