Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/PaddlePaddle/PaddleCloud
/ functions
Functions
439 in github.com/PaddlePaddle/PaddleCloud
⨍
Functions
439
◇
Types & classes
95
↓ 178 callers
Method
Error
()
pkg/sampleset/ctrls/base_controller.go:187
↓ 60 callers
Function
RequeueWithError
(err error)
pkg/sampleset/utils/ctrl_utils.go:53
↓ 40 callers
Function
NoRequeue
()
pkg/sampleset/utils/ctrl_utils.go:49
↓ 23 callers
Method
DeepCopyInto
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 callers
Method
run
(self, spec, action)
pipeline/src/training.py:440
↓ 15 callers
Function
RequeueAfter
(requeueAfter time.Duration)
pkg/sampleset/utils/ctrl_utils.go:57
↓ 15 callers
Method
UpdateResourceStatus
(object client.Object, r *Resource)
pkg/sampleset/ctrls/base_controller.go:706
↓ 12 callers
Function
NewResource
(name string)
pkg/sampleset/ctrls/base_controller.go:205
↓ 11 callers
Method
DeepCopyInto
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 callers
Method
DeepCopyInto
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 callers
Function
GetDriver
GetDriver get csi driver by name, return error if not found
pkg/sampleset/driver/driver.go:104
↓ 11 callers
Method
Run
()
pkg/sampleset/manager/server.go:104
↓ 10 callers
Method
GetName
()
pkg/sampleset/ctrls/base_controller.go:190
↓ 10 callers
Method
GetRuntimeName
GetRuntimeName get the runtime StatefulSet name
pkg/sampleset/driver/driver.go:73
↓ 8 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CSI.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:34
↓ 8 callers
Method
GetLabel
GetLabel get the label to mark pv、pvc and nodes which have cached data
pkg/sampleset/driver/driver.go:61
↓ 8 callers
Method
GetSpecs
()
pkg/apis/paddlejob/v1/paddlejob_types.go:250
↓ 7 callers
Method
GetServiceName
GetServiceName get the name of runtime StatefulSet service
pkg/sampleset/driver/driver.go:67
↓ 7 callers
Method
ListResources
(list client.ObjectList, r *Resource)
pkg/sampleset/ctrls/base_controller.go:607
↓ 6 callers
Function
CanaryServiceName
(name string)
pkg/serving/constants/constants.go:80
↓ 6 callers
Method
GetResource
(object client.Object, r *Resource)
pkg/sampleset/ctrls/base_controller.go:546
↓ 5 callers
Function
NewJobOptions
(name string)
pkg/sampleset/ctrls/base_controller.go:409
↓ 5 callers
Function
NoZeroOptionToArgs
(options interface{})
pkg/sampleset/utils/ctrl_utils.go:97
↓ 5 callers
Method
ResourcesExist
(r *Resource)
pkg/sampleset/ctrls/base_controller.go:574
↓ 5 callers
Method
SetupWithManager
SetupWithManager sets up the controller with the Manager.
pkg/paddlejob/paddlejob_controller.go:555
↓ 5 callers
Method
UpdateResource
(object client.Object, r *Resource)
pkg/sampleset/ctrls/base_controller.go:698
↓ 5 callers
Method
getRuntimeDataMountPath
(name string)
pkg/sampleset/driver/driver.go:339
↓ 5 callers
Method
writeResultFile
(status common.JobStatus, message string, pattern string, optionFile string)
pkg/sampleset/manager/server.go:280
↓ 4 callers
Method
CreateResource
(r *Resource)
pkg/sampleset/ctrls/base_controller.go:619
↓ 4 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PaddleJob.
pkg/apis/paddlejob/v1/zz_generated.deepcopy.go:37
↓ 4 callers
Function
DefaultServiceName
(name string)
pkg/serving/constants/constants.go:76
↓ 4 callers
Method
DeleteResource
(r *Resource)
pkg/sampleset/ctrls/base_controller.go:678
↓ 4 callers
Function
HasDeletionTimestamp
HasDeletionTimestamp method to check if an object need to delete.
pkg/sampleset/utils/ctrl_utils.go:35
↓ 4 callers
Function
HasFinalizer
HasFinalizer check
pkg/sampleset/utils/ctrl_utils.go:40
↓ 4 callers
Function
NewServiceBuilder
(paddlesvc *elasticservingv1.PaddleService)
pkg/serving/resources/knative/service.go:43
↓ 4 callers
Function
WaitFileCreatedWithTimeout
(ctx context.Context, path string, duration time.Duration)
pkg/sampleset/utils/ctrl_utils.go:281
↓ 4 callers
Method
createResource
(ctx context.Context, pdj *pdv1.PaddleJob, obj client.Object)
pkg/paddlejob/paddlejob_controller.go:413
↓ 4 callers
Method
do
(pattern string, optionFile string)
pkg/sampleset/manager/server.go:256
↓ 3 callers
Method
CollectCacheStatus
(podNames []string)
pkg/sampleset/ctrls/base_controller.go:855
↓ 3 callers
Method
CreateJobOptions
(opt interface{}, j *JobType)
pkg/sampleset/ctrls/base_controller.go:656
↓ 3 callers
Method
CreateRevision
(serviceName string, paddlesvc *elasticservingv1.PaddleService, isCanary bool)
pkg/serving/resources/knative/service.go:206
↓ 3 callers
Method
CreateService
CreateService create a service for runtime StatefulSet
pkg/sampleset/driver/driver.go:64
↓ 3 callers
Method
DoClearJob
DoClearJob call by runtime server, clear the cached data
pkg/sampleset/driver/driver.go:94
↓ 3 callers
Method
DoSyncJob
DoSyncJob call by runtime server, sync data from remote storage to cache engine
pkg/sampleset/driver/driver.go:91
↓ 3 callers
Method
ErrorDoJob
()
pkg/sampleset/ctrls/base_controller.go:428
↓ 3 callers
Function
Get
(url string, filename types.UID)
pkg/sampleset/utils/http_utils.go:54
↓ 3 callers
Function
GetBaseUriByIndex
(runtimeName, serviceName string, index int)
pkg/sampleset/utils/http_utils.go:58
↓ 3 callers
Function
GetJobOption
(option interface{}, filename types.UID, baseUri, optionPath string)
pkg/sampleset/utils/http_utils.go:210
↓ 3 callers
Method
GetJobResult
(filename types.UID, j *JobType)
pkg/sampleset/ctrls/base_controller.go:821
↓ 3 callers
Function
GetSampleJobFinalizer
(name string)
pkg/sampleset/ctrls/base_controller.go:892
↓ 3 callers
Function
GetSampleSetFinalizer
(name string)
pkg/sampleset/ctrls/base_controller.go:888
↓ 3 callers
Method
GetStatuses
()
pkg/apis/paddlejob/v1/paddlejob_types.go:258
↓ 3 callers
Function
containsString
(slice []string, s string)
pkg/paddlejob/paddlejob_helper.go:415
↓ 3 callers
Method
deleteResource
(ctx context.Context, pdj *pdv1.PaddleJob, obj client.Object)
pkg/paddlejob/paddlejob_controller.go:400
↓ 3 callers
Function
genPaddleResName
genPaddleResName generate the identifier for pod and service
pkg/paddlejob/paddlejob_helper.go:203
↓ 3 callers
Function
isCoordContainerRunning
(pod *corev1.Pod)
pkg/paddlejob/paddlejob_helper.go:163
↓ 2 callers
Method
AddTrafficRoute
(serviceName string, paddlesvc *elasticservingv1.PaddleService, service *knservingv1.Service)
pkg/serving/resources/knative/service.go:179
↓ 2 callers
Method
CollectCacheStatusByIndex
(index int)
pkg/sampleset/ctrls/base_controller.go:873
↓ 2 callers
Function
ContainsString
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 callers
Method
CreateClearJobOptions
CreateClearJobOptions create the options of clear job, used by SampleJob controller
pkg/sampleset/driver/driver.go:85
↓ 2 callers
Method
CreateRmrJobOptions
CreateRmrJobOptions create the options of rmr job, used by SampleJob controller
pkg/sampleset/driver/driver.go:82
↓ 2 callers
Method
CreateService
(serviceName string, paddlesvc *elasticservingv1.PaddleService, isCanary bool)
pkg/serving/resources/knative/service.go:65
↓ 2 callers
Method
CreateSuccessfully
()
pkg/sampleset/ctrls/base_controller.go:432
↓ 2 callers
Function
DiskUsageOfPaths
(timeout time.Duration, paths ...string)
pkg/sampleset/utils/ctrl_utils.go:123
↓ 2 callers
Method
DoJobSuccessfully
()
pkg/sampleset/ctrls/base_controller.go:436
↓ 2 callers
Method
DoWarmupJob
DoWarmupJob call by runtime server, warmup data to local storage on each node respectively
pkg/sampleset/driver/driver.go:97
↓ 2 callers
Method
ErrorCreateObject
()
pkg/sampleset/ctrls/base_controller.go:224
↓ 2 callers
Function
GetBaseUriByName
(runtimePodName, serviceName string)
pkg/sampleset/utils/http_utils.go:62
↓ 2 callers
Method
GetLabel
GetLabel label is concatenated by PaddleLabel、driver name and SampleSet name
pkg/sampleset/driver/driver.go:319
↓ 2 callers
Method
GetRequestContext
(d Dependence)
pkg/sampleset/ctrls/base_controller.go:714
↓ 2 callers
Function
GetResultUri
(baseUri, resultPath string)
pkg/sampleset/utils/http_utils.go:70
↓ 2 callers
Method
GetRuntimeName
(sampleSetName string)
pkg/sampleset/driver/driver.go:323
↓ 2 callers
Function
NewJuiceFSDriver
()
pkg/sampleset/driver/juicefs.go:97
↓ 2 callers
Function
NoZeroOptionToMap
(optionMap map[string]reflect.Value, i interface{})
pkg/sampleset/utils/ctrl_utils.go:83
↓ 2 callers
Method
Post
(url string, filename types.UID, body io.Reader)
pkg/sampleset/utils/http_utils.go:40
↓ 2 callers
Method
PostJobOptions
(filename types.UID, j *JobType)
pkg/sampleset/ctrls/base_controller.go:812
↓ 2 callers
Method
PostJobOptionsWithParam
(filename types.UID, j *JobType, param string)
pkg/sampleset/ctrls/base_controller.go:768
↓ 2 callers
Function
RemoveFinalizer
(obj *metav1.ObjectMeta, finalizer string)
pkg/sampleset/utils/ctrl_utils.go:44
↓ 2 callers
Method
ResourcesExistWithObject
(object client.Object, r *Resource)
pkg/sampleset/ctrls/base_controller.go:589
↓ 2 callers
Method
__init__
(self, client=None)
pipeline/src/training.py:222
↓ 2 callers
Method
buildAnnotations
(metadata metav1.ObjectMeta, paddlesvcSpec elasticservingv1.PaddleServiceSpec)
pkg/serving/resources/knative/service.go:296
↓ 2 callers
Method
buildResources
(metadata metav1.ObjectMeta, paddlesvcSpec elasticservingv1.PaddleServiceSpec)
pkg/serving/resources/knative/service.go:365
↓ 2 callers
Function
constructPod
(pdj *pdv1.PaddleJob, resType string, idx int)
pkg/paddlejob/paddlejob_helper.go:282
↓ 2 callers
Function
extractNameIndex
(name string)
pkg/paddlejob/paddlejob_helper.go:207
↓ 2 callers
Method
finalizeCanaryEndpoint
(serviceName, namespace string, serviceSpec knservingv1.ServiceSpec)
pkg/serving/reconcilers/knative/service_reconciler.go:130
↓ 2 callers
Function
getMountOptions
GetMountOptions get the JuiceFS mount command options set by user
pkg/sampleset/driver/juicefs.go:175
↓ 2 callers
Method
getVolumeInfo
(pv *v1.PersistentVolume)
pkg/sampleset/driver/juicefs.go:377
↓ 2 callers
Function
isPodCreated
(spec *pdv1.ResourceSpec, status *pdv1.ResourceStatus)
pkg/paddlejob/paddlejob_helper.go:67
↓ 2 callers
Method
is_expected_conditions
(self, inst, expected_conditions)
pipeline/src/launch_crd.py:105
↓ 2 callers
Function
knativeRevisionSemanticEquals
(desired, existing *knservingv1.Revision)
pkg/serving/reconcilers/knative/service_reconciler.go:305
↓ 2 callers
Function
postWarmupMaster
(ctx context.Context, mountPath string, partitions int, log logr.Logger)
pkg/sampleset/driver/juicefs.go:674
↓ 2 callers
Function
postWarmupWorker
(ctx context.Context, mountPath string, index int, log logr.Logger)
pkg/sampleset/driver/juicefs.go:712
↓ 2 callers
Function
preWarmupMaster
(ctx context.Context, mountPath string, opt *v1alpha1.WarmupJobOptions)
pkg/sampleset/driver/juicefs.go:535
↓ 2 callers
Function
preWarmupWorker
(ctx context.Context, mountPath string, index int)
pkg/sampleset/driver/juicefs.go:655
↓ 2 callers
Method
wait_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 callers
Function
withoutVolcano
for volcano
pkg/paddlejob/paddlejob_helper.go:460
↓ 1 callers
Method
AddFinalizer
AddFinalizer add finalizer to SampleJob
pkg/sampleset/ctrls/samplejob_controller.go:156
↓ 1 callers
Method
AddFinalizer
AddFinalizer add finalizer to SampleSet
pkg/sampleset/ctrls/sampleset_controller.go:114
↓ 1 callers
Function
CollectAllCacheStatus
(runtimePodNames []string, serviceName string)
pkg/sampleset/utils/http_utils.go:107
↓ 1 callers
Method
CollectCacheStatusByPartitions
(partitions int)
pkg/sampleset/ctrls/base_controller.go:879
next →
1–100 of 439, ranked by callers