Versions in this module Expand all Collapse all v0 v0.2.0-rc1 Jun 21, 2018 v0.1.0 Mar 29, 2018 Changes in this version + const FailedCreateReason + const SuccessfulCreateReason + type ClusterSpec map[string][]string + type KubernetesLabels map[string]string + func (l KubernetesLabels) ToSelector() (string, error) + type TFConfig struct + Cluster ClusterSpec + Environment string + Task TaskSpec + type TFReplicaSet struct + ClientSet kubernetes.Interface + Job *TrainingJob + Spec tfv1alpha1.TFReplicaSpec + func NewTFReplicaSet(clientSet kubernetes.Interface, recorder record.EventRecorder, ...) (*TFReplicaSet, error) + func (s *TFReplicaSet) CreatePodWithIndex(index int32) (*v1.Pod, error) + func (s *TFReplicaSet) CreateServiceWithIndex(index int32) (*v1.Service, error) + func (s *TFReplicaSet) Delete() error + func (s *TFReplicaSet) GetSingleReplicaStatus(index int32) tfv1alpha1.ReplicaState + func (s *TFReplicaSet) GetStatus() (tfv1alpha1.TFReplicaStatus, error) + func (s *TFReplicaSet) Labels() KubernetesLabels + func (s *TFReplicaSet) LabelsByIndex(index int32) KubernetesLabels + func (s *TFReplicaSet) SyncPods() error + func (s *TFReplicaSet) SyncServices() error + type TFReplicaSetInterface interface + Create func() error + Delete func() error + GetStatus func() (tfv1alpha1.TFReplicaStatus, error) + type TaskSpec struct + Index int + Type string + type TrainingJob struct + KubeCli kubernetes.Interface + Replicas []*TFReplicaSet + func NewJob(kubeCli kubernetes.Interface, tfJobClient tfjobclient.Interface, ...) (*TrainingJob, error) + func (j *TrainingJob) ClusterSpec() ClusterSpec + func (j *TrainingJob) Delete() + func (j *TrainingJob) GetStatus() (tfv1alpha1.State, []*tfv1alpha1.TFReplicaStatus, error) + func (j *TrainingJob) Reconcile(config *tfv1alpha1.ControllerConfig, enableGangScheduling bool) error + func (j *TrainingJob) SchedulerName() string + func (j *TrainingJob) UID() types.UID + func (j *TrainingJob) Update(newJob *tfv1alpha1.TFJob)
Go to main page