commands

package

Go to main page

Versions in this module

v0

v0.5.0

Jul 9, 2020

Changes in this version

+ func NewSubmitPyTorchJobCommand() *cobra.Command

+ type PyTorchJob struct

+ func (p *PyTorchJob) GetPriorityClass() string

+ func (pj *PyTorchJob) Age() time.Duration

+ func (pj *PyTorchJob) AllPods() []v1.Pod

+ func (pj *PyTorchJob) AllocatedGPU() int64

+ func (pj *PyTorchJob) ChiefPod() v1.Pod

+ func (pj *PyTorchJob) Duration() time.Duration

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

+ func (pj *PyTorchJob) GetStatus() (status string)

+ func (pj *PyTorchJob) HostIPOfChief() (hostIP string)

+ func (pj *PyTorchJob) Name() string

+ func (pj *PyTorchJob) Namespace() string

+ func (pj *PyTorchJob) RequestedGPU() int64

+ func (pj *PyTorchJob) StartTime() *metav1.Time

+ func (pj *PyTorchJob) Trainer() string

+ func (pj *PyTorchJob) Uid() string

+ type PyTorchJobTrainer struct

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

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

+ func (tt *PyTorchJobTrainer) ListTrainingJobs() (jobs []TrainingJob, err error)

+ func (tt *PyTorchJobTrainer) Type() string

type Trainer

+ func NewPyTorchJobTrainer(client *kubernetes.Clientset) Trainer

v0.4.1

Jul 2, 2020

v0.4.0

May 12, 2020

v0.3.3

Mar 14, 2020

Changes in this version

+ type Runtime interface

v0.3.2

Feb 7, 2020

v0.3.1

Jan 9, 2020

Changes in this version

+ const ALIYUNGPUResourceName

+ func NewServingLogCommand() *cobra.Command

type ServeArgs

+ Annotations map[string]string

+ NodeSelectors map[string]string

+ Tolerations []string

v0.3.1-beta

Dec 2, 2019

v0.3.1-alpha

Aug 19, 2019

v0.3.0

Aug 19, 2019

Changes in this version

+ const ResourceTypeJob

+ const ResourceTypePod

+ const ResourceTypeStatefulSet

+ var ErrNotFoundJobs = errors.New(`not found jobs under the assigned conditions.`)

+ var ErrTooManyJobs = errors.New(`found jobs more than one,please use --version or --type to filter.`)

+ func FilterServingJobs(jobs []printer.ServingJobPrinter, servingVersion, servingType string) ([]printer.ServingJobPrinter, error)

+ func FormatServingJobs(format string, job printer.ServingJobPrinter) ([]byte, error)

+ func GetMulJobsHelpInfo(jobs []printer.ServingJobPrinter) string

+ func GetResourcesEvents(client *kubernetes.Clientset, namespace string, resources []Resource) (map[string][]v1.Event, error)

+ func GetServingJobsByName(client *kubernetes.Clientset, servingName string) ([]printer.ServingJobPrinter, error)

+ func ListServingsByName(client *kubernetes.Clientset, name string) (servings []types.Serving, err error)

+ func NewServingCustomCommand() *cobra.Command

+ func NewServingGetCommand() *cobra.Command

+ func PrepareCheck() error

+ func ServingGetExecute(client *kubernetes.Clientset, servingName string)

+ type BasicJobInfo struct

+ func (j *BasicJobInfo) Resources() []Resource

type HorovodJob

+ func (hj *HorovodJob) GetPriorityClass() string

type JobInfo

+ func (ji *JobInfo) Uid() string

type MPIJob

+ func (m *MPIJob) GetPriorityClass() string

+ func (mj *MPIJob) Uid() string

+ type Resource struct

+ Name string

+ ResourceType ResourceType

+ Uid string

+ type ResourceType string

type ServeArgs

+ GPUMemory int

+ ModelServiceExists bool

+ func (s ServeArgs) PreCheck() error

+ type ServeCustomArgs struct

+ Image string

type ServeTensorFlowArgs

+ ModelName string

+ ModelPath string

type SparkJob

+ func (sj *SparkJob) GetPriorityClass() string

+ func (sj *SparkJob) Uid() string

type StandaloneJob

+ func (sj *StandaloneJob) GetPriorityClass() string

type TensorFlowJob

+ func (t *TensorFlowJob) GetPriorityClass() string

+ func (tj *TensorFlowJob) Uid() string

type TrainingJob

+ GetPriorityClass func() string

+ Resources func() []Resource

type VolcanoJob

+ func (vj *VolcanoJob) GetPriorityClass() string

+ func (vj *VolcanoJob) Uid() string

v0.3.0-rc.0

Aug 19, 2019

v0.2.0

Jul 11, 2019

Changes in this version

+ const DefaultArenaConfigPath

+ const KUBEFLOW_NAMESPACE

+ const RecommendedConfigPathEnvVar

+ func BuildJobInfo(job TrainingJob) *types.JobInfo

+ func GetNamespace() string

+ func ListServing(client *kubernetes.Clientset) ([]types.Serving, error)

+ func ListServingJobsByHelm() ([]types.Serving, error)

+ func NewServingTensorRTCommand() *cobra.Command

+ func NewSparkApplicationCommand() *cobra.Command

+ func NewSubmitSparkJobArgs() *submitSparkJobArgs

+ func NewSubmitVolcanoJobArgs() *submitVolcanoJobArgs

+ func NewVolcanoJobCommand() *cobra.Command

+ type Driver struct

+ CPURequest int

+ MemoryRequest string

+ type Executor struct

+ CPURequest int

+ MemoryRequest string

+ Replicas int

type HorovodJobTrainer

+ func (hj *HorovodJobTrainer) ListTrainingJobs() (jobs []TrainingJob, err error)

type JobInfo

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

+ func (ji *JobInfo) Namespace() string

type MPIJob

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

+ func (mj *MPIJob) Namespace() string

type MPIJobTrainer

+ func (tt *MPIJobTrainer) ListTrainingJobs() (jobs []TrainingJob, err error)

type ServeTensorFlowArgs

+ Image string

+ type ServeTensorRTArgs struct

+ AllowMetrics bool

+ GrpcPort int

+ HttpPort int

+ Image string

+ MetricsPort int

+ ModelStore string

+ type SortPodConditionByLastTransitionTime []v1.PodCondition

+ func (s SortPodConditionByLastTransitionTime) Len() int

+ func (s SortPodConditionByLastTransitionTime) Less(i, j int) bool

+ func (s SortPodConditionByLastTransitionTime) Swap(i, j int)

+ type SparkJob struct

+ func (sj *SparkJob) Age() time.Duration

+ func (sj *SparkJob) AllPods() []v1.Pod

+ func (sj *SparkJob) AllocatedGPU() int64

+ func (sj *SparkJob) ChiefPod() v1.Pod

+ func (sj *SparkJob) Duration() time.Duration

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

+ func (sj *SparkJob) GetStatus() (status string)

+ func (sj *SparkJob) HostIPOfChief() (hostIP string)

+ func (sj *SparkJob) Name() string

+ func (sj *SparkJob) Namespace() string

+ func (sj *SparkJob) RequestedGPU() int64

+ func (sj *SparkJob) StartTime() *metav1.Time

+ func (sj *SparkJob) Trainer() string

+ type SparkJobTrainer struct

+ func (st *SparkJobTrainer) GetTrainingJob(name, namespace string) (job TrainingJob, err error)

+ func (st *SparkJobTrainer) IsSupported(name, ns string) bool

+ func (st *SparkJobTrainer) ListTrainingJobs() (jobs []TrainingJob, err error)

+ func (st *SparkJobTrainer) Type() string

type StandaloneJobTrainer

+ func (s *StandaloneJobTrainer) ListTrainingJobs() (jobs []TrainingJob, err error)

type TensorFlowJob

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

+ func (tj *TensorFlowJob) Namespace() string

type TensorFlowJobTrainer

+ func (tt *TensorFlowJobTrainer) ListTrainingJobs() (jobs []TrainingJob, err error)

type Trainer

+ func NewSparkJobTrainer(client *kubernetes.Clientset) Trainer

+ func NewVolcanoJobTrainer(client *kubernetes.Clientset) Trainer

+ ListTrainingJobs func() ([]TrainingJob, error)

type TrainingJob

+ Duration func() time.Duration

+ Namespace func() string

+ type VolcanoJob struct

+ func (vj *VolcanoJob) Age() time.Duration

+ func (vj *VolcanoJob) AllPods() []v1.Pod

+ func (vj *VolcanoJob) AllocatedGPU() int64

+ func (vj *VolcanoJob) ChiefPod() v1.Pod

+ func (vj *VolcanoJob) Duration() time.Duration

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

+ func (vj *VolcanoJob) GetStatus() (status string)

+ func (vj *VolcanoJob) HostIPOfChief() (hostIP string)

+ func (vj *VolcanoJob) Name() string

+ func (vj *VolcanoJob) Namespace() string

+ func (vj *VolcanoJob) RequestedGPU() int64

+ func (vj *VolcanoJob) StartTime() *metav1.Time

+ func (vj *VolcanoJob) Trainer() string

+ type VolcanoJobTrainer struct

+ func NewVolcanoJobTrainerSubmit(client *kubernetes.Clientset) *VolcanoJobTrainer

+ func (st *VolcanoJobTrainer) GetTrainingJob(name, namespace string) (job TrainingJob, err error)

+ func (st *VolcanoJobTrainer) GetTrainingJobAtSubmit(name, namespace string) (job TrainingJob, err error)

+ func (st *VolcanoJobTrainer) IsSupported(name, ns string) bool

+ func (st *VolcanoJobTrainer) ListTrainingJobs() (jobs []TrainingJob, err error)

+ func (st *VolcanoJobTrainer) Type() string

v0.2.0-rc.2

Jun 18, 2019

v0.2.0-rc.1

May 9, 2019

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL