controllers

package
v0.0.0-...-89e9fa0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 3, 2024 License: Apache-2.0 Imports: 27 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL