manager

Documentation

Index

• Constants
• Variables
• type DataMigration
  • func NewDataMigrator() DataMigration
• type DataMigrator
  • func (m *DataMigrator) LatestVersion(target string) int
  • func (m *DataMigrator) Migrate(ctx context.Context, s *session.Session, target string, currentVersion int, ...) (int, error)
  • func (m *DataMigrator) Register(ver int, target string, plugin Plugin) error
• type Plugin

Constants

const (
	ApplianceConfigure = "ApplianceConfigure"
	ContainerConfigure = "ContainerConfigure"

	ApplianceVersionKey = "guestinfo.vice./init/version/PluginVersion"
	ContainerVersionKey = "guestinfo.vice./version/PluginVersion"
)

Variables

var (
	Migrator = NewDataMigrator()
)

Types

type DataMigration

type DataMigration interface {
	// Register plugin to data migration system
	Register(version int, target string, plugin Plugin) error
	// Migrate data with current version ID, return maximum ID number of executed plugins
	Migrate(ctx context.Context, s *session.Session, target string, currentVersion int, data interface{}) (int, error)
	// LatestVersion return the latest plugin version for specified target
	LatestVersion(target string) int
}

func NewDataMigrator

func NewDataMigrator() DataMigration

type DataMigrator

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

func (*DataMigrator) LatestVersion

func (m *DataMigrator) LatestVersion(target string) int

LatestVersion return the latest plugin version for specified target

func (*DataMigrator) Migrate

func (m *DataMigrator) Migrate(ctx context.Context, s *session.Session, target string, currentVersion int, data interface{}) (int, error)

Migrate data with current version ID, return true if has any plugin executed

func (*DataMigrator) Register

func (m *DataMigrator) Register(ver int, target string, plugin Plugin) error

Register plugin to data migration system

type Plugin

type Plugin interface {
	Migrate(ctx context.Context, s *session.Session, data interface{}) error
}