pkg

func BuildahDeleteImage(imageName string)

func CleanUp(ctx context.Context, clientset *kubernetes.Clientset, pod *v1.Pod, namespace string)

func CountFilesInFolder(folderPath string) (int, error)

func CreateTable(ctx context.Context, conn *pgx.Conn, tableName string, columns string)

func CreateTestContainers(ctx context.Context, numContainers int, clientset *kubernetes.Clientset, reconciler controllers.LiveMigrationReconciler, namespace string) *v1.Pod

func DeleteDummyPodAndService(ctx context.Context, clientset *kubernetes.Clientset, namespace string, podName string, serviceName string) error

func DeletePodsStartingWithTest(ctx context.Context, clientset *kubernetes.Clientset, namespace string) error

func GetBackLatency(ctx context.Context, clientset *kubernetes.Clientset, namespace string, db *pgx.Conn, numContainers int, logger *log.Logger)

func GetCheckpointImageRestoreSize(ctx context.Context, clientset *kubernetes.Clientset, numContainers int, db *pgx.Conn, namespace string)

func GetCheckpointSizePipelined(ctx context.Context, clientset *kubernetes.Clientset, numContainers int, db *pgx.Conn, namespace string)

func GetCheckpointSizeSequential(ctx context.Context, clientset *kubernetes.Clientset, numContainers int, db *pgx.Conn, namespace string)

func GetCheckpointTimePipelined(ctx context.Context, clientset *kubernetes.Clientset, numContainers int, db *pgx.Conn, namespace string)

func GetCheckpointTimeSequential(ctx context.Context, clientset *kubernetes.Clientset, numContainers int, db *pgx.Conn, namespace string)

func GetForthLatency(ctx context.Context, clientset *kubernetes.Clientset, namespace string, db *pgx.Conn, numContainers int, logger *log.Logger)

func GetImageSize(imageName string) (float64, error)

func GetRestoreTimeParallelized(ctx context.Context, clientset *kubernetes.Clientset, numContainers int, db *pgx.Conn, namespace string)

func GetRestoreTimeSequential(ctx context.Context, clientset *kubernetes.Clientset, numContainers int, db *pgx.Conn, namespace string)

func GetTriangularizedTime(ctx context.Context, clientset *kubernetes.Clientset, numContainers int, db *pgx.Conn, namespace string)

func Receive(logger *log.Logger)

func SaveAbsoluteTimeToDB(
	ctx context.Context,
	conn *pgx.Conn,
	numContainers int,
	time time.Time,
	checkpointType string,
	tableName string,
	column1 string,
	column2 string)

func SaveSizeToDB(
	ctx context.Context,
	conn *pgx.Conn,
	numContainers int,
	size float64,
	checkpointType string,
	tableName string,
	column1 string,
	column2 string)

func SaveTimeToDB(
	ctx context.Context,
	conn *pgx.Conn,
	numContainers int,
	time time.Duration,
	checkpointType string,
	tableName string,
	column1 string,
	column2 string)

func Sender(logger *log.Logger)