Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/deepinsight/mxnet-operator
/ functions
Functions
146 in github.com/deepinsight/mxnet-operator
⨍
Functions
146
◇
Types & classes
48
Function
IsKubernetesResourceAlreadyExistError
(err error)
pkg/util/k8sutil/k8sutil.go:69
Function
IsKubernetesResourceNotFoundError
(err error)
pkg/util/k8sutil/k8sutil.go:73
Method
IsLeader
IsLeader returns true if the last observed leader was this client else returns false.
pkg/util/k8sutil/election/election.go:170
Function
IsRetryFailure
(err error)
pkg/util/retryutil/retry_util.go:16
Function
JobListOpt
We are using internal api types for cluster related.
pkg/util/k8sutil/k8sutil.go:78
Method
List
(ns string)
pkg/util/k8sutil/mxjobclient.go:109
Method
List
(ns string)
pkg/util/k8sutil/fake/fake.go:21
Function
MustNewApiExtensionsClient
()
pkg/util/k8sutil/k8sutil.go:39
Function
MustNewKubeClient
()
pkg/util/k8sutil/k8sutil.go:30
Function
New
(kubecli kubernetes.Interface, mxJobClient k8sutil.MxJobClient, ns string)
pkg/garbagecollection/gc.go:37
Function
New
(kubeCli kubernetes.Interface, apiCli apiextensionsclient.Interface, mxJobClient k8sutil.MxJobClient, ns strin
pkg/controller/controller.go:63
Function
NewJob
(kubeCli kubernetes.Interface, mxJobClient k8sutil.MxJobClient, mxjob *spec.MxJob, stopC <-chan struct{}, wg *
pkg/trainer/training.go:89
Function
NewMxJobClient
()
pkg/util/k8sutil/mxjobclient.go:56
Function
NewMxJobClientExternal
New MXJob client for out-of-cluster
pkg/util/k8sutil/mxjobclient.go:78
Method
PauseControl
PauseControl set cs ControlPaused = true
pkg/spec/mx_job.go:412
Function
Pformat
Pformat returns a pretty format output of any value that can be marshalled to JSON.
pkg/util/util.go:13
Function
RandString
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
Method
RecordEvent
RecordEvent in leader election while adding meta-data
pkg/util/k8sutil/election/resourcelock/endpointslock.go:89
Function
Resource
Resource takes an unqualified resource and returns a Group-qualified GroupResource.
pkg/spec/register.go:20
Function
Retry
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
Function
RunOrDie
RunOrDie starts a client with the provided config or panics if the config fails to validate.
pkg/util/k8sutil/election/election.go:155
Method
SetReadyCondition
SetReadyCondition for mxnet job status
pkg/spec/mx_job.go:477
Function
TestAddAccelertor
(t *testing.T)
pkg/spec/mx_job_test.go:13
Function
TestIsRetryableTerminationState
(t *testing.T)
pkg/trainer/training_test.go:16
Function
TestJobSetup
(t *testing.T)
pkg/trainer/training_test.go:75
Function
TestMXReplicaSet
(t *testing.T)
pkg/trainer/replicas_test.go:20
Function
TestMXReplicaSetStatusFromPodList
(t *testing.T)
pkg/trainer/replicas_test.go:116
Function
TestSetDefaults
(t *testing.T)
pkg/spec/mx_job_test.go:235
Method
UnmarshalJSON
UnmarshalJSON for MxJob
pkg/spec/mx_job_list.go:32
Method
UnmarshalJSON
UnmarshalJSON for MxJobList
pkg/spec/mx_job_list.go:44
Method
Update
Update sends an update event for the job.
pkg/trainer/training.go:353
Method
Update
(ns string, j *spec.MxJob)
pkg/util/k8sutil/mxjobclient.go:154
Method
Update
Update will update and existing annotation on a given resource.
pkg/util/k8sutil/election/resourcelock/endpointslock.go:75
Method
Update
Update a MxJob.
pkg/util/k8sutil/fake/fake.go:31
Method
WaitTPRReady
WaitTPRReady blocks until the MxJob TPR is ready.
pkg/util/k8sutil/fake/fake.go:43
Method
Watch
(host, ns string, httpClient *http.Client, resourceVersion string)
pkg/util/k8sutil/mxjobclient.go:104
Method
Watch
Watch MxJobs.
pkg/util/k8sutil/fake/fake.go:38
Function
addKnownTypes
addKnownTypes adds the set of types defined in this package to the supplied scheme.
pkg/spec/register.go:25
Function
addOwnerRefToObject
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
Function
init
()
cmd/mx_operator/main.go:49
Function
main
()
test/e2e/main.go:202
Function
main
()
cmd/mx_operator/main.go:89
Method
masterName
()
pkg/trainer/training.go:251
Function
mergeLabels
mergeLabels merges l2 into l1. Conflicting labels will be skipped.
pkg/util/k8sutil/k8sutil.go:106
Method
name
()
pkg/trainer/training.go:523
Function
run
(stop <-chan struct{})
cmd/mx_operator/main.go:154
← previous
101–146 of 146, ranked by callers