Documentation ¶
Index ¶
- func MakeNodesAndPodsForEvenPodsSpread(labels map[string]string, existingPodsNum, allNodesNum, filteredNodesNum int) (existingPods []*v1.Pod, allNodes []*v1.Node, filteredNodes []*v1.Node)
- type ClaimParametersWrapper
- func (wrapper *ClaimParametersWrapper) GeneratedFrom(value *resourcev1alpha2.ResourceClaimParametersReference) *ClaimParametersWrapper
- func (wrapper *ClaimParametersWrapper) Name(s string) *ClaimParametersWrapper
- func (wrapper *ClaimParametersWrapper) NamedResourcesRequests(driverName string, selectors ...string) *ClaimParametersWrapper
- func (wrapper *ClaimParametersWrapper) Namespace(s string) *ClaimParametersWrapper
- func (wrapper *ClaimParametersWrapper) Obj() *resourcev1alpha2.ResourceClaimParameters
- func (wrapper *ClaimParametersWrapper) Shareable(value bool) *ClaimParametersWrapper
- func (wrapper *ClaimParametersWrapper) UID(s string) *ClaimParametersWrapper
- type ClassParametersWrapper
- func (wrapper *ClassParametersWrapper) GeneratedFrom(value *resourcev1alpha2.ResourceClassParametersReference) *ClassParametersWrapper
- func (wrapper *ClassParametersWrapper) Name(s string) *ClassParametersWrapper
- func (wrapper *ClassParametersWrapper) NamedResourcesFilters(driverName string, selectors ...string) *ClassParametersWrapper
- func (wrapper *ClassParametersWrapper) Namespace(s string) *ClassParametersWrapper
- func (wrapper *ClassParametersWrapper) Obj() *resourcev1alpha2.ResourceClassParameters
- func (wrapper *ClassParametersWrapper) UID(s string) *ClassParametersWrapper
- type ContainerWrapper
- func (c *ContainerWrapper) ContainerPort(ports []v1.ContainerPort) *ContainerWrapper
- func (c *ContainerWrapper) HostPort(hostPort int32) *ContainerWrapper
- func (c *ContainerWrapper) Image(image string) *ContainerWrapper
- func (c *ContainerWrapper) Name(n string) *ContainerWrapper
- func (c *ContainerWrapper) Obj() v1.Container
- func (c *ContainerWrapper) ResourceLimits(limMap map[v1.ResourceName]string) *ContainerWrapper
- func (c *ContainerWrapper) ResourceRequests(reqMap map[v1.ResourceName]string) *ContainerWrapper
- func (c *ContainerWrapper) Resources(resMap map[v1.ResourceName]string) *ContainerWrapper
- type LabelSelectorWrapper
- func (s *LabelSelectorWrapper) Exists(k string) *LabelSelectorWrapper
- func (s *LabelSelectorWrapper) In(key string, vals []string) *LabelSelectorWrapper
- func (s *LabelSelectorWrapper) Label(k, v string) *LabelSelectorWrapper
- func (s *LabelSelectorWrapper) NotExist(k string) *LabelSelectorWrapper
- func (s *LabelSelectorWrapper) NotIn(key string, vals []string) *LabelSelectorWrapper
- func (s *LabelSelectorWrapper) Obj() *metav1.LabelSelector
- type NodeSelectorWrapper
- type NodeWrapper
- func (n *NodeWrapper) Annotation(k, v string) *NodeWrapper
- func (n *NodeWrapper) Capacity(resources map[v1.ResourceName]string) *NodeWrapper
- func (n *NodeWrapper) Condition(typ v1.NodeConditionType, status v1.ConditionStatus, message, reason string) *NodeWrapper
- func (n *NodeWrapper) Images(images map[string]int64) *NodeWrapper
- func (n *NodeWrapper) Label(k, v string) *NodeWrapper
- func (n *NodeWrapper) Name(s string) *NodeWrapper
- func (n *NodeWrapper) Obj() *v1.Node
- func (n *NodeWrapper) Taints(taints []v1.Taint) *NodeWrapper
- func (n *NodeWrapper) UID(s string) *NodeWrapper
- func (n *NodeWrapper) Unschedulable(unschedulable bool) *NodeWrapper
- type PersistentVolumeClaimWrapper
- func (p *PersistentVolumeClaimWrapper) AccessModes(accessModes []v1.PersistentVolumeAccessMode) *PersistentVolumeClaimWrapper
- func (p *PersistentVolumeClaimWrapper) Annotation(key, value string) *PersistentVolumeClaimWrapper
- func (p *PersistentVolumeClaimWrapper) Name(s string) *PersistentVolumeClaimWrapper
- func (p *PersistentVolumeClaimWrapper) Namespace(s string) *PersistentVolumeClaimWrapper
- func (p *PersistentVolumeClaimWrapper) Obj() *v1.PersistentVolumeClaim
- func (p *PersistentVolumeClaimWrapper) Resources(resources v1.VolumeResourceRequirements) *PersistentVolumeClaimWrapper
- func (p *PersistentVolumeClaimWrapper) VolumeName(name string) *PersistentVolumeClaimWrapper
- type PersistentVolumeWrapper
- func (p *PersistentVolumeWrapper) AccessModes(accessModes []v1.PersistentVolumeAccessMode) *PersistentVolumeWrapper
- func (p *PersistentVolumeWrapper) Capacity(capacity v1.ResourceList) *PersistentVolumeWrapper
- func (p *PersistentVolumeWrapper) HostPathVolumeSource(src *v1.HostPathVolumeSource) *PersistentVolumeWrapper
- func (p *PersistentVolumeWrapper) Name(s string) *PersistentVolumeWrapper
- func (p *PersistentVolumeWrapper) NodeAffinityIn(key string, vals []string) *PersistentVolumeWrapper
- func (p *PersistentVolumeWrapper) Obj() *v1.PersistentVolume
- type PodAffinityKind
- type PodSchedulingWrapper
- func (wrapper *PodSchedulingWrapper) Label(k, v string) *PodSchedulingWrapper
- func (wrapper *PodSchedulingWrapper) Name(s string) *PodSchedulingWrapper
- func (wrapper *PodSchedulingWrapper) Namespace(s string) *PodSchedulingWrapper
- func (wrapper *PodSchedulingWrapper) Obj() *resourcev1alpha2.PodSchedulingContext
- func (wrapper *PodSchedulingWrapper) OwnerReference(name, uid string, gvk schema.GroupVersionKind) *PodSchedulingWrapper
- func (wrapper *PodSchedulingWrapper) PotentialNodes(nodes ...string) *PodSchedulingWrapper
- func (wrapper *PodSchedulingWrapper) ResourceClaims(statuses ...resourcev1alpha2.ResourceClaimSchedulingStatus) *PodSchedulingWrapper
- func (wrapper *PodSchedulingWrapper) SelectedNode(s string) *PodSchedulingWrapper
- func (wrapper *PodSchedulingWrapper) UID(s string) *PodSchedulingWrapper
- type PodWrapper
- func (p *PodWrapper) Annotation(key, value string) *PodWrapper
- func (p *PodWrapper) Annotations(annotations map[string]string) *PodWrapper
- func (p *PodWrapper) Condition(t v1.PodConditionType, s v1.ConditionStatus, r string) *PodWrapper
- func (p *PodWrapper) Conditions(conditions []v1.PodCondition) *PodWrapper
- func (p *PodWrapper) Container(s string) *PodWrapper
- func (p *PodWrapper) ContainerPort(ports []v1.ContainerPort) *PodWrapper
- func (p *PodWrapper) Containers(containers []v1.Container) *PodWrapper
- func (p *PodWrapper) CreationTimestamp(t metav1.Time) *PodWrapper
- func (p *PodWrapper) HostPort(port int32) *PodWrapper
- func (p *PodWrapper) InitReq(resMap map[v1.ResourceName]string) *PodWrapper
- func (p *PodWrapper) Label(k, v string) *PodWrapper
- func (p *PodWrapper) Labels(labels map[string]string) *PodWrapper
- func (p *PodWrapper) Lim(limMap map[v1.ResourceName]string) *PodWrapper
- func (p *PodWrapper) Name(s string) *PodWrapper
- func (p *PodWrapper) Namespace(s string) *PodWrapper
- func (p *PodWrapper) Node(s string) *PodWrapper
- func (p *PodWrapper) NodeAffinityIn(key string, vals []string) *PodWrapper
- func (p *PodWrapper) NodeAffinityNotIn(key string, vals []string) *PodWrapper
- func (p *PodWrapper) NodeSelector(m map[string]string) *PodWrapper
- func (p *PodWrapper) NominatedNodeName(n string) *PodWrapper
- func (p *PodWrapper) Obj() *v1.Pod
- func (p *PodWrapper) Overhead(rl v1.ResourceList) *PodWrapper
- func (p *PodWrapper) OwnerReference(name string, gvk schema.GroupVersionKind) *PodWrapper
- func (p *PodWrapper) PVC(name string) *PodWrapper
- func (p *PodWrapper) Phase(phase v1.PodPhase) *PodWrapper
- func (p *PodWrapper) PodAffinity(topologyKey string, labelSelector *metav1.LabelSelector, kind PodAffinityKind) *PodWrapper
- func (p *PodWrapper) PodAffinityExists(labelKey, topologyKey string, kind PodAffinityKind) *PodWrapper
- func (p *PodWrapper) PodAffinityIn(labelKey, topologyKey string, vals []string, kind PodAffinityKind) *PodWrapper
- func (p *PodWrapper) PodAffinityNotExists(labelKey, topologyKey string, kind PodAffinityKind) *PodWrapper
- func (p *PodWrapper) PodAffinityNotIn(labelKey, topologyKey string, vals []string, kind PodAffinityKind) *PodWrapper
- func (p *PodWrapper) PodAntiAffinity(topologyKey string, labelSelector *metav1.LabelSelector, kind PodAffinityKind) *PodWrapper
- func (p *PodWrapper) PodAntiAffinityExists(labelKey, topologyKey string, kind PodAffinityKind) *PodWrapper
- func (p *PodWrapper) PodAntiAffinityIn(labelKey, topologyKey string, vals []string, kind PodAffinityKind) *PodWrapper
- func (p *PodWrapper) PodAntiAffinityNotExists(labelKey, topologyKey string, kind PodAffinityKind) *PodWrapper
- func (p *PodWrapper) PodAntiAffinityNotIn(labelKey, topologyKey string, vals []string, kind PodAffinityKind) *PodWrapper
- func (p *PodWrapper) PodResourceClaims(podResourceClaims ...v1.PodResourceClaim) *PodWrapper
- func (p *PodWrapper) PreemptionPolicy(policy v1.PreemptionPolicy) *PodWrapper
- func (p *PodWrapper) Priority(val int32) *PodWrapper
- func (p *PodWrapper) Req(reqMap map[v1.ResourceName]string) *PodWrapper
- func (p *PodWrapper) Res(resMap map[v1.ResourceName]string) *PodWrapper
- func (p *PodWrapper) SchedulerName(s string) *PodWrapper
- func (p *PodWrapper) SchedulingGates(gates []string) *PodWrapper
- func (p *PodWrapper) SpreadConstraint(maxSkew int, tpKey string, mode v1.UnsatisfiableConstraintAction, ...) *PodWrapper
- func (p *PodWrapper) StartTime(t metav1.Time) *PodWrapper
- func (p *PodWrapper) Terminating() *PodWrapper
- func (p *PodWrapper) Toleration(key string) *PodWrapper
- func (p *PodWrapper) UID(s string) *PodWrapper
- func (p *PodWrapper) Volume(volume v1.Volume) *PodWrapper
- func (p *PodWrapper) Volumes(volumes []v1.Volume) *PodWrapper
- func (p *PodWrapper) ZeroTerminationGracePeriod() *PodWrapper
- type ResourceClaimWrapper
- func (wrapper *ResourceClaimWrapper) Allocation(driverName string, allocation *resourcev1alpha2.AllocationResult) *ResourceClaimWrapper
- func (wrapper *ResourceClaimWrapper) AllocationMode(a resourcev1alpha2.AllocationMode) *ResourceClaimWrapper
- func (wrapper *ResourceClaimWrapper) DeallocationRequested(deallocationRequested bool) *ResourceClaimWrapper
- func (wrapper *ResourceClaimWrapper) Name(s string) *ResourceClaimWrapper
- func (wrapper *ResourceClaimWrapper) Namespace(s string) *ResourceClaimWrapper
- func (wrapper *ResourceClaimWrapper) Obj() *resourcev1alpha2.ResourceClaim
- func (wrapper *ResourceClaimWrapper) OwnerReference(name, uid string, gvk schema.GroupVersionKind) *ResourceClaimWrapper
- func (wrapper *ResourceClaimWrapper) ParametersRef(name string) *ResourceClaimWrapper
- func (wrapper *ResourceClaimWrapper) ReservedFor(consumers ...resourcev1alpha2.ResourceClaimConsumerReference) *ResourceClaimWrapper
- func (wrapper *ResourceClaimWrapper) ReservedForPod(podName string, podUID types.UID) *ResourceClaimWrapper
- func (wrapper *ResourceClaimWrapper) ResourceClassName(name string) *ResourceClaimWrapper
- func (wrapper *ResourceClaimWrapper) Structured(nodeName string, namedResourcesInstances ...string) *ResourceClaimWrapper
- func (wrapper *ResourceClaimWrapper) UID(s string) *ResourceClaimWrapper
- type ResourceSliceWrapper
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MakeNodesAndPodsForEvenPodsSpread ¶ added in v1.17.0
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 ¶ added in v1.25.0
ContainerWrapper wraps a Container inside.
func MakeContainer ¶ added in v1.25.0
func MakeContainer() *ContainerWrapper
MakeContainer creates a Container wrapper.
func (*ContainerWrapper) ContainerPort ¶ added in v1.25.0
func (c *ContainerWrapper) ContainerPort(ports []v1.ContainerPort) *ContainerWrapper
ContainerPort sets `ports` as the ports of the inner Container.
func (*ContainerWrapper) HostPort ¶ added in v1.25.0
func (c *ContainerWrapper) HostPort(hostPort int32) *ContainerWrapper
HostPort sets `hostPort` as the host port of the inner Container.
func (*ContainerWrapper) Image ¶ added in v1.25.0
func (c *ContainerWrapper) Image(image string) *ContainerWrapper
Image sets `image` as the image of the inner Container.
func (*ContainerWrapper) Name ¶ added in v1.25.0
func (c *ContainerWrapper) Name(n string) *ContainerWrapper
Name sets `n` as the name of the inner Container.
func (*ContainerWrapper) Obj ¶ added in v1.25.0
func (c *ContainerWrapper) Obj() v1.Container
Obj returns the inner Container.
func (*ContainerWrapper) ResourceLimits ¶ added in v1.27.0
func (c *ContainerWrapper) ResourceLimits(limMap map[v1.ResourceName]string) *ContainerWrapper
ResourceLimits sets the container resource limits to the given resource map.
func (*ContainerWrapper) ResourceRequests ¶ added in v1.27.0
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 ¶ added in v1.25.0
func (c *ContainerWrapper) Resources(resMap map[v1.ResourceName]string) *ContainerWrapper
Resources sets the container resources to the given resource map.
type LabelSelectorWrapper ¶ added in v1.16.0
type LabelSelectorWrapper struct{ metav1.LabelSelector }
LabelSelectorWrapper wraps a LabelSelector inside.
func MakeLabelSelector ¶ added in v1.16.0
func MakeLabelSelector() *LabelSelectorWrapper
MakeLabelSelector creates a LabelSelector wrapper.
func (*LabelSelectorWrapper) Exists ¶ added in v1.16.0
func (s *LabelSelectorWrapper) Exists(k string) *LabelSelectorWrapper
Exists injects a matchExpression (with an operator Exists) to the inner labelSelector.
func (*LabelSelectorWrapper) In ¶ added in v1.16.0
func (s *LabelSelectorWrapper) In(key string, vals []string) *LabelSelectorWrapper
In injects a matchExpression (with an operator In) to the inner labelSelector.
func (*LabelSelectorWrapper) Label ¶ added in v1.16.0
func (s *LabelSelectorWrapper) Label(k, v string) *LabelSelectorWrapper
Label applies a {k,v} pair to the inner LabelSelector.
func (*LabelSelectorWrapper) NotExist ¶ added in v1.16.0
func (s *LabelSelectorWrapper) NotExist(k string) *LabelSelectorWrapper
NotExist injects a matchExpression (with an operator NotExist) to the inner labelSelector.
func (*LabelSelectorWrapper) NotIn ¶ added in v1.16.0
func (s *LabelSelectorWrapper) NotIn(key string, vals []string) *LabelSelectorWrapper
NotIn injects a matchExpression (with an operator NotIn) to the inner labelSelector.
func (*LabelSelectorWrapper) Obj ¶ added in v1.16.0
func (s *LabelSelectorWrapper) Obj() *metav1.LabelSelector
Obj returns the inner LabelSelector.
type NodeSelectorWrapper ¶ added in v1.16.0
type NodeSelectorWrapper struct{ v1.NodeSelector }
NodeSelectorWrapper wraps a NodeSelector inside.
func MakeNodeSelector ¶ added in v1.16.0
func MakeNodeSelector() *NodeSelectorWrapper
MakeNodeSelector creates a NodeSelector wrapper.
func (*NodeSelectorWrapper) In ¶ added in v1.16.0
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 ¶ added in v1.16.0
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 ¶ added in v1.16.0
func (s *NodeSelectorWrapper) Obj() *v1.NodeSelector
Obj returns the inner NodeSelector.
type NodeWrapper ¶ added in v1.16.0
NodeWrapper wraps a Node inside.
func (*NodeWrapper) Annotation ¶ added in v1.30.0
func (n *NodeWrapper) Annotation(k, v string) *NodeWrapper
Annotation applies a {k,v} annotation pair to the inner node.
func (*NodeWrapper) Capacity ¶ added in v1.19.0
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 ¶ added in v1.30.0
func (n *NodeWrapper) Condition(typ v1.NodeConditionType, status v1.ConditionStatus, message, reason string) *NodeWrapper
Condition applies the node condition.
func (*NodeWrapper) Images ¶ added in v1.19.0
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 ¶ added in v1.16.0
func (n *NodeWrapper) Label(k, v string) *NodeWrapper
Label applies a {k,v} label pair to the inner node.
func (*NodeWrapper) Name ¶ added in v1.16.0
func (n *NodeWrapper) Name(s string) *NodeWrapper
Name sets `s` as the name of the inner pod.
func (*NodeWrapper) Obj ¶ added in v1.16.0
func (n *NodeWrapper) Obj() *v1.Node
Obj returns the inner Node.
func (*NodeWrapper) Taints ¶ added in v1.21.13
func (n *NodeWrapper) Taints(taints []v1.Taint) *NodeWrapper
Taints applies taints to the inner node.
func (*NodeWrapper) UID ¶ added in v1.18.0
func (n *NodeWrapper) UID(s string) *NodeWrapper
UID sets `s` as the UID of the inner pod.
func (*NodeWrapper) Unschedulable ¶ added in v1.30.0
func (n *NodeWrapper) Unschedulable(unschedulable bool) *NodeWrapper
Unschedulable applies the unschedulable field.
type PersistentVolumeClaimWrapper ¶ added in v1.26.0
type PersistentVolumeClaimWrapper struct{ v1.PersistentVolumeClaim }
PersistentVolumeClaimWrapper wraps a PersistentVolumeClaim inside.
func MakePersistentVolumeClaim ¶ added in v1.26.0
func MakePersistentVolumeClaim() *PersistentVolumeClaimWrapper
MakePersistentVolumeClaim creates a PersistentVolumeClaim wrapper.
func (*PersistentVolumeClaimWrapper) AccessModes ¶ added in v1.26.0
func (p *PersistentVolumeClaimWrapper) AccessModes(accessModes []v1.PersistentVolumeAccessMode) *PersistentVolumeClaimWrapper
AccessModes sets `accessModes` as the access modes of the inner PersistentVolumeClaim.
func (*PersistentVolumeClaimWrapper) Annotation ¶ added in v1.26.0
func (p *PersistentVolumeClaimWrapper) Annotation(key, value string) *PersistentVolumeClaimWrapper
Annotation sets a {k,v} pair to the inner PersistentVolumeClaim.
func (*PersistentVolumeClaimWrapper) Name ¶ added in v1.26.0
func (p *PersistentVolumeClaimWrapper) Name(s string) *PersistentVolumeClaimWrapper
Name sets `s` as the name of the inner PersistentVolumeClaim.
func (*PersistentVolumeClaimWrapper) Namespace ¶ added in v1.26.0
func (p *PersistentVolumeClaimWrapper) Namespace(s string) *PersistentVolumeClaimWrapper
Namespace sets `s` as the namespace of the inner PersistentVolumeClaim.
func (*PersistentVolumeClaimWrapper) Obj ¶ added in v1.26.0
func (p *PersistentVolumeClaimWrapper) Obj() *v1.PersistentVolumeClaim
Obj returns the inner PersistentVolumeClaim.
func (*PersistentVolumeClaimWrapper) Resources ¶ added in v1.26.0
func (p *PersistentVolumeClaimWrapper) Resources(resources v1.VolumeResourceRequirements) *PersistentVolumeClaimWrapper
Resources sets `resources` as the resource requirements of the inner PersistentVolumeClaim.
func (*PersistentVolumeClaimWrapper) VolumeName ¶ added in v1.26.0
func (p *PersistentVolumeClaimWrapper) VolumeName(name string) *PersistentVolumeClaimWrapper
VolumeName sets `name` as the volume name of the inner PersistentVolumeClaim.
type PersistentVolumeWrapper ¶ added in v1.26.0
type PersistentVolumeWrapper struct{ v1.PersistentVolume }
PersistentVolumeWrapper wraps a PersistentVolume inside.
func MakePersistentVolume ¶ added in v1.26.0
func MakePersistentVolume() *PersistentVolumeWrapper
MakePersistentVolume creates a PersistentVolume wrapper.
func (*PersistentVolumeWrapper) AccessModes ¶ added in v1.26.0
func (p *PersistentVolumeWrapper) AccessModes(accessModes []v1.PersistentVolumeAccessMode) *PersistentVolumeWrapper
AccessModes sets `accessModes` as the access modes of the inner PersistentVolume.
func (*PersistentVolumeWrapper) Capacity ¶ added in v1.26.0
func (p *PersistentVolumeWrapper) Capacity(capacity v1.ResourceList) *PersistentVolumeWrapper
Capacity sets `capacity` as the resource list of the inner PersistentVolume.
func (*PersistentVolumeWrapper) HostPathVolumeSource ¶ added in v1.26.0
func (p *PersistentVolumeWrapper) HostPathVolumeSource(src *v1.HostPathVolumeSource) *PersistentVolumeWrapper
HostPathVolumeSource sets `src` as the host path volume source of the inner PersistentVolume.
func (*PersistentVolumeWrapper) Name ¶ added in v1.26.0
func (p *PersistentVolumeWrapper) Name(s string) *PersistentVolumeWrapper
Name sets `s` as the name of the inner PersistentVolume.
func (*PersistentVolumeWrapper) NodeAffinityIn ¶ added in v1.27.14
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 ¶ added in v1.26.0
func (p *PersistentVolumeWrapper) Obj() *v1.PersistentVolume
Obj returns the inner PersistentVolume.
type PodAffinityKind ¶ added in v1.17.0
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 ¶ added in v1.26.0
type PodSchedulingWrapper struct {
resourcev1alpha2.PodSchedulingContext
}
PodSchedulingWrapper wraps a PodSchedulingContext inside.
func FromPodSchedulingContexts ¶ added in v1.27.0
func FromPodSchedulingContexts(other *resourcev1alpha2.PodSchedulingContext) *PodSchedulingWrapper
FromPodSchedulingContexts creates a PodSchedulingContext wrapper from an existing object.
func MakePodSchedulingContexts ¶ added in v1.27.0
func MakePodSchedulingContexts() *PodSchedulingWrapper
MakePodSchedulingContexts creates a PodSchedulingContext wrapper.
func (*PodSchedulingWrapper) Label ¶ added in v1.26.0
func (wrapper *PodSchedulingWrapper) Label(k, v string) *PodSchedulingWrapper
Label applies a {k,v} label pair to the inner object
func (*PodSchedulingWrapper) Name ¶ added in v1.26.0
func (wrapper *PodSchedulingWrapper) Name(s string) *PodSchedulingWrapper
Name sets `s` as the name of the inner object.
func (*PodSchedulingWrapper) Namespace ¶ added in v1.26.0
func (wrapper *PodSchedulingWrapper) Namespace(s string) *PodSchedulingWrapper
Namespace sets `s` as the namespace of the inner object.
func (*PodSchedulingWrapper) Obj ¶ added in v1.26.0
func (wrapper *PodSchedulingWrapper) Obj() *resourcev1alpha2.PodSchedulingContext
Obj returns the inner object.
func (*PodSchedulingWrapper) OwnerReference ¶ added in v1.26.0
func (wrapper *PodSchedulingWrapper) OwnerReference(name, uid string, gvk schema.GroupVersionKind) *PodSchedulingWrapper
OwnerReference updates the owning controller of the inner object.
func (*PodSchedulingWrapper) PotentialNodes ¶ added in v1.26.0
func (wrapper *PodSchedulingWrapper) PotentialNodes(nodes ...string) *PodSchedulingWrapper
PotentialNodes sets that field of the inner object.
func (*PodSchedulingWrapper) ResourceClaims ¶ added in v1.26.0
func (wrapper *PodSchedulingWrapper) ResourceClaims(statuses ...resourcev1alpha2.ResourceClaimSchedulingStatus) *PodSchedulingWrapper
ResourceClaims sets that field of the inner object.
func (*PodSchedulingWrapper) SelectedNode ¶ added in v1.26.0
func (wrapper *PodSchedulingWrapper) SelectedNode(s string) *PodSchedulingWrapper
SelectedNode sets that field of the inner object.
func (*PodSchedulingWrapper) UID ¶ added in v1.26.0
func (wrapper *PodSchedulingWrapper) UID(s string) *PodSchedulingWrapper
UID sets `s` as the UID of the inner object.
type PodWrapper ¶ added in v1.16.0
PodWrapper wraps a Pod inside.
func (*PodWrapper) Annotation ¶ added in v1.25.0
func (p *PodWrapper) Annotation(key, value string) *PodWrapper
Annotation sets a {k,v} pair to the inner pod annotation.
func (*PodWrapper) Annotations ¶ added in v1.25.0
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 ¶ added in v1.25.0
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 ¶ added in v1.25.0
func (p *PodWrapper) Conditions(conditions []v1.PodCondition) *PodWrapper
Conditions sets `conditions` as .status.Conditions of the inner pod.
func (*PodWrapper) Container ¶ added in v1.16.0
func (p *PodWrapper) Container(s string) *PodWrapper
Container appends a container into PodSpec of the inner pod.
func (*PodWrapper) ContainerPort ¶ added in v1.25.0
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 ¶ added in v1.25.0
func (p *PodWrapper) Containers(containers []v1.Container) *PodWrapper
Containers sets `containers` to the PodSpec of the inner pod.
func (*PodWrapper) CreationTimestamp ¶ added in v1.25.0
func (p *PodWrapper) CreationTimestamp(t metav1.Time) *PodWrapper
CreationTimestamp sets the inner pod's CreationTimestamp.
func (*PodWrapper) HostPort ¶ added in v1.22.0
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 ¶ added in v1.25.0
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 ¶ added in v1.16.0
func (p *PodWrapper) Label(k, v string) *PodWrapper
Label sets a {k,v} pair to the inner pod label.
func (*PodWrapper) Labels ¶ added in v1.25.0
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 ¶ added in v1.27.0
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 ¶ added in v1.16.0
func (p *PodWrapper) Name(s string) *PodWrapper
Name sets `s` as the name of the inner pod.
func (*PodWrapper) Namespace ¶ added in v1.16.0
func (p *PodWrapper) Namespace(s string) *PodWrapper
Namespace sets `s` as the namespace of the inner pod.
func (*PodWrapper) Node ¶ added in v1.16.0
func (p *PodWrapper) Node(s string) *PodWrapper
Node sets `s` as the nodeName of the inner pod.
func (*PodWrapper) NodeAffinityIn ¶ added in v1.16.0
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 ¶ added in v1.16.0
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 ¶ added in v1.16.0
func (p *PodWrapper) NodeSelector(m map[string]string) *PodWrapper
NodeSelector sets `m` as the nodeSelector of the inner pod.
func (*PodWrapper) NominatedNodeName ¶ added in v1.19.0
func (p *PodWrapper) NominatedNodeName(n string) *PodWrapper
NominatedNodeName sets `n` as the .Status.NominatedNodeName of the inner pod.
func (*PodWrapper) Obj ¶ added in v1.16.0
func (p *PodWrapper) Obj() *v1.Pod
Obj returns the inner Pod.
func (*PodWrapper) Overhead ¶ added in v1.24.0
func (p *PodWrapper) Overhead(rl v1.ResourceList) *PodWrapper
Overhead sets the give ResourceList to the inner pod
func (*PodWrapper) OwnerReference ¶ added in v1.22.0
func (p *PodWrapper) OwnerReference(name string, gvk schema.GroupVersionKind) *PodWrapper
OwnerReference updates the owning controller of the pod.
func (*PodWrapper) PVC ¶ added in v1.23.0
func (p *PodWrapper) PVC(name string) *PodWrapper
PVC creates a Volume with a PVC and injects into the inner pod.
func (*PodWrapper) Phase ¶ added in v1.25.0
func (p *PodWrapper) Phase(phase v1.PodPhase) *PodWrapper
Phase sets `phase` as .status.Phase of the inner pod.
func (*PodWrapper) PodAffinity ¶ added in v1.25.0
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 ¶ added in v1.17.0
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 ¶ added in v1.25.0
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 ¶ added in v1.25.0
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 ¶ added in v1.25.0
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 ¶ added in v1.25.0
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 ¶ added in v1.17.0
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 ¶ added in v1.25.0
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 ¶ added in v1.25.0
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 ¶ added in v1.25.0
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 ¶ added in v1.26.0
func (p *PodWrapper) PodResourceClaims(podResourceClaims ...v1.PodResourceClaim) *PodWrapper
PodResourceClaims appends PodResourceClaims into PodSpec of the inner pod.
func (*PodWrapper) PreemptionPolicy ¶ added in v1.19.0
func (p *PodWrapper) PreemptionPolicy(policy v1.PreemptionPolicy) *PodWrapper
PreemptionPolicy sets the give preemption policy to the inner pod.
func (*PodWrapper) Priority ¶ added in v1.16.0
func (p *PodWrapper) Priority(val int32) *PodWrapper
Priority sets a priority value into PodSpec of the inner pod.
func (*PodWrapper) Req ¶ added in v1.19.0
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 ¶ added in v1.27.0
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 ¶ added in v1.18.0
func (p *PodWrapper) SchedulerName(s string) *PodWrapper
SchedulerName sets `s` as the scheduler name of the inner pod.
func (*PodWrapper) SchedulingGates ¶ added in v1.26.0
func (p *PodWrapper) SchedulingGates(gates []string) *PodWrapper
SchedulingGates sets `gates` as additional SchedulerGates of the inner pod.
func (*PodWrapper) SpreadConstraint ¶ added in v1.16.0
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 ¶ added in v1.19.0
func (p *PodWrapper) StartTime(t metav1.Time) *PodWrapper
StartTime sets `t` as .status.startTime for the inner pod.
func (*PodWrapper) Terminating ¶ added in v1.18.0
func (p *PodWrapper) Terminating() *PodWrapper
Terminating sets the inner pod's deletionTimestamp to current timestamp.
func (*PodWrapper) Toleration ¶ added in v1.21.13
func (p *PodWrapper) Toleration(key string) *PodWrapper
Toleration creates a toleration (with the operator Exists) and injects into the inner pod.
func (*PodWrapper) UID ¶ added in v1.18.0
func (p *PodWrapper) UID(s string) *PodWrapper
UID sets `s` as the UID of the inner pod.
func (*PodWrapper) Volume ¶ added in v1.25.0
func (p *PodWrapper) Volume(volume v1.Volume) *PodWrapper
Volume creates volume and injects into the inner pod.
func (*PodWrapper) Volumes ¶ added in v1.29.0
func (p *PodWrapper) Volumes(volumes []v1.Volume) *PodWrapper
Volumes set the volumes and inject into the inner pod.
func (*PodWrapper) ZeroTerminationGracePeriod ¶ added in v1.16.0
func (p *PodWrapper) ZeroTerminationGracePeriod() *PodWrapper
ZeroTerminationGracePeriod sets the TerminationGracePeriodSeconds of the inner pod to zero.
type ResourceClaimWrapper ¶ added in v1.26.0
type ResourceClaimWrapper struct{ resourcev1alpha2.ResourceClaim }
ResourceClaimWrapper wraps a ResourceClaim inside.
func FromResourceClaim ¶ added in v1.26.0
func FromResourceClaim(other *resourcev1alpha2.ResourceClaim) *ResourceClaimWrapper
FromResourceClaim creates a ResourceClaim wrapper from some existing object.
func MakeResourceClaim ¶ added in v1.26.0
func MakeResourceClaim() *ResourceClaimWrapper
MakeResourceClaim creates a ResourceClaim wrapper.
func (*ResourceClaimWrapper) Allocation ¶ added in v1.26.0
func (wrapper *ResourceClaimWrapper) Allocation(driverName string, allocation *resourcev1alpha2.AllocationResult) *ResourceClaimWrapper
Allocation sets the allocation of the inner object.
func (*ResourceClaimWrapper) AllocationMode ¶ added in v1.26.0
func (wrapper *ResourceClaimWrapper) AllocationMode(a resourcev1alpha2.AllocationMode) *ResourceClaimWrapper
AllocationMode sets the allocation mode of the inner object.
func (*ResourceClaimWrapper) DeallocationRequested ¶ added in v1.26.0
func (wrapper *ResourceClaimWrapper) DeallocationRequested(deallocationRequested bool) *ResourceClaimWrapper
DeallocationRequested sets that field of the inner object.
func (*ResourceClaimWrapper) Name ¶ added in v1.26.0
func (wrapper *ResourceClaimWrapper) Name(s string) *ResourceClaimWrapper
Name sets `s` as the name of the inner object.
func (*ResourceClaimWrapper) Namespace ¶ added in v1.26.0
func (wrapper *ResourceClaimWrapper) Namespace(s string) *ResourceClaimWrapper
Namespace sets `s` as the namespace of the inner object.
func (*ResourceClaimWrapper) Obj ¶ added in v1.26.0
func (wrapper *ResourceClaimWrapper) Obj() *resourcev1alpha2.ResourceClaim
Obj returns the inner ResourceClaim.
func (*ResourceClaimWrapper) OwnerReference ¶ added in v1.26.0
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 ¶ added in v1.26.0
func (wrapper *ResourceClaimWrapper) ReservedFor(consumers ...resourcev1alpha2.ResourceClaimConsumerReference) *ResourceClaimWrapper
ReservedFor sets that field of the inner object.
func (*ResourceClaimWrapper) ReservedForPod ¶ added in v1.31.0
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 ¶ added in v1.26.0
func (wrapper *ResourceClaimWrapper) ResourceClassName(name string) *ResourceClaimWrapper
ResourceClassName sets the resource class name of the inner object.
func (*ResourceClaimWrapper) Structured ¶ added in v1.31.0
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 ¶ added in v1.26.0
func (wrapper *ResourceClaimWrapper) UID(s string) *ResourceClaimWrapper
UID sets `s` as the UID of the inner object.
type ResourceSliceWrapper ¶ added in v1.31.0
type ResourceSliceWrapper struct {
resourcev1alpha2.ResourceSlice
}
func MakeResourceSlice ¶ added in v1.31.0
func MakeResourceSlice(nodeName, driverName string) *ResourceSliceWrapper
func (*ResourceSliceWrapper) NamedResourcesInstances ¶
func (wrapper *ResourceSliceWrapper) NamedResourcesInstances(names ...string) *ResourceSliceWrapper
func (*ResourceSliceWrapper) Obj ¶ added in v1.31.0
func (wrapper *ResourceSliceWrapper) Obj() *resourcev1alpha2.ResourceSlice