- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 107 for vnopts (0.2 sec)
-
cmd/object-handlers.go
} return nil } var opts untarOptions opts.ignoreDirs = strings.EqualFold(r.Header.Get(xhttp.MinIOSnowballIgnoreDirs), "true") opts.ignoreErrs = strings.EqualFold(r.Header.Get(xhttp.MinIOSnowballIgnoreErrors), "true") opts.prefixAll = r.Header.Get(xhttp.MinIOSnowballPrefix) if opts.prefixAll != "" { opts.prefixAll = trimLeadingSlash(pathJoin(opts.prefixAll, slashSeparator)) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cmd/erasure-server-pool.go
return ObjectInfo{}, err } ctx = lkctx.Context() defer lk.Unlock(lkctx) if opts.DeletePrefix { return ObjectInfo{}, z.deletePrefix(ctx, bucket, object) } gopts := opts gopts.NoLock = true pinfo, noReadQuorumPools, err := z.getPoolInfoExistingWithOpts(ctx, bucket, object, gopts) if err != nil { if _, ok := err.(InsufficientReadQuorum); ok {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K 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 } }
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) -
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) -
cmd/erasure-server-pool-rebalance.go
return r.loadWithOpts(ctx, store, ObjectOptions{}) } func (r *rebalanceMeta) loadWithOpts(ctx context.Context, store objectIO, opts ObjectOptions) error { data, _, err := readConfigWithMetadata(ctx, store, rebalMetaName, opts) if err != nil { return err } if len(data) == 0 { return nil } if len(data) <= 4 { return fmt.Errorf("rebalanceMeta: no data") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
cmd/naughty-disk_test.go
func (d *naughtyDisk) UpdateMetadata(ctx context.Context, volume, path string, fi FileInfo, opts UpdateMetadataOpts) (err error) { if err := d.calcError(); err != nil { return err } return d.disk.UpdateMetadata(ctx, volume, path, fi, opts) } func (d *naughtyDisk) DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) (err error) { if err := d.calcError(); err != nil { return err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/object_api_suite_test.go
} var bytesBuffer1 bytes.Buffer var opts ObjectOptions _, err = obj.PutObject(context.Background(), "bucket", "object", mustGetPutObjReader(t, readerEOF, length, "", ""), opts) if err != nil { t.Fatalf("%s: <ERROR> %s", instanceType, err) } err = GetObject(context.Background(), obj, "bucket", "object", 0, length, &bytesBuffer1, "", opts) if err != nil { t.Fatalf("%s: <ERROR> %s", instanceType, err)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 32.3K bytes - Viewed (0) -
cmd/erasure-object_test.go
} res, err := objLayer.NewMultipartUpload(ctx, "bucket1", "mpartObj1", opts) if err != nil { t.Fatal(err) } fiveMBBytes := bytes.Repeat([]byte("a"), 5*humanize.MiByte) md5Hex := getMD5Hash(fiveMBBytes) _, err = objLayer.PutObjectPart(ctx, "bucket1", "mpartObj1", res.UploadID, 1, mustGetPutObjReader(t, bytes.NewReader(fiveMBBytes), 5*humanize.MiByte, md5Hex, ""), opts) if err != nil { t.Fatal(err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 36.8K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
return errDiskNotFound } func (p *xlStorageDiskIDCheck) DiskInfo(ctx context.Context, opts DiskInfoOptions) (info DiskInfo, err error) { if contextCanceled(ctx) { return DiskInfo{}, ctx.Err() } si := p.updateStorageMetrics(storageMetricDiskInfo) defer si(&err) if opts.NoOp { if opts.Metrics { info.Metrics = p.getMetrics() } info.Metrics.TotalWrites = p.totalWrites.Load()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/metrics-v2.go
} } func getClusterHealthMetrics(opts MetricsGroupOpts) *MetricsGroupV2 { mg := &MetricsGroupV2{ cacheInterval: 10 * time.Second, metricsGroupOpts: opts, } mg.RegisterRead(func(ctx context.Context) (metrics []MetricV2) { objLayer := newObjectLayerFn() opts := HealthOptions{} result := objLayer.Health(ctx, opts) metrics = make([]MetricV2, 0, 2+4*len(result.ESHealth))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0)