package testing

func MakeNodesAndPodsForEvenPodsSpread(labels map[string]string, existingPodsNum, allNodesNum, filteredNodesNum int) (existingPods []*v1.Pod, allNodes []*v1.Node, filteredNodes []*v1.Node)

MakeNodesAndPodsForEvenPodsSpread serves as a testing helper for EvenPodsSpread feature. It builds a fake cluster containing running Pods and Nodes. The size of Pods and Nodes are determined by input arguments. The specs of Pods and Nodes are generated with the following rules:

Each generated node is applied with a unique label: "node: node<i>".
Each generated node is applied with a rotating label: "zone: zone[0-9]".
Depending on the input labels, each generated pod will be applied with label "key1", "key1,key2", ..., "key1,key2,...,keyN" in a rotating manner.

Types ¶

type ClaimParametersWrapper ¶

type ClaimParametersWrapper struct {
	resourcev1alpha2.ResourceClaimParameters
}

func FromClaimParameters ¶

func FromClaimParameters(other *resourcev1alpha2.ResourceClaimParameters) *ClaimParametersWrapper

FromClaimParameters creates a ResourceClaimParameters wrapper from an existing object.

func MakeClaimParameters ¶

func MakeClaimParameters() *ClaimParametersWrapper

func (*ClaimParametersWrapper) GeneratedFrom ¶

func (wrapper *ClaimParametersWrapper) GeneratedFrom(value *resourcev1alpha2.ResourceClaimParametersReference) *ClaimParametersWrapper

func (*ClaimParametersWrapper) Name ¶

func (wrapper *ClaimParametersWrapper) Name(s string) *ClaimParametersWrapper

func (*ClaimParametersWrapper) NamedResourcesRequests ¶

func (wrapper *ClaimParametersWrapper) NamedResourcesRequests(driverName string, selectors ...string) *ClaimParametersWrapper

func (*ClaimParametersWrapper) Namespace ¶

func (wrapper *ClaimParametersWrapper) Namespace(s string) *ClaimParametersWrapper

func (*ClaimParametersWrapper) Obj ¶

func (wrapper *ClaimParametersWrapper) Obj() *resourcev1alpha2.ResourceClaimParameters

func (*ClaimParametersWrapper) Shareable ¶

func (wrapper *ClaimParametersWrapper) Shareable(value bool) *ClaimParametersWrapper

func (*ClaimParametersWrapper) UID ¶

func (wrapper *ClaimParametersWrapper) UID(s string) *ClaimParametersWrapper

type ClassParametersWrapper ¶

type ClassParametersWrapper struct {
	resourcev1alpha2.ResourceClassParameters
}

func FromClassParameters ¶

func FromClassParameters(other *resourcev1alpha2.ResourceClassParameters) *ClassParametersWrapper

FromClassParameters creates a ResourceClassParameters wrapper from an existing object.

func MakeClassParameters ¶

func MakeClassParameters() *ClassParametersWrapper

func (*ClassParametersWrapper) GeneratedFrom ¶

func (wrapper *ClassParametersWrapper) GeneratedFrom(value *resourcev1alpha2.ResourceClassParametersReference) *ClassParametersWrapper

func (*ClassParametersWrapper) Name ¶

func (wrapper *ClassParametersWrapper) Name(s string) *ClassParametersWrapper

func (*ClassParametersWrapper) NamedResourcesFilters ¶

func (wrapper *ClassParametersWrapper) NamedResourcesFilters(driverName string, selectors ...string) *ClassParametersWrapper

func (*ClassParametersWrapper) Namespace ¶

func (wrapper *ClassParametersWrapper) Namespace(s string) *ClassParametersWrapper

func (*ClassParametersWrapper) Obj ¶

func (wrapper *ClassParametersWrapper) Obj() *resourcev1alpha2.ResourceClassParameters

func (*ClassParametersWrapper) UID ¶

func (wrapper *ClassParametersWrapper) UID(s string) *ClassParametersWrapper

type ContainerWrapper ¶

type ContainerWrapper struct{ v1.Container }

ContainerWrapper wraps a Container inside.

func MakeContainer ¶

func MakeContainer() *ContainerWrapper

MakeContainer creates a Container wrapper.

func (*ContainerWrapper) ContainerPort ¶

func (c *ContainerWrapper) ContainerPort(ports []v1.ContainerPort) *ContainerWrapper

ContainerPort sets `ports` as the ports of the inner Container.

func (*ContainerWrapper) HostPort ¶

func (c *ContainerWrapper) HostPort(hostPort int32) *ContainerWrapper

HostPort sets `hostPort` as the host port of the inner Container.

func (*ContainerWrapper) Image ¶

func (c *ContainerWrapper) Image(image string) *ContainerWrapper

Image sets `image` as the image of the inner Container.

func (*ContainerWrapper) Name ¶

func (c *ContainerWrapper) Name(n string) *ContainerWrapper

Name sets `n` as the name of the inner Container.

func (*ContainerWrapper) Obj ¶

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

Obj returns the inner Container.

func (*ContainerWrapper) ResourceLimits ¶

func (c *ContainerWrapper) ResourceLimits(limMap map[v1.ResourceName]string) *ContainerWrapper

ResourceLimits sets the container resource limits to the given resource map.

func (*ContainerWrapper) ResourceRequests ¶

func (c *ContainerWrapper) ResourceRequests(reqMap map[v1.ResourceName]string) *ContainerWrapper

ResourceRequests sets the container resources requests to the given resource map of requests.

func (*ContainerWrapper) Resources ¶

func (c *ContainerWrapper) Resources(resMap map[v1.ResourceName]string) *ContainerWrapper

Resources sets the container resources to the given resource map.

type LabelSelectorWrapper ¶

type LabelSelectorWrapper struct{ metav1.LabelSelector }

LabelSelectorWrapper wraps a LabelSelector inside.

func MakeLabelSelector ¶

func MakeLabelSelector() *LabelSelectorWrapper

MakeLabelSelector creates a LabelSelector wrapper.

func (*LabelSelectorWrapper) Exists ¶

func (s *LabelSelectorWrapper) Exists(k string) *LabelSelectorWrapper

Exists injects a matchExpression (with an operator Exists) to the inner labelSelector.

func (*LabelSelectorWrapper) In ¶

func (s *LabelSelectorWrapper) In(key string, vals []string) *LabelSelectorWrapper

In injects a matchExpression (with an operator In) to the inner labelSelector.

func (*LabelSelectorWrapper) Label ¶

func (s *LabelSelectorWrapper) Label(k, v string) *LabelSelectorWrapper

Label applies a {k,v} pair to the inner LabelSelector.

func (*LabelSelectorWrapper) NotExist ¶

func (s *LabelSelectorWrapper) NotExist(k string) *LabelSelectorWrapper

NotExist injects a matchExpression (with an operator NotExist) to the inner labelSelector.

func (*LabelSelectorWrapper) NotIn ¶

func (s *LabelSelectorWrapper) NotIn(key string, vals []string) *LabelSelectorWrapper

NotIn injects a matchExpression (with an operator NotIn) to the inner labelSelector.

func (*LabelSelectorWrapper) Obj ¶

func (s *LabelSelectorWrapper) Obj() *metav1.LabelSelector

Obj returns the inner LabelSelector.

type NodeSelectorWrapper ¶

type NodeSelectorWrapper struct{ v1.NodeSelector }

NodeSelectorWrapper wraps a NodeSelector inside.

func MakeNodeSelector ¶

func MakeNodeSelector() *NodeSelectorWrapper

MakeNodeSelector creates a NodeSelector wrapper.

func (*NodeSelectorWrapper) In ¶

func (s *NodeSelectorWrapper) In(key string, vals []string) *NodeSelectorWrapper

In injects a matchExpression (with an operator IN) as a selectorTerm to the inner nodeSelector. NOTE: appended selecterTerms are ORed.

func (*NodeSelectorWrapper) NotIn ¶

func (s *NodeSelectorWrapper) NotIn(key string, vals []string) *NodeSelectorWrapper

NotIn injects a matchExpression (with an operator NotIn) as a selectorTerm to the inner nodeSelector.

func (*NodeSelectorWrapper) Obj ¶

func (s *NodeSelectorWrapper) Obj() *v1.NodeSelector

Obj returns the inner NodeSelector.

type NodeWrapper ¶

type NodeWrapper struct{ v1.Node }

NodeWrapper wraps a Node inside.

func MakeNode ¶

func MakeNode() *NodeWrapper

MakeNode creates a Node wrapper.

func (*NodeWrapper) Annotation ¶

func (n *NodeWrapper) Annotation(k, v string) *NodeWrapper

Annotation applies a {k,v} annotation pair to the inner node.

func (*NodeWrapper) Capacity ¶

func (n *NodeWrapper) Capacity(resources map[v1.ResourceName]string) *NodeWrapper

Capacity sets the capacity and the allocatable resources of the inner node. Each entry in `resources` corresponds to a resource name and its quantity. By default, the capacity and allocatable number of pods are set to 32.

func (*NodeWrapper) Condition ¶

func (n *NodeWrapper) Condition(typ v1.NodeConditionType, status v1.ConditionStatus, message, reason string) *NodeWrapper

Condition applies the node condition.

func (*NodeWrapper) Images ¶

func (n *NodeWrapper) Images(images map[string]int64) *NodeWrapper

Images sets the images of the inner node. Each entry in `images` corresponds to an image name and its size in bytes.

func (*NodeWrapper) Label ¶

func (n *NodeWrapper) Label(k, v string) *NodeWrapper

Label applies a {k,v} label pair to the inner node.

func (*NodeWrapper) Name ¶

func (n *NodeWrapper) Name(s string) *NodeWrapper

Name sets `s` as the name of the inner pod.

func (*NodeWrapper) Obj ¶

func (n *NodeWrapper) Obj() *v1.Node

Obj returns the inner Node.

func (*NodeWrapper) Taints ¶

func (n *NodeWrapper) Taints(taints []v1.Taint) *NodeWrapper

Taints applies taints to the inner node.

func (*NodeWrapper) UID ¶

func (n *NodeWrapper) UID(s string) *NodeWrapper

UID sets `s` as the UID of the inner pod.

func (*NodeWrapper) Unschedulable ¶

func (n *NodeWrapper) Unschedulable(unschedulable bool) *NodeWrapper

Unschedulable applies the unschedulable field.

type PersistentVolumeClaimWrapper ¶

type PersistentVolumeClaimWrapper struct{ v1.PersistentVolumeClaim }

PersistentVolumeClaimWrapper wraps a PersistentVolumeClaim inside.

func MakePersistentVolumeClaim ¶

func MakePersistentVolumeClaim() *PersistentVolumeClaimWrapper

MakePersistentVolumeClaim creates a PersistentVolumeClaim wrapper.

func (*PersistentVolumeClaimWrapper) AccessModes ¶

func (p *PersistentVolumeClaimWrapper) AccessModes(accessModes []v1.PersistentVolumeAccessMode) *PersistentVolumeClaimWrapper

AccessModes sets `accessModes` as the access modes of the inner PersistentVolumeClaim.

func (*PersistentVolumeClaimWrapper) Annotation ¶

func (p *PersistentVolumeClaimWrapper) Annotation(key, value string) *PersistentVolumeClaimWrapper

Annotation sets a {k,v} pair to the inner PersistentVolumeClaim.

func (*PersistentVolumeClaimWrapper) Name ¶

func (p *PersistentVolumeClaimWrapper) Name(s string) *PersistentVolumeClaimWrapper

Name sets `s` as the name of the inner PersistentVolumeClaim.

func (*PersistentVolumeClaimWrapper) Namespace ¶

func (p *PersistentVolumeClaimWrapper) Namespace(s string) *PersistentVolumeClaimWrapper

Namespace sets `s` as the namespace of the inner PersistentVolumeClaim.

func (*PersistentVolumeClaimWrapper) Obj ¶

func (p *PersistentVolumeClaimWrapper) Obj() *v1.PersistentVolumeClaim

Obj returns the inner PersistentVolumeClaim.

func (*PersistentVolumeClaimWrapper) Resources ¶

func (p *PersistentVolumeClaimWrapper) Resources(resources v1.VolumeResourceRequirements) *PersistentVolumeClaimWrapper

Resources sets `resources` as the resource requirements of the inner PersistentVolumeClaim.

func (*PersistentVolumeClaimWrapper) VolumeName ¶

func (p *PersistentVolumeClaimWrapper) VolumeName(name string) *PersistentVolumeClaimWrapper

VolumeName sets `name` as the volume name of the inner PersistentVolumeClaim.

type PersistentVolumeWrapper ¶

type PersistentVolumeWrapper struct{ v1.PersistentVolume }

PersistentVolumeWrapper wraps a PersistentVolume inside.

func MakePersistentVolume ¶

func MakePersistentVolume() *PersistentVolumeWrapper

MakePersistentVolume creates a PersistentVolume wrapper.

func (*PersistentVolumeWrapper) AccessModes ¶

func (p *PersistentVolumeWrapper) AccessModes(accessModes []v1.PersistentVolumeAccessMode) *PersistentVolumeWrapper

AccessModes sets `accessModes` as the access modes of the inner PersistentVolume.

func (*PersistentVolumeWrapper) Capacity ¶

func (p *PersistentVolumeWrapper) Capacity(capacity v1.ResourceList) *PersistentVolumeWrapper

Capacity sets `capacity` as the resource list of the inner PersistentVolume.

func (*PersistentVolumeWrapper) HostPathVolumeSource ¶

func (p *PersistentVolumeWrapper) HostPathVolumeSource(src *v1.HostPathVolumeSource) *PersistentVolumeWrapper

HostPathVolumeSource sets `src` as the host path volume source of the inner PersistentVolume.

func (*PersistentVolumeWrapper) Name ¶

func (p *PersistentVolumeWrapper) Name(s string) *PersistentVolumeWrapper

Name sets `s` as the name of the inner PersistentVolume.

func (*PersistentVolumeWrapper) NodeAffinityIn ¶

func (p *PersistentVolumeWrapper) NodeAffinityIn(key string, vals []string) *PersistentVolumeWrapper

NodeAffinityIn creates a HARD node affinity (with the operator In) and injects into the pv.

func (*PersistentVolumeWrapper) Obj ¶

func (p *PersistentVolumeWrapper) Obj() *v1.PersistentVolume

Obj returns the inner PersistentVolume.

type PodAffinityKind ¶

type PodAffinityKind int

PodAffinityKind represents different kinds of PodAffinity.

const (
	// NilPodAffinity is a no-op which doesn't apply any PodAffinity.
	NilPodAffinity PodAffinityKind = iota
	// PodAffinityWithRequiredReq applies a HARD requirement to pod.spec.affinity.PodAffinity.
	PodAffinityWithRequiredReq
	// PodAffinityWithPreferredReq applies a SOFT requirement to pod.spec.affinity.PodAffinity.
	PodAffinityWithPreferredReq
	// PodAffinityWithRequiredPreferredReq applies HARD and SOFT requirements to pod.spec.affinity.PodAffinity.
	PodAffinityWithRequiredPreferredReq
	// PodAntiAffinityWithRequiredReq applies a HARD requirement to pod.spec.affinity.PodAntiAffinity.
	PodAntiAffinityWithRequiredReq
	// PodAntiAffinityWithPreferredReq applies a SOFT requirement to pod.spec.affinity.PodAntiAffinity.
	PodAntiAffinityWithPreferredReq
	// PodAntiAffinityWithRequiredPreferredReq applies HARD and SOFT requirements to pod.spec.affinity.PodAntiAffinity.
	PodAntiAffinityWithRequiredPreferredReq
)

type PodSchedulingWrapper ¶

type PodSchedulingWrapper struct {
	resourcev1alpha2.PodSchedulingContext
}

PodSchedulingWrapper wraps a PodSchedulingContext inside.

func FromPodSchedulingContexts ¶

func FromPodSchedulingContexts(other *resourcev1alpha2.PodSchedulingContext) *PodSchedulingWrapper

FromPodSchedulingContexts creates a PodSchedulingContext wrapper from an existing object.

func MakePodSchedulingContexts ¶

func MakePodSchedulingContexts() *PodSchedulingWrapper

MakePodSchedulingContexts creates a PodSchedulingContext wrapper.

func (*PodSchedulingWrapper) Label ¶

func (wrapper *PodSchedulingWrapper) Label(k, v string) *PodSchedulingWrapper

Label applies a {k,v} label pair to the inner object

func (*PodSchedulingWrapper) Name ¶

func (wrapper *PodSchedulingWrapper) Name(s string) *PodSchedulingWrapper

Name sets `s` as the name of the inner object.

func (*PodSchedulingWrapper) Namespace ¶

func (wrapper *PodSchedulingWrapper) Namespace(s string) *PodSchedulingWrapper

Namespace sets `s` as the namespace of the inner object.

func (*PodSchedulingWrapper) Obj ¶

func (wrapper *PodSchedulingWrapper) Obj() *resourcev1alpha2.PodSchedulingContext

Obj returns the inner object.

func (*PodSchedulingWrapper) OwnerReference ¶

func (wrapper *PodSchedulingWrapper) OwnerReference(name, uid string, gvk schema.GroupVersionKind) *PodSchedulingWrapper

OwnerReference updates the owning controller of the inner object.

func (*PodSchedulingWrapper) PotentialNodes ¶

func (wrapper *PodSchedulingWrapper) PotentialNodes(nodes ...string) *PodSchedulingWrapper

PotentialNodes sets that field of the inner object.

func (*PodSchedulingWrapper) ResourceClaims ¶

func (wrapper *PodSchedulingWrapper) ResourceClaims(statuses ...resourcev1alpha2.ResourceClaimSchedulingStatus) *PodSchedulingWrapper

ResourceClaims sets that field of the inner object.

func (*PodSchedulingWrapper) SelectedNode ¶

func (wrapper *PodSchedulingWrapper) SelectedNode(s string) *PodSchedulingWrapper

SelectedNode sets that field of the inner object.

func (*PodSchedulingWrapper) UID ¶

func (wrapper *PodSchedulingWrapper) UID(s string) *PodSchedulingWrapper

UID sets `s` as the UID of the inner object.

type PodWrapper ¶

type PodWrapper struct{ v1.Pod }

PodWrapper wraps a Pod inside.

func MakePod ¶

func MakePod() *PodWrapper

MakePod creates a Pod wrapper.

func (*PodWrapper) Annotation ¶

func (p *PodWrapper) Annotation(key, value string) *PodWrapper

Annotation sets a {k,v} pair to the inner pod annotation.

func (*PodWrapper) Annotations ¶

func (p *PodWrapper) Annotations(annotations map[string]string) *PodWrapper

Annotations sets all {k,v} pair provided by `annotations` to the inner pod annotations.

func (*PodWrapper) Condition ¶

func (p *PodWrapper) Condition(t v1.PodConditionType, s v1.ConditionStatus, r string) *PodWrapper

Condition adds a `condition(Type, Status, Reason)` to .Status.Conditions.

func (*PodWrapper) Conditions ¶

func (p *PodWrapper) Conditions(conditions []v1.PodCondition) *PodWrapper

Conditions sets `conditions` as .status.Conditions of the inner pod.

func (*PodWrapper) Container ¶

func (p *PodWrapper) Container(s string) *PodWrapper

Container appends a container into PodSpec of the inner pod.

func (*PodWrapper) ContainerPort ¶

func (p *PodWrapper) ContainerPort(ports []v1.ContainerPort) *PodWrapper

ContainerPort creates a container with ports valued `ports`, and injects into the inner pod.

func (*PodWrapper) Containers ¶

func (p *PodWrapper) Containers(containers []v1.Container) *PodWrapper

Containers sets `containers` to the PodSpec of the inner pod.

func (*PodWrapper) CreationTimestamp ¶

func (p *PodWrapper) CreationTimestamp(t metav1.Time) *PodWrapper

CreationTimestamp sets the inner pod's CreationTimestamp.

func (*PodWrapper) HostPort ¶

func (p *PodWrapper) HostPort(port int32) *PodWrapper

HostPort creates a container with a hostPort valued `hostPort`, and injects into the inner pod.

func (*PodWrapper) InitReq ¶

func (p *PodWrapper) InitReq(resMap map[v1.ResourceName]string) *PodWrapper

InitReq adds a new init container to the inner pod with given resource map.

func (*PodWrapper) Label ¶

func (p *PodWrapper) Label(k, v string) *PodWrapper

Label sets a {k,v} pair to the inner pod label.

func (*PodWrapper) Labels ¶

func (p *PodWrapper) Labels(labels map[string]string) *PodWrapper

Labels sets all {k,v} pair provided by `labels` to the inner pod labels.

func (*PodWrapper) Lim ¶

func (p *PodWrapper) Lim(limMap map[v1.ResourceName]string) *PodWrapper

Lim adds a new container to the inner pod with given resource map of limits.

func (*PodWrapper) Name ¶

func (p *PodWrapper) Name(s string) *PodWrapper

Name sets `s` as the name of the inner pod.

func (*PodWrapper) Namespace ¶

func (p *PodWrapper) Namespace(s string) *PodWrapper

Namespace sets `s` as the namespace of the inner pod.

func (*PodWrapper) Node ¶

func (p *PodWrapper) Node(s string) *PodWrapper

Node sets `s` as the nodeName of the inner pod.

func (*PodWrapper) NodeAffinityIn ¶

func (p *PodWrapper) NodeAffinityIn(key string, vals []string) *PodWrapper

NodeAffinityIn creates a HARD node affinity (with the operator In) and injects into the inner pod.

func (*PodWrapper) NodeAffinityNotIn ¶

func (p *PodWrapper) NodeAffinityNotIn(key string, vals []string) *PodWrapper

NodeAffinityNotIn creates a HARD node affinity (with the operator NotIn) and injects into the inner pod.

func (*PodWrapper) NodeSelector ¶

func (p *PodWrapper) NodeSelector(m map[string]string) *PodWrapper

NodeSelector sets `m` as the nodeSelector of the inner pod.

func (*PodWrapper) NominatedNodeName ¶

func (p *PodWrapper) NominatedNodeName(n string) *PodWrapper

NominatedNodeName sets `n` as the .Status.NominatedNodeName of the inner pod.

func (*PodWrapper) Obj ¶

func (p *PodWrapper) Obj() *v1.Pod

Obj returns the inner Pod.

func (*PodWrapper) Overhead ¶

func (p *PodWrapper) Overhead(rl v1.ResourceList) *PodWrapper

Overhead sets the give ResourceList to the inner pod

func (*PodWrapper) OwnerReference ¶

func (p *PodWrapper) OwnerReference(name string, gvk schema.GroupVersionKind) *PodWrapper

OwnerReference updates the owning controller of the pod.

func (*PodWrapper) PVC ¶

func (p *PodWrapper) PVC(name string) *PodWrapper

PVC creates a Volume with a PVC and injects into the inner pod.

func (*PodWrapper) Phase ¶

func (p *PodWrapper) Phase(phase v1.PodPhase) *PodWrapper

Phase sets `phase` as .status.Phase of the inner pod.

func (*PodWrapper) PodAffinity ¶

func (p *PodWrapper) PodAffinity(topologyKey string, labelSelector *metav1.LabelSelector, kind PodAffinityKind) *PodWrapper

PodAffinity creates a PodAffinity with topology key and label selector and injects into the inner pod.

func (*PodWrapper) PodAffinityExists ¶

func (p *PodWrapper) PodAffinityExists(labelKey, topologyKey string, kind PodAffinityKind) *PodWrapper

PodAffinityExists creates a PodAffinity with the operator "Exists" and injects into the inner pod.

func (*PodWrapper) PodAffinityIn ¶

func (p *PodWrapper) PodAffinityIn(labelKey, topologyKey string, vals []string, kind PodAffinityKind) *PodWrapper

PodAffinityIn creates a PodAffinity with the operator "In" and injects into the inner pod.

func (*PodWrapper) PodAffinityNotExists ¶

func (p *PodWrapper) PodAffinityNotExists(labelKey, topologyKey string, kind PodAffinityKind) *PodWrapper

PodAffinityNotExists creates a PodAffinity with the operator "NotExists" and injects into the inner pod.

func (*PodWrapper) PodAffinityNotIn ¶

func (p *PodWrapper) PodAffinityNotIn(labelKey, topologyKey string, vals []string, kind PodAffinityKind) *PodWrapper

PodAffinityNotIn creates a PodAffinity with the operator "NotIn" and injects into the inner pod.

func (*PodWrapper) PodAntiAffinity ¶

func (p *PodWrapper) PodAntiAffinity(topologyKey string, labelSelector *metav1.LabelSelector, kind PodAffinityKind) *PodWrapper

PodAntiAffinity creates a PodAntiAffinity with topology key and label selector and injects into the inner pod.

func (*PodWrapper) PodAntiAffinityExists ¶

func (p *PodWrapper) PodAntiAffinityExists(labelKey, topologyKey string, kind PodAffinityKind) *PodWrapper

PodAntiAffinityExists creates a PodAntiAffinity with the operator "Exists" and injects into the inner pod.

func (*PodWrapper) PodAntiAffinityIn ¶

func (p *PodWrapper) PodAntiAffinityIn(labelKey, topologyKey string, vals []string, kind PodAffinityKind) *PodWrapper

PodAntiAffinityIn creates a PodAntiAffinity with the operator "In" and injects into the inner pod.

func (*PodWrapper) PodAntiAffinityNotExists ¶

func (p *PodWrapper) PodAntiAffinityNotExists(labelKey, topologyKey string, kind PodAffinityKind) *PodWrapper

PodAntiAffinityNotExists creates a PodAntiAffinity with the operator "NotExists" and injects into the inner pod.

func (*PodWrapper) PodAntiAffinityNotIn ¶

func (p *PodWrapper) PodAntiAffinityNotIn(labelKey, topologyKey string, vals []string, kind PodAffinityKind) *PodWrapper

PodAntiAffinityNotIn creates a PodAntiAffinity with the operator "NotIn" and injects into the inner pod.

func (*PodWrapper) PodResourceClaims ¶

func (p *PodWrapper) PodResourceClaims(podResourceClaims ...v1.PodResourceClaim) *PodWrapper

PodResourceClaims appends PodResourceClaims into PodSpec of the inner pod.

func (*PodWrapper) PreemptionPolicy ¶

func (p *PodWrapper) PreemptionPolicy(policy v1.PreemptionPolicy) *PodWrapper

PreemptionPolicy sets the give preemption policy to the inner pod.

func (*PodWrapper) Priority ¶

func (p *PodWrapper) Priority(val int32) *PodWrapper

Priority sets a priority value into PodSpec of the inner pod.

func (*PodWrapper) Req ¶

func (p *PodWrapper) Req(reqMap map[v1.ResourceName]string) *PodWrapper

Req adds a new container to the inner pod with given resource map of requests.

func (*PodWrapper) Res ¶

func (p *PodWrapper) Res(resMap map[v1.ResourceName]string) *PodWrapper

Res adds a new container to the inner pod with given resource map.

func (*PodWrapper) SchedulerName ¶

func (p *PodWrapper) SchedulerName(s string) *PodWrapper

SchedulerName sets `s` as the scheduler name of the inner pod.

func (*PodWrapper) SchedulingGates ¶

func (p *PodWrapper) SchedulingGates(gates []string) *PodWrapper

SchedulingGates sets `gates` as additional SchedulerGates of the inner pod.

func (*PodWrapper) SpreadConstraint ¶

func (p *PodWrapper) SpreadConstraint(maxSkew int, tpKey string, mode v1.UnsatisfiableConstraintAction, selector *metav1.LabelSelector, minDomains *int32, nodeAffinityPolicy, nodeTaintsPolicy *v1.NodeInclusionPolicy, matchLabelKeys []string) *PodWrapper

SpreadConstraint constructs a TopologySpreadConstraint object and injects into the inner pod.

func (*PodWrapper) StartTime ¶

func (p *PodWrapper) StartTime(t metav1.Time) *PodWrapper

StartTime sets `t` as .status.startTime for the inner pod.

func (*PodWrapper) Terminating ¶

func (p *PodWrapper) Terminating() *PodWrapper

Terminating sets the inner pod's deletionTimestamp to current timestamp.

func (*PodWrapper) Toleration ¶

func (p *PodWrapper) Toleration(key string) *PodWrapper

Toleration creates a toleration (with the operator Exists) and injects into the inner pod.

func (*PodWrapper) UID ¶

func (p *PodWrapper) UID(s string) *PodWrapper

UID sets `s` as the UID of the inner pod.

func (*PodWrapper) Volume ¶

func (p *PodWrapper) Volume(volume v1.Volume) *PodWrapper

Volume creates volume and injects into the inner pod.

func (*PodWrapper) Volumes ¶

func (p *PodWrapper) Volumes(volumes []v1.Volume) *PodWrapper

Volumes set the volumes and inject into the inner pod.

func (*PodWrapper) ZeroTerminationGracePeriod ¶

func (p *PodWrapper) ZeroTerminationGracePeriod() *PodWrapper

ZeroTerminationGracePeriod sets the TerminationGracePeriodSeconds of the inner pod to zero.

type ResourceClaimWrapper ¶

type ResourceClaimWrapper struct{ resourcev1alpha2.ResourceClaim }

ResourceClaimWrapper wraps a ResourceClaim inside.

func FromResourceClaim ¶

func FromResourceClaim(other *resourcev1alpha2.ResourceClaim) *ResourceClaimWrapper

FromResourceClaim creates a ResourceClaim wrapper from some existing object.

func MakeResourceClaim ¶

func MakeResourceClaim() *ResourceClaimWrapper

MakeResourceClaim creates a ResourceClaim wrapper.

func (*ResourceClaimWrapper) Allocation ¶

func (wrapper *ResourceClaimWrapper) Allocation(driverName string, allocation *resourcev1alpha2.AllocationResult) *ResourceClaimWrapper

Allocation sets the allocation of the inner object.

func (*ResourceClaimWrapper) AllocationMode ¶

func (wrapper *ResourceClaimWrapper) AllocationMode(a resourcev1alpha2.AllocationMode) *ResourceClaimWrapper

AllocationMode sets the allocation mode of the inner object.

func (*ResourceClaimWrapper) DeallocationRequested ¶

func (wrapper *ResourceClaimWrapper) DeallocationRequested(deallocationRequested bool) *ResourceClaimWrapper

DeallocationRequested sets that field of the inner object.

func (*ResourceClaimWrapper) Name ¶

func (wrapper *ResourceClaimWrapper) Name(s string) *ResourceClaimWrapper

Name sets `s` as the name of the inner object.

func (*ResourceClaimWrapper) Namespace ¶

func (wrapper *ResourceClaimWrapper) Namespace(s string) *ResourceClaimWrapper

Namespace sets `s` as the namespace of the inner object.

func (*ResourceClaimWrapper) Obj ¶

func (wrapper *ResourceClaimWrapper) Obj() *resourcev1alpha2.ResourceClaim

Obj returns the inner ResourceClaim.

func (*ResourceClaimWrapper) OwnerReference ¶

func (wrapper *ResourceClaimWrapper) OwnerReference(name, uid string, gvk schema.GroupVersionKind) *ResourceClaimWrapper

OwnerReference updates the owning controller of the object.

func (*ResourceClaimWrapper) ParametersRef ¶

func (wrapper *ResourceClaimWrapper) ParametersRef(name string) *ResourceClaimWrapper

ParametersRef sets a reference to a ResourceClaimParameters.resource.k8s.io.

func (*ResourceClaimWrapper) ReservedFor ¶

func (wrapper *ResourceClaimWrapper) ReservedFor(consumers ...resourcev1alpha2.ResourceClaimConsumerReference) *ResourceClaimWrapper

ReservedFor sets that field of the inner object.

func (*ResourceClaimWrapper) ReservedForPod ¶

func (wrapper *ResourceClaimWrapper) ReservedForPod(podName string, podUID types.UID) *ResourceClaimWrapper

ReservedFor sets that field of the inner object given information about one pod.

func (*ResourceClaimWrapper) ResourceClassName ¶

func (wrapper *ResourceClaimWrapper) ResourceClassName(name string) *ResourceClaimWrapper

ResourceClassName sets the resource class name of the inner object.

func (*ResourceClaimWrapper) Structured ¶

func (wrapper *ResourceClaimWrapper) Structured(nodeName string, namedResourcesInstances ...string) *ResourceClaimWrapper

Structured turns a "normal" claim into one which was allocated via structured parameters. This modifies the allocation result and adds the reserved finalizer if the claim is allocated. The claim has to become local to a node. The assumption is that "named resources" are used.

func (*ResourceClaimWrapper) UID ¶

func (wrapper *ResourceClaimWrapper) UID(s string) *ResourceClaimWrapper

UID sets `s` as the UID of the inner object.

type ResourceSliceWrapper ¶

type ResourceSliceWrapper struct {
	resourcev1alpha2.ResourceSlice
}

func MakeResourceSlice ¶

func MakeResourceSlice(nodeName, driverName string) *ResourceSliceWrapper

func (*ResourceSliceWrapper) NamedResourcesInstances ¶

func (wrapper *ResourceSliceWrapper) NamedResourcesInstances(names ...string) *ResourceSliceWrapper

func (*ResourceSliceWrapper) Obj ¶

func (wrapper *ResourceSliceWrapper) Obj() *resourcev1alpha2.ResourceSlice

Source Files ¶

workload_prep.go wrappers.go

Directories ¶

Path	Synopsis
pkg/scheduler/testing/framework

Version: v1.31.0-alpha.2
Published: Jun 18, 2024
Platform: js/wasm
Imports: 10 packages
Last checked: 2 hours ago –

Tools for package owners.

?	: This menu
/	: Search site
f	: Jump to identifier
g then g	: Go to top of page
g then b	: Go to end of page
G	: Go to end of page
g then i	: Go to index
g then e	: Go to examples