- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 166 for vnopts (0.17 sec)
-
cmd/s3-zip-handlers.go
return } // Validate pre-conditions if any. opts.CheckPrecondFn = func(oi ObjectInfo) bool { if _, err := DecryptObjectInfo(&oi, r); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return true } return checkPreconditions(ctx, w, r, oi, opts) } zipObjInfo, err := getObjectInfo(ctx, bucket, zipPath, opts) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 09 10:41:25 GMT 2024 - 15.8K bytes - Viewed (0) -
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 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 55.2K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
} gopts := WarmBackendGetOpts{} // get correct offsets for object if off >= 0 && length >= 0 { gopts.startOffset = off gopts.length = length } timeTierAction := auditTierActions(ctx, oi.TransitionedObject.Tier, length) reader, err := tgtClient.Get(ctx, oi.TransitionedObject.Name, remoteVersionID(oi.TransitionedObject.VersionID), gopts) if err != nil { return nil, err } closer := func() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/erasure-healing.go
return } opts := AuditLogOptions{ Event: "HealObject", Bucket: bucket, Object: object, VersionID: versionID, } if err != nil { opts.Error = err.Error() } if result.After.Drives != nil { opts.Tags = map[string]interface{}{"drives-result": result.After.Drives} } auditLogInternal(ctx, opts) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/object-api-utils.go
// not all run!). func NewGetObjectReader(rs *HTTPRangeSpec, oi ObjectInfo, opts ObjectOptions) ( fn ObjReaderFn, off, length int64, err error, ) { if opts.CheckPrecondFn != nil && opts.CheckPrecondFn(oi) { return nil, 0, 0, PreConditionFailed{} } if rs == nil && opts.PartNumber > 0 { rs = partNumberToRangeSpec(oi, opts.PartNumber) } _, isEncrypted := crypto.IsEncrypted(oi.UserDefined)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
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/notification.go
if report == nil || report.BucketStats == nil { continue } for opts := range report.BucketStats { d, ok := consolidatedReport.BucketStats[opts] if !ok { d = bandwidth.Details{ LimitInBytesPerSecond: report.BucketStats[opts].LimitInBytesPerSecond, } } dt, ok := report.BucketStats[opts] if ok { d.CurrentBandwidthInBytesPerSecond += dt.CurrentBandwidthInBytesPerSecond
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K 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) -
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/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 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Mar 27 15:10:40 GMT 2024 - 47.6K bytes - Viewed (0)