Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for getHits (0.13 sec)

  1. cmd/object-api-options.go

    		opts.ServerSideEncryption = encrypt.NewSSE()
    	}
    
    	return
    }
    
    // get ObjectOptions for GET calls from encryption headers
    func getOpts(ctx context.Context, r *http.Request, bucket, object string) (ObjectOptions, error) {
    	var opts ObjectOptions
    
    	var partNumber int
    	var err error
    	if pn := r.Form.Get(xhttp.PartNumber); pn != "" {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 06:56:12 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  2. cmd/object-multipart-handlers.go

    		return
    	}
    	srcOpts.VersionID = vid
    
    	// convert copy src and dst encryption options for GET/PUT calls
    	getOpts := ObjectOptions{VersionID: srcOpts.VersionID}
    	if srcOpts.ServerSideEncryption != nil {
    		getOpts.ServerSideEncryption = encrypt.SSE(srcOpts.ServerSideEncryption)
    	}
    
    	dstOpts, err = copyDstOpts(ctx, r, dstBucket, dstObject, nil)
    	if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 38.8K bytes
    - Viewed (0)
  3. cmd/s3-zip-handlers.go

    		return
    	}
    
    	zipPath, object, err := splitZipExtensionPath(object)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	opts, err := getOpts(ctx, r, bucket, zipPath)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	getObjectInfo := objectAPI.GetObjectInfo
    
    	// Check for auth type to return S3 compatible error.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_test.go

    		t.Fatalf("Failed to initialize cacher: %v", err)
    	}
    	ctx := context.Background()
    	terminate := func() {
    		cacher.Stop()
    		server.Terminate(t)
    	}
    
    	// Since some tests depend on the fact that GetList shouldn't fail,
    	// we wait until the error from the underlying storage is consumed.
    	if err := wait.PollInfinite(100*time.Millisecond, wrappedStorage.ErrorsConsumed); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 17K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go

    	_, watchErr := store.Watch(ctx, invalidKey, storage.ListOptions{})
    	expectInvalidKey("Watch", watchErr)
    	expectInvalidKey("Get", store.Get(ctx, invalidKey, storage.GetOptions{}, nil))
    	expectInvalidKey("GetList", store.GetList(ctx, invalidKey, storage.ListOptions{}, nil))
    	expectInvalidKey("GuaranteedUpdate", store.GuaranteedUpdate(ctx, invalidKey, nil, true, nil, nil, nil))
    	_, countErr := store.Count(invalidKey)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 26.5K bytes
    - Viewed (0)
  6. cluster/gce/upgrade.sh

    master_upgrade=true
    node_upgrade=true
    node_prereqs=false
    local_binaries=false
    env_os_distro=false
    node_upgrade_parallelism=1
    
    while getopts ":MNPlcho" opt; do
      case "${opt}" in
        M)
          node_upgrade=false
          ;;
        N)
          master_upgrade=false
          ;;
        P)
          node_prereqs=true
          ;;
        l)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 21:13:22 UTC 2024
    - 25.2K bytes
    - Viewed (0)
Back to top