- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 37 for recycler (0.16 sec)
-
pkg/controller/volume/persistentvolume/recycle_test.go
expectedEvents: noevents, errors: noerrors, // Inject recycler into the controller and call syncVolume. The // recycler simulates one recycle() call that succeeds. test: wrapTestWithReclaimCalls(operationRecycle, []error{nil}, testSyncVolume), }, { // recycle volume bound by user name: "6-2 - successful recycle with prebound volume",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 14.2K bytes - Viewed (0) -
pkg/volume/plugins.go
// 2. pod.GenerateName helps distinguish recycler pods by name. Recommended. // Default is "pv-recycler-". // 3. pod.Spec.ActiveDeadlineSeconds gives the recycler pod a maximum timeout // before failing. Recommended. Default is 60 seconds. // // See HostPath and NFS for working recycler examples func NewPersistentVolumeRecyclerPodTemplate() *v1.Pod { timeout := int64(60) pod := &v1.Pod{ ObjectMeta: metav1.ObjectMeta{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0) -
internal/grid/types.go
"sort" "strings" "sync" "github.com/tinylib/msgp/msgp" ) // Recycler will override the internal reuse in typed handlers. // When this is supported, the handler will not do internal pooling of objects, // call Recycle() when the object is no longer needed. // The recycler should handle nil pointers. type Recycler interface { Recycle() } // MSS is a map[string]string that can be serialized.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Apr 01 23:42:09 UTC 2024 - 15.4K bytes - Viewed (0) -
internal/grid/handlers.go
newReq func() Req newResp func() Resp recycleReq func(Req) recycleResp func(Resp) } func recycleFunc[RT RoundTripper](newRT func() RT) (newFn func() RT, recycle func(r RT)) { rAny := any(newRT()) var rZero RT if _, ok := rAny.(Recycler); ok { return newRT, func(r RT) { if r != rZero { if rc, ok := any(r).(Recycler); ok { rc.Recycle() } } } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.1K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/framework_test.go
) // wrapTestWithPluginCalls returns a testCall that: // - configures controller with a volume plugin that implements recycler, // deleter and provisioner. The plugin returns provided errors when a volume // is deleted, recycled or provisioned. // - calls given testCall
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 09:54:00 UTC 2023 - 38.3K bytes - Viewed (0) -
src/main/resources/fess_config.properties
-Djcifs.smb1.smb.client.connTimeout=60000\n\ -Djcifs.smb1.smb.client.soTimeout=35000\n\ -Djcifs.smb1.smb.client.responseTimeout=30000\n\ -Dio.netty.noUnsafe=true\n\ -Dio.netty.noKeySetOptimization=true\n\ -Dio.netty.recycler.maxCapacityPerThread=0\n\ -Dlog4j.shutdownHookEnabled=false\n\ -Dlog4j2.formatMsgNoLookups=true\n\ -Dlog4j2.disable.jmx=true\n\ -Dlog4j.skipJansi=true\n\ -Dsun.java2d.cmm=sun.java2d.cmm.kcms.KcmsServiceProvider\n\
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Apr 11 02:34:53 UTC 2024 - 30.6K bytes - Viewed (0) -
pkg/volume/hostpath/host_path_test.go
} if deleter.GetPath() != tempPath { t.Errorf("Expected %s but got %s", tempPath, deleter.GetPath()) } if err := deleter.Delete(); err != nil { t.Errorf("Mock Recycler expected to return nil but got %s", err) } if exists, _ := utilpath.Exists(utilpath.CheckFollowSymlink, tempPath); exists { t.Errorf("Temp path expected to be deleted, but was found at %s", tempPath) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 20.5K bytes - Viewed (0) -
pkg/volume/util/util.go
if err := apiruntime.DecodeInto(codec, podDef, pod); err != nil { return nil, fmt.Errorf("failed decoding file: %v", err) } return pod, nil } // CalculateTimeoutForVolume calculates time for a Recycler pod to complete a // recycle operation. The calculation and return value is either the // minimumTimeout or the timeoutIncrement per Gi of storage size, whichever is // greater.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 28.8K bytes - Viewed (0) -
pkg/volume/hostpath/host_path.go
return &hostPathUnmounter{&hostPath{ path: "", }}, nil } // Recycle recycles/scrubs clean a HostPath volume. // Recycle blocks until the pod has completed or any error occurs. // HostPath recycling only works in single node clusters and is meant for testing purposes only. func (plugin *hostPathPlugin) Recycle(pvName string, spec *volume.Spec, eventRecorder recyclerclient.RecycleEventRecorder) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 15.3K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/provision_test.go
{Verb: "create", Resource: "persistentvolumes", Error: errors.New("Mock creation error5")}, }, test: wrapTestWithPluginCalls( nil, // recycle calls []error{nil}, // delete calls []provisionCall{provision1Success}, // provision calls testSyncClaim, ), }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 35.3K bytes - Viewed (0)