storageversionmigrator

type ResourceVersionController ¶

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

ResourceVersionController adds the resource version obtained from a randomly nonexistent namespace to the SVM status before the migration is initiated. This resource version is utilized for checking freshness of GC cache before the migration is initiated.

func NewResourceVersionController(
	ctx context.Context,
	kubeClient clientset.Interface,
	discoveryClient discovery.DiscoveryInterface,
	metadataClient metadata.Interface,
	svmInformer svminformers.StorageVersionMigrationInformer,
	mapper meta.ResettableRESTMapper,
) *ResourceVersionController

func (rv *ResourceVersionController) Run(ctx context.Context)

type SVMController ¶

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

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) Run(ctx context.Context)