testing

package
v0.6.3 Latest Latest
Warning

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

Go to latest
Published: May 28, 2024 License: Apache-2.0 Imports: 31 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 NewFakeClientSSAAsSM added in v0.6.3

func NewFakeClientSSAAsSM(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

func TreatSSAAsStrategicMerge added in v0.6.3

func TreatSSAAsStrategicMerge(ctx context.Context, clnt client.Client, SubResourceName string, obj client.Object, patch client.Patch, opts ...client.SubResourcePatchOption) error

TreatSSAAsStrategicMerge - can be used as a SubResourcePatch interceptor function to treat SSA patches as StrategicMergePatchType. Note: By doing so the values set in the patch will be updated but the call will have no knowledge of FieldManagement when it comes to detecting conflicts between managers or removing fields that are missing from the patch.

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 (*AdmissionCheckWrapper) Condition added in v0.6.0

func (*AdmissionCheckWrapper) ControllerName added in v0.5.0

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

func (*AdmissionCheckWrapper) Obj added in v0.5.0

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 (*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

FlavorFungibility sets the flavorFungibility policies.

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.

func (*ClusterQueueWrapper) StopPolicy added in v0.6.0

type ContainerWrapper added in v0.6.3

type ContainerWrapper struct{ corev1.Container }

ContainerWrapper wraps a corev1.Container.

func MakeContainer added in v0.6.3

func MakeContainer() *ContainerWrapper

MakeContainer wraps a ContainerWrapper with an empty ResourceList.

func (*ContainerWrapper) AsSidecar added in v0.6.3

func (c *ContainerWrapper) AsSidecar() *ContainerWrapper

AsSidecar makes the container a sidecar when used as an Init Container.

func (*ContainerWrapper) Obj added in v0.6.3

func (c *ContainerWrapper) Obj() *corev1.Container

Obj returns the inner corev1.Container.

func (*ContainerWrapper) WithResourceReq added in v0.6.3

func (c *ContainerWrapper) WithResourceReq(resourceName corev1.ResourceName, quantity string) *ContainerWrapper

WithResourceReq appends a resource request to the container.

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

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

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

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 (*PodSetWrapper) NodeName added in v0.6.3

func (p *PodSetWrapper) NodeName(name 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 (*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

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.

func (*ResourceFlavorWrapper) Toleration added in v0.5.0

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

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

Obj returns the inner WorkloadPriorityClass.

func (*WorkloadPriorityClassWrapper) PriorityValue added in v0.5.0

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 (*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 (*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 (*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 (*WorkloadWrapper) UID added in v0.6.2

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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