MCPcopy Create free account

hub / github.com/deepinsight/mxnet-operator / functions

Functions146 in github.com/deepinsight/mxnet-operator

FunctionIsKubernetesResourceAlreadyExistError
(err error)
pkg/util/k8sutil/k8sutil.go:69
FunctionIsKubernetesResourceNotFoundError
(err error)
pkg/util/k8sutil/k8sutil.go:73
MethodIsLeader
IsLeader returns true if the last observed leader was this client else returns false.
pkg/util/k8sutil/election/election.go:170
FunctionIsRetryFailure
(err error)
pkg/util/retryutil/retry_util.go:16
FunctionJobListOpt
We are using internal api types for cluster related.
pkg/util/k8sutil/k8sutil.go:78
MethodList
(ns string)
pkg/util/k8sutil/mxjobclient.go:109
MethodList
(ns string)
pkg/util/k8sutil/fake/fake.go:21
FunctionMustNewApiExtensionsClient
()
pkg/util/k8sutil/k8sutil.go:39
FunctionMustNewKubeClient
()
pkg/util/k8sutil/k8sutil.go:30
FunctionNew
(kubecli kubernetes.Interface, mxJobClient k8sutil.MxJobClient, ns string)
pkg/garbagecollection/gc.go:37
FunctionNew
(kubeCli kubernetes.Interface, apiCli apiextensionsclient.Interface, mxJobClient k8sutil.MxJobClient, ns strin
pkg/controller/controller.go:63
FunctionNewJob
(kubeCli kubernetes.Interface, mxJobClient k8sutil.MxJobClient, mxjob *spec.MxJob, stopC <-chan struct{}, wg *
pkg/trainer/training.go:89
FunctionNewMxJobClient
()
pkg/util/k8sutil/mxjobclient.go:56
FunctionNewMxJobClientExternal
New MXJob client for out-of-cluster
pkg/util/k8sutil/mxjobclient.go:78
MethodPauseControl
PauseControl set cs ControlPaused = true
pkg/spec/mx_job.go:412
FunctionPformat
Pformat returns a pretty format output of any value that can be marshalled to JSON.
pkg/util/util.go:13
FunctionRandString
RandString generates a random string of the desired length. The string is DNS-1035 label compliant; i.e. its only alphanumeric lowercase. From: https
pkg/util/util.go:38
MethodRecordEvent
RecordEvent in leader election while adding meta-data
pkg/util/k8sutil/election/resourcelock/endpointslock.go:89
FunctionResource
Resource takes an unqualified resource and returns a Group-qualified GroupResource.
pkg/spec/register.go:20
FunctionRetry
Retry retries f every interval until after maxRetries. The interval won't be affected by how long f takes. For example, if interval is 3s, f takes 1s,
pkg/util/retryutil/retry_util.go:27
FunctionRunOrDie
RunOrDie starts a client with the provided config or panics if the config fails to validate.
pkg/util/k8sutil/election/election.go:155
MethodSetReadyCondition
SetReadyCondition for mxnet job status
pkg/spec/mx_job.go:477
FunctionTestAddAccelertor
(t *testing.T)
pkg/spec/mx_job_test.go:13
FunctionTestIsRetryableTerminationState
(t *testing.T)
pkg/trainer/training_test.go:16
FunctionTestJobSetup
(t *testing.T)
pkg/trainer/training_test.go:75
FunctionTestMXReplicaSet
(t *testing.T)
pkg/trainer/replicas_test.go:20
FunctionTestMXReplicaSetStatusFromPodList
(t *testing.T)
pkg/trainer/replicas_test.go:116
FunctionTestSetDefaults
(t *testing.T)
pkg/spec/mx_job_test.go:235
MethodUnmarshalJSON
UnmarshalJSON for MxJob
pkg/spec/mx_job_list.go:32
MethodUnmarshalJSON
UnmarshalJSON for MxJobList
pkg/spec/mx_job_list.go:44
MethodUpdate
Update sends an update event for the job.
pkg/trainer/training.go:353
MethodUpdate
(ns string, j *spec.MxJob)
pkg/util/k8sutil/mxjobclient.go:154
MethodUpdate
Update will update and existing annotation on a given resource.
pkg/util/k8sutil/election/resourcelock/endpointslock.go:75
MethodUpdate
Update a MxJob.
pkg/util/k8sutil/fake/fake.go:31
MethodWaitTPRReady
WaitTPRReady blocks until the MxJob TPR is ready.
pkg/util/k8sutil/fake/fake.go:43
MethodWatch
(host, ns string, httpClient *http.Client, resourceVersion string)
pkg/util/k8sutil/mxjobclient.go:104
MethodWatch
Watch MxJobs.
pkg/util/k8sutil/fake/fake.go:38
FunctionaddKnownTypes
addKnownTypes adds the set of types defined in this package to the supplied scheme.
pkg/spec/register.go:25
FunctionaddOwnerRefToObject
TODO(jlewi): I think this function is used to add an owner to a resource. I think we we should use this method to ensure all resources created for the
pkg/util/k8sutil/k8sutil.go:26
Functioninit
()
cmd/mx_operator/main.go:49
Functionmain
()
test/e2e/main.go:202
Functionmain
()
cmd/mx_operator/main.go:89
MethodmasterName
()
pkg/trainer/training.go:251
FunctionmergeLabels
mergeLabels merges l2 into l1. Conflicting labels will be skipped.
pkg/util/k8sutil/k8sutil.go:106
Methodname
()
pkg/trainer/training.go:523
Functionrun
(stop <-chan struct{})
cmd/mx_operator/main.go:154
← previous101–146 of 146, ranked by callers