common

Documentation

Index

• Constants
• func Add(left *si.Resource, right *si.Resource) *si.Resource
• func CreateReleaseAllocationRequestForTask(appId, allocUuid, partition string) si.UpdateRequest
• func CreateUpdateRequestForDeleteNode(node Node) si.UpdateRequest
• func CreateUpdateRequestForNewNode(node Node) si.UpdateRequest
• func CreateUpdateRequestForTask(appId, taskId string, resource *si.Resource) si.UpdateRequest
• func CreateUpdateRequestForUpdatedNode(node Node) si.UpdateRequest
• func Equals(left *si.Resource, right *si.Resource) bool
• func GetNodeResource(nodeStatus *v1.NodeStatus) *si.Resource
• func GetPodResource(pod *v1.Pod) (resource *si.Resource)
• type Node
  • func CreateFrom(node *v1.Node) Node
  • func CreateFromNodeSpec(nodeName string, nodeUid string, nodeResource *si.Resource) Node
• type ResourceBuilder
  • func NewResourceBuilder() *ResourceBuilder
  • func (w *ResourceBuilder) AddResource(name string, value int64) *ResourceBuilder
  • func (w *ResourceBuilder) Build() *si.Resource

Constants

const ApplicationDefaultQueue = "root"

const CPU = "vcore"

const DefaultConfigMapName = "yunikorn-configs"

Configuration

const DefaultNodeAttributeHostNameKey = "si.io/hostname"

Cluster

const DefaultNodeAttributeRackNameKey = "si.io/rackname"

const DefaultPartition = "default"

const DefaultRackName = "/rack-default"

const LabelApplicationId = "applicationId"

Application

const LabelQueueName = "queue"

const Memory = "memory"

Resource

const SparkLabelAppId = "spark-app-id"

Spark

const SparkLabelRole = "spark-role"

const SparkLabelRoleDriver = "driver"

Functions

func Add

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

func CreateReleaseAllocationRequestForTask

func CreateReleaseAllocationRequestForTask(appId, allocUuid, partition string) si.UpdateRequest

func CreateUpdateRequestForDeleteNode

func CreateUpdateRequestForDeleteNode(node Node) si.UpdateRequest

func CreateUpdateRequestForNewNode

func CreateUpdateRequestForNewNode(node Node) si.UpdateRequest

func CreateUpdateRequestForTask

func CreateUpdateRequestForTask(appId, taskId string, resource *si.Resource) si.UpdateRequest

func CreateUpdateRequestForUpdatedNode

func CreateUpdateRequestForUpdatedNode(node Node) si.UpdateRequest

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)

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

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