types

Documentation

Index

• Variables
• func IsPodControllerByDeploment(pod v1.Pod, deploy app_v1.Deployment) bool
• type Instance
• type JobInfo
• type JobStatus
• type Serving
  • func NewServingJob(client *kubernetes.Clientset, deploy app_v1.Deployment, allPods []v1.Pod) Serving
  • func (s Serving) AllPods() []v1.Pod
  • func (s Serving) GetClusterIP() string
  • func (s Serving) GetName() string
  • func (s Serving) GetStatus() string
• type TrainingJobInfo

Variables

var KubeConfig string

var SERVING_CHARTS = map[string]string{
	"tensorflow-serving-0.2.0":        "Tensorflow",
	"tensorrt-inference-server-0.0.1": "TensorRT",
}

var SERVING_TYPE = map[string]string{
	"tf-serving":  "Tensorflow",
	"trt-serving": "TensorRT",
}

Functions

func IsPodControllerByDeploment

func IsPodControllerByDeploment(pod v1.Pod, deploy app_v1.Deployment) bool

Types

type Instance

type Instance struct {
	// the status of of instance
	Status string `json:"status"`
	// the name of instance
	Name string `json:"name"`
	// the age of instance
	Age string `json:"age"`
	// the node instance runs on
	Node string `json:"node"`
	// the instance is chief or not
	IsChief bool `json:"chief" yaml:"chief"`
}

type JobInfo

type JobInfo struct {
	// The name of the training job
	Name string `json:"name"`
	// The namespace of the training job
	Namespace string `json:"namespace"`
	// The time of the training job
	Duration string `json:"duration"`
	// The status of the training Job
	Status JobStatus `json:"status"`

	// The training type of the training job
	Trainer string `json:"trainer"`
	// The tensorboard of the training job
	Tensorboard string `json:"tensorboard,omitempty"`

	// The name of the chief Instance
	ChiefName string `json:"chiefName" yaml:"chiefName"`

	// The instances under the training job
	Instances []Instance `json:"instances"`
}

type JobStatus

type JobStatus string

all the kinds of JobStatus

const (
	// JobPending means the job is pending
	JobPending JobStatus = "PENDING"
	// JobRunning means the job is running
	JobRunning JobStatus = "RUNNING"
	// JobSucceeded means the job is Succeeded
	JobSucceeded JobStatus = "SUCCEEDED"
	// JobFailed means the job is failed
	JobFailed JobStatus = "FAILED"
)

type Serving

type Serving struct {
	Name      string
	ServeType string
	Namespace string
	Version   string
	// contains filtered or unexported fields
}

func NewServingJob

func NewServingJob(client *kubernetes.Clientset, deploy app_v1.Deployment, allPods []v1.Pod) Serving

func (Serving) AllPods

func (s Serving) AllPods() []v1.Pod

func (Serving) GetClusterIP

func (s Serving) GetClusterIP() string

func (Serving) GetName

func (s Serving) GetName() string

func (Serving) GetStatus

func (s Serving) GetStatus() string

type TrainingJobInfo

type TrainingJobInfo struct {
	Name      string
	Type      string
	Namespace string
}