Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

commands

package

Go to main page

Versions in this module

v0

v0.2.0-rc.0

Feb 1, 2019

v0.1.0

Jan 19, 2019

Changes in this version

+ const CHART_PKG_LOC

+ const CLIName

+ const DeprecatedNVIDIAGPUResourceName

+ const KUBE_SYSTEM_NAMESPACE

+ const NVIDIAGPUResourceName

+ const POD_METRIC_TMP

+ const PROMETHEUS_INSTALL_DOC_URL

+ const PROMETHEUS_SCHEME

+ const PROMETHEUS_SVC_LABEL

+ var GPU_METRIC_LIST = []string

+ func GetJobDashboards(dashboard string, job *v1.Job, pods []corev1.Pod) []string

+ func GetJobRealStatus(job TrainingJob) string

+ func GetPodEvents(client *kubernetes.Clientset, namespace string, pods []v1.Pod) (map[string][]v1.Event, error)

+ func GetPrometheusServiceName(client *kubernetes.Clientset) string

+ func GpuMonitoringInstalled(client *kubernetes.Clientset) bool

+ func NewCommand() *cobra.Command

+ func NewCompletionCommand() *cobra.Command

+ func NewDataCommand() *cobra.Command

+ func NewDataListCommand() *cobra.Command

+ func NewDeleteCommand() *cobra.Command

+ func NewGetCommand() *cobra.Command

+ func NewListCommand() *cobra.Command

+ func NewLogViewerCommand() *cobra.Command

+ func NewLogsCommand() *cobra.Command

+ func NewPruneCommand() *cobra.Command

+ func NewServeCommand() *cobra.Command

+ func NewServingDeleteCommand() *cobra.Command

+ func NewServingListCommand() *cobra.Command

+ func NewServingTensorFlowCommand() *cobra.Command

+ func NewSubmitCommand() *cobra.Command

+ func NewSubmitHorovodJobCommand() *cobra.Command

+ func NewSubmitMPIJobCommand() *cobra.Command

+ func NewSubmitStandaloneJobCommand() *cobra.Command

+ func NewSubmitTFJobCommand() *cobra.Command

+ func NewTopCommand() *cobra.Command

+ func NewTopJobCommand() *cobra.Command

+ func NewTopNodeCommand() *cobra.Command

+ func NewTrafficRouterSplitCommand() *cobra.Command

+ func NewVersionCmd(cliName string) *cobra.Command

+ func ParseMountPath(dataset []string) (err error)

+ func PrintLine(w io.Writer, fields ...string)

+ func SortMapKeys(podMetric PodGpuMetric) []string

+ type Destination struct

+ Port *PortSelector

+ type DestinationRuleCRD struct

+ APIVersion string

+ Kind string

+ Spec istiov1alpha3.DestinationRule

+ type DestinationWeight struct

+ Destination *Destination

+ Weight int32

+ type GpuMetric struct

+ GpuDutyCycle float64

+ GpuMemoryTotal float64

+ GpuMemoryUsed float64

+ type GpuMetricInfo struct

+ ContainerName string

+ GPUUID string

+ Id string

+ MetricName string

+ NodeName string

+ PodName string

+ PodNamespace string

+ Time float64

+ Value string

+ func QueryMetricByPrometheus(client *kubernetes.Clientset, prometheusServiceName string, query string) ([]GpuMetricInfo, error)

+ type HTTPMatchRequest struct

+ Uri *StringMatchPrefix

+ type HTTPRoute struct

+ Match []*HTTPMatchRequest

+ Route []*DestinationWeight

+ type HorovodJob struct

+ func (hj *HorovodJob) AllPods() []v1.Pod

+ func (hj *HorovodJob) ChiefPod() v1.Pod

+ func (hj *HorovodJob) GetJobDashboards(client *kubernetes.Clientset) ([]string, error)

+ func (hj *HorovodJob) HostIPOfChief() (hostIP string)

+ type HorovodJobTrainer struct

+ func (m *HorovodJobTrainer) GetTrainingJob(name, namespace string) (tj TrainingJob, err error)

+ func (m *HorovodJobTrainer) IsSupported(name, ns string) bool

+ func (m *HorovodJobTrainer) Type() string

+ type JobGpuMetric map[string]PodGpuMetric

+ func GetJobGpuMetric(client *kubernetes.Clientset, job TrainingJob) (jobMetric JobGpuMetric, err error)

+ func GetPodsGpuInfo(client *kubernetes.Clientset, prometheusServiceName string, podNames []string) (JobGpuMetric, error)

+ func (m *JobGpuMetric) SetPodMetric(metric GpuMetricInfo)

+ func (m JobGpuMetric) GetPodMetrics(podName string) PodGpuMetric

+ type JobInfo struct

+ func (ji *JobInfo) Age() time.Duration

+ func (ji *JobInfo) AllPods() []v1.Pod

+ func (ji *JobInfo) AllocatedGPU() int64

+ func (ji *JobInfo) ChiefPod() v1.Pod

+ func (ji *JobInfo) GetStatus() (status string)

+ func (ji *JobInfo) HostIPOfChief() (hostIP string)

+ func (ji *JobInfo) Name() string

+ func (ji *JobInfo) RequestedGPU() int64

+ func (ji *JobInfo) StartTime() *metav1.Time

+ func (ji *JobInfo) Trainer() string

+ type MPIJob struct

+ func (mj *MPIJob) Age() time.Duration

+ func (mj *MPIJob) AllPods() []v1.Pod

+ func (mj *MPIJob) AllocatedGPU() int64

+ func (mj *MPIJob) ChiefPod() v1.Pod

+ func (mj *MPIJob) GetJobDashboards(client *kubernetes.Clientset) ([]string, error)

+ func (mj *MPIJob) GetStatus() (status string)

+ func (mj *MPIJob) HostIPOfChief() (hostIP string)

+ func (mj *MPIJob) Name() string

+ func (mj *MPIJob) RequestedGPU() int64

+ func (mj *MPIJob) StartTime() *metav1.Time

+ func (mj *MPIJob) Trainer() string

+ type MPIJobTrainer struct

+ func (tt *MPIJobTrainer) GetTrainingJob(name, namespace string) (tj TrainingJob, err error)

+ func (tt *MPIJobTrainer) IsSupported(name, ns string) bool

+ func (tt *MPIJobTrainer) Type() string

+ type NodeDescriber struct

+ type NodeInfo struct

+ type PodGpuMetric map[string]*GpuMetric

+ type PortSelector struct

+ Number uint32

+ type PreprocesObject struct

+ DestinationRule DestinationRuleCRD

+ Namespace string

+ ServiceName string

+ VirtualService VirtualServiceCRD

+ type PrintArgs struct

+ Output string

+ ShowEvents bool

+ type PrometheusMetric struct

+ Data PrometheusMetricData

+ Status string

+ type PrometheusMetricData struct

+ Result []PrometheusMetricResult

+ ResultType string

+ type PrometheusMetricResult struct

+ Metric map[string]string

+ Value []PrometheusMetricValue

+ type PrometheusMetricValue interface

+ type PruneArgs struct

+ type ServeArgs struct

+ Command string

+ Cpu string

+ EnableIstio bool

+ Envs map[string]string

+ ExposeService bool

+ GPUCount int

+ Image string

+ ImagePullPolicy string

+ Memory string

+ ModelDirs map[string]string

+ ModelName string

+ ModelPath string

+ Port int

+ Replicas int

+ RestfulPort int

+ ServingName string

+ ServingVersion string

+ type ServeTensorFlowArgs struct

+ ModelConfigFile string

+ ModelConfigFileContent string

+ ModelServiceExists bool

+ VersionPolicy string

+ type StandaloneJob struct

+ func (sj *StandaloneJob) GetJobDashboards(client *kubernetes.Clientset) ([]string, error)

+ type StandaloneJobTrainer struct

+ func (s *StandaloneJobTrainer) GetTrainingJob(name, namespace string) (tj TrainingJob, err error)

+ func (s *StandaloneJobTrainer) IsSupported(name, ns string) bool

+ func (s *StandaloneJobTrainer) Type() string

+ type StringMatchPrefix struct

+ Prefix string

+ type TensorFlowJob struct

+ func (tj *TensorFlowJob) Age() time.Duration

+ func (tj *TensorFlowJob) AllPods() []v1.Pod

+ func (tj *TensorFlowJob) AllocatedGPU() int64

+ func (tj *TensorFlowJob) ChiefPod() v1.Pod

+ func (tj *TensorFlowJob) GetJobDashboards(client *kubernetes.Clientset) ([]string, error)

+ func (tj *TensorFlowJob) GetStatus() (status string)

+ func (tj *TensorFlowJob) HostIPOfChief() (hostIP string)

+ func (tj *TensorFlowJob) Name() string

+ func (tj *TensorFlowJob) RequestedGPU() int64

+ func (tj *TensorFlowJob) StartTime() *metav1.Time

+ func (tj *TensorFlowJob) Trainer() string

+ type TensorFlowJobTrainer struct

+ func (tt *TensorFlowJobTrainer) GetTrainingJob(name, namespace string) (tj TrainingJob, err error)

+ func (tt *TensorFlowJobTrainer) IsSupported(name, ns string) bool

+ func (tt *TensorFlowJobTrainer) Type() string

+ type Trainer interface

+ GetTrainingJob func(name, namespace string) (TrainingJob, error)

+ IsSupported func(name, ns string) bool

+ Type func() string

+ func NewHorovodJobTrainer(client *kubernetes.Clientset) Trainer

+ func NewMPIJobTrainer(client *kubernetes.Clientset) Trainer

+ func NewStandaloneJobTrainer(client *kubernetes.Clientset) Trainer

+ func NewTensorFlowJobTrainer(client *kubernetes.Clientset) Trainer

+ func NewTrainers(client *kubernetes.Clientset) []Trainer

+ type TrainingJob interface

+ Age func() time.Duration

+ AllPods func() []v1.Pod

+ AllocatedGPU func() int64

+ ChiefPod func() v1.Pod

+ GetJobDashboards func(client *kubernetes.Clientset) ([]string, error)

+ GetStatus func() string

+ HostIPOfChief func() string

+ Name func() string

+ RequestedGPU func() int64

+ StartTime func() *metav1.Time

+ Trainer func() string

+ type VirtualService struct

+ Http []*HTTPRoute

+ type VirtualServiceCRD struct

+ APIVersion string

+ Kind string

+ Spec VirtualService

v0.1.0-rc.3

Jan 18, 2019

v0.1.0-rc.2

Aug 31, 2018

v0.1.0-rc.1

Aug 9, 2018

v0.1.0-rc.0

Jul 30, 2018