controllers

Documentation

Index

• func CheckpointPodPipelined(containers []types.Container, namespace string, podName string) error
• type LiveMigrationReconciler
  • func (r *LiveMigrationReconciler) BuildahRestore(ctx context.Context, path string, clientset *kubernetes.Clientset, ...) (*corev1.Pod, error)
  • func (r *LiveMigrationReconciler) BuildahRestoreParallelized(ctx context.Context, path string, clientset *kubernetes.Clientset, ...) (*corev1.Pod, error)
  • func (r *LiveMigrationReconciler) BuildahRestorePipelined(ctx context.Context, path string, clientset *kubernetes.Clientset, ...) (*corev1.Pod, error)
  • func (r *LiveMigrationReconciler) CheckpointPodCrio(containers []types.Container, namespace string, podName string) error
  • func (r *LiveMigrationReconciler) MigrateCheckpoint(ctx context.Context, directory string, clientset *kubernetes.Clientset, ...) error
  • func (r *LiveMigrationReconciler) MigrateCheckpointParallelized(ctx context.Context, files []os.DirEntry, dir string, ...) error
  • func (r *LiveMigrationReconciler) MigrateDummyFile(ctx context.Context, directory string, clientset *kubernetes.Clientset, ...) error
  • func (r *LiveMigrationReconciler) MigratePod(ctx context.Context, clientset *kubernetes.Clientset, ...) (ctrl.Result, error)
  • func (r *LiveMigrationReconciler) MigratePodPipelined(ctx context.Context, clientset *kubernetes.Clientset, ...) (ctrl.Result, error)
  • func (r *LiveMigrationReconciler) NewKubernetesClient() (*kubernetes.Clientset, error)
  • func (r *LiveMigrationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *LiveMigrationReconciler) RemoveCheckpointPod(ctx context.Context, clientset *kubernetes.Clientset, pod *corev1.Pod, ...) error
  • func (r *LiveMigrationReconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *LiveMigrationReconciler) TerminateCheckpointedPod(ctx context.Context, podName string, clientset *kubernetes.Clientset, ...) error

Functions

func CheckpointPodPipelined

func CheckpointPodPipelined(containers []types.Container, namespace string, podName string) error

Types

type LiveMigrationReconciler

type LiveMigrationReconciler struct {
	client.Client
	Scheme *run.Scheme
}

func (*LiveMigrationReconciler) BuildahRestore

func (r *LiveMigrationReconciler) BuildahRestore(ctx context.Context, path string, clientset *kubernetes.Clientset, namespace string) (*corev1.Pod, error)

func (*LiveMigrationReconciler) BuildahRestoreParallelized

func (r *LiveMigrationReconciler) BuildahRestoreParallelized(ctx context.Context, path string, clientset *kubernetes.Clientset, namespace string) (*corev1.Pod, error)

func (*LiveMigrationReconciler) BuildahRestorePipelined

func (r *LiveMigrationReconciler) BuildahRestorePipelined(ctx context.Context, path string, clientset *kubernetes.Clientset, namespace string) (*corev1.Pod, error)

func (*LiveMigrationReconciler) CheckpointPodCrio

func (r *LiveMigrationReconciler) CheckpointPodCrio(containers []types.Container, namespace string, podName string) error

func (*LiveMigrationReconciler) MigrateCheckpoint

func (r *LiveMigrationReconciler) MigrateCheckpoint(ctx context.Context, directory string, clientset *kubernetes.Clientset, namespace string) error

func (*LiveMigrationReconciler) MigrateCheckpointParallelized

func (r *LiveMigrationReconciler) MigrateCheckpointParallelized(ctx context.Context, files []os.DirEntry, dir string, clientset *kubernetes.Clientset, namespace string) error

func (*LiveMigrationReconciler) MigrateDummyFile

func (r *LiveMigrationReconciler) MigrateDummyFile(ctx context.Context, directory string, clientset *kubernetes.Clientset, namespace string) error

func (*LiveMigrationReconciler) MigratePod

func (r *LiveMigrationReconciler) MigratePod(ctx context.Context, clientset *kubernetes.Clientset, migratingPod *api.LiveMigration, namespace string) (ctrl.Result, error)

func (*LiveMigrationReconciler) MigratePodPipelined

func (r *LiveMigrationReconciler) MigratePodPipelined(ctx context.Context, clientset *kubernetes.Clientset, migratingPod *api.LiveMigration, namespace string) (ctrl.Result, error)

func (*LiveMigrationReconciler) NewKubernetesClient

func (r *LiveMigrationReconciler) NewKubernetesClient() (*kubernetes.Clientset, error)

func (*LiveMigrationReconciler) Reconcile

func (r *LiveMigrationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*LiveMigrationReconciler) RemoveCheckpointPod

func (r *LiveMigrationReconciler) RemoveCheckpointPod(ctx context.Context, clientset *kubernetes.Clientset, pod *corev1.Pod, snapshotPathCurrent, newPodName string, namespace string) error

func (*LiveMigrationReconciler) SetupWithManager

func (r *LiveMigrationReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

func (*LiveMigrationReconciler) TerminateCheckpointedPod

func (r *LiveMigrationReconciler) TerminateCheckpointedPod(ctx context.Context, podName string, clientset *kubernetes.Clientset, namespace string) error