- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for ToOpts (0.15 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)