migration

Documentation

Overview

This package contains helper functions that can be reused by all migrations

Index

• func ForEachInstance(client *kube.Client, ns string, f func(ov *kudoapi.Instance) error) error
• func ForEachNamespace(client *kube.Client, f func(ns string) error) error
• func ForEachOperatorVersion(client *kube.Client, ns string, f func(ov *kudoapi.OperatorVersion) error) error
• type Migrater

Functions

func ForEachInstance

func ForEachInstance(client *kube.Client, ns string, f func(ov *kudoapi.Instance) error) error

ForEachInstance calls the given function for all instances in the given namespace

func ForEachNamespace

func ForEachNamespace(client *kube.Client, f func(ns string) error) error

ForEachNamespace calls the given function for all namespaces in the cluster

func ForEachOperatorVersion

func ForEachOperatorVersion(client *kube.Client, ns string, f func(ov *kudoapi.OperatorVersion) error) error

ForEachOperatorVersion calls the given function for all operatorversions in the given namespace

Types

type Migrater

type Migrater interface {
	// CanMigrate checks if there are any conditions that would prevent this migration to run
	// This function should only return an error if it is sure that the migration can not be executed
	CanMigrate() error

	// Migrate executes the migration. The call must be idempotent and ignore already migrated resources
	// It can be called multiple times on the same cluster and encounter migrated and unmigrated resources.
	Migrate() error
}

Migrater is the base interface for migrations.