Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for ToOpts (0.15 sec)

  1. cmd/batch-handlers.go

    			return err
    		}
    		return r.copyWithMultipartfromSource(ctx, api, core, srcObjInfo, opts, partsCount)
    	}
    	gopts := miniogo.GetObjectOptions{
    		VersionID: srcObjInfo.VersionID,
    	}
    	if err := gopts.SetMatchETag(srcObjInfo.ETag); err != nil {
    		return err
    	}
    	rd, objInfo, _, err := core.GetObject(ctx, srcBucket, srcObject, gopts)
    	if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 56K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    		if err != nil {
    			return ObjectInfo{}, err
    		}
    		if dsc.ReplicateAny() {
    			opts.SetDeleteReplicationState(dsc, opts.VersionID)
    			goi.replicationDecision = opts.DeleteReplication.ReplicateDecisionStr
    		}
    	}
    
    	if opts.EvalRetentionBypassFn != nil {
    		if err := opts.EvalRetentionBypassFn(goi, gerr); err != nil {
    			return ObjectInfo{}, err
    		}
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 78.6K bytes
    - Viewed (0)
  3. cmd/erasure-healing_test.go

    	data := bytes.Repeat([]byte("a"), 5*1024*1024)
    	var opts ObjectOptions
    
    	err = objLayer.MakeBucket(ctx, bucket, MakeBucketOptions{})
    	if err != nil {
    		t.Fatalf("Failed to make a bucket - %v", err)
    	}
    
    	// Create an object with multiple parts uploaded in decreasing
    	// part number.
    	res, err := objLayer.NewMultipartUpload(ctx, bucket, object, opts)
    	if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    		p := storage.Everything
    		p.AllowWatchBookmarks = allowBookmarks
    
    		opts := storage.ListOptions{}
    		opts.Predicate = p
    		opts.SendInitialEvents = sendInitialEvents
    		opts.ResourceVersion = rv
    		return opts
    	}
    
    	scenarios := []struct {
    		name string
    		opts storage.ListOptions
    
    		expectedWatchResourceVersion int
    	}{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
  5. tests/integration/ambient/baseline_test.go

    			}
    			SupportsHBone := func(from echo.Instance, opts echo.CallOptions) bool {
    				if !from.Config().IsUncaptured() && !opts.To.Config().IsUncaptured() {
    					return true
    				}
    				if !from.Config().IsUncaptured() && opts.To.Config().HasSidecar() {
    					return true
    				}
    				if from.Config().HasSidecar() && !opts.To.Config().IsUncaptured() {
    					return true
    				}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 00:07:28 UTC 2024
    - 78.4K bytes
    - Viewed (0)
  6. cmd/iam.go

    	}
    	if len(opts.secretKey) > 0 && len(opts.accessKey) == 0 {
    		return auth.Credentials{}, time.Time{}, auth.ErrNoAccessKeyWithSecretKey
    	}
    
    	var policyBuf []byte
    	if opts.sessionPolicy != nil {
    		err := opts.sessionPolicy.Validate()
    		if err != nil {
    			return auth.Credentials{}, time.Time{}, err
    		}
    		policyBuf, err = json.Marshal(opts.sessionPolicy)
    		if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 71.9K bytes
    - Viewed (0)
  7. cmd/bucket-handlers.go

    		}
    
    		if !globalTierConfigMgr.Empty() {
    			oss[index] = newObjSweeper(bucket, object.ObjectName).WithVersion(opts.VersionID).WithVersioning(opts.Versioned, opts.VersionSuspended)
    			oss[index].SetTransitionState(goi.TransitionedObject)
    		}
    
    		// All deletes on directory objects needs to be for `nullVersionID`
    		if isDirObject(object.ObjectName) && object.VersionID == "" {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 61.2K bytes
    - Viewed (0)
  8. cmd/iam-store.go

    			return updatedAt, auth.ErrInvalidSecretKeyLength
    		}
    		cr.SecretKey = opts.secretKey
    	}
    
    	if opts.name != "" {
    		cr.Name = opts.name
    	}
    
    	if opts.description != "" {
    		cr.Description = opts.description
    	}
    
    	if opts.expiration != nil {
    		expirationInUTC := opts.expiration.UTC()
    		if err := validateSvcExpirationInUTC(expirationInUTC); err != nil {
    			return updatedAt, err
    		}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 75.8K bytes
    - Viewed (0)
  9. cmd/xl-storage.go

    		defer metaDataPoolPut(buf)
    		if err != nil {
    			return err
    		}
    
    		return s.WriteAll(ctx, volume, pathJoin(path, xlStorageFormatFile), buf)
    	}
    
    	if opts.UndoWrite && opts.OldDataDir != "" {
    		return renameAll(pathJoin(filePath, opts.OldDataDir, xlStorageFormatFileBackup), pathJoin(filePath, xlStorageFormatFile), filePath)
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (0)
  10. testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/executer/AbstractGradleExecuter.java

            if (gradleVersionOverride != null) {
                executer.withGradleVersionOverride(gradleVersionOverride);
            }
    
            executer.startBuildProcessInDebugger(opts -> debug.copyTo(opts))
                .startLauncherInDebugger(opts -> debugLauncher.copyTo(opts))
                .withProfiler(profiler)
                .withForceInteractive(interactive);
    
            if (!checkDeprecations) {
                executer.noDeprecationChecks();
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 09:51:15 UTC 2024
    - 55.1K bytes
    - Viewed (0)
Back to top