util

package

v0.3.0 Latest Latest Go to latest Published: Apr 6, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kubernetes-sigs/kueue

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func AdmitWorkload(ctx context.Context, k8sClient client.Client, wl *kueue.Workload, ...) error
func DeleteClusterQueue(ctx context.Context, c client.Client, cq *kueue.ClusterQueue) error
func DeleteLocalQueue(ctx context.Context, c client.Client, q *kueue.LocalQueue) error
func DeleteNamespace(ctx context.Context, c client.Client, ns *corev1.Namespace) error
func DeleteResourceFlavor(ctx context.Context, c client.Client, rf *kueue.ResourceFlavor) error
func DeleteRuntimeClass(ctx context.Context, c client.Client, runtimeClass *nodev1.RuntimeClass) error
func DeleteWorkload(ctx context.Context, c client.Client, wl *kueue.Workload) error
func DeleteWorkloadsInNamespace(ctx context.Context, c client.Client, ns *corev1.Namespace) error
func ExpectAdmittedActiveWorkloadsMetric(cq *kueue.ClusterQueue, v int)
func ExpectAdmittedWorkloadsTotalMetric(cq *kueue.ClusterQueue, v int)
func ExpectClusterQueueStatusMetric(cq *kueue.ClusterQueue, status metrics.ClusterQueueStatus)
func ExpectClusterQueueToBeDeleted(ctx context.Context, k8sClient client.Client, cq *kueue.ClusterQueue, ...)
func ExpectPendingWorkloadsMetric(cq *kueue.ClusterQueue, active, inadmissible int)
func ExpectResourceFlavorToBeDeleted(ctx context.Context, k8sClient client.Client, rf *kueue.ResourceFlavor, ...)
func ExpectWorkloadToBeAdmittedAs(ctx context.Context, k8sClient client.Client, wl *kueue.Workload, ...)
func ExpectWorkloadsToBeAdmitted(ctx context.Context, k8sClient client.Client, cqName string, ...)
func ExpectWorkloadsToBeFrozen(ctx context.Context, k8sClient client.Client, cq string, ...)
func ExpectWorkloadsToBePending(ctx context.Context, k8sClient client.Client, wls ...*kueue.Workload)
func ExpectWorkloadsToBeWaiting(ctx context.Context, k8sClient client.Client, wls ...*kueue.Workload)
func FinishWorkloads(ctx context.Context, k8sClient client.Client, workloads ...*kueue.Workload)
func SetAdmission(ctx context.Context, k8sClient client.Client, wl *kueue.Workload, ...)

Constants ¶

View Source

const (
	Timeout            = time.Second * 30
	ConsistentDuration = time.Second * 3
	Interval           = time.Millisecond * 250
)

Variables ¶

This section is empty.

Functions ¶

func AdmitWorkload ¶

func AdmitWorkload(ctx context.Context, k8sClient client.Client, wl *kueue.Workload, admission *kueue.Admission) error

func DeleteClusterQueue ¶

func DeleteClusterQueue(ctx context.Context, c client.Client, cq *kueue.ClusterQueue) error

func DeleteLocalQueue ¶

func DeleteLocalQueue(ctx context.Context, c client.Client, q *kueue.LocalQueue) error

func DeleteNamespace ¶

func DeleteNamespace(ctx context.Context, c client.Client, ns *corev1.Namespace) error

DeleteNamespace deletes all objects the tests typically create in the namespace.

func DeleteResourceFlavor ¶

func DeleteResourceFlavor(ctx context.Context, c client.Client, rf *kueue.ResourceFlavor) error

func DeleteRuntimeClass ¶

func DeleteRuntimeClass(ctx context.Context, c client.Client, runtimeClass *nodev1.RuntimeClass) error

func DeleteWorkload ¶

func DeleteWorkload(ctx context.Context, c client.Client, wl *kueue.Workload) error

func DeleteWorkloadsInNamespace ¶

func DeleteWorkloadsInNamespace(ctx context.Context, c client.Client, ns *corev1.Namespace) error

func ExpectAdmittedActiveWorkloadsMetric ¶

func ExpectAdmittedActiveWorkloadsMetric(cq *kueue.ClusterQueue, v int)

func ExpectAdmittedWorkloadsTotalMetric ¶

func ExpectAdmittedWorkloadsTotalMetric(cq *kueue.ClusterQueue, v int)

func ExpectClusterQueueStatusMetric ¶

func ExpectClusterQueueStatusMetric(cq *kueue.ClusterQueue, status metrics.ClusterQueueStatus)

func ExpectClusterQueueToBeDeleted ¶

func ExpectClusterQueueToBeDeleted(ctx context.Context, k8sClient client.Client, cq *kueue.ClusterQueue, deleteCq bool)

func ExpectPendingWorkloadsMetric ¶

func ExpectPendingWorkloadsMetric(cq *kueue.ClusterQueue, active, inadmissible int)

func ExpectResourceFlavorToBeDeleted ¶

func ExpectResourceFlavorToBeDeleted(ctx context.Context, k8sClient client.Client, rf *kueue.ResourceFlavor, deleteRf bool)

func ExpectWorkloadToBeAdmittedAs ¶

func ExpectWorkloadToBeAdmittedAs(ctx context.Context, k8sClient client.Client, wl *kueue.Workload, admission *kueue.Admission)

func ExpectWorkloadsToBeAdmitted ¶

func ExpectWorkloadsToBeAdmitted(ctx context.Context, k8sClient client.Client, cqName string, wls ...*kueue.Workload)

func ExpectWorkloadsToBeFrozen ¶

func ExpectWorkloadsToBeFrozen(ctx context.Context, k8sClient client.Client, cq string, wls ...*kueue.Workload)

func ExpectWorkloadsToBePending ¶

func ExpectWorkloadsToBePending(ctx context.Context, k8sClient client.Client, wls ...*kueue.Workload)

func ExpectWorkloadsToBeWaiting ¶

func ExpectWorkloadsToBeWaiting(ctx context.Context, k8sClient client.Client, wls ...*kueue.Workload)

func FinishWorkloads ¶

func FinishWorkloads(ctx context.Context, k8sClient client.Client, workloads ...*kueue.Workload)

func SetAdmission ¶

func SetAdmission(ctx context.Context, k8sClient client.Client, wl *kueue.Workload, admission *kueue.Admission)

Types ¶

This section is empty.

Source Files ¶

View all Source files

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