kubernetes/pkg/controller/storageversionmigrator/storageversionmigrator.go

const workers …

const migrationSuccessStatusReason …

const migrationRunningStatusReason …

const migrationFailedStatusReason …

type SVMController …

func NewSVMController(
	ctx context.Context,
	kubeClient kubernetes.Interface,
	dynamicClient *dynamic.DynamicClient,
	svmInformer svminformers.StorageVersionMigrationInformer,
	controllerName string,
	mapper meta.ResettableRESTMapper,
	dependencyGraphBuilder *garbagecollector.GraphBuilder,
) *SVMController { … }

func (svmc *SVMController) Name() string { … }

func (svmc *SVMController) addSVM(logger klog.Logger, obj interface{ … }

func (svmc *SVMController) updateSVM(logger klog.Logger, oldObj, newObj interface{ … }

func (svmc *SVMController) enqueue(svm *svmv1alpha1.StorageVersionMigration) { … }

func (svmc *SVMController) Run(ctx context.Context) { … }

func (svmc *SVMController) worker(ctx context.Context) { … }

func (svmc *SVMController) processNext(ctx context.Context) bool { … }

func (svmc *SVMController) sync(ctx context.Context, key string) error { … }

type typeMetaUIDRV …

type objectMetaUIDandRV …