utils

Documentation

Index

• Constants
• func AppsParseToPod(rc string, data io.Reader) ([]NodeConfig, MutiAppsRequest, error)
• func GetMasterFromKubeConfig(filename string) (string, error)
• func GetUID(uid string) types.UID
• func ParseDeployToPod(deploy *appsv1.Deployment) (*v1.Pod, int32, error)
• func ParseStatefulSetToPod(statefulset *appsv1.StatefulSet) (*v1.Pod, int32, error)
• func ParseToPod(rc string, data io.Reader) (*v1.Pod, int32, error)
• func PrintPod(pod *v1.Pod, format string) error
• type AppGroup
• type Apps
• type MutiAppsRequest
• type NodeCapacity
• type NodeConfig
  • func NodeConfigParse(data io.Reader) (*NodeConfig, error)
• type NodeInfo
• type NodeInfoList
• type Option
• type PodRequest
• type PodsConfig
  • func PodsConfigParse(data io.Reader) (*PodsConfig, error)
• type PodsInfo
• type SimulatorJob

Constants

const DefaultSchedulerName = "default-scheduler"

Functions

func AppsParseToPod

func AppsParseToPod(rc string, data io.Reader) ([]NodeConfig, MutiAppsRequest, error)

ParseToPod, convert deployment or statefulset to v1.pod

func GetMasterFromKubeConfig

func GetMasterFromKubeConfig(filename string) (string, error)

func GetUID

func GetUID(uid string) types.UID

func ParseDeployToPod

func ParseDeployToPod(deploy *appsv1.Deployment) (*v1.Pod, int32, error)

func ParseStatefulSetToPod

func ParseStatefulSetToPod(statefulset *appsv1.StatefulSet) (*v1.Pod, int32, error)

ParseToPod, convert deployment or statefulset to v1.pod

func ParseToPod

func ParseToPod(rc string, data io.Reader) (*v1.Pod, int32, error)

ParseToPod, convert deployment or statefulset to v1.pod

func PrintPod

func PrintPod(pod *v1.Pod, format string) error

Types

type AppGroup

type AppGroup struct {
	EmulatorType string       `json:"emulatorType"`
	Nodes        []NodeConfig `json:"nodes"`
	Apps         []PodRequest `json:"apps"`
	OldPods      []v1.Pod     `json:"odlPods"`
	PodsConfig   *PodsConfig  `json:"podsConfig"`
}

type Apps

type Apps struct {
	Nodes           []NodeConfig          `json:"nodes"`
	DeployApps      []*appsv1.Deployment  `json:"deployApps"`
	StatefulsetApps []*appsv1.StatefulSet `json:"statefulsetApps"`
}

type MutiAppsRequest

type MutiAppsRequest struct {
	PodRequestList []PodRequest
}

type NodeCapacity

type NodeCapacity struct {
	GPUNumber int64 `json:"gpunumber"`
	CPU       int64 `json:"cpu"`
	Memory    int64 `json:"memory"`
	Storage   int64 `json:"storage"`
}

type NodeConfig

type NodeConfig struct {
	NodeNumber   int               `json:"nodeNumber"`
	NodeCapacity *NodeCapacity     `json:"nodeCapacity"`
	NodeLabels   map[string]string `json:"nodeLabels"`
}

func NodeConfigParse

func NodeConfigParse(data io.Reader) (*NodeConfig, error)

type NodeInfo

type NodeInfo struct {
	Name          string `json:"name"`
	UsedCPU       int64  `json:"usedCPU"`
	UsedMemory    int64  `json:"usedMemory"`
	CPU           int64  `json:"cpu"`
	Memory        int64  `json:"memory"`
	CPUPercent    string `json:"cpuPercent"`
	MemoryPercent string `json:"memoryPercent"`
	PodNumber     int64  `json:"podNumber"`
}

type NodeInfoList

type NodeInfoList struct {
	NodeNumber        int            `json:"nodeNumber"`
	PodNumber         int            `json:"podNumber"`
	RunningPod        int            `json:"runingPod"`
	Status            v1.PodPhase    `json:"status"`
	NotRunningPod     int            `json:"notRuningPod"`
	NodeInfoPodNumber int            `json:"nodeInfoPodNumber"`
	NodeInfoNumber    int            `json:"nodeInfoNumber"`
	NotNodeInfoNumber int            `json:"notNodeInfoNumber"`
	BindFailed        int            `json:"bindFailed"`
	BindSuccess       int            `json:"bindSuccess"`
	NodePods          map[string]int `json:"nodePods"`
	NodeInfoPods      map[string]int `json:"nodeInfoPods"`
	NodeList          *v1.NodeList   `json:"nodeList"`
}

type Option

type Option func(fruntime.Registry) error

Option configures a framework.Registry.

type PodRequest

type PodRequest struct {
	Pod      *v1.Pod
	Replicas int32  `json:"Replicas"`
	Kind     string `json:"kind"`
}

type PodsConfig

type PodsConfig struct {
	Op   string     `json:"op"`
	Pods []PodsInfo `json:"pods"`
}

func PodsConfigParse

func PodsConfigParse(data io.Reader) (*PodsConfig, error)

type PodsInfo

type PodsInfo struct {
	Name           string `json:"name"`
	NameSpace      string `json:"namespace"`
	TargetNodeName string `json:"targetnodename"`
}

type SimulatorJob

type SimulatorJob struct {
	Id string `json:"id"`
}