common

Documentation

Index

• func Add(left *si.Resource, right *si.Resource) *si.Resource
• func CreateAllocationRequestForTask(appID, taskID string, resource *si.Resource, placeholder bool, ...) si.AllocationRequest
• func CreateReleaseAllocationRequestForTask(appID, allocUUID, partition, terminationType string) si.AllocationRequest
• func CreateReleaseAskRequestForTask(appID, taskID, partition string) si.AllocationRequest
• func CreateTagsForTask(pod *v1.Pod) map[string]string
• func CreateUpdateRequestForDeleteNode(node Node) si.NodeRequest
• func CreateUpdateRequestForNewNode(node Node) si.NodeRequest
• func CreateUpdateRequestForRemoveApplication(appID, partition string) si.ApplicationRequest
• func CreateUpdateRequestForUpdatedNode(node Node) si.NodeRequest
• func Equals(left *si.Resource, right *si.Resource) bool
• func GetNodeResource(nodeStatus *v1.NodeStatus) *si.Resource
• func GetPodResource(pod *v1.Pod) (resource *si.Resource)
• func GetTGResource(resMap map[string]resource.Quantity, members int64) *si.Resource
• func GetTerminationTypeFromString(terminationTypeStr string) si.TerminationType
• func IsZero(r *si.Resource) bool
• func ParseResource(cpuStr, memStr string) *si.Resource
• func Sub(left *si.Resource, right *si.Resource) *si.Resource
• type Node
  • func CreateFrom(node *v1.Node) Node
  • func CreateFromNodeSpec(nodeName string, nodeUID string, nodeResource *si.Resource) Node
  • func NewNode(name, uid string, capacity *si.Resource, occupied *si.Resource) Node
• type ResourceBuilder
  • func NewResourceBuilder() *ResourceBuilder
  • func (w *ResourceBuilder) AddResource(name string, value int64) *ResourceBuilder
  • func (w *ResourceBuilder) Build() *si.Resource

Functions

func Add

func Add(left *si.Resource, right *si.Resource) *si.Resource

func CreateAllocationRequestForTask

func CreateAllocationRequestForTask(appID, taskID string, resource *si.Resource, placeholder bool, taskGroupName string, pod *v1.Pod) si.AllocationRequest

func CreateReleaseAllocationRequestForTask

func CreateReleaseAllocationRequestForTask(appID, allocUUID, partition, terminationType string) si.AllocationRequest

func CreateReleaseAskRequestForTask

func CreateReleaseAskRequestForTask(appID, taskID, partition string) si.AllocationRequest

func CreateTagsForTask

func CreateTagsForTask(pod *v1.Pod) map[string]string

func CreateUpdateRequestForDeleteNode

func CreateUpdateRequestForDeleteNode(node Node) si.NodeRequest

func CreateUpdateRequestForNewNode

func CreateUpdateRequestForNewNode(node Node) si.NodeRequest

func CreateUpdateRequestForRemoveApplication

func CreateUpdateRequestForRemoveApplication(appID, partition string) si.ApplicationRequest

func CreateUpdateRequestForUpdatedNode

func CreateUpdateRequestForUpdatedNode(node Node) si.NodeRequest

func Equals

func Equals(left *si.Resource, right *si.Resource) bool

func GetNodeResource

func GetNodeResource(nodeStatus *v1.NodeStatus) *si.Resource

func GetPodResource

func GetPodResource(pod *v1.Pod) (resource *si.Resource)

Get the resources from a pod's containers and convert that into a internal resource. A pod has two resource parts: Requests and Limits. Based on the values a pod gets a QOS assigned, as per https://kubernetes.io/docs/tasks/configure-pod-container/quality-service-pod/ QOS class Guaranteed and Burstable are supported. However Burstable is scheduled based on the request values, limits are ignored in the current setup. BestEffort pods are scheduled using a minimum resource of 1MB only.

func GetTGResource

func GetTGResource(resMap map[string]resource.Quantity, members int64) *si.Resource

func GetTerminationTypeFromString

func GetTerminationTypeFromString(terminationTypeStr string) si.TerminationType

func IsZero

func IsZero(r *si.Resource) bool

func ParseResource

func ParseResource(cpuStr, memStr string) *si.Resource

parse cpu and memory from string to si.Resource, both of them are optional if parse failed with some errors, log the error and return a nil

func Sub

func Sub(left *si.Resource, right *si.Resource) *si.Resource

Types

type Node

type Node struct {
	// contains filtered or unexported fields
}

stores info about what scheduler cares about a node

func CreateFrom

func CreateFrom(node *v1.Node) Node

func CreateFromNodeSpec

func CreateFromNodeSpec(nodeName string, nodeUID string, nodeResource *si.Resource) Node

func NewNode

func NewNode(name, uid string, capacity *si.Resource, occupied *si.Resource) Node

type ResourceBuilder

type ResourceBuilder struct {
	// contains filtered or unexported fields
}

resource builder is a helper struct to construct si resources

func NewResourceBuilder

func NewResourceBuilder() *ResourceBuilder

func (*ResourceBuilder) AddResource

func (w *ResourceBuilder) AddResource(name string, value int64) *ResourceBuilder

func (*ResourceBuilder) Build

func (w *ResourceBuilder) Build() *si.Resource