storageversion

Documentation

Index

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

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) *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