testing

Nov 5, 2024

Changes in this version

+ func BeInvalidError() types.GomegaMatcher

+ func CheckEventRecordedFor(ctx context.Context, k8sClient client.Client, eventReason string, ...) (bool, error)

+ func HaveCondition(condition string) types.GomegaMatcher

+ func HaveConditionStatus(condition string, status metav1.ConditionStatus) types.GomegaMatcher

+ func HaveConditionStatusFalse(condition string) types.GomegaMatcher

+ func HaveConditionStatusTrue(condition string) types.GomegaMatcher

+ func ResourceGroup(flavors ...kueue.FlavorQuotas) kueue.ResourceGroup

type AdmissionWrapper

+ func (w *AdmissionWrapper) TopologyAssignment(ts *kueue.TopologyAssignment) *AdmissionWrapper

+ type CohortWrapper struct

+ func MakeCohort(name string) *CohortWrapper

+ func (c *CohortWrapper) Obj() *kueuealpha.Cohort

+ func (c *CohortWrapper) Parent(parentName string) *CohortWrapper

+ func (c *CohortWrapper) ResourceGroup(flavors ...kueue.FlavorQuotas) *CohortWrapper

type PodSetWrapper

+ func (p *PodSetWrapper) PreferredTopologyRequest(level string) *PodSetWrapper

+ func (p *PodSetWrapper) RequiredTopologyRequest(level string) *PodSetWrapper

type ResourceFlavorWrapper

+ func (rf *ResourceFlavorWrapper) TopologyName(name string) *ResourceFlavorWrapper

+ type TopologyWrapper struct

+ func MakeTopology(name string) *TopologyWrapper

+ func (t *TopologyWrapper) Levels(levels []string) *TopologyWrapper

+ func (t *TopologyWrapper) Obj() *kueuealpha.Topology

type WorkloadWrapper

+ func (w *WorkloadWrapper) AdmittedAt(a bool, t time.Time) *WorkloadWrapper

+ func (w *WorkloadWrapper) MaximumExecutionTimeSeconds(v int32) *WorkloadWrapper

+ func (w *WorkloadWrapper) PastAdmittedTime(v int32) *WorkloadWrapper

Jul 19, 2024

Changes in this version

+ func HasEventAppeared(ctx context.Context, k8sClient client.Client, event corev1.Event) (bool, error)

type ClusterQueueWrapper

+ func (c *ClusterQueueWrapper) DeletionTimestamp(t time.Time) *ClusterQueueWrapper

type FlavorQuotasWrapper

+ func (f *FlavorQuotasWrapper) ResourceQuotaWrapper(name corev1.ResourceName) *resourceQuotaWrapper

type LocalQueueWrapper

+ func (q *LocalQueueWrapper) StopPolicy(p kueue.StopPolicy) *LocalQueueWrapper

type ResourceFlavorWrapper

+ func (rf *ResourceFlavorWrapper) Creation(t time.Time) *ResourceFlavorWrapper

+ func (rf *ResourceFlavorWrapper) NodeLabel(k, v string) *ResourceFlavorWrapper

May 31, 2024

Changes in this version

+ const ForbiddenError

+ const InvalidError

+ const NotFoundError

+ func BeAPIError(name errorMatcher) types.GomegaMatcher

+ func RestConfigToKubeConfig(restConfig *rest.Config) ([]byte, error)

+ type AdmissionCheckStrategyRuleWrapper struct

+ func MakeAdmissionCheckStrategyRule(name string, flavors ...kueue.ResourceFlavorReference) *AdmissionCheckStrategyRuleWrapper

+ func (acs *AdmissionCheckStrategyRuleWrapper) Obj() *kueue.AdmissionCheckStrategyRule

+ func (acs *AdmissionCheckStrategyRuleWrapper) OnFlavors(flavors []kueue.ResourceFlavorReference) *AdmissionCheckStrategyRuleWrapper

type AdmissionCheckWrapper

+ func (ac *AdmissionCheckWrapper) ApplyToAllFlavors(applyToAllFlavors bool, reason, message string, observedGeneration int64) *AdmissionCheckWrapper

+ func (ac *AdmissionCheckWrapper) Generation(num int64) *AdmissionCheckWrapper

+ func (ac *AdmissionCheckWrapper) SingleInstanceInClusterQueue(singleInstance bool, reason, message string, observedGeneration int64) *AdmissionCheckWrapper

type ClusterQueueWrapper

+ func (c *ClusterQueueWrapper) AdmissionCheckStrategy(acs ...kueue.AdmissionCheckStrategyRule) *ClusterQueueWrapper

+ func (c *ClusterQueueWrapper) AdmittedWorkloads(n int32) *ClusterQueueWrapper

+ func (c *ClusterQueueWrapper) Creation(t time.Time) *ClusterQueueWrapper

+ func (c *ClusterQueueWrapper) FairWeight(w resource.Quantity) *ClusterQueueWrapper

+ func (c *ClusterQueueWrapper) Generation(num int64) *ClusterQueueWrapper

+ func (c *ClusterQueueWrapper) Label(k, v string) *ClusterQueueWrapper

+ func (c *ClusterQueueWrapper) PendingWorkloads(n int32) *ClusterQueueWrapper

type LocalQueueWrapper

+ func (q *LocalQueueWrapper) AdmittedWorkloads(n int32) *LocalQueueWrapper

+ func (q *LocalQueueWrapper) Condition(conditionType string, status metav1.ConditionStatus, reason, message string, ...) *LocalQueueWrapper

+ func (q *LocalQueueWrapper) Creation(t time.Time) *LocalQueueWrapper

+ func (q *LocalQueueWrapper) Generation(num int64) *LocalQueueWrapper

+ func (q *LocalQueueWrapper) Label(k, v string) *LocalQueueWrapper

type MultiKueueClusterWrapper

+ func (mkc *MultiKueueClusterWrapper) Generation(num int64) *MultiKueueClusterWrapper

type WorkloadWrapper

+ func (w *WorkloadWrapper) Admission(admission *kueue.Admission) *WorkloadWrapper

+ func (w *WorkloadWrapper) Conditions(conditions ...metav1.Condition) *WorkloadWrapper

+ func (w *WorkloadWrapper) Generation(num int64) *WorkloadWrapper

+ func (w *WorkloadWrapper) Name(name string) *WorkloadWrapper

+ func (w *WorkloadWrapper) QuotaReservedTime(t time.Time) *WorkloadWrapper

+ func (w *WorkloadWrapper) SimpleReserveQuota(cq, flavor string, now time.Time) *WorkloadWrapper

May 28, 2024

Changes in this version

+ func NewFakeClientSSAAsSM(objs ...client.Object) client.Client

+ func TreatSSAAsStrategicMerge(ctx context.Context, clnt client.Client, SubResourceName string, ...) error

+ type ContainerWrapper struct

+ func MakeContainer() *ContainerWrapper

+ func (c *ContainerWrapper) AsSidecar() *ContainerWrapper

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

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

type PodSetWrapper

+ func (p *PodSetWrapper) NodeName(name string) *PodSetWrapper

Apr 10, 2024

Changes in this version

type WorkloadWrapper

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

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

Feb 14, 2024

Changes in this version

+ func SortEvents(ei, ej EventRecord) bool

type AdmissionCheckWrapper

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

type ClusterQueueWrapper

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

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

+ type MultiKueueClusterWrapper struct

+ func MakeMultiKueueCluster(name string) *MultiKueueClusterWrapper

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

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

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

+ type MultiKueueConfigWrapper struct

+ func MakeMultiKueueConfig(name string) *MultiKueueConfigWrapper

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

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

type PodSetWrapper

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

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

type WorkloadWrapper

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

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

+ func (w *WorkloadWrapper) Clone() *WorkloadWrapper

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

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

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

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

Feb 9, 2024

Changes in this version

type WorkloadWrapper

+ func (w *WorkloadWrapper) Finished() *WorkloadWrapper

Jan 18, 2024

Changes in this version

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

+ type EventRecord struct

+ EventType string

+ Key types.NamespacedName

+ Message string

+ Reason string

+ type EventRecorder struct

+ RecordedEvents []EventRecord

+ func (tr *EventRecorder) AnnotatedEventf(targetObject runtime.Object, annotations map[string]string, ...)

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

+ func (tr *EventRecorder) Eventf(object runtime.Object, eventtype, reason, messageFmt string, ...)

type WorkloadWrapper

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

+ func (w *WorkloadWrapper) OwnerReference(apiVersion, kind, name, uid string, controller, blockDeletion bool) *WorkloadWrapper

Oct 25, 2023

Changes in this version

+ type AdmissionCheckWrapper struct

+ func MakeAdmissionCheck(name string) *AdmissionCheckWrapper

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

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

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

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

type ClusterQueueWrapper

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

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

type PodSetWrapper

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

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

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

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

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

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

type ResourceFlavorWrapper

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

+ type WorkloadPriorityClassWrapper struct

+ func MakeWorkloadPriorityClass(name string) *WorkloadPriorityClassWrapper

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

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

type WorkloadWrapper

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

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

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

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

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

+ func (w *WorkloadWrapper) PriorityClassSource(source string) *WorkloadWrapper

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

Jul 7, 2023

Changes in this version

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

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

type AdmissionWrapper

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

type PodSetWrapper

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

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

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

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

type WorkloadWrapper

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

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

Apr 6, 2023

Changes in this version

+ func BeForbiddenError() types.GomegaMatcher

+ func NewClientBuilder() *fake.ClientBuilder

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

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

type AdmissionWrapper

+ func (w *AdmissionWrapper) Assignment(r corev1.ResourceName, f kueue.ResourceFlavorReference, value string) *AdmissionWrapper

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

type ClusterQueueWrapper

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

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

+ type FlavorQuotasWrapper struct

+ func MakeFlavorQuotas(name string) *FlavorQuotasWrapper

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

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

+ type LimitRangeWrapper struct

+ func MakeLimitRange(name, namespace string) *LimitRangeWrapper

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

+ func (lr *LimitRangeWrapper) WithType(t corev1.LimitType) *LimitRangeWrapper

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

+ type PodSetWrapper struct

+ func MakePodSet(name string, count int) *PodSetWrapper

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

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

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

type WorkloadWrapper

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

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

Aug 25, 2022

Changes in this version

+ func BeNotFoundError() types.GomegaMatcher

+ type LocalQueueWrapper struct

+ func MakeLocalQueue(name, ns string) *LocalQueueWrapper

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

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

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

type ResourceFlavorWrapper

+ func (rf *ResourceFlavorWrapper) MultiLabels(kv map[string]string) *ResourceFlavorWrapper

+ type RuntimeClassWrapper struct

+ func MakeRuntimeClass(name, handler string) *RuntimeClassWrapper

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

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

type WorkloadWrapper

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

+ func (w *WorkloadWrapper) PodSets(podSets []kueue.PodSet) *WorkloadWrapper

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

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

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

Apr 12, 2022

Changes in this version

+ const Gi

+ const Ki

+ const Mi

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

+ func Equal(expected interface{}, options ...cmp.Option) types.GomegaMatcher

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

+ type AdmissionWrapper struct

+ func MakeAdmission(cq string) *AdmissionWrapper

+ func (w *AdmissionWrapper) Flavor(r corev1.ResourceName, f string) *AdmissionWrapper

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

+ type ClusterQueueWrapper struct

+ func MakeClusterQueue(name string) *ClusterQueueWrapper

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

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

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

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

+ func (c *ClusterQueueWrapper) Resource(r *kueue.Resource) *ClusterQueueWrapper

+ type FlavorWrapper struct

+ func MakeFlavor(rf, min string) *FlavorWrapper

+ func (f *FlavorWrapper) Max(c string) *FlavorWrapper

+ func (f *FlavorWrapper) Obj() *kueue.Flavor

+ type JobWrapper struct

+ func MakeJob(name, ns string) *JobWrapper

+ func (j *JobWrapper) NodeSelector(k, v string) *JobWrapper

+ func (j *JobWrapper) Obj() *batchv1.Job

+ func (j *JobWrapper) Parallelism(p int32) *JobWrapper

+ func (j *JobWrapper) PriorityClass(pc string) *JobWrapper

+ func (j *JobWrapper) Queue(queue string) *JobWrapper

+ func (j *JobWrapper) Request(r corev1.ResourceName, v string) *JobWrapper

+ func (j *JobWrapper) Suspend(s bool) *JobWrapper

+ func (j *JobWrapper) Toleration(t corev1.Toleration) *JobWrapper

+ type PriorityClassWrapper struct

+ func MakePriorityClass(name string) *PriorityClassWrapper

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

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

+ type QueueWrapper struct

+ func MakeQueue(name, ns string) *QueueWrapper

+ func (q *QueueWrapper) ClusterQueue(c string) *QueueWrapper

+ func (q *QueueWrapper) Obj() *kueue.Queue

+ type ResourceFlavorWrapper struct

+ func MakeResourceFlavor(name string) *ResourceFlavorWrapper

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

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

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

+ type ResourceWrapper struct

+ func MakeResource(name corev1.ResourceName) *ResourceWrapper

+ func (r *ResourceWrapper) Flavor(f *kueue.Flavor) *ResourceWrapper

+ func (r *ResourceWrapper) Obj() *kueue.Resource

+ type WorkloadWrapper struct

+ func MakeWorkload(name, ns string) *WorkloadWrapper

+ func (w *WorkloadWrapper) Admit(a *kueue.Admission) *WorkloadWrapper

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

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

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

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

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