utils

Documentation

Index

• Constants
• Variables
• func DeletePodSyncByName(f *framework.Framework, podName string)
• func DeletePodsAsync(f *framework.Framework, podMap map[string]*v1.Pod)
• func FilterNodesWithEnoughCores(nodes []v1.Node, cpuAmount string) ([]v1.Node, error)
• func GetNodesByRole(f *framework.Framework, role string) ([]v1.Node, error)
• func GetNodesBySelector(f *framework.Framework, selector labels.Selector) ([]v1.Node, error)
• func GetWorkerNodes(f *framework.Framework) ([]v1.Node, error)
• func MakeBestEffortSleeperPod() *v1.Pod
• func MakeGuaranteedSleeperPod(cpuLimit string) *v1.Pod

Constants

const (
	// LabelRole contains the key for the role label
	LabelRole = "node-role.kubernetes.io"
	// LabelHostname contains the key for the hostname label
	LabelHostname = "kubernetes.io/hostname"
)

const (
	CentosImage = "quay.io/centos/centos:8"
)

const (
	// RoleWorker contains the worker role
	RoleWorker = "worker"
)

Variables

var BinariesPath string

Functions

func DeletePodSyncByName

func DeletePodSyncByName(f *framework.Framework, podName string)

func DeletePodsAsync

func DeletePodsAsync(f *framework.Framework, podMap map[string]*v1.Pod)

func FilterNodesWithEnoughCores

func FilterNodesWithEnoughCores(nodes []v1.Node, cpuAmount string) ([]v1.Node, error)

FilterNodesWithEnoughCores returns all nodes with at least the amount of given CPU allocatable

func GetNodesByRole

func GetNodesByRole(f *framework.Framework, role string) ([]v1.Node, error)

GetByRole returns all nodes with the specified role

func GetNodesBySelector

func GetNodesBySelector(f *framework.Framework, selector labels.Selector) ([]v1.Node, error)

GetBySelector returns all nodes with the specified selector

func GetWorkerNodes

func GetWorkerNodes(f *framework.Framework) ([]v1.Node, error)

GetWorkerNodes returns all nodes labeled as worker

func MakeBestEffortSleeperPod

func MakeBestEffortSleeperPod() *v1.Pod

func MakeGuaranteedSleeperPod

func MakeGuaranteedSleeperPod(cpuLimit string) *v1.Pod