manager

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
}

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

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