cluster

Documentation

Index

• Constants
• func InitClientSets(it kubeclientset.Interface, mit kubeshareclientset.Interface, ...)
• type GPUInfo
  • func (this *GPUInfo) DeepCopy() *GPUInfo
• type NodeResource
  • func (this *NodeResource) DeepCopy() *NodeResource
• type NodeResources
  • func SyncClusterResource() (nodeResources NodeResources, err error)
  • func (this *NodeResources) DeepCopy() *NodeResources
  • func (this *NodeResources) PrintMe()
• type PodRequest
• type PodRequests

Constants

const (
	ResourceKubeShareGPU = "kubeshare/gpu"
	ResourceNvidiaGPU    = "nvidia.com/gpu"
)

Functions

func InitClientSets

func InitClientSets(it kubeclientset.Interface, mit kubeshareclientset.Interface, op *options.ServerOption)

Types

type GPUInfo

type GPUInfo struct {
	GPUFreeReq int64
	// GPUFreeMem in bytes
	GPUFreeMem int64
}

func (*GPUInfo) DeepCopy

func (this *GPUInfo) DeepCopy() *GPUInfo

type NodeResource

type NodeResource struct {
	CpuTotal int64
	MemTotal int64
	GpuTotal int
	// GpuMemTotal in bytes
	GpuMemTotal int64
	CpuFree     int64
	MemFree     int64
	/* Available GPU calculate */
	// Total GPU count - Pods using nvidia.com/gpu
	GpuFreeCount int
	// GPUs available usage (1.0 - SharePod usage)
	// GPUID to integer index mapping
	GpuFree map[string]*GPUInfo
}

func (*NodeResource) DeepCopy

func (this *NodeResource) DeepCopy() *NodeResource

type NodeResources

type NodeResources map[string]*NodeResource

NodeResources: Available resources in cluster to schedule Training Jobs

func SyncClusterResource

func SyncClusterResource() (nodeResources NodeResources, err error)

func (*NodeResources) DeepCopy

func (this *NodeResources) DeepCopy() *NodeResources

func (*NodeResources) PrintMe

func (this *NodeResources) PrintMe()

type PodRequest

type PodRequest struct {
	CpuReq    int64
	MemReq    int64
	GpuReq    int64
	GpuMemReq int64
}

type PodRequests

type PodRequests []*PodRequest