util

Sep 7, 2023

Changes in this version

+ func ConvertComputeResourceToResourceGroups(cr v12.ComputeResource, shape v12.ComputeResource) v13.ResourceGroups

+ func ConvertResourceGroupsToComputeResource(groups v13.ResourceGroups) v12.ComputeResource

Jun 9, 2022

Changes in this version

+ func GetNormalizedCapacityGroupName(c *v1.CapacityGroup) string

Apr 26, 2021

Changes in this version

+ var ComputeResourcesUnitProportional = titusPool.ComputeResource

+ var MachineFromUnitProportional96 = func() *machineTypeV1.MachineTypeConfig

Mar 22, 2021

Changes in this version

+ func GetGpu(limits v1.ResourceList) int64

Feb 12, 2021

Changes in this version

+ var ComputeResourceLowCPU = v1.ComputeResource

+ var ComputeResourcesHighCPU = v1.ComputeResource

Feb 4, 2021

Changes in this version

+ var ComputeResourceLowCpu = v1.ComputeResource

+ var ComputeResourcesHighCpu = v1.ComputeResource

+ var ComputeResourcesRegular = v1.ComputeResource

+ func ButPodCapacityGroup(pod *v1.Pod, capacityGroup string) *v1.Pod

Jan 28, 2021

Changes in this version

+ func ButNodeLabel(node *v1.Node, key string, value string) *v1.Node

Jan 22, 2021

Changes in this version

+ const OneMBPS

+ const OneMegaByte

+ const ResourceGpu

+ const ResourceNetwork

+ const ResourcePoolElastic

+ const True

+ var M5Metal = func() *v1.MachineTypeConfig

+ var R5Metal = func() *v1.MachineTypeConfig

+ var TheBiggestMachineThatCouldBe = func() *v1.MachineTypeConfig

+ var TheBiggestMachineThatCouldBeResources = TheBiggestMachineThatCouldBe().Spec.ComputeResource

+ func ButNodeCreatedTimestamp(node *v1.Node, timestamp time.Time) *v1.Node

+ func ButNodeDecommissioned(source string, node *v1.Node) *v1.Node

+ func ButNodeRemovable(node *v1.Node) *v1.Node

+ func ButNodeScalingDown(source string, node *v1.Node) *v1.Node

+ func ButNodeWithTaint(node *v1.Node, taint *v1.Taint) *v1.Node

+ func ButPodAssignedToNode(pod *v1.Pod, node *v1.Node) *v1.Pod

+ func ButPodName(pod *v1.Pod, name string) *v1.Pod

+ func ButPodResourcePools(pod *v1.Pod, resourcePools ...string) *v1.Pod

+ func ButPodRunningOnNode(pod *v1.Pod, node *v1.Node) *v1.Pod

+ func CountNotScheduledPods(pods []*v1.Pod) int64

+ func FilterRunningPods(pods []*v1.Pod) []*v1.Pod

+ func FindLabel(labels map[string]string, labelName string) (string, bool)

+ func FindNotScheduledPods(pods []*v1.Pod) []*v1.Pod

+ func FindOldNotScheduledPods(pods []*v1.Pod, youngPodThreshold time.Duration, now time.Time) []*v1.Pod

+ func FindPodAssignedResourcePools(pod *v1.Pod) ([]string, bool)

+ func FindPodPrimaryResourcePool(pod *v1.Pod) (string, bool)

+ func FindPodsWithPrimaryResourcePool(resourcePool string, pods []*v1.Pod) []*v1.Pod

+ func FindTaint(node *v1.Node, taintKey string) *v1.Taint

+ func FormatMachineType(machineType *poolV1.MachineTypeConfig, options FormatterOptions) string

+ func FormatNode(node *v1.Node, ageThreshold time.Duration, options FormatterOptions) string

+ func FormatPod(pod *v1.Pod, options FormatterOptions) string

+ func FormatResourcePool(resourcePool *poolV1.ResourcePoolConfig, options FormatterOptions) string

+ func FromComputeResourceToResourceList(resources v12.ComputeResource) v1.ResourceList

+ func FromNodeToComputeResource(node *v1.Node) v12.ComputeResource

+ func FromPodToComputeResource(pod *v1.Pod) v12.ComputeResource

+ func FromResourceListToComputeResource(limits v1.ResourceList) v12.ComputeResource

+ func GroupNodesAndPods(resourcePool *v12.ResourcePoolSpec, allPods []*v1.Pod, allNodes []*v1.Node) (map[string]NodeAndPods, []*v1.Pod)

+ func HasLabelAndValue(labels map[string]string, labelName string, value string) bool

+ func HasNoExecuteTaint(node *v1.Node) bool

+ func IsNodeAvailableForScheduling(node *v1.Node, now time.Time, ageThreshold time.Duration) bool

+ func IsNodeBootstrapping(node *v1.Node, now time.Time, ageThreshold time.Duration) bool

+ func IsNodeBroken(node *v1.Node) bool

+ func IsNodeDecommissioned(node *v1.Node) bool

+ func IsNodeOnItsWayOut(node *v1.Node) bool

+ func IsNodeRemovable(node *v1.Node) bool

+ func IsNodeScalingDown(node *v1.Node) bool

+ func IsNodeTerminated(node *v1.Node) bool

+ func IsNodeToRemove(node *v1.Node) bool

+ func IsPodFinished(pod *v1.Pod) bool

+ func IsPodRunning(pod *v1.Pod) bool

+ func IsPodWaitingToBeScheduled(pod *v1.Pod) bool

+ func NewDecommissioningTaint(source string, now time.Time) *v1.Taint

+ func NewNode(name string, resourcePoolName string, machineTypeConfig *v1.MachineTypeConfig) *v13.Node

+ func NewNodes(count int64, namePrefix string, resourcePoolName string, ...) []*v13.Node

+ func NewNotScheduledPod(resourcePoolName string, resources v1.ComputeResource, now time.Time) *v13.Pod

+ func NewNotScheduledPodWithName(name string, resourcePoolName string, resources v1.ComputeResource, ...) *v13.Pod

+ func NewNotScheduledPods(count int64, namePrefix string, resourcePoolName string, ...) []*v13.Pod

+ func NewRandomNode(transformers ...func(node *v13.Node)) *v13.Node

+ func NewRandomNotScheduledPod() *v13.Pod

+ func NewResourcePoolCrdOf(name string, shapeDimensions v1.ComputeResource, shapeCount int64) *v1.ResourcePoolConfig

+ func NewResourcePoolCrdOfMachine(name string, machineTypeConfig *v1.MachineTypeConfig, partsCount int64, ...) *v1.ResourcePoolConfig

+ func NewScalingDownTaint(source string, now time.Time) *v1.Taint

+ func NewScalingDownTaintWithValue(now time.Time, value string) *v1.Taint

+ func NodeAge(node *v1.Node, now time.Time) time.Duration

+ func NodeBelongsToResourcePool(node *v1.Node, resourcePool *v12.ResourcePoolSpec) bool

+ func NodeNames(nodes []*v1.Node) []string

+ func PodAge(pod *v1.Pod, now time.Time) time.Duration

+ func PodBelongsToResourcePool(pod *v1.Pod, resourcePool *v12.ResourcePoolSpec, nodes []*v1.Node) bool

+ func PodNames(pods *[]v1.Pod) []string

+ func SortNodesByAge(nodes []*v1.Node) []*v1.Node

+ func SumNodeResources(nodes []*v1.Node) v12.ComputeResource

+ func SumPodResources(pods []*v1.Pod) v12.ComputeResource

+ func ToJSONString(value interface{}) string

+ type FormatDetailsLevel int

+ const FormatCompact

+ const FormatDetails

+ const FormatEssentials

+ type FormatterOptions struct

+ Level FormatDetailsLevel

+ type NodeAndPods struct

+ Node *v1.Node

+ Pods []*v1.Pod