migrate

Documentation

Index

• Constants
• func GetDestAccessModes(srcPVC corev1.PersistentVolumeClaim) ([]corev1.PersistentVolumeAccessMode, error)
• func Migrate(ctx context.Context, w *log.Logger, clientset k8sclient.Interface, ...) error
• type LineReader
• type Options

Constants

const (
	DesiredAccessModeAnnotation = baseAnnotation + "-destinationaccessmode"
)

const IsDefaultStorageClassAnnotation = "storageclass.kubernetes.io/is-default-class"

IsDefaultStorageClassAnnotation - this is also exported by https://github.com/kubernetes/kubernetes/blob/v1.21.3/pkg/apis/storage/v1/util/helpers.go#L25 but that would require adding the k8s import overrides to our go.mod

Functions

func GetDestAccessModes

func GetDestAccessModes(srcPVC corev1.PersistentVolumeClaim) ([]corev1.PersistentVolumeAccessMode, error)

func Migrate

func Migrate(ctx context.Context, w *log.Logger, clientset k8sclient.Interface, options Options) error

Migrate moves data and PVCs from one StorageClass to another

Types

type LineReader

type LineReader interface {
	ReadLine() ([]byte, bool, error)
}

LineReader is a helper so we can easily implement tests using concrete implementations. This is implemented by bufio.Reader type and that is the type we are targeting here.

type Options

type Options struct {
	SourceSCName         string
	DestSCName           string
	RsyncImage           string
	RsyncFlags           []string
	Namespace            string
	SetDefaults          bool
	VerboseCopy          bool
	SkipSourceValidation bool
	PodReadyTimeout      time.Duration
	DeletePVTimeout      time.Duration
}

Options is the set of options that should be provided to Migrate