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
Constants ¶
View Source
const ( StatusIndex = "Status" StatusRunning = "Running" StatusPending = "Pending" StatusCompleted = "Completed" ResourceIndex = "Resource" )
Variables ¶
This section is empty.
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{})
Source Files
Click to show internal directories.
Click to hide internal directories.