package storageversionmigrator

import "k8s.io/kubernetes/pkg/controller/storageversionmigrator"

Index ¶

• Constants
• func IsConditionTrue(svm *svmv1alpha1.StorageVersionMigration, conditionType svmv1alpha1.MigrationConditionType) bool
• type ResourceVersionController
• func NewResourceVersionController( ctx context.Context, kubeClient clientset.Interface, discoveryClient *discovery.DiscoveryClient, metadataClient metadata.Interface, svmInformer svminformers.StorageVersionMigrationInformer, mapper meta.ResettableRESTMapper, ) *ResourceVersionController
• func (rv *ResourceVersionController) Run(ctx context.Context)
• 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) Run(ctx context.Context)

Constants ¶

const (
	ResourceVersionControllerName string = "resource-version-controller"
)

Functions ¶

func IsConditionTrue ¶

func IsConditionTrue(svm *svmv1alpha1.StorageVersionMigration, conditionType svmv1alpha1.MigrationConditionType) bool

IsConditionTrue returns true if the StorageVersionMigration has the given condition It is exported for use in tests

Types ¶

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 ¶

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

func (*ResourceVersionController) Run ¶

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

type SVMController ¶

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

func NewSVMController ¶

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

func (*SVMController) Name ¶

func (svmc *SVMController) Name() string

func (*SVMController) Run ¶

func (svmc *SVMController) Run(ctx context.Context)

Source Files ¶

resourceversion.go storageversionmigrator.go util.go