var zero … type NodeSelectorWrapper … // MakeNodeSelector creates a NodeSelector wrapper. func MakeNodeSelector() *NodeSelectorWrapper { … } type NodeSelectorType … const NodeSelectorTypeMatchExpressions … const NodeSelectorTypeMatchFields … // In injects a matchExpression (with an operator IN) as a selectorTerm // to the inner nodeSelector. // NOTE: appended selecterTerms are ORed. func (s *NodeSelectorWrapper) In(key string, vals []string, t NodeSelectorType) *NodeSelectorWrapper { … } // NotIn injects a matchExpression (with an operator NotIn) as a selectorTerm // to the inner nodeSelector. func (s *NodeSelectorWrapper) NotIn(key string, vals []string) *NodeSelectorWrapper { … } // Obj returns the inner NodeSelector. func (s *NodeSelectorWrapper) Obj() *v1.NodeSelector { … } type LabelSelectorWrapper … // MakeLabelSelector creates a LabelSelector wrapper. func MakeLabelSelector() *LabelSelectorWrapper { … } // Label applies a {k,v} pair to the inner LabelSelector. func (s *LabelSelectorWrapper) Label(k, v string) *LabelSelectorWrapper { … } // In injects a matchExpression (with an operator In) to the inner labelSelector. func (s *LabelSelectorWrapper) In(key string, vals []string) *LabelSelectorWrapper { … } // NotIn injects a matchExpression (with an operator NotIn) to the inner labelSelector. func (s *LabelSelectorWrapper) NotIn(key string, vals []string) *LabelSelectorWrapper { … } // Exists injects a matchExpression (with an operator Exists) to the inner labelSelector. func (s *LabelSelectorWrapper) Exists(k string) *LabelSelectorWrapper { … } // NotExist injects a matchExpression (with an operator NotExist) to the inner labelSelector. func (s *LabelSelectorWrapper) NotExist(k string) *LabelSelectorWrapper { … } // Obj returns the inner LabelSelector. func (s *LabelSelectorWrapper) Obj() *metav1.LabelSelector { … } type ContainerWrapper … // MakeContainer creates a Container wrapper. func MakeContainer() *ContainerWrapper { … } // Obj returns the inner Container. func (c *ContainerWrapper) Obj() v1.Container { … } // Name sets `n` as the name of the inner Container. func (c *ContainerWrapper) Name(n string) *ContainerWrapper { … } // Image sets `image` as the image of the inner Container. func (c *ContainerWrapper) Image(image string) *ContainerWrapper { … } // HostPort sets `hostPort` as the host port of the inner Container. func (c *ContainerWrapper) HostPort(hostPort int32) *ContainerWrapper { … } // ContainerPort sets `ports` as the ports of the inner Container. func (c *ContainerWrapper) ContainerPort(ports []v1.ContainerPort) *ContainerWrapper { … } // Resources sets the container resources to the given resource map. func (c *ContainerWrapper) Resources(resMap map[v1.ResourceName]string) *ContainerWrapper { … } // ResourceRequests sets the container resources requests to the given resource map of requests. func (c *ContainerWrapper) ResourceRequests(reqMap map[v1.ResourceName]string) *ContainerWrapper { … } // ResourceLimits sets the container resource limits to the given resource map. func (c *ContainerWrapper) ResourceLimits(limMap map[v1.ResourceName]string) *ContainerWrapper { … } // RestartPolicy sets the container's restartPolicy to the given restartPolicy. func (c *ContainerWrapper) RestartPolicy(restartPolicy v1.ContainerRestartPolicy) *ContainerWrapper { … } type PodDisruptionBudgetWrapper … // MakePDB creates a PodDisruptionBudget wrapper. func MakePDB() *PodDisruptionBudgetWrapper { … } // Obj returns the inner PodDisruptionBudget. func (p *PodDisruptionBudgetWrapper) Obj() *policy.PodDisruptionBudget { … } // Name sets `name` as the name of the inner PodDisruptionBudget. func (p *PodDisruptionBudgetWrapper) Name(name string) *PodDisruptionBudgetWrapper { … } // Namespace sets `namespace` as the namespace of the inner PodDisruptionBudget. func (p *PodDisruptionBudgetWrapper) Namespace(namespace string) *PodDisruptionBudgetWrapper { … } // MinAvailable sets `minAvailable` to the inner PodDisruptionBudget.Spec.MinAvailable. func (p *PodDisruptionBudgetWrapper) MinAvailable(minAvailable string) *PodDisruptionBudgetWrapper { … } // MatchLabel adds a {key,value} to the inner PodDisruptionBudget.Spec.Selector.MatchLabels. func (p *PodDisruptionBudgetWrapper) MatchLabel(key, value string) *PodDisruptionBudgetWrapper { … } // DisruptionsAllowed sets `disruptionsAllowed` to the inner PodDisruptionBudget.Status.DisruptionsAllowed. func (p *PodDisruptionBudgetWrapper) DisruptionsAllowed(disruptionsAllowed int32) *PodDisruptionBudgetWrapper { … } type PodWrapper … // MakePod creates a Pod wrapper. func MakePod() *PodWrapper { … } // Obj returns the inner Pod. func (p *PodWrapper) Obj() *v1.Pod { … } // Name sets `s` as the name of the inner pod. func (p *PodWrapper) Name(s string) *PodWrapper { … } // UID sets `s` as the UID of the inner pod. func (p *PodWrapper) UID(s string) *PodWrapper { … } // SchedulerName sets `s` as the scheduler name of the inner pod. func (p *PodWrapper) SchedulerName(s string) *PodWrapper { … } // Namespace sets `s` as the namespace of the inner pod. func (p *PodWrapper) Namespace(s string) *PodWrapper { … } // OwnerReference updates the owning controller of the pod. func (p *PodWrapper) OwnerReference(name string, gvk schema.GroupVersionKind) *PodWrapper { … } // Container appends a container into PodSpec of the inner pod. func (p *PodWrapper) Container(s string) *PodWrapper { … } // Containers sets `containers` to the PodSpec of the inner pod. func (p *PodWrapper) Containers(containers []v1.Container) *PodWrapper { … } // PodResourceClaims appends PodResourceClaims into PodSpec of the inner pod. func (p *PodWrapper) PodResourceClaims(podResourceClaims ...v1.PodResourceClaim) *PodWrapper { … } // PodResourceClaims appends claim statuses into PodSpec of the inner pod. func (p *PodWrapper) ResourceClaimStatuses(resourceClaimStatuses ...v1.PodResourceClaimStatus) *PodWrapper { … } // Priority sets a priority value into PodSpec of the inner pod. func (p *PodWrapper) Priority(val int32) *PodWrapper { … } // CreationTimestamp sets the inner pod's CreationTimestamp. func (p *PodWrapper) CreationTimestamp(t metav1.Time) *PodWrapper { … } // Terminating sets the inner pod's deletionTimestamp to current timestamp. func (p *PodWrapper) Terminating() *PodWrapper { … } // ZeroTerminationGracePeriod sets the TerminationGracePeriodSeconds of the inner pod to zero. func (p *PodWrapper) ZeroTerminationGracePeriod() *PodWrapper { … } // Node sets `s` as the nodeName of the inner pod. func (p *PodWrapper) Node(s string) *PodWrapper { … } // NodeSelector sets `m` as the nodeSelector of the inner pod. func (p *PodWrapper) NodeSelector(m map[string]string) *PodWrapper { … } // NodeAffinityIn creates a HARD node affinity (with the operator In) // and injects into the inner pod. func (p *PodWrapper) NodeAffinityIn(key string, vals []string, t NodeSelectorType) *PodWrapper { … } // NodeAffinityNotIn creates a HARD node affinity (with MatchExpressinos and the operator NotIn) // and injects into the inner pod. func (p *PodWrapper) NodeAffinityNotIn(key string, vals []string) *PodWrapper { … } // StartTime sets `t` as .status.startTime for the inner pod. func (p *PodWrapper) StartTime(t metav1.Time) *PodWrapper { … } // NominatedNodeName sets `n` as the .Status.NominatedNodeName of the inner pod. func (p *PodWrapper) NominatedNodeName(n string) *PodWrapper { … } // Phase sets `phase` as .status.Phase of the inner pod. func (p *PodWrapper) Phase(phase v1.PodPhase) *PodWrapper { … } // Condition adds a `condition(Type, Status, Reason)` to .Status.Conditions. func (p *PodWrapper) Condition(t v1.PodConditionType, s v1.ConditionStatus, r string) *PodWrapper { … } // Conditions sets `conditions` as .status.Conditions of the inner pod. func (p *PodWrapper) Conditions(conditions []v1.PodCondition) *PodWrapper { … } // Toleration creates a toleration (with the operator Exists) // and injects into the inner pod. func (p *PodWrapper) Toleration(key string) *PodWrapper { … } // HostPort creates a container with a hostPort valued `hostPort`, // and injects into the inner pod. func (p *PodWrapper) HostPort(port int32) *PodWrapper { … } // ContainerPort creates a container with ports valued `ports`, // and injects into the inner pod. func (p *PodWrapper) ContainerPort(ports []v1.ContainerPort) *PodWrapper { … } // PVC creates a Volume with a PVC and injects into the inner pod. func (p *PodWrapper) PVC(name string) *PodWrapper { … } // Volume creates volume and injects into the inner pod. func (p *PodWrapper) Volume(volume v1.Volume) *PodWrapper { … } // Volumes set the volumes and inject into the inner pod. func (p *PodWrapper) Volumes(volumes []v1.Volume) *PodWrapper { … } // SchedulingGates sets `gates` as additional SchedulerGates of the inner pod. func (p *PodWrapper) SchedulingGates(gates []string) *PodWrapper { … } type PodAffinityKind … const NilPodAffinity … const PodAffinityWithRequiredReq … const PodAffinityWithPreferredReq … const PodAffinityWithRequiredPreferredReq … const PodAntiAffinityWithRequiredReq … const PodAntiAffinityWithPreferredReq … const PodAntiAffinityWithRequiredPreferredReq … // PodAffinity creates a PodAffinity with topology key and label selector // and injects into the inner pod. func (p *PodWrapper) PodAffinity(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 (p *PodWrapper) PodAntiAffinity(topologyKey string, labelSelector *metav1.LabelSelector, kind PodAffinityKind) *PodWrapper { … } // PodAffinityExists creates a PodAffinity with the operator "Exists" // and injects into the inner pod. func (p *PodWrapper) PodAffinityExists(labelKey, topologyKey string, kind PodAffinityKind) *PodWrapper { … } // PodAntiAffinityExists creates a PodAntiAffinity with the operator "Exists" // and injects into the inner pod. func (p *PodWrapper) PodAntiAffinityExists(labelKey, topologyKey string, kind PodAffinityKind) *PodWrapper { … } // PodAffinityNotExists creates a PodAffinity with the operator "NotExists" // and injects into the inner pod. func (p *PodWrapper) PodAffinityNotExists(labelKey, topologyKey string, kind PodAffinityKind) *PodWrapper { … } // PodAntiAffinityNotExists creates a PodAntiAffinity with the operator "NotExists" // and injects into the inner pod. func (p *PodWrapper) PodAntiAffinityNotExists(labelKey, topologyKey string, kind PodAffinityKind) *PodWrapper { … } // PodAffinityIn creates a PodAffinity with the operator "In" // and injects into the inner pod. func (p *PodWrapper) PodAffinityIn(labelKey, topologyKey string, vals []string, kind PodAffinityKind) *PodWrapper { … } // PodAntiAffinityIn creates a PodAntiAffinity with the operator "In" // and injects into the inner pod. func (p *PodWrapper) PodAntiAffinityIn(labelKey, topologyKey string, vals []string, kind PodAffinityKind) *PodWrapper { … } // PodAffinityNotIn creates a PodAffinity with the operator "NotIn" // and injects into the inner pod. func (p *PodWrapper) PodAffinityNotIn(labelKey, topologyKey string, vals []string, kind PodAffinityKind) *PodWrapper { … } // PodAntiAffinityNotIn creates a PodAntiAffinity with the operator "NotIn" // and injects into the inner pod. func (p *PodWrapper) PodAntiAffinityNotIn(labelKey, topologyKey string, vals []string, kind PodAffinityKind) *PodWrapper { … } // SpreadConstraint constructs a TopologySpreadConstraint object and injects // into the inner pod. func (p *PodWrapper) SpreadConstraint(maxSkew int, tpKey string, mode v1.UnsatisfiableConstraintAction, selector *metav1.LabelSelector, minDomains *int32, nodeAffinityPolicy, nodeTaintsPolicy *v1.NodeInclusionPolicy, matchLabelKeys []string) *PodWrapper { … } // Label sets a {k,v} pair to the inner pod label. func (p *PodWrapper) Label(k, v string) *PodWrapper { … } // Labels sets all {k,v} pair provided by `labels` to the inner pod labels. func (p *PodWrapper) Labels(labels map[string]string) *PodWrapper { … } // Annotation sets a {k,v} pair to the inner pod annotation. func (p *PodWrapper) Annotation(key, value string) *PodWrapper { … } // Annotations sets all {k,v} pair provided by `annotations` to the inner pod annotations. func (p *PodWrapper) Annotations(annotations map[string]string) *PodWrapper { … } // Res adds a new container to the inner pod with given resource map. func (p *PodWrapper) Res(resMap map[v1.ResourceName]string) *PodWrapper { … } // Req adds a new container to the inner pod with given resource map of requests. func (p *PodWrapper) Req(reqMap map[v1.ResourceName]string) *PodWrapper { … } // Lim adds a new container to the inner pod with given resource map of limits. func (p *PodWrapper) Lim(limMap map[v1.ResourceName]string) *PodWrapper { … } // InitReq adds a new init container to the inner pod with given resource map. func (p *PodWrapper) InitReq(resMap map[v1.ResourceName]string) *PodWrapper { … } // SidecarReq adds a new sidecar container to the inner pod with given resource map. func (p *PodWrapper) SidecarReq(resMap map[v1.ResourceName]string) *PodWrapper { … } // PreemptionPolicy sets the give preemption policy to the inner pod. func (p *PodWrapper) PreemptionPolicy(policy v1.PreemptionPolicy) *PodWrapper { … } // Overhead sets the give ResourceList to the inner pod func (p *PodWrapper) Overhead(rl v1.ResourceList) *PodWrapper { … } type NodeWrapper … // MakeNode creates a Node wrapper. func MakeNode() *NodeWrapper { … } // Obj returns the inner Node. func (n *NodeWrapper) Obj() *v1.Node { … } // Name sets `s` as the name of the inner pod. func (n *NodeWrapper) Name(s string) *NodeWrapper { … } // UID sets `s` as the UID of the inner pod. func (n *NodeWrapper) UID(s string) *NodeWrapper { … } // Label applies a {k,v} label pair to the inner node. func (n *NodeWrapper) Label(k, v string) *NodeWrapper { … } // Annotation applies a {k,v} annotation pair to the inner node. func (n *NodeWrapper) Annotation(k, v 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 (n *NodeWrapper) Capacity(resources map[v1.ResourceName]string) *NodeWrapper { … } // Images sets the images of the inner node. Each entry in `images` corresponds // to an image name and its size in bytes. func (n *NodeWrapper) Images(images map[string]int64) *NodeWrapper { … } // Taints applies taints to the inner node. func (n *NodeWrapper) Taints(taints []v1.Taint) *NodeWrapper { … } // Unschedulable applies the unschedulable field. func (n *NodeWrapper) Unschedulable(unschedulable bool) *NodeWrapper { … } // Condition applies the node condition. func (n *NodeWrapper) Condition(typ v1.NodeConditionType, status v1.ConditionStatus, message, reason string) *NodeWrapper { … } type PersistentVolumeClaimWrapper … // MakePersistentVolumeClaim creates a PersistentVolumeClaim wrapper. func MakePersistentVolumeClaim() *PersistentVolumeClaimWrapper { … } // Obj returns the inner PersistentVolumeClaim. func (p *PersistentVolumeClaimWrapper) Obj() *v1.PersistentVolumeClaim { … } // Name sets `s` as the name of the inner PersistentVolumeClaim. func (p *PersistentVolumeClaimWrapper) Name(s string) *PersistentVolumeClaimWrapper { … } // Namespace sets `s` as the namespace of the inner PersistentVolumeClaim. func (p *PersistentVolumeClaimWrapper) Namespace(s string) *PersistentVolumeClaimWrapper { … } // Annotation sets a {k,v} pair to the inner PersistentVolumeClaim. func (p *PersistentVolumeClaimWrapper) Annotation(key, value string) *PersistentVolumeClaimWrapper { … } // VolumeName sets `name` as the volume name of the inner // PersistentVolumeClaim. func (p *PersistentVolumeClaimWrapper) VolumeName(name string) *PersistentVolumeClaimWrapper { … } // AccessModes sets `accessModes` as the access modes of the inner // PersistentVolumeClaim. func (p *PersistentVolumeClaimWrapper) AccessModes(accessModes []v1.PersistentVolumeAccessMode) *PersistentVolumeClaimWrapper { … } // Resources sets `resources` as the resource requirements of the inner // PersistentVolumeClaim. func (p *PersistentVolumeClaimWrapper) Resources(resources v1.VolumeResourceRequirements) *PersistentVolumeClaimWrapper { … } type PersistentVolumeWrapper … // MakePersistentVolume creates a PersistentVolume wrapper. func MakePersistentVolume() *PersistentVolumeWrapper { … } // Obj returns the inner PersistentVolume. func (p *PersistentVolumeWrapper) Obj() *v1.PersistentVolume { … } // Name sets `s` as the name of the inner PersistentVolume. func (p *PersistentVolumeWrapper) Name(s string) *PersistentVolumeWrapper { … } // AccessModes sets `accessModes` as the access modes of the inner // PersistentVolume. func (p *PersistentVolumeWrapper) AccessModes(accessModes []v1.PersistentVolumeAccessMode) *PersistentVolumeWrapper { … } // Capacity sets `capacity` as the resource list of the inner PersistentVolume. func (p *PersistentVolumeWrapper) Capacity(capacity v1.ResourceList) *PersistentVolumeWrapper { … } // HostPathVolumeSource sets `src` as the host path volume source of the inner // PersistentVolume. func (p *PersistentVolumeWrapper) HostPathVolumeSource(src *v1.HostPathVolumeSource) *PersistentVolumeWrapper { … } // NodeAffinityIn creates a HARD node affinity (with MatchExpressions and the operator In) // and injects into the pv. func (p *PersistentVolumeWrapper) NodeAffinityIn(key string, vals []string) *PersistentVolumeWrapper { … } // Labels sets all {k,v} pair provided by `labels` to the pv. func (p *PersistentVolumeWrapper) Labels(labels map[string]string) *PersistentVolumeWrapper { … } // Label sets a {k,v} pair to the pv. func (p *PersistentVolumeWrapper) Label(k, v string) *PersistentVolumeWrapper { … } type ResourceClaimWrapper … // MakeResourceClaim creates a ResourceClaim wrapper. func MakeResourceClaim() *ResourceClaimWrapper { … } // FromResourceClaim creates a ResourceClaim wrapper from some existing object. func FromResourceClaim(other *resourceapi.ResourceClaim) *ResourceClaimWrapper { … } // Obj returns the inner ResourceClaim. func (wrapper *ResourceClaimWrapper) Obj() *resourceapi.ResourceClaim { … } // Name sets `s` as the name of the inner object. func (wrapper *ResourceClaimWrapper) Name(s string) *ResourceClaimWrapper { … } // UID sets `s` as the UID of the inner object. func (wrapper *ResourceClaimWrapper) UID(s string) *ResourceClaimWrapper { … } // Namespace sets `s` as the namespace of the inner object. func (wrapper *ResourceClaimWrapper) Namespace(s string) *ResourceClaimWrapper { … } // OwnerReference updates the owning controller of the object. func (wrapper *ResourceClaimWrapper) OwnerReference(name, uid string, gvk schema.GroupVersionKind) *ResourceClaimWrapper { … } // Request adds one device request for the given device class. func (wrapper *ResourceClaimWrapper) Request(deviceClassName string) *ResourceClaimWrapper { … } // Allocation sets the allocation of the inner object. func (wrapper *ResourceClaimWrapper) Allocation(allocation *resourceapi.AllocationResult) *ResourceClaimWrapper { … } // Deleting sets the deletion timestamp of the inner object. func (wrapper *ResourceClaimWrapper) Deleting(time metav1.Time) *ResourceClaimWrapper { … } // ReservedFor sets that field of the inner object. func (wrapper *ResourceClaimWrapper) ReservedFor(consumers ...resourceapi.ResourceClaimConsumerReference) *ResourceClaimWrapper { … } // ReservedForPod sets that field of the inner object given information about one pod. func (wrapper *ResourceClaimWrapper) ReservedForPod(podName string, podUID types.UID) *ResourceClaimWrapper { … } type ResourceSliceWrapper … func MakeResourceSlice(nodeName, driverName string) *ResourceSliceWrapper { … } // FromResourceSlice creates a ResourceSlice wrapper from some existing object. func FromResourceSlice(other *resourceapi.ResourceSlice) *ResourceSliceWrapper { … } func (wrapper *ResourceSliceWrapper) Obj() *resourceapi.ResourceSlice { … } // Devices sets the devices field of the inner object. func (wrapper *ResourceSliceWrapper) Devices(names ...string) *ResourceSliceWrapper { … } // Device sets the devices field of the inner object. func (wrapper *ResourceSliceWrapper) Device(name string, attrs map[resourceapi.QualifiedName]resourceapi.DeviceAttribute) *ResourceSliceWrapper { … } type StorageClassWrapper … // MakeStorageClass creates a StorageClass wrapper. func MakeStorageClass() *StorageClassWrapper { … } // Obj returns the inner StorageClass. func (s *StorageClassWrapper) Obj() *storagev1.StorageClass { … } // Name sets `n` as the name of the inner StorageClass. func (s *StorageClassWrapper) Name(n string) *StorageClassWrapper { … } // VolumeBindingMode sets mode as the mode of the inner StorageClass. func (s *StorageClassWrapper) VolumeBindingMode(mode storagev1.VolumeBindingMode) *StorageClassWrapper { … } // Provisoner sets p as the provisioner of the inner StorageClass. func (s *StorageClassWrapper) Provisioner(p string) *StorageClassWrapper { … }
Codebase Browser
kubernetes