Documentation
¶
Index ¶
- func AddOrUpdateTolerationInPodSpec(spec *v1.PodSpec, toleration *v1.Toleration) bool
- func ContainsAccessMode(modes []v1.PersistentVolumeAccessMode, mode v1.PersistentVolumeAccessMode) bool
- func GetAccessModesAsString(modes []v1.PersistentVolumeAccessMode) string
- func GetAccessModesFromString(modes string) []v1.PersistentVolumeAccessMode
- func GetMatchingTolerations(taints []v1.Taint, tolerations []v1.Toleration) (bool, []v1.Toleration)
- func HugePageResourceName(pageSize resource.Quantity) v1.ResourceName
- func HugePageSizeFromMedium(medium v1.StorageMedium) (resource.Quantity, error)
- func HugePageSizeFromResourceName(name v1.ResourceName) (resource.Quantity, error)
- func HugePageUnitSizeFromByteSize(size int64) (string, error)
- func IsAttachableVolumeResourceName(name v1.ResourceName) bool
- func IsExtendedResourceName(name v1.ResourceName) bool
- func IsHugePageMedium(medium v1.StorageMedium) bool
- func IsHugePageResourceName(name v1.ResourceName) bool
- func IsNativeResource(name v1.ResourceName) bool
- func IsOvercommitAllowed(name v1.ResourceName) bool
- func IsPrefixedNativeResource(name v1.ResourceName) bool
- func IsServiceIPSet(service *v1.Service) bool
- func LoadBalancerStatusEqual(l, r *v1.LoadBalancerStatus) bool
- func MatchTopologySelectorTerms(topologySelectorTerms []v1.TopologySelectorTerm, lbls labels.Set) bool
- func NodeSelectorRequirementKeysExistInNodeSelectorTerms(reqs []v1.NodeSelectorRequirement, terms []v1.NodeSelectorTerm) bool
- func ScopedResourceSelectorRequirementsAsSelector(ssr v1.ScopedResourceSelectorRequirement) (labels.Selector, error)
- func TopologySelectorRequirementsAsSelector(tsm []v1.TopologySelectorLabelRequirement) (labels.Selector, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddOrUpdateTolerationInPodSpec ¶
func AddOrUpdateTolerationInPodSpec(spec *v1.PodSpec, toleration *v1.Toleration) bool
AddOrUpdateTolerationInPodSpec tries to add a toleration to the toleration list in PodSpec. Returns true if something was updated, false otherwise.
func ContainsAccessMode ¶
func ContainsAccessMode(modes []v1.PersistentVolumeAccessMode, mode v1.PersistentVolumeAccessMode) bool
func GetAccessModesAsString ¶
func GetAccessModesAsString(modes []v1.PersistentVolumeAccessMode) string
GetAccessModesAsString returns a string representation of an array of access modes. modes, when present, are always in the same order: RWO,ROX,RWX,RWOP.
func GetAccessModesFromString ¶
func GetAccessModesFromString(modes string) []v1.PersistentVolumeAccessMode
GetAccessModesFromString returns an array of AccessModes from a string created by GetAccessModesAsString
func GetMatchingTolerations ¶
func GetMatchingTolerations(taints []v1.Taint, tolerations []v1.Toleration) (bool, []v1.Toleration)
GetMatchingTolerations returns true and list of Tolerations matching all Taints if all are tolerated, or false otherwise.
func HugePageResourceName ¶
func HugePageResourceName(pageSize resource.Quantity) v1.ResourceName
HugePageResourceName returns a ResourceName with the canonical hugepage prefix prepended for the specified page size. The page size is converted to its canonical representation.
func HugePageSizeFromMedium ¶
func HugePageSizeFromMedium(medium v1.StorageMedium) (resource.Quantity, error)
HugePageSizeFromMedium returns the page size for the specified huge page medium. If the specified input is not a valid huge page medium an error is returned.
func HugePageSizeFromResourceName ¶
func HugePageSizeFromResourceName(name v1.ResourceName) (resource.Quantity, error)
HugePageSizeFromResourceName returns the page size for the specified huge page resource name. If the specified input is not a valid huge page resource name an error is returned.
func HugePageUnitSizeFromByteSize ¶
HugePageUnitSizeFromByteSize returns hugepage size has the format. `size` must be guaranteed to divisible into the largest units that can be expressed. <size><unit-prefix>B (1024 = "1KB", 1048576 = "1MB", etc).
func IsAttachableVolumeResourceName ¶
func IsAttachableVolumeResourceName(name v1.ResourceName) bool
IsAttachableVolumeResourceName returns true when the resource name is prefixed in attachable volume
func IsExtendedResourceName ¶
func IsExtendedResourceName(name v1.ResourceName) bool
IsExtendedResourceName returns true if: 1. the resource name is not in the default namespace; 2. resource name does not have "requests." prefix, to avoid confusion with the convention in quota 3. it satisfies the rules in IsQualifiedName() after converted into quota resource name
func IsHugePageMedium ¶
func IsHugePageMedium(medium v1.StorageMedium) bool
IsHugePageMedium returns true if the volume medium is in 'HugePages[-size]' format
func IsHugePageResourceName ¶
func IsHugePageResourceName(name v1.ResourceName) bool
IsHugePageResourceName returns true if the resource name has the huge page resource prefix.
func IsNativeResource ¶
func IsNativeResource(name v1.ResourceName) bool
IsNativeResource returns true if the resource name is in the *kubernetes.io/ namespace. Partially-qualified (unprefixed) names are implicitly in the kubernetes.io/ namespace.
func IsOvercommitAllowed ¶
func IsOvercommitAllowed(name v1.ResourceName) bool
IsOvercommitAllowed returns true if the resource is in the default namespace and is not hugepages.
func IsPrefixedNativeResource ¶
func IsPrefixedNativeResource(name v1.ResourceName) bool
IsPrefixedNativeResource returns true if the resource name is in the *kubernetes.io/ namespace.
func IsServiceIPSet ¶
IsServiceIPSet aims to check if the service's ClusterIP is set or not the objective is not to perform validation here
func LoadBalancerStatusEqual ¶
func LoadBalancerStatusEqual(l, r *v1.LoadBalancerStatus) bool
LoadBalancerStatusEqual evaluates the given load balancers' ingress IP addresses and hostnames and returns true if equal or false if otherwise TODO: make method on LoadBalancerStatus?
func MatchTopologySelectorTerms ¶
func MatchTopologySelectorTerms(topologySelectorTerms []v1.TopologySelectorTerm, lbls labels.Set) bool
MatchTopologySelectorTerms checks whether given labels match topology selector terms in ORed; nil or empty term matches no objects; while empty term list matches all objects.
func NodeSelectorRequirementKeysExistInNodeSelectorTerms ¶
func NodeSelectorRequirementKeysExistInNodeSelectorTerms(reqs []v1.NodeSelectorRequirement, terms []v1.NodeSelectorTerm) bool
NodeSelectorRequirementKeysExistInNodeSelectorTerms checks if a NodeSelectorTerm with key is already specified in terms
func ScopedResourceSelectorRequirementsAsSelector ¶
func ScopedResourceSelectorRequirementsAsSelector(ssr v1.ScopedResourceSelectorRequirement) (labels.Selector, error)
ScopedResourceSelectorRequirementsAsSelector converts the ScopedResourceSelectorRequirement api type into a struct that implements labels.Selector.
func TopologySelectorRequirementsAsSelector ¶
func TopologySelectorRequirementsAsSelector(tsm []v1.TopologySelectorLabelRequirement) (labels.Selector, error)
TopologySelectorRequirementsAsSelector converts the []TopologySelectorLabelRequirement api type into a struct that implements labels.Selector.
Types ¶
This section is empty.
Source Files
Directories