upgrade

Documentation

Index

• func MigrateStorageVersion(ctx context.Context, logger *zap.SugaredLogger, migrator *Migrator, ...)
• type Migrator
  • func NewMigrator(d dynamic.Interface, a apixclient.Interface, logger *zap.SugaredLogger) *Migrator
  • func (m *Migrator) Migrate(ctx context.Context, gr schema.GroupResource) error

Functions

func MigrateStorageVersion

func MigrateStorageVersion(ctx context.Context, logger *zap.SugaredLogger, migrator *Migrator, crdGroups []string)

performs crd storage version upgrade lists all the resources and, keeps only one storage version on the crd continues the execution, even though exception happens

Types

type Migrator

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

Migrator will read custom resource definitions and upgrade the associated resources to the latest storage version

func NewMigrator

func NewMigrator(d dynamic.Interface, a apixclient.Interface, logger *zap.SugaredLogger) *Migrator

NewMigrator will return a new Migrator

func (*Migrator) Migrate

func (m *Migrator) Migrate(ctx context.Context, gr schema.GroupResource) error

Migrate takes a group resource (ie. resource.some.group.dev) and updates instances of the resource to the latest storage version

This is done by listing all the resources and performing an empty patch which triggers a migration on the K8s API server

Finally the migrator will update the CRD's status and drop older storage versions