- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 110 for inState (0.39 sec)
-
cmd/erasure-multipart.go
} // NewMultipartUpload - initialize a new multipart upload, returns a // unique id. The unique id returned here is of UUID form, for each // subsequent request each UUID is unique. // // Implements S3 compatible initiate multipart API. func (er erasureObjects) NewMultipartUpload(ctx context.Context, bucket, object string, opts ObjectOptions) (*NewMultipartUploadResult, error) { if !opts.NoAuditLog { auditObjectErasureSet(ctx, object, &er)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 44.8K bytes - Viewed (0) -
cmd/object-api-putobject_test.go
err := obj.MakeBucket(context.Background(), bucket, MakeBucketOptions{}) if err != nil { // Failed to create newbucket, abort. t.Fatalf("%s : %s", instanceType, err.Error()) } opts := ObjectOptions{} // Initiate Multipart Upload on the above created bucket. res, err := obj.NewMultipartUpload(context.Background(), bucket, object, opts) if err != nil { // Failed to create NewMultipartUpload, abort.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 25.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/interfaces.go
EncodeWithAllocator(obj Object, w io.Writer, memAlloc MemoryAllocator) error } // Decoder attempts to load an object from data. type Decoder interface { // Decode attempts to deserialize the provided data using either the innate typing of the scheme or the // default kind, group, and version provided. It returns a decoded object as well as the kind, group, and
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun May 28 03:26:35 UTC 2023 - 19K bytes - Viewed (0) -
src/runtime/mprof.go
prof.stack[2] = 0 return } var nstk int gp := getg() sp := getcallersp() pc := getcallerpc() systemstack(func() { var u unwinder u.initAt(pc, sp, 0, gp, unwindSilentErrors|unwindJumpStack) nstk = 1 + tracebackPCs(&u, skip, prof.stack[1:]) }) if nstk < len(prof.stack) { prof.stack[nstk] = 0 } } func (prof *mLockProfile) store() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 53.3K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_test.go
"k8s.io/kubernetes/pkg/volume/csimigration" "k8s.io/kubernetes/pkg/volume/util" ) // Test the real controller methods (add/update/delete claim/volume) with // a fake API server. // There is no controller API to 'initiate syncAll now', therefore these tests // can't reliably simulate periodic sync of volumes/claims - it would be // either very timing-sensitive or slow to wait for real periodic sync. func TestControllerSync(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 43.4K bytes - Viewed (0) -
cmd/encryption-v1.go
} } objects = objects[N:] } return nil } // isMultipart returns true if the current object is // uploaded by the user using multipart mechanism: // initiate new multipart, upload part, complete upload func (o *ObjectInfo) isMultipart() bool { _, encrypted := crypto.IsEncrypted(o.UserDefined) if encrypted { if !crypto.IsMultiPart(o.UserDefined) { return false }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 37.1K bytes - Viewed (0) -
pkg/kubelet/apis/config/types.go
// ShutdownGracePeriodByPodPriority specifies the shutdown grace period for Pods based // on their associated priority class value. // When a shutdown request is received, the Kubelet will initiate shutdown on all pods // running on the node with a grace period that depends on the priority of the pod, // and then wait for all pods to exit.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 21:10:42 UTC 2024 - 35.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
t.Errorf("timeout after %v", wait.ForeverTestTimeout) } } func RunTestWatcherTimeout(ctx context.Context, t *testing.T, store storage.Interface) { // initialRV is used to initate the watcher at the beginning of the world. podList := example.PodList{} options := storage.ListOptions{ Predicate: storage.Everything, Recursive: true, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder.go
// RevertAssumedPodVolumes will revert assumed PV and PVC cache. RevertAssumedPodVolumes(podVolumes *PodVolumes) // BindPodVolumes will: // 1. Initiate the volume binding by making the API call to prebind the PV // to its matching PVC. // 2. Trigger the volume provisioning by making the API call to set related // annotations on the PVC
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 14:55:34 UTC 2024 - 42.6K bytes - Viewed (0) -
LICENSE
rights granted or affirmed under this License. For example, you may not impose a license fee, royalty, or other charge for exercise of rights granted under this License, and you may not initiate litigation (including a cross-claim or counterclaim in a lawsuit) alleging that any patent claim is infringed by making, using, selling, offering for sale, or importing the Program or any portion of it. 11. Patents.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 23 18:58:53 UTC 2021 - 33.7K bytes - Viewed (0)