Versions in this module Expand all Collapse all v0 v0.9.1 Feb 29, 2020 v0.9.0 Feb 20, 2020 Changes in this version + const LabelGroupName + const LabelPS + const LabelTFJobName + const LabelWorker + const SleepInterval + const TestImageName + const TestTFJobName + const ThreadCount + var AlwaysReady = func() bool + var GroupName = tfv1.GroupName + var KeyFunc = cache.DeletionHandlingMetaNamespaceKeyFunc + func CheckCondition(tfJob *tfv1.TFJob, condition common.JobConditionType, reason string) bool + func ConvertTFJobToUnstructured(tfJob *tfv1.TFJob) (*unstructured.Unstructured, error) + func GenLabels(jobName string) map[string]string + func GenOwnerReference(tfjob *tfv1.TFJob) *metav1.OwnerReference + func GetKey(tfJob *tfv1.TFJob, t *testing.T) string + func NewBasePod(name string, tfJob *tfv1.TFJob, t *testing.T) *v1.Pod + func NewBaseService(name string, tfJob *tfv1.TFJob, t *testing.T) *v1.Service + func NewPod(tfJob *tfv1.TFJob, typ string, index int, t *testing.T) *v1.Pod + func NewPodList(count int32, status v1.PodPhase, tfJob *tfv1.TFJob, typ string, start int32, ...) []*v1.Pod + func NewService(tfJob *tfv1.TFJob, typ string, index int, t *testing.T) *v1.Service + func NewServiceList(count int32, tfJob *tfv1.TFJob, typ string, t *testing.T) []*v1.Service + func NewTFJob(worker, ps int) *tfv1.TFJob + func NewTFJobWithActiveDeadlineSeconds(chief, worker, ps int, ads *int64) *tfv1.TFJob + func NewTFJobWithBackoffLimit(chief, worker, ps int, backoffLimit *int32) *tfv1.TFJob + func NewTFJobWithChief(worker, ps int) *tfv1.TFJob + func NewTFJobWithCleanPolicy(chief, worker, ps int, policy common.CleanPodPolicy) *tfv1.TFJob + func NewTFJobWithCleanupJobDelay(chief, worker, ps int, ttl *int32) *tfv1.TFJob + func NewTFJobWithEvaluator(worker, ps, evaluator int) *tfv1.TFJob + func NewTFJobWithEvaluatorAndNamespace(worker, ps, evaluator int, ns string) *tfv1.TFJob + func NewTFJobWithNamespace(worker, ps int, ns string) *tfv1.TFJob + func NewTFReplicaSpecTemplate() v1.PodTemplateSpec + func SetPodsStatuses(podIndexer cache.Indexer, tfJob *tfv1.TFJob, typ string, ...) + func SetServices(serviceIndexer cache.Indexer, tfJob *tfv1.TFJob, typ string, ...) + func SetTFJobCompletionTime(tfJob *tfv1.TFJob)
Go to main page