testing

package
v0.6.2 Latest Latest
Warning

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

 Go to latest Published: Apr 10, 2024 License: Apache-2.0 Imports: 29 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 SetDuringTest added in v0.5.2 

func SetDuringTest[T any](val *T, newVal T) func()

func SingleContainerForRequest added in v0.3.0 

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

func SortEvents added in v0.6.0 

func SortEvents(ei, ej EventRecord) bool

Types

type AdmissionCheckWrapper added in v0.5.0 

type AdmissionCheckWrapper struct{ kueue.AdmissionCheck }

func MakeAdmissionCheck added in v0.5.0 

func MakeAdmissionCheck(name string) *AdmissionCheckWrapper

func (*AdmissionCheckWrapper) Active added in v0.5.0 

func (ac *AdmissionCheckWrapper) Active(status metav1.ConditionStatus) *AdmissionCheckWrapper

func (*AdmissionCheckWrapper) Condition added in v0.6.0 

func (ac *AdmissionCheckWrapper) Condition(cond metav1.Condition) *AdmissionCheckWrapper

func (*AdmissionCheckWrapper) ControllerName added in v0.5.0 

func (ac *AdmissionCheckWrapper) ControllerName(c string) *AdmissionCheckWrapper

func (*AdmissionCheckWrapper) Obj added in v0.5.0 

func (ac *AdmissionCheckWrapper) Obj() *kueue.AdmissionCheck

func (*AdmissionCheckWrapper) Parameters added in v0.5.0 

func (ac *AdmissionCheckWrapper) Parameters(apigroup, kind, name string) *AdmissionCheckWrapper

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 (w *AdmissionWrapper) Assignment(r corev1.ResourceName, f kueue.ResourceFlavorReference, value string) *AdmissionWrapper

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) AdmissionChecks added in v0.5.0 

func (c *ClusterQueueWrapper) AdmissionChecks(checks ...string) *ClusterQueueWrapper

AdmissionChecks replaces the queue additional checks

func (*ClusterQueueWrapper) Cohort 

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

Cohort sets the borrowing cohort.

func (*ClusterQueueWrapper) Condition added in v0.6.0 

func (c *ClusterQueueWrapper) Condition(conditionType string, status metav1.ConditionStatus, reason, message string) *ClusterQueueWrapper

func (*ClusterQueueWrapper) FlavorFungibility added in v0.5.0 

func (c *ClusterQueueWrapper) FlavorFungibility(p kueue.FlavorFungibility) *ClusterQueueWrapper

FlavorFungibility sets the flavorFungibility policies.

func (*ClusterQueueWrapper) NamespaceSelector 

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

NamespaceSelector sets the namespace selector.

func (*ClusterQueueWrapper) Obj 

func (c *ClusterQueueWrapper) Obj() *kueue.ClusterQueue

Obj returns the inner ClusterQueue.

func (*ClusterQueueWrapper) Preemption added in v0.3.0 

func (c *ClusterQueueWrapper) Preemption(p kueue.ClusterQueuePreemption) *ClusterQueueWrapper

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.

func (*ClusterQueueWrapper) StopPolicy added in v0.6.0 

func (c *ClusterQueueWrapper) StopPolicy(p kueue.StopPolicy) *ClusterQueueWrapper

type EventRecord added in v0.5.2 

type EventRecord struct {
	Key       types.NamespacedName
	EventType string
	Reason    string
	Message   string
}

type EventRecorder added in v0.5.2 

type EventRecorder struct {
	RecordedEvents []EventRecord
	// contains filtered or unexported fields
}

func (*EventRecorder) AnnotatedEventf added in v0.5.2 

func (tr *EventRecorder) AnnotatedEventf(targetObject runtime.Object, annotations map[string]string, eventtype, reason, messageFmt string, args ...interface{})

func (*EventRecorder) Event added in v0.5.2 

func (tr *EventRecorder) Event(object runtime.Object, eventtype, reason, message string)

func (*EventRecorder) Eventf added in v0.5.2 

func (tr *EventRecorder) Eventf(object runtime.Object, eventtype, reason, messageFmt string, args ...interface{})

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 

func (f *FlavorQuotasWrapper) Obj() *kueue.FlavorQuotas

Obj returns the inner flavor.

func (*FlavorQuotasWrapper) Resource added in v0.3.0 

func (f *FlavorQuotasWrapper) Resource(name corev1.ResourceName, qs ...string) *FlavorQuotasWrapper

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 (lr *LimitRangeWrapper) WithType(t corev1.LimitType) *LimitRangeWrapper

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 

func (q *LocalQueueWrapper) Obj() *kueue.LocalQueue

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 MultiKueueClusterWrapper added in v0.6.0 

type MultiKueueClusterWrapper struct {
	kueuealpha.MultiKueueCluster
}

func MakeMultiKueueCluster added in v0.6.0 

func MakeMultiKueueCluster(name string) *MultiKueueClusterWrapper

func (*MultiKueueClusterWrapper) Active added in v0.6.0 

func (mkc *MultiKueueClusterWrapper) Active(state metav1.ConditionStatus, reason, message string) *MultiKueueClusterWrapper

func (*MultiKueueClusterWrapper) KubeConfig added in v0.6.0 

func (mkc *MultiKueueClusterWrapper) KubeConfig(LocationType kueuealpha.LocationType, location string) *MultiKueueClusterWrapper

func (*MultiKueueClusterWrapper) Obj added in v0.6.0 

func (mkc *MultiKueueClusterWrapper) Obj() *kueuealpha.MultiKueueCluster

type MultiKueueConfigWrapper added in v0.6.0 

type MultiKueueConfigWrapper struct {
	kueuealpha.MultiKueueConfig
}

func MakeMultiKueueConfig added in v0.6.0 

func MakeMultiKueueConfig(name string) *MultiKueueConfigWrapper

func (*MultiKueueConfigWrapper) Clusters added in v0.6.0 

func (mkc *MultiKueueConfigWrapper) Clusters(clusters ...string) *MultiKueueConfigWrapper

func (*MultiKueueConfigWrapper) Obj added in v0.6.0 

func (mkc *MultiKueueConfigWrapper) Obj() *kueuealpha.MultiKueueConfig

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) Annotations added in v0.5.0 

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

func (*PodSetWrapper) Containers added in v0.4.0 

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

func (*PodSetWrapper) Image added in v0.5.0 

func (p *PodSetWrapper) Image(image string) *PodSetWrapper

func (*PodSetWrapper) InitContainers added in v0.4.0 

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

func (*PodSetWrapper) Labels added in v0.5.0 

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

func (*PodSetWrapper) Limit added in v0.5.0 

func (p *PodSetWrapper) Limit(r corev1.ResourceName, q string) *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) PodOverHead added in v0.6.0 

func (p *PodSetWrapper) PodOverHead(resources corev1.ResourceList) *PodSetWrapper

func (*PodSetWrapper) PriorityClass added in v0.5.0 

func (p *PodSetWrapper) PriorityClass(pc string) *PodSetWrapper

func (*PodSetWrapper) Request added in v0.3.0 

func (p *PodSetWrapper) Request(r corev1.ResourceName, q string) *PodSetWrapper

func (*PodSetWrapper) RuntimeClass added in v0.6.0 

func (p *PodSetWrapper) RuntimeClass(name string) *PodSetWrapper

func (*PodSetWrapper) SchedulingGates added in v0.5.0 

func (p *PodSetWrapper) SchedulingGates(sg ...corev1.PodSchedulingGate) *PodSetWrapper

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 

func (p *PriorityClassWrapper) Obj() *schedulingv1.PriorityClass

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 

func (rf *ResourceFlavorWrapper) Label(k, v string) *ResourceFlavorWrapper

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

func (*ResourceFlavorWrapper) Obj 

func (rf *ResourceFlavorWrapper) Obj() *kueue.ResourceFlavor

Obj returns the inner ResourceFlavor.

func (*ResourceFlavorWrapper) Taint 

func (rf *ResourceFlavorWrapper) Taint(t corev1.Taint) *ResourceFlavorWrapper

Taint adds a taint to the ResourceFlavor.

func (*ResourceFlavorWrapper) Toleration added in v0.5.0 

func (rf *ResourceFlavorWrapper) Toleration(t corev1.Toleration) *ResourceFlavorWrapper

Toleration 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 

func (rc *RuntimeClassWrapper) Obj() *nodev1.RuntimeClass

Obj returns the inner flavor.

func (*RuntimeClassWrapper) PodOverhead added in v0.2.0 

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

PodOverhead adds an Overhead to the RuntimeClass.

type WorkloadPriorityClassWrapper added in v0.5.0 

type WorkloadPriorityClassWrapper struct {
	kueue.WorkloadPriorityClass
}

WorkloadPriorityClassWrapper wraps a WorkloadPriorityClass.

func MakeWorkloadPriorityClass added in v0.5.0 

func MakeWorkloadPriorityClass(name string) *WorkloadPriorityClassWrapper

MakeWorkloadPriorityClass creates a wrapper for a WorkloadPriorityClass.

func (*WorkloadPriorityClassWrapper) Obj added in v0.5.0 

func (p *WorkloadPriorityClassWrapper) Obj() *kueue.WorkloadPriorityClass

Obj returns the inner WorkloadPriorityClass.

func (*WorkloadPriorityClassWrapper) PriorityValue added in v0.5.0 

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

PriorityValue updates value of WorkloadPriorityClass.

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) Active added in v0.6.0 

func (w *WorkloadWrapper) Active(a bool) *WorkloadWrapper

func (*WorkloadWrapper) AdmissionCheck added in v0.5.0 

func (w *WorkloadWrapper) AdmissionCheck(ac kueue.AdmissionCheckState) *WorkloadWrapper

func (*WorkloadWrapper) AdmissionChecks added in v0.5.0 

func (w *WorkloadWrapper) AdmissionChecks(checks ...kueue.AdmissionCheckState) *WorkloadWrapper

func (*WorkloadWrapper) Admitted added in v0.5.0 

func (w *WorkloadWrapper) Admitted(a bool) *WorkloadWrapper

func (*WorkloadWrapper) Annotations added in v0.6.0 

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

func (*WorkloadWrapper) Clone added in v0.6.0 

func (w *WorkloadWrapper) Clone() *WorkloadWrapper

func (*WorkloadWrapper) Condition added in v0.3.0 

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

func (*WorkloadWrapper) ControllerReference added in v0.6.0 

func (w *WorkloadWrapper) ControllerReference(gvk schema.GroupVersionKind, name, uid string) *WorkloadWrapper

func (*WorkloadWrapper) Creation 

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

func (*WorkloadWrapper) DeletionTimestamp added in v0.5.2 

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

DeletionTimestamp sets a deletion timestamp for the workload.

func (*WorkloadWrapper) Finalizers added in v0.5.0 

func (w *WorkloadWrapper) Finalizers(fin ...string) *WorkloadWrapper

func (*WorkloadWrapper) Finished added in v0.5.3 

func (w *WorkloadWrapper) Finished() *WorkloadWrapper

func (*WorkloadWrapper) Label added in v0.6.0 

func (w *WorkloadWrapper) Label(k, v string) *WorkloadWrapper

func (*WorkloadWrapper) Labels added in v0.5.0 

func (w *WorkloadWrapper) Labels(l map[string]string) *WorkloadWrapper

func (*WorkloadWrapper) Limit added in v0.3.0 

func (w *WorkloadWrapper) Limit(r corev1.ResourceName, q string) *WorkloadWrapper

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) OwnerReference added in v0.5.2 

func (w *WorkloadWrapper) OwnerReference(gvk schema.GroupVersionKind, name, uid string) *WorkloadWrapper

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) PriorityClassSource added in v0.5.0 

func (w *WorkloadWrapper) PriorityClassSource(source 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 (w *WorkloadWrapper) Request(r corev1.ResourceName, q string) *WorkloadWrapper

func (*WorkloadWrapper) RequeueState added in v0.6.0 

func (w *WorkloadWrapper) RequeueState(count *int32, requeueAt *metav1.Time) *WorkloadWrapper

func (*WorkloadWrapper) ReserveQuota added in v0.5.0 

func (w *WorkloadWrapper) ReserveQuota(a *kueue.Admission) *WorkloadWrapper

ReserveQuota sets workload admission and adds a "QuotaReserved" status condition

func (*WorkloadWrapper) ReserveQuotaAt added in v0.6.2 

func (w *WorkloadWrapper) ReserveQuotaAt(a *kueue.Admission, now time.Time) *WorkloadWrapper

ReserveQuotaAt sets workload admission and adds a "QuotaReserved" status condition

func (*WorkloadWrapper) ResourceVersion added in v0.6.0 

func (w *WorkloadWrapper) ResourceVersion(v string) *WorkloadWrapper

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 

func (w *WorkloadWrapper) Toleration(t corev1.Toleration) *WorkloadWrapper

func (*WorkloadWrapper) UID added in v0.6.2 

func (w *WorkloadWrapper) UID(uid types.UID) *WorkloadWrapper

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.