storageversionmigrator

Documentation

Index

• Constants
• func IsConditionTrue(svm *svmv1alpha1.StorageVersionMigration, ...) bool
• type ResourceVersionController
  • func NewResourceVersionController(ctx context.Context, kubeClient clientset.Interface, ...) *ResourceVersionController
  • func (rv *ResourceVersionController) Run(ctx context.Context)
• type SVMController
  • func NewSVMController(ctx context.Context, kubeClient kubernetes.Interface, ...) *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)