MCPcopy Create free account

hub / github.com/PaddlePaddle/PaddleCloud / functions

Functions439 in github.com/PaddlePaddle/PaddleCloud

⨍ Functions 439◇ Types & classes 95
↓ 1 callersMethoddelete
(self, name, namespace)
pipeline/src/launch_crd.py:169
↓ 1 callersMethoddeleteSampleJob
(ctx context.Context, sampleJob *v1alpha1.SampleJob)
pkg/sampleset/ctrls/samplejob_controller.go:165
↓ 1 callersMethoddeleteSampleSet
()
pkg/sampleset/ctrls/sampleset_controller.go:481
↓ 1 callersFunctionendpoints2hosts
(eps []string)
pkg/paddlejob/paddlejob_helper.go:397
↓ 1 callersMethodexecInPod
(namespace string, podName string, containerName string, cmd []string)
pkg/paddlejob/paddlejob_controller.go:511
↓ 1 callersFunctionextractPattern
(path string)
pkg/sampleset/manager/server.go:425
↓ 1 callersMethodfinalize
(ctx context.Context, pdj *pdv1.PaddleJob)
pkg/paddlejob/paddlejob_controller.go:480
↓ 1 callersMethodfinalizeService
(serviceName, namespace string)
pkg/serving/reconcilers/knative/service_reconciler.go:113
↓ 1 callersFunctiongenCoordinateInitContainer
(coordContainerImage string)
pkg/paddlejob/paddlejob_helper.go:380
↓ 1 callersFunctiongetHostMountPathMap
(volumes []v1.Volume, volumeMounts []v1.VolumeMount)
pkg/sampleset/driver/driver.go:347
↓ 1 callersFunctiongetPGMinResource
(pdj *pdv1.PaddleJob)
pkg/paddlejob/paddlejob_helper.go:521
↓ 1 callersFunctiongetPaddleJobCompleteTime
(pdj *pdv1.PaddleJob)
pkg/paddlejob/paddlejob_helper.go:184
↓ 1 callersFunctiongetPaddleJobMode
(pdj *pdv1.PaddleJob)
pkg/paddlejob/paddlejob_helper.go:192
↓ 1 callersFunctiongetPaddleJobPhase
(pdj *pdv1.PaddleJob)
pkg/paddlejob/paddlejob_helper.go:93
↓ 1 callersFunctiongetPaddleJobStartTime
(pdj *pdv1.PaddleJob)
pkg/paddlejob/paddlejob_helper.go:176
↓ 1 callersMethodgetRuntimeCacheMountPath
(name string)
pkg/sampleset/driver/driver.go:331
↓ 1 callersFunctiongetTotalReplicas
(pdj *pdv1.PaddleJob)
pkg/paddlejob/paddlejob_helper.go:510
↓ 1 callersFunctiongetValidClearPath
(path string, hostMountMap map[string]string)
pkg/sampleset/driver/driver.go:363
↓ 1 callersMethodget_action_status
(self, action=None)
pipeline/src/launch_crd.py:208
↓ 1 callersMethodget_command
(self, spec)
pipeline/src/training.py:26
↓ 1 callersMethodget_command
(self, spec)
pipeline/src/training.py:231
↓ 1 callersMethodget_ocr_command
(self, spec)
pipeline/src/training.py:33
↓ 1 callersMethodget_ocr_command
(self, spec)
pipeline/src/training.py:238
↓ 1 callersMethodget_spec
(self, spec)
pipeline/src/training.py:419
↓ 1 callersMethodget_spec
(self, spec)
pipeline/src/launch_crd.py:205
↓ 1 callersMethodhandleEvent
(event fsnotify.Event)
pkg/sampleset/manager/server.go:234
↓ 1 callersFunctionisAllCoordContainerRunning
(childPods corev1.PodList)
pkg/paddlejob/paddlejob_helper.go:154
↓ 1 callersFunctionisAllPodsCreated
(pdj *pdv1.PaddleJob)
pkg/paddlejob/paddlejob_helper.go:56
↓ 1 callersFunctionisAllPodsReady
(pdj *pdv1.PaddleJob, childPods corev1.PodList)
pkg/paddlejob/paddlejob_helper.go:44
↓ 1 callersFunctionisFailed
(status *pdv1.ResourceStatus)
pkg/paddlejob/paddlejob_helper.go:77
↓ 1 callersFunctionisPending
(status *pdv1.ResourceStatus)
pkg/paddlejob/paddlejob_helper.go:80
↓ 1 callersFunctionisPodRealRuning
(pod *corev1.Pod)
pkg/paddlejob/paddlejob_helper.go:135
↓ 1 callersFunctionisSecretValid
isSecretValid check if the secret created by user is valid for JuiceFS csi driver
pkg/sampleset/driver/juicefs.go:165
↓ 1 callersFunctionisStarting
(status *pdv1.ResourceStatus)
pkg/paddlejob/paddlejob_helper.go:83
↓ 1 callersFunctionknativeServiceTrafficSemanticEquals
(desired, existing *knservingv1.Service)
pkg/serving/reconcilers/knative/service_reconciler.go:301
↓ 1 callersFunctionknativeSpecSemanticEquals
(desired, existing interface{})
pkg/serving/reconcilers/knative/service_reconciler.go:297
↓ 1 callersFunctionmain
()
pipeline/src/modelhub.py:101
↓ 1 callersFunctionmain
()
pipeline/src/dataset.py:110
↓ 1 callersFunctionmain
()
pipeline/src/training.py:459
↓ 1 callersFunctionmain
(argv=None)
pipeline/src/serving.py:57
↓ 1 callersMethodpatch
Apply namespaced service Args: spec: The spec for the CR
pipeline/src/training.py:367
↓ 1 callersMethodpatch
Apply custom resource Args: spec: The spec for the CR
pipeline/src/launch_crd.py:114
↓ 1 callersFunctionrandStringRunes
(n int)
pkg/serving/suite_test.go:146
↓ 1 callersMethodreconcileBound
reconcileBound After create PV/PVC then create runtime StatefulSet
pkg/sampleset/ctrls/sampleset_controller.go:266
↓ 1 callersMethodreconcileCanaryEndpoint
(paddlesvc *elasticservingv1.PaddleService, desired *knservingv1.Service, serviceSpec knservingv1.ServiceSpec)
pkg/serving/reconcilers/knative/service_reconciler.go:226
↓ 1 callersMethodreconcileDefaultEndpoint
(paddlesvc *elasticservingv1.PaddleService, desired *knservingv1.Service)
pkg/serving/reconcilers/knative/service_reconciler.go:158
↓ 1 callersMethodreconcileFailed
()
pkg/sampleset/ctrls/samplejob_controller.go:365
↓ 1 callersMethodreconcileMount
reconcileMount After create runtime daemon set and mounted, before sync data job done
pkg/sampleset/ctrls/sampleset_controller.go:328
↓ 1 callersMethodreconcileNone
reconcileNone job: post
pkg/sampleset/ctrls/samplejob_controller.go:233
↓ 1 callersMethodreconcileNone
reconcileNone After user create SampleSet CR then create PV and PVC automatically
pkg/sampleset/ctrls/sampleset_controller.go:201
↓ 1 callersMethodreconcilePartialReady
()
pkg/sampleset/ctrls/sampleset_controller.go:593
↓ 1 callersMethodreconcilePending
()
pkg/sampleset/ctrls/samplejob_controller.go:293
↓ 1 callersMethodreconcilePhase
()
pkg/sampleset/ctrls/samplejob_controller.go:214
↓ 1 callersMethodreconcilePhase
()
pkg/sampleset/ctrls/sampleset_controller.go:173
↓ 1 callersMethodreconcileReady
reconcileReady reconcile
pkg/sampleset/ctrls/sampleset_controller.go:422
↓ 1 callersMethodreconcileRunning
()
pkg/sampleset/ctrls/samplejob_controller.go:329
↓ 1 callersMethodreconcileSucceeded
()
pkg/sampleset/ctrls/samplejob_controller.go:411
↓ 1 callersMethodreconcileSyncFailed
()
pkg/sampleset/ctrls/sampleset_controller.go:539
↓ 1 callersMethodreconcileSyncing
reconcileSyncing wait the sync data job done and return to mount phase
pkg/sampleset/ctrls/sampleset_controller.go:371
↓ 1 callersFunctionremoveString
(slice []string, s string)
pkg/paddlejob/paddlejob_helper.go:423
↓ 1 callersMethodsyncCurrentStatus
(ctx context.Context, pdj *pdv1.PaddleJob, childPods corev1.PodList)
pkg/paddlejob/paddlejob_controller.go:349
↓ 1 callersFunctionsyncEtcd
(ctx context.Context, etcdCli *clientv3.Client, path string, np string)
pkg/paddlejob/paddlejob_elastic.go:27
↓ 1 callersFunctionsyncNP
(etcdCli *clientv3.Client, pdj *pdv1.PaddleJob)
pkg/paddlejob/paddlejob_elastic.go:41
↓ 1 callersMethoduploadHandleFunc
(pattern string)
pkg/sampleset/manager/server.go:160
↓ 1 callersFunctionwarmupRandomly
(opt *v1alpha1.WarmupJobOptions, writers []*bufio.Writer)
pkg/sampleset/driver/juicefs.go:636
↓ 1 callersFunctionwarmupSequentially
(opt *v1alpha1.WarmupJobOptions, writers []*bufio.Writer)
pkg/sampleset/driver/juicefs.go:617
↓ 1 callersMethodwatchAndDo
()
pkg/sampleset/manager/server.go:217
↓ 1 callersMethodwriteCacheStatus
()
pkg/sampleset/manager/server.go:391
FunctionAllBaseUris
(c *Controller)
pkg/sampleset/ctrls/base_controller.go:503
FunctionClearCreateOptions
(c *Controller, opt interface{}, ctx *common.RequestContext)
pkg/sampleset/ctrls/base_controller.go:481
FunctionClearOptions
()
pkg/sampleset/ctrls/base_controller.go:446
MethodCreateCacheStatus
(opt *common.ServerOptions, status *v1alpha1.CacheStatus)
pkg/sampleset/driver/driver.go:210
MethodCreateClearJobOptions
(opt *v1alpha1.ClearJobOptions, ctx *common.RequestContext)
pkg/sampleset/driver/driver.go:288
MethodCreatePV
CreatePV create JuiceFS persistent volume with mount options. How to set parameters of pv can refer to https://github.com/juicedata/juicefs-csi-driver
pkg/sampleset/driver/juicefs.go:107
MethodCreatePVC
CreatePVC create persistent volume claim, and it will be used by runtime server and PaddleJob worker pods
pkg/sampleset/driver/driver.go:119
MethodCreateRmrJobOptions
(opt *v1alpha1.RmrJobOptions, ctx *common.RequestContext)
pkg/sampleset/driver/driver.go:270
MethodCreateRuntime
(ds *appv1.StatefulSet, ctx *common.RequestContext)
pkg/sampleset/driver/juicefs.go:248
MethodCreateService
CreateService create service for runtime StatefulSet server
pkg/sampleset/driver/driver.go:155
MethodCreateSuccessfully
()
pkg/sampleset/ctrls/base_controller.go:232
MethodCreateSyncJobOptions
CreateSyncJobOptions create sync job options by the information from request context, the options is used by controller to request runtime server do s
pkg/sampleset/driver/juicefs.go:753
MethodCreateWarmupJobOptions
(opt *v1alpha1.WarmupJobOptions, ctx *common.RequestContext)
pkg/sampleset/driver/juicefs.go:811
MethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Cache.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:54
MethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CacheLevel.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:69
MethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CacheStatus.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:84
MethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClearJobOptions.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:104
MethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronJobStatus.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:128
MethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobOptions.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:163
MethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobsName.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:178
MethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JuiceFSMountOptions.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:193
MethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JuiceFSSyncOptions.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:208
MethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JuiceFSWarmupOptions.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:223
MethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MountOptions.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:243
MethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RmrJobOptions.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:263
MethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RuntimeStatus.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:278
MethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SampleJobSpec.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:363
MethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SampleJobStatus.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:378
MethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SampleSetSpec.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:480
MethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SampleSetStatus.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:506
MethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SampleStrategy.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:521
MethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Source.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:541
← previousnext →201–300 of 439, ranked by callers