testing

package
v0.4.2 Latest Latest
Warning

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

Go to latest
Published: Oct 11, 2023 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Ki = 1 << 10
	Mi = Ki * Ki
	Gi = Ki * Mi
)

Variables

This section is empty.

Functions

func AsIndexer added in v0.4.0

func AsIndexer(builder *fake.ClientBuilder) client.FieldIndexer

func BeForbiddenError added in v0.3.0

func BeForbiddenError() types.GomegaMatcher

func BeNotFoundError added in v0.2.0

func BeNotFoundError() types.GomegaMatcher

func CheckLatestEvent

func CheckLatestEvent(ctx context.Context, k8sClient client.Client,
	eventReason string,
	eventType string, eventNote string) (bool, error)

CheckLatestEvent will return true if the latest event is as you want.

func ContextWithLog added in v0.4.0

func ContextWithLog(t *testing.T) (context.Context, logr.Logger)

func NewClientBuilder added in v0.3.0

func NewClientBuilder(addToSchemes ...func(s *runtime.Scheme) error) *fake.ClientBuilder

func NewFakeClient added in v0.3.0

func NewFakeClient(objs ...client.Object) client.Client

func PodSpecForRequest

func PodSpecForRequest(request map[corev1.ResourceName]string) corev1.PodSpec

func SingleContainerForRequest added in v0.3.0

func SingleContainerForRequest(request map[corev1.ResourceName]string) []corev1.Container

Types

type AdmissionWrapper

type AdmissionWrapper struct{ kueue.Admission }

AdmissionWrapper wraps an Admission

func MakeAdmission

func MakeAdmission(cq string, podSetNames ...string) *AdmissionWrapper

func (*AdmissionWrapper) Assignment added in v0.3.0

func (*AdmissionWrapper) AssignmentPodCount added in v0.4.0

func (w *AdmissionWrapper) AssignmentPodCount(value int32) *AdmissionWrapper

func (*AdmissionWrapper) Obj

func (w *AdmissionWrapper) Obj() *kueue.Admission

func (*AdmissionWrapper) PodSets added in v0.3.0

func (w *AdmissionWrapper) PodSets(podSets ...kueue.PodSetAssignment) *AdmissionWrapper

type ClusterQueueWrapper

type ClusterQueueWrapper struct{ kueue.ClusterQueue }

ClusterQueueWrapper wraps a ClusterQueue.

func MakeClusterQueue

func MakeClusterQueue(name string) *ClusterQueueWrapper

MakeClusterQueue creates a wrapper for a ClusterQueue with a select-all NamespaceSelector.

func (*ClusterQueueWrapper) Cohort

func (c *ClusterQueueWrapper) Cohort(cohort string) *ClusterQueueWrapper

Cohort sets the borrowing cohort.

func (*ClusterQueueWrapper) NamespaceSelector

func (c *ClusterQueueWrapper) NamespaceSelector(s *metav1.LabelSelector) *ClusterQueueWrapper

NamespaceSelector sets the namespace selector.

func (*ClusterQueueWrapper) Obj

Obj returns the inner ClusterQueue.

func (*ClusterQueueWrapper) Preemption added in v0.3.0

Preemption sets the preeemption policies.

func (*ClusterQueueWrapper) QueueingStrategy

func (c *ClusterQueueWrapper) QueueingStrategy(strategy kueue.QueueingStrategy) *ClusterQueueWrapper

QueueingStrategy sets the queueing strategy in this ClusterQueue.

func (*ClusterQueueWrapper) ResourceGroup added in v0.3.0

func (c *ClusterQueueWrapper) ResourceGroup(flavors ...kueue.FlavorQuotas) *ClusterQueueWrapper

ResourceGroup adds a ResourceGroup with flavors.

type FlavorQuotasWrapper added in v0.3.0

type FlavorQuotasWrapper struct{ kueue.FlavorQuotas }

FlavorQuotasWrapper wraps a FlavorQuotas object.

func MakeFlavorQuotas added in v0.3.0

func MakeFlavorQuotas(name string) *FlavorQuotasWrapper

MakeFlavorQuotas creates a wrapper for a resource flavor.

func (*FlavorQuotasWrapper) Obj added in v0.3.0

Obj returns the inner flavor.

func (*FlavorQuotasWrapper) Resource added in v0.3.0

type LimitRangeWrapper added in v0.3.0

type LimitRangeWrapper struct{ corev1.LimitRange }

func MakeLimitRange added in v0.3.0

func MakeLimitRange(name, namespace string) *LimitRangeWrapper

func (*LimitRangeWrapper) Obj added in v0.3.0

func (lr *LimitRangeWrapper) Obj() *corev1.LimitRange

func (*LimitRangeWrapper) WithType added in v0.3.0

func (*LimitRangeWrapper) WithValue added in v0.3.0

func (lr *LimitRangeWrapper) WithValue(member string, t corev1.ResourceName, q string) *LimitRangeWrapper

type LocalQueueWrapper added in v0.2.0

type LocalQueueWrapper struct{ kueue.LocalQueue }

LocalQueueWrapper wraps a Queue.

func MakeLocalQueue added in v0.2.0

func MakeLocalQueue(name, ns string) *LocalQueueWrapper

MakeLocalQueue creates a wrapper for a LocalQueue.

func (*LocalQueueWrapper) ClusterQueue added in v0.2.0

func (q *LocalQueueWrapper) ClusterQueue(c string) *LocalQueueWrapper

ClusterQueue updates the clusterQueue the queue points to.

func (*LocalQueueWrapper) Obj added in v0.2.0

Obj returns the inner LocalQueue.

func (*LocalQueueWrapper) PendingWorkloads added in v0.2.0

func (q *LocalQueueWrapper) PendingWorkloads(n int32) *LocalQueueWrapper

PendingWorkloads updates the pendingWorkloads in status.

type PodSetWrapper added in v0.3.0

type PodSetWrapper struct{ kueue.PodSet }

func MakePodSet added in v0.3.0

func MakePodSet(name string, count int) *PodSetWrapper

func (*PodSetWrapper) Containers added in v0.4.0

func (p *PodSetWrapper) Containers(containers ...corev1.Container) *PodSetWrapper

func (*PodSetWrapper) InitContainers added in v0.4.0

func (p *PodSetWrapper) InitContainers(containers ...corev1.Container) *PodSetWrapper

func (*PodSetWrapper) NodeSelector added in v0.4.0

func (p *PodSetWrapper) NodeSelector(kv map[string]string) *PodSetWrapper

func (*PodSetWrapper) Obj added in v0.3.0

func (p *PodSetWrapper) Obj() *kueue.PodSet

func (*PodSetWrapper) Request added in v0.3.0

func (*PodSetWrapper) SetMinimumCount added in v0.4.0

func (p *PodSetWrapper) SetMinimumCount(mc int32) *PodSetWrapper

func (*PodSetWrapper) Toleration added in v0.3.0

func (p *PodSetWrapper) Toleration(t corev1.Toleration) *PodSetWrapper

type PriorityClassWrapper

type PriorityClassWrapper struct {
	schedulingv1.PriorityClass
}

PriorityClassWrapper wraps a PriorityClass.

func MakePriorityClass

func MakePriorityClass(name string) *PriorityClassWrapper

MakePriorityClass creates a wrapper for a PriorityClass.

func (*PriorityClassWrapper) Obj

Obj returns the inner PriorityClass.

func (*PriorityClassWrapper) PriorityValue

func (p *PriorityClassWrapper) PriorityValue(v int32) *PriorityClassWrapper

PriorityValue update value of PriorityClass。

type ResourceFlavorWrapper

type ResourceFlavorWrapper struct{ kueue.ResourceFlavor }

ResourceFlavorWrapper wraps a ResourceFlavor.

func MakeResourceFlavor

func MakeResourceFlavor(name string) *ResourceFlavorWrapper

MakeResourceFlavor creates a wrapper for a ResourceFlavor.

func (*ResourceFlavorWrapper) Label

Label add a label kueue and value pair to the ResourceFlavor.

func (*ResourceFlavorWrapper) Obj

Obj returns the inner ResourceFlavor.

func (*ResourceFlavorWrapper) Taint

Taint adds a taint to the ResourceFlavor.

type RuntimeClassWrapper added in v0.2.0

type RuntimeClassWrapper struct{ nodev1.RuntimeClass }

RuntimeClassWrapper wraps a RuntimeClass.

func MakeRuntimeClass added in v0.2.0

func MakeRuntimeClass(name, handler string) *RuntimeClassWrapper

MakeRuntimeClass creates a wrapper for a Runtime.

func (*RuntimeClassWrapper) Obj added in v0.2.0

Obj returns the inner flavor.

func (*RuntimeClassWrapper) PodOverhead added in v0.2.0

func (rc *RuntimeClassWrapper) PodOverhead(resources corev1.ResourceList) *RuntimeClassWrapper

PodOverhead adds a Overhead to the RuntimeClass.

type WorkloadWrapper

type WorkloadWrapper struct{ kueue.Workload }

func MakeWorkload

func MakeWorkload(name, ns string) *WorkloadWrapper

MakeWorkload creates a wrapper for a Workload with a single pod with a single container.

func (*WorkloadWrapper) Admit

func (*WorkloadWrapper) Condition added in v0.3.0

func (w *WorkloadWrapper) Condition(condition metav1.Condition) *WorkloadWrapper

func (*WorkloadWrapper) Creation

func (w *WorkloadWrapper) Creation(t time.Time) *WorkloadWrapper

func (*WorkloadWrapper) Limit added in v0.3.0

func (*WorkloadWrapper) NodeSelector added in v0.2.0

func (w *WorkloadWrapper) NodeSelector(kv map[string]string) *WorkloadWrapper

func (*WorkloadWrapper) Obj

func (w *WorkloadWrapper) Obj() *kueue.Workload

func (*WorkloadWrapper) PodSets added in v0.2.0

func (w *WorkloadWrapper) PodSets(podSets ...kueue.PodSet) *WorkloadWrapper

func (*WorkloadWrapper) Priority added in v0.2.0

func (w *WorkloadWrapper) Priority(priority int32) *WorkloadWrapper

func (*WorkloadWrapper) PriorityClass

func (w *WorkloadWrapper) PriorityClass(priorityClassName string) *WorkloadWrapper

func (*WorkloadWrapper) Queue

func (w *WorkloadWrapper) Queue(q string) *WorkloadWrapper

func (*WorkloadWrapper) ReclaimablePods added in v0.4.0

func (w *WorkloadWrapper) ReclaimablePods(rps ...kueue.ReclaimablePod) *WorkloadWrapper

func (*WorkloadWrapper) Request

func (*WorkloadWrapper) RuntimeClass added in v0.2.0

func (w *WorkloadWrapper) RuntimeClass(name string) *WorkloadWrapper

func (*WorkloadWrapper) SetOrReplaceCondition added in v0.4.0

func (w *WorkloadWrapper) SetOrReplaceCondition(condition metav1.Condition) *WorkloadWrapper

func (*WorkloadWrapper) Toleration added in v0.2.0

Jump to

Keyboard shortcuts

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