- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 173 for vnopts (0.17 sec)
-
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 } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
internal/grid/benchmark_test.go
// This will give an estimate of the total ops/s. latency := float64(atomic.LoadInt64(&lat)) / float64(time.Millisecond) b.ReportMetric(float64(n)*float64(ops)/spent.Seconds(), "vops/s") b.ReportMetric(latency/float64(ops), "ms/op") } }) } }) b.Run("rpc", func(b *testing.B) { for par := 1; par <= 32; par *= 2 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 12.2K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } opts := extractReplicateDiffOpts(r.Form) if opts.ARN != "" { tgt := globalBucketTargetSys.GetRemoteBucketTargetByArn(ctx, bucket, opts.ARN) if tgt.Empty() { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrInvalidRequest, fmt.Errorf("invalid arn : '%s'", opts.ARN)), r.URL) return } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 32.5K bytes - Viewed (0) -
cmd/os_unix.go
return nil } } return err } // Return count entries at the directory dirPath and all entries // if count is set to -1 func readDirWithOpts(dirPath string, opts readDirOpts) (entries []string, err error) { fd, err := openFileWithFD(dirPath, readMode, 0o666) if err != nil { if !osIsPermission(err) { return nil, osErrToFileErr(err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/tier.go
return nil, nil, err } pReader, err := NewPutObjReader(hr).WithEncryption(encHr, &oek) if err != nil { return nil, nil, err } opts := &ObjectOptions{ UserDefined: metadata, MTime: UTCNow(), MaxParity: true, } return pReader, opts, nil } // Reload updates config by reloading remote tier config from config store.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cmd/storage-rest-server.go
s.IsValid(w, r) } // DiskInfoHandler - returns disk info. func (s *storageRESTServer) DiskInfoHandler(opts *DiskInfoOptions) (*DiskInfo, *grid.RemoteErr) { if !s.checkID(opts.DiskID) { return nil, grid.NewRemoteErr(errDiskNotFound) } info, err := s.getStorage().DiskInfo(context.Background(), *opts) if err != nil { info.Error = err.Error() } return &info, nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
cmd/bucket-object-lock.go
return mode, retainDate, legalHold, ErrNone } opts, err := getOpts(ctx, rq, bucket, object) if err != nil { return mode, retainDate, legalHold, toAPIErrorCode(ctx, err) } replica := rq.Header.Get(xhttp.AmzBucketReplicationStatus) == replication.Replica.String() if opts.VersionID != "" && !replica { if objInfo, err := getObjectInfoFn(ctx, bucket, object, opts); err == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 13.2K bytes - Viewed (0) -
docs/sts/web-identity.go
return } opts := &minio.Options{ Creds: sts, BucketLookup: minio.BucketLookupAuto, } u, err := url.Parse(stsEndpoint) if err != nil { log.Println(fmt.Errorf("Failed to parse STS Endpoint: %s", err)) http.Error(w, err.Error(), http.StatusBadRequest) return } clnt, err := minio.New(u.Host, opts) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 19 09:13:33 GMT 2023 - 7.8K bytes - Viewed (3) -
cni/pkg/nodeagent/net_test.go
"istio.io/istio/pkg/test/util/assert" "istio.io/istio/tools/istio-iptables/pkg/dependencies" ) func setupLogging() { opts := istiolog.DefaultOptions() opts.SetDefaultOutputLevel(istiolog.OverrideScopeName, istiolog.DebugLevel) istiolog.Configure(opts) for _, scope := range istiolog.Scopes() { scope.SetOutputLevel(istiolog.DebugLevel) } } type netTestFixture struct {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
} opts, err := putOptsFromReq(ctx, r, bucket, object, metadata) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } if opts.PreserveETag != "" || r.Header.Get(xhttp.IfMatch) != "" || r.Header.Get(xhttp.IfNoneMatch) != "" { opts.CheckPrecondFn = func(oi ObjectInfo) bool {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0)