Documentation
¶
Index ¶
- Variables
- func DefinePodPhaseStatus(pod v1.Pod) (string, int, int, int)
- func IsPodControllerByDeploment(pod v1.Pod, deploy app_v1.Deployment) bool
- type Instance
- type JobInfo
- type JobStatus
- type Serving
- func (s Serving) AllPods() []v1.Pod
- func (s Serving) AllSvcs() (svcs []v1.Service)
- func (s Serving) AvailableInstances() int32
- func (s Serving) DesiredInstances() int32
- func (s Serving) GetAge() string
- func (s Serving) GetClusterIP() string
- func (s Serving) GetName() string
- func (s Serving) GetPorts() string
- func (s Serving) GetStatus() string
- type ServingType
- type TrainingJobInfo
Constants ¶
This section is empty.
Variables ¶
View Source
var KubeConfig string
View Source
var SERVING_CHARTS = map[string]string{
"tensorflow-serving-0.2.0": "Tensorflow",
"tensorrt-inference-server-0.0.1": "TensorRT",
}
Functions ¶
func DefinePodPhaseStatus ¶ added in v0.3.0
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"`
// The priority of the training job
Priority string `json:"priority"`
}
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 `yaml:"name" json:"name"`
Namespace string `yaml:"namespace" json:"namespace"`
ServeType ServingType `yaml:"serving_type" json:"serving_type"`
Version string `yaml:"version" json:"version"`
// contains filtered or unexported fields
}
func NewServingJob ¶
func NewServingJob(client *kubernetes.Clientset, deploy app_v1.Deployment, allPods []v1.Pod) Serving
func (Serving) AvailableInstances ¶ added in v0.3.0
Available instances
func (Serving) DesiredInstances ¶ added in v0.3.0
Desired Instances
type ServingType ¶ added in v0.3.0
type ServingType string
const ( // tensorflow ServingTF ServingType = "TENSORFLOW" // tensorrt ServingTRT ServingType = "TENSORRT" // custom ServingCustom ServingType = "CUSTOM" )
three serving types.
func KeyMapServingType ¶ added in v0.3.0
func KeyMapServingType(servingKey string) ServingType
type TrainingJobInfo ¶
Click to show internal directories.
Click to hide internal directories.