MCPcopy Create free account

hub / github.com/PaddlePaddle/PaddleCloud / functions

Functions439 in github.com/PaddlePaddle/PaddleCloud

↓ 178 callersMethodError
()
pkg/sampleset/ctrls/base_controller.go:187
↓ 60 callersFunctionRequeueWithError
(err error)
pkg/sampleset/utils/ctrl_utils.go:53
↓ 40 callersFunctionNoRequeue
()
pkg/sampleset/utils/ctrl_utils.go:49
↓ 23 callersMethodDeepCopyInto
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:28
↓ 16 callersMethodrun
(self, spec, action)
pipeline/src/training.py:440
↓ 15 callersFunctionRequeueAfter
(requeueAfter time.Duration)
pkg/sampleset/utils/ctrl_utils.go:57
↓ 15 callersMethodUpdateResourceStatus
(object client.Object, r *Resource)
pkg/sampleset/ctrls/base_controller.go:706
↓ 12 callersFunctionNewResource
(name string)
pkg/sampleset/ctrls/base_controller.go:205
↓ 11 callersMethodDeepCopyInto
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
pkg/apis/paddlejob/v1/zz_generated.deepcopy.go:28
↓ 11 callersMethodDeepCopyInto
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
pkg/apis/serving/v1/zz_generated.deepcopy.go:174
↓ 11 callersFunctionGetDriver
GetDriver get csi driver by name, return error if not found
pkg/sampleset/driver/driver.go:104
↓ 11 callersMethodRun
()
pkg/sampleset/manager/server.go:104
↓ 10 callersMethodGetName
()
pkg/sampleset/ctrls/base_controller.go:190
↓ 10 callersMethodGetRuntimeName
GetRuntimeName get the runtime StatefulSet name
pkg/sampleset/driver/driver.go:73
↓ 8 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CSI.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:34
↓ 8 callersMethodGetLabel
GetLabel get the label to mark pv、pvc and nodes which have cached data
pkg/sampleset/driver/driver.go:61
↓ 8 callersMethodGetSpecs
()
pkg/apis/paddlejob/v1/paddlejob_types.go:250
↓ 7 callersMethodGetServiceName
GetServiceName get the name of runtime StatefulSet service
pkg/sampleset/driver/driver.go:67
↓ 7 callersMethodListResources
(list client.ObjectList, r *Resource)
pkg/sampleset/ctrls/base_controller.go:607
↓ 6 callersFunctionCanaryServiceName
(name string)
pkg/serving/constants/constants.go:80
↓ 6 callersMethodGetResource
(object client.Object, r *Resource)
pkg/sampleset/ctrls/base_controller.go:546
↓ 5 callersFunctionNewJobOptions
(name string)
pkg/sampleset/ctrls/base_controller.go:409
↓ 5 callersFunctionNoZeroOptionToArgs
(options interface{})
pkg/sampleset/utils/ctrl_utils.go:97
↓ 5 callersMethodResourcesExist
(r *Resource)
pkg/sampleset/ctrls/base_controller.go:574
↓ 5 callersMethodSetupWithManager
SetupWithManager sets up the controller with the Manager.
pkg/paddlejob/paddlejob_controller.go:555
↓ 5 callersMethodUpdateResource
(object client.Object, r *Resource)
pkg/sampleset/ctrls/base_controller.go:698
↓ 5 callersMethodgetRuntimeDataMountPath
(name string)
pkg/sampleset/driver/driver.go:339
↓ 5 callersMethodwriteResultFile
(status common.JobStatus, message string, pattern string, optionFile string)
pkg/sampleset/manager/server.go:280
↓ 4 callersMethodCreateResource
(r *Resource)
pkg/sampleset/ctrls/base_controller.go:619
↓ 4 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PaddleJob.
pkg/apis/paddlejob/v1/zz_generated.deepcopy.go:37
↓ 4 callersFunctionDefaultServiceName
(name string)
pkg/serving/constants/constants.go:76
↓ 4 callersMethodDeleteResource
(r *Resource)
pkg/sampleset/ctrls/base_controller.go:678
↓ 4 callersFunctionHasDeletionTimestamp
HasDeletionTimestamp method to check if an object need to delete.
pkg/sampleset/utils/ctrl_utils.go:35
↓ 4 callersFunctionHasFinalizer
HasFinalizer check
pkg/sampleset/utils/ctrl_utils.go:40
↓ 4 callersFunctionNewServiceBuilder
(paddlesvc *elasticservingv1.PaddleService)
pkg/serving/resources/knative/service.go:43
↓ 4 callersFunctionWaitFileCreatedWithTimeout
(ctx context.Context, path string, duration time.Duration)
pkg/sampleset/utils/ctrl_utils.go:281
↓ 4 callersMethodcreateResource
(ctx context.Context, pdj *pdv1.PaddleJob, obj client.Object)
pkg/paddlejob/paddlejob_controller.go:413
↓ 4 callersMethoddo
(pattern string, optionFile string)
pkg/sampleset/manager/server.go:256
↓ 3 callersMethodCollectCacheStatus
(podNames []string)
pkg/sampleset/ctrls/base_controller.go:855
↓ 3 callersMethodCreateJobOptions
(opt interface{}, j *JobType)
pkg/sampleset/ctrls/base_controller.go:656
↓ 3 callersMethodCreateRevision
(serviceName string, paddlesvc *elasticservingv1.PaddleService, isCanary bool)
pkg/serving/resources/knative/service.go:206
↓ 3 callersMethodCreateService
CreateService create a service for runtime StatefulSet
pkg/sampleset/driver/driver.go:64
↓ 3 callersMethodDoClearJob
DoClearJob call by runtime server, clear the cached data
pkg/sampleset/driver/driver.go:94
↓ 3 callersMethodDoSyncJob
DoSyncJob call by runtime server, sync data from remote storage to cache engine
pkg/sampleset/driver/driver.go:91
↓ 3 callersMethodErrorDoJob
()
pkg/sampleset/ctrls/base_controller.go:428
↓ 3 callersFunctionGet
(url string, filename types.UID)
pkg/sampleset/utils/http_utils.go:54
↓ 3 callersFunctionGetBaseUriByIndex
(runtimeName, serviceName string, index int)
pkg/sampleset/utils/http_utils.go:58
↓ 3 callersFunctionGetJobOption
(option interface{}, filename types.UID, baseUri, optionPath string)
pkg/sampleset/utils/http_utils.go:210
↓ 3 callersMethodGetJobResult
(filename types.UID, j *JobType)
pkg/sampleset/ctrls/base_controller.go:821
↓ 3 callersFunctionGetSampleJobFinalizer
(name string)
pkg/sampleset/ctrls/base_controller.go:892
↓ 3 callersFunctionGetSampleSetFinalizer
(name string)
pkg/sampleset/ctrls/base_controller.go:888
↓ 3 callersMethodGetStatuses
()
pkg/apis/paddlejob/v1/paddlejob_types.go:258
↓ 3 callersFunctioncontainsString
(slice []string, s string)
pkg/paddlejob/paddlejob_helper.go:415
↓ 3 callersMethoddeleteResource
(ctx context.Context, pdj *pdv1.PaddleJob, obj client.Object)
pkg/paddlejob/paddlejob_controller.go:400
↓ 3 callersFunctiongenPaddleResName
genPaddleResName generate the identifier for pod and service
pkg/paddlejob/paddlejob_helper.go:203
↓ 3 callersFunctionisCoordContainerRunning
(pod *corev1.Pod)
pkg/paddlejob/paddlejob_helper.go:163
↓ 2 callersMethodAddTrafficRoute
(serviceName string, paddlesvc *elasticservingv1.PaddleService, service *knservingv1.Service)
pkg/serving/resources/knative/service.go:179
↓ 2 callersMethodCollectCacheStatusByIndex
(index int)
pkg/sampleset/ctrls/base_controller.go:873
↓ 2 callersFunctionContainsString
ContainsString Determine whether the string array contains a specific string, return true if contains the string and return false if not.
pkg/sampleset/utils/ctrl_utils.go:64
↓ 2 callersMethodCreateClearJobOptions
CreateClearJobOptions create the options of clear job, used by SampleJob controller
pkg/sampleset/driver/driver.go:85
↓ 2 callersMethodCreateRmrJobOptions
CreateRmrJobOptions create the options of rmr job, used by SampleJob controller
pkg/sampleset/driver/driver.go:82
↓ 2 callersMethodCreateService
(serviceName string, paddlesvc *elasticservingv1.PaddleService, isCanary bool)
pkg/serving/resources/knative/service.go:65
↓ 2 callersMethodCreateSuccessfully
()
pkg/sampleset/ctrls/base_controller.go:432
↓ 2 callersFunctionDiskUsageOfPaths
(timeout time.Duration, paths ...string)
pkg/sampleset/utils/ctrl_utils.go:123
↓ 2 callersMethodDoJobSuccessfully
()
pkg/sampleset/ctrls/base_controller.go:436
↓ 2 callersMethodDoWarmupJob
DoWarmupJob call by runtime server, warmup data to local storage on each node respectively
pkg/sampleset/driver/driver.go:97
↓ 2 callersMethodErrorCreateObject
()
pkg/sampleset/ctrls/base_controller.go:224
↓ 2 callersFunctionGetBaseUriByName
(runtimePodName, serviceName string)
pkg/sampleset/utils/http_utils.go:62
↓ 2 callersMethodGetLabel
GetLabel label is concatenated by PaddleLabel、driver name and SampleSet name
pkg/sampleset/driver/driver.go:319
↓ 2 callersMethodGetRequestContext
(d Dependence)
pkg/sampleset/ctrls/base_controller.go:714
↓ 2 callersFunctionGetResultUri
(baseUri, resultPath string)
pkg/sampleset/utils/http_utils.go:70
↓ 2 callersMethodGetRuntimeName
(sampleSetName string)
pkg/sampleset/driver/driver.go:323
↓ 2 callersFunctionNewJuiceFSDriver
()
pkg/sampleset/driver/juicefs.go:97
↓ 2 callersFunctionNoZeroOptionToMap
(optionMap map[string]reflect.Value, i interface{})
pkg/sampleset/utils/ctrl_utils.go:83
↓ 2 callersMethodPost
(url string, filename types.UID, body io.Reader)
pkg/sampleset/utils/http_utils.go:40
↓ 2 callersMethodPostJobOptions
(filename types.UID, j *JobType)
pkg/sampleset/ctrls/base_controller.go:812
↓ 2 callersMethodPostJobOptionsWithParam
(filename types.UID, j *JobType, param string)
pkg/sampleset/ctrls/base_controller.go:768
↓ 2 callersFunctionRemoveFinalizer
(obj *metav1.ObjectMeta, finalizer string)
pkg/sampleset/utils/ctrl_utils.go:44
↓ 2 callersMethodResourcesExistWithObject
(object client.Object, r *Resource)
pkg/sampleset/ctrls/base_controller.go:589
↓ 2 callersMethod__init__
(self, client=None)
pipeline/src/training.py:222
↓ 2 callersMethodbuildAnnotations
(metadata metav1.ObjectMeta, paddlesvcSpec elasticservingv1.PaddleServiceSpec)
pkg/serving/resources/knative/service.go:296
↓ 2 callersMethodbuildResources
(metadata metav1.ObjectMeta, paddlesvcSpec elasticservingv1.PaddleServiceSpec)
pkg/serving/resources/knative/service.go:365
↓ 2 callersFunctionconstructPod
(pdj *pdv1.PaddleJob, resType string, idx int)
pkg/paddlejob/paddlejob_helper.go:282
↓ 2 callersFunctionextractNameIndex
(name string)
pkg/paddlejob/paddlejob_helper.go:207
↓ 2 callersMethodfinalizeCanaryEndpoint
(serviceName, namespace string, serviceSpec knservingv1.ServiceSpec)
pkg/serving/reconcilers/knative/service_reconciler.go:130
↓ 2 callersFunctiongetMountOptions
GetMountOptions get the JuiceFS mount command options set by user
pkg/sampleset/driver/juicefs.go:175
↓ 2 callersMethodgetVolumeInfo
(pv *v1.PersistentVolume)
pkg/sampleset/driver/juicefs.go:377
↓ 2 callersFunctionisPodCreated
(spec *pdv1.ResourceSpec, status *pdv1.ResourceStatus)
pkg/paddlejob/paddlejob_helper.go:67
↓ 2 callersMethodis_expected_conditions
(self, inst, expected_conditions)
pipeline/src/launch_crd.py:105
↓ 2 callersFunctionknativeRevisionSemanticEquals
(desired, existing *knservingv1.Revision)
pkg/serving/reconcilers/knative/service_reconciler.go:305
↓ 2 callersFunctionpostWarmupMaster
(ctx context.Context, mountPath string, partitions int, log logr.Logger)
pkg/sampleset/driver/juicefs.go:674
↓ 2 callersFunctionpostWarmupWorker
(ctx context.Context, mountPath string, index int, log logr.Logger)
pkg/sampleset/driver/juicefs.go:712
↓ 2 callersFunctionpreWarmupMaster
(ctx context.Context, mountPath string, opt *v1alpha1.WarmupJobOptions)
pkg/sampleset/driver/juicefs.go:535
↓ 2 callersFunctionpreWarmupWorker
(ctx context.Context, mountPath string, index int)
pkg/sampleset/driver/juicefs.go:655
↓ 2 callersMethodwait_for_condition
Waits until any of the specified conditions occur. Args: namespace: namespace for the CR. name: Name of the CR
pipeline/src/launch_crd.py:31
↓ 2 callersFunctionwithoutVolcano
for volcano
pkg/paddlejob/paddlejob_helper.go:460
↓ 1 callersMethodAddFinalizer
AddFinalizer add finalizer to SampleJob
pkg/sampleset/ctrls/samplejob_controller.go:156
↓ 1 callersMethodAddFinalizer
AddFinalizer add finalizer to SampleSet
pkg/sampleset/ctrls/sampleset_controller.go:114
↓ 1 callersFunctionCollectAllCacheStatus
(runtimePodNames []string, serviceName string)
pkg/sampleset/utils/http_utils.go:107
↓ 1 callersMethodCollectCacheStatusByPartitions
(partitions int)
pkg/sampleset/ctrls/base_controller.go:879
next →1–100 of 439, ranked by callers