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
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SyncJobOptions.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:557
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PaddleJobSpec.
pkg/apis/paddlejob/v1/zz_generated.deepcopy.go:127
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PaddleJobStatus.
pkg/apis/paddlejob/v1/zz_generated.deepcopy.go:170
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceSpec.
pkg/apis/paddlejob/v1/zz_generated.deepcopy.go:196
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceStatus.
pkg/apis/paddlejob/v1/zz_generated.deepcopy.go:216
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SampleSetRef.
pkg/apis/paddlejob/v1/zz_generated.deepcopy.go:231
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchedulingPolicy.
pkg/apis/paddlejob/v1/zz_generated.deepcopy.go:258
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointSpec.
pkg/apis/serving/v1/zz_generated.deepcopy.go:33
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PaddleServiceSpec.
pkg/apis/serving/v1/zz_generated.deepcopy.go:138
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PaddleServiceStatus.
pkg/apis/serving/v1/zz_generated.deepcopy.go:164
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceSpec.
pkg/apis/serving/v1/zz_generated.deepcopy.go:184
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StatusConfigurationSpec.
pkg/apis/serving/v1/zz_generated.deepcopy.go:199
Method
DeepCopyObject
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:307
Method
DeepCopyObject
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:339
Method
DeepCopyObject
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:407
Method
DeepCopyObject
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
pkg/apis/sampleset/v1alpha1/zz_generated.deepcopy.go:439
Method
DeepCopyObject
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
pkg/apis/paddlejob/v1/zz_generated.deepcopy.go:47
Method
DeepCopyObject
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
pkg/apis/paddlejob/v1/zz_generated.deepcopy.go:79
Method
DeepCopyObject
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
pkg/apis/serving/v1/zz_generated.deepcopy.go:62
Method
DeepCopyObject
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
pkg/apis/serving/v1/zz_generated.deepcopy.go:94
Method
DoClearJob
DoClearJob clear the cache data in folders specified by options
pkg/sampleset/driver/driver.go:192
Method
DoRmrJob
DoRmrJob delete the data of JuiceFS storage backend under the specified paths. TODO: there some bugs in JuiceFS rmr command, after rmr paths the sync
pkg/sampleset/driver/juicefs.go:730
Method
DoSyncJob
DoSyncJob sync data from source databases to JuiceFS backend object storage, this job will only work in the first runtime server. According to the des
pkg/sampleset/driver/juicefs.go:462
Method
DoWarmupJob
DoWarmupJob warmup data from remote object storage to cache nodes, this can speed up model training process in kubernetes cluster TODO: different cach
pkg/sampleset/driver/juicefs.go:484
Function
EventIndexerFunc
(obj client.Object)
pkg/sampleset/ctrls/base_controller.go:896
Function
EventListOptions
ListOptions func(c *Controller) []client.ListOption
pkg/sampleset/ctrls/base_controller.go:360
Function
FileNumberOfPaths
(timeout time.Duration, paths ...string)
pkg/sampleset/utils/ctrl_utils.go:157
Function
FirstBaseUri
BaseUris func(c *Controller) ([]string, error)
pkg/sampleset/ctrls/base_controller.go:496
Method
GetCondition
GetCondition returns the condition by name.
pkg/apis/serving/v1/paddleservice_status.go:53
Method
GetDependents
()
pkg/sampleset/ctrls/base_controller.go:213
Method
GetDependents
()
pkg/sampleset/ctrls/base_controller.go:417
Method
GetName
()
pkg/sampleset/ctrls/base_controller.go:209
Method
GetName
()
pkg/sampleset/ctrls/base_controller.go:413
Method
InitializeConditions
()
pkg/apis/serving/v1/paddleservice_status.go:43
Method
IsReady
IsReady returns if the service is ready to serve the requested configuration.
pkg/apis/serving/v1/paddleservice_status.go:48
Function
JuiceFileNumberOfPath
(timeout time.Duration, path ...string)
pkg/sampleset/utils/ctrl_utils.go:178
Function
NameObjectKey
ObjectKey func(c *Controller) client.ObjectKey
pkg/sampleset/ctrls/base_controller.go:258
Function
NamespacedObjectKey
(c *Controller)
pkg/sampleset/ctrls/base_controller.go:262
Function
NodeListOptions
(c *Controller)
pkg/sampleset/ctrls/base_controller.go:371
Function
PVCCreateObject
(c *Controller, object client.Object, ctx *common.RequestContext)
pkg/sampleset/ctrls/base_controller.go:334
Function
PVCObject
()
pkg/sampleset/ctrls/base_controller.go:244
Function
PVCreateObject
func(c *Controller, object client.Object, ctx *common.RequestContext) error
pkg/sampleset/ctrls/base_controller.go:326
Function
PVObject
Object func() client.Object
pkg/sampleset/ctrls/base_controller.go:242
Function
PaddleJobIndexerFunc
(obj client.Object)
pkg/sampleset/ctrls/base_controller.go:913
Function
PaddleJobListOptions
(c *Controller)
pkg/sampleset/ctrls/base_controller.go:389
Method
PropagateStatus
(serviceStatus *knservingv1.ServiceStatus)
pkg/apis/serving/v1/paddleservice_status.go:57
Method
Reconcile
+kubebuilder:rbac:groups=batch.paddlepaddle.org,resources=samplejobs,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=batch.pa
pkg/sampleset/ctrls/samplejob_controller.go:68
Method
Reconcile
+kubebuilder:rbac:groups=batch.paddlepaddle.org,resources=samplesets,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=batch.pa
pkg/sampleset/ctrls/sampleset_controller.go:70
Method
Reconcile
+kubebuilder:rbac:groups=batch.paddlepaddle.org,resources=paddlejobs,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=batch.pa
pkg/paddlejob/paddlejob_controller.go:108
Method
Reconcile
+kubebuilder:rbac:groups=serving.paddlepaddle.org,resources=paddleservices,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=se
pkg/serving/paddleflow_serving_controller.go:47
Function
RmrCreateOptions
(c *Controller, opt interface{}, ctx *common.RequestContext)
pkg/sampleset/ctrls/base_controller.go:463
Function
RmrOptions
()
pkg/sampleset/ctrls/base_controller.go:448
Function
RuntimePodIndexerFunc
(obj client.Object)
pkg/sampleset/ctrls/base_controller.go:908
Function
RuntimePodListOptions
(c *Controller)
pkg/sampleset/ctrls/base_controller.go:376
Function
SampleJobObject
()
pkg/sampleset/ctrls/base_controller.go:254
Function
SampleJobObjectKey
(c *Controller)
pkg/sampleset/ctrls/base_controller.go:319
Function
SampleSetObject
()
pkg/sampleset/ctrls/base_controller.go:252
Function
SecretObject
()
pkg/sampleset/ctrls/base_controller.go:246
Function
SecretObjectKey
(c *Controller)
pkg/sampleset/ctrls/base_controller.go:266
Function
ServiceCreateObject
(c *Controller, object client.Object, ctx *common.RequestContext)
pkg/sampleset/ctrls/base_controller.go:342
Function
ServiceObject
()
pkg/sampleset/ctrls/base_controller.go:248
Function
ServiceObjectKey
(c *Controller)
pkg/sampleset/ctrls/base_controller.go:309
Function
SetupNs
SetupTest will set up a testing environment. This includes: * creating a Namespace to be used during the test * starting the 'PaddleService Reconciler
pkg/serving/suite_test.go:105
Method
SetupWithManager
SetupWithManager sets up the controller with the Manager.
pkg/sampleset/ctrls/samplejob_controller.go:181
Method
SetupWithManager
SetupWithManager sets up the controller with the Manager.
pkg/sampleset/ctrls/sampleset_controller.go:124
Function
SourceSecretObjectKey
(c *Controller)
pkg/sampleset/ctrls/base_controller.go:278
Function
StatefulSetCreateObject
(c *Controller, object client.Object, ctx *common.RequestContext)
pkg/sampleset/ctrls/base_controller.go:350
Function
StatefulSetObject
()
pkg/sampleset/ctrls/base_controller.go:250
Function
StatefulSetObjectKey
(c *Controller)
pkg/sampleset/ctrls/base_controller.go:314
Function
SyncCreateOptions
CreateOptions func(c *Controller, opt *JobOptions, ctx *common.RequestContext) error
pkg/sampleset/ctrls/base_controller.go:454
Function
SyncOptions
Options func() interface{}
pkg/sampleset/ctrls/base_controller.go:442
Function
TerminateCreateOptions
(c *Controller, opt interface{}, ctx *common.RequestContext)
pkg/sampleset/ctrls/base_controller.go:490
Function
TerminateOptions
()
pkg/sampleset/ctrls/base_controller.go:450
Function
TestAPIs
(t *testing.T)
pkg/paddlejob/suite_test.go:43
Function
TestAPIs
(t *testing.T)
pkg/serving/suite_test.go:52
Function
TestBaseDriver_CreateClearJobOptions
(t *testing.T)
pkg/sampleset/driver/driver_test.go:60
Function
TestBaseDriver_CreateRmrJobOptions
(t *testing.T)
pkg/sampleset/driver/driver_test.go:141
Function
TestBaseDriver_DoClearJob
(t *testing.T)
pkg/sampleset/driver/driver_test.go:32
Function
TestCanaryPaddleServiceToKnativeService
(t *testing.T)
pkg/serving/resources/knative/service_test.go:281
Function
TestDefaultPaddleServiceToKnativeService
(t *testing.T)
pkg/serving/resources/knative/service_test.go:258
Function
TestJuiceFS_DoWarmupJob
(t *testing.T)
pkg/sampleset/driver/juicefs_test.go:142
Function
TestJuiceFS_getMountOptions
(t *testing.T)
pkg/sampleset/driver/juicefs_test.go:36
Function
TestJuiceFS_getVolumeInfo
(t *testing.T)
pkg/sampleset/driver/juicefs_test.go:114
Function
TestPaddleEndpointToKnativeRevision
(t *testing.T)
pkg/serving/resources/knative/service_test.go:357
Method
UpdateSuccessfully
()
pkg/sampleset/ctrls/base_controller.go:236
Function
WarmupCreateOptions
(c *Controller, opt interface{}, ctx *common.RequestContext)
pkg/sampleset/ctrls/base_controller.go:472
Function
WarmupOptions
()
pkg/sampleset/ctrls/base_controller.go:444
Method
__init__
(self, client=None)
pipeline/src/modelhub.py:11
Method
__init__
(self, client=None)
pipeline/src/dataset.py:46
Method
__init__
(self, client=None)
pipeline/src/training.py:14
Method
__init__
(self, client=None)
pipeline/src/training.py:160
Method
__init__
(self, client=None)
pipeline/src/training.py:364
Method
__init__
(self, group, plural, version, client)
pipeline/src/launch_crd.py:25
Method
__init__
(self, client=None)
pipeline/src/serving.py:53
Method
doClear
(body []byte)
pkg/sampleset/manager/server.go:322
Method
doRmr
(body []byte)
pkg/sampleset/manager/server.go:342
Method
doSync
(body []byte)
pkg/sampleset/manager/server.go:312
Method
doWarmup
(body []byte)
pkg/sampleset/manager/server.go:332
Function
genEndpoints
(name string, resType string, num int, port int)
pkg/paddlejob/paddlejob_helper.go:406
Method
get_action_status
(self, action=None)
pipeline/src/modelhub.py:14
← previous
next →
301–400 of 439, ranked by callers