controller

Documentation

Index

• Constants
• func HasCondition(m *migrationv1alpha1.StorageVersionMigration, ...) bool
• func NewStatusAndResourceIndexedInformer(c migrationclient.Interface) cache.SharedIndexInformer
• func NewStatusIndexedInformer(c migrationclient.Interface) cache.SharedIndexInformer
• func ToIndex(r migration_v1alpha1.GroupVersionResource) string
• type KubeMigrator
  • func NewKubeMigrator(dynamic dynamic.Interface, migrationClient migrationclient.Interface) *KubeMigrator
  • func (km *KubeMigrator) Run(stopCh <-chan struct{})

Constants

const (
	StatusIndex     = "Status"
	StatusRunning   = "Running"
	StatusPending   = "Pending"
	StatusCompleted = "Completed"

	ResourceIndex = "Resource"
)

Functions

func HasCondition

func HasCondition(m *migrationv1alpha1.StorageVersionMigration, conditionType migrationv1alpha1.MigrationConditionType) bool

func NewStatusAndResourceIndexedInformer

func NewStatusAndResourceIndexedInformer(c migrationclient.Interface) cache.SharedIndexInformer

func NewStatusIndexedInformer

func NewStatusIndexedInformer(c migrationclient.Interface) cache.SharedIndexInformer

func ToIndex

func ToIndex(r migration_v1alpha1.GroupVersionResource) string

Types

type KubeMigrator

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

KubeMigrator monitors storageVersionMigraiton objects, fulfills the migration, and updates the status of the storageVersionMigration objects.

func NewKubeMigrator

func NewKubeMigrator(dynamic dynamic.Interface, migrationClient migrationclient.Interface) *KubeMigrator

NewKubeMigrator creates KubeMigrator.

func (*KubeMigrator) Run

func (km *KubeMigrator) Run(stopCh <-chan struct{})