framework

Documentation

Index

• Constants
• func DeleteClusterQueue(ctx context.Context, c client.Client, cq *kueue.ClusterQueue) error
• func DeleteNamespace(ctx context.Context, c client.Client, ns *corev1.Namespace) error
• func DeleteQueue(ctx context.Context, c client.Client, q *kueue.LocalQueue) 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 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 FinishWorkloads(ctx context.Context, k8sClient client.Client, workloads ...*kueue.Workload)
• type Framework
  • func (f *Framework) Setup() (context.Context, *rest.Config, client.Client)
  • func (f *Framework) Teardown()
• type ManagerSetup

Constants

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

Functions

func DeleteClusterQueue

func DeleteClusterQueue(ctx context.Context, c client.Client, cq *kueue.ClusterQueue) 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 DeleteQueue

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

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 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 FinishWorkloads

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

Types

type Framework

type Framework struct {
	CRDPath      string
	WebhookPath  string
	ManagerSetup ManagerSetup
	// contains filtered or unexported fields
}

func (*Framework) Setup

func (f *Framework) Setup() (context.Context, *rest.Config, client.Client)

func (*Framework) Teardown

func (f *Framework) Teardown()

type ManagerSetup

type ManagerSetup func(manager.Manager, context.Context)