scheduler

Aug 22, 2022

Changes in this version

type NodeResource

+ GPUID2GPU map[string]*GPUInfo

+ PodIP string

+ PodManagerPortBitmap *bitmap.RRBitmap

+ UUID2Port map[string]string

May 21, 2022

Changes in this version

+ const ErrResourceExists

+ const KubeShareScheduleAffinity

+ const KubeShareScheduleAntiAffinity

+ const KubeShareScheduleExclusion

+ const MessageResourceExists

+ const MessageResourceSynced

+ const SuccessSynced

+ func GPUAffinityFilter(nodeResources NodeResources, sharepod *kubesharev1.SharePod)

+ func GPUAntiAffinityFilter(nodeResources NodeResources, sharepod *kubesharev1.SharePod)

+ func GPUExclusionFilter(nodeResources NodeResources, sharepod *kubesharev1.SharePod)

+ func ScheduleAlgorithmBestFit(isGPUPod bool, gpu_request float64, gpu_mem int64, ...) (schedNodeName string, schedGPUID string)

+ type Controller struct

+ func NewController(kubeclientset kubernetes.Interface, kubeshareclientset clientset.Interface, ...) *Controller

+ func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error

+ type GPUInfo struct

+ GPUAffinityTags []string

+ GPUAntiAffinityTags []string

+ GPUExclusionTags []string

+ GPUFreeMem int64

+ GPUFreeReq int64

+ func (this *GPUInfo) DeepCopy() *GPUInfo

+ type NodeResource struct

+ CpuFree int64

+ CpuTotal int64

+ GpuFree map[string]*GPUInfo

+ GpuFreeCount int

+ GpuMemTotal int64

+ GpuTotal int

+ MemFree int64

+ MemTotal int64

+ func (this *NodeResource) DeepCopy() *NodeResource

+ type NodeResources map[string]*NodeResource

+ func (this *NodeResources) DeepCopy() *NodeResources

+ func (this *NodeResources) PrintMe()