- Sort Score
- Num 10 results
- Language All
Results 11 - 20 of 26 for objectSize (0.08 seconds)
-
cmd/perf-tests.go
go func(i int) { defer wg.Done() for { t := time.Now() reader := newRandomReader(opts.objectSize) tmpObjName := pathJoin(objNamePrefix, fmt.Sprintf("%d/%d", i, objCountPerThread[i])) info, err := clnt.PutObject(uploadsCtx, opts.bucketName, tmpObjName, reader, int64(opts.objectSize), popts) if err != nil { if !contextCanceled(uploadsCtx) && !errors.Is(err, context.Canceled) {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 11.8K bytes - Click Count (0) -
cmd/bucket-replication.go
time.Sleep(time.Duration(rand.Int63n(int64(time.Second)))) } } }() var ( hr *hash.Reader isSSEC = crypto.SSEC.IsEncrypted(objInfo.UserDefined) ) var objectSize int64 for _, partInfo := range objInfo.Parts { if isSSEC { hr, err = hash.NewReader(ctx, io.LimitReader(r, partInfo.Size), partInfo.Size, "", "", partInfo.ActualSize) } else {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 118.2K bytes - Click Count (0) -
cmd/batch-handlers.go
break } return nil } //msgp:ignore batchReplicationJobError type batchReplicationJobError struct { Code string Description string HTTPStatusCode int ObjectSize int64 } func (e batchReplicationJobError) Error() string { return e.Description } // Validate validates the job definition inputCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 63.5K bytes - Click Count (1) -
cmd/global-heal.go
healingLogIf(ctx, fmt.Errorf("unable to heal object %s/%s: %w", bucket, entry.name, err)) } else { bgSeq.countHealed(madmin.HealItemObject) result = healEntrySuccess(uint64(res.ObjectSize)) } send(result) return } var versionNotFound int for _, version := range fivs.Versions { // Ignore healing a version if:
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Apr 04 13:49:12 GMT 2025 - 16.2K bytes - Click Count (0) -
cmd/object-api-options.go
valid = false return opts, valid } for tag := range opts.ObjectAttributes { switch tag { case xhttp.ETag: case xhttp.Checksum: case xhttp.StorageClass: case xhttp.ObjectSize: case xhttp.ObjectParts: default: apiErr = errorCodes.ToAPIErr(ErrInvalidAttributeName) argumentName = strings.ToLower(xhttp.AmzObjectAttributes) argumentValue = tag valid = falseCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 14.3K bytes - Click Count (0) -
cmd/admin-handlers.go
}() keepAliveTicker := time.NewTicker(500 * time.Millisecond) defer keepAliveTicker.Stop() enc := json.NewEncoder(w) ch := objectSpeedTest(ctx, speedTestOpts{ objectSize: size, concurrencyStart: concurrent, duration: duration, autotune: autotune, storageClass: storageClass, bucketName: customBucket, enableSha256: enableSha256,
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 99.7K bytes - Click Count (0) -
cmd/data-scanner.go
} healOpts := madmin.HealOpts{ Remove: healDeleteDangling, ScanMode: scanMode, } res, _ := o.HealObject(ctx, i.bucket, i.objectPath(), oi.VersionID, healOpts) if res.ObjectSize > 0 { return res.ObjectSize } return 0 } func (i *scannerItem) alertExcessiveVersions(remainingVersions int, cumulativeSize int64) { if remainingVersions >= int(scannerExcessObjectVersions.Load()) {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 45.5K bytes - Click Count (0) -
cmd/peer-rest-client.go
} }() return ch, nil } func (client *peerRESTClient) SpeedTest(ctx context.Context, opts speedTestOpts) (SpeedTestResult, error) { values := make(url.Values) values.Set(peerRESTSize, strconv.Itoa(opts.objectSize)) values.Set(peerRESTConcurrent, strconv.Itoa(opts.concurrency)) values.Set(peerRESTDuration, opts.duration.String()) values.Set(peerRESTStorageClass, opts.storageClass) values.Set(peerRESTBucket, opts.bucketName)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 26.1K bytes - Click Count (0) -
cmd/object-handlers.go
} } } if _, ok := opts.ObjectAttributes[xhttp.ETag]; ok { OA.ETag = objInfo.ETag } if _, ok := opts.ObjectAttributes[xhttp.ObjectSize]; ok { OA.ObjectSize, _ = objInfo.GetActualSize() } if _, ok := opts.ObjectAttributes[xhttp.StorageClass]; ok { OA.StorageClass = filterStorageClass(ctx, objInfo.StorageClass) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 120.6K bytes - Click Count (0) -
docs/en/docs/management-tasks.md
Try to avoid using bitter sarcasm or potentially passive-aggressive comments. If something is wrong, it's better to be direct (try to be gentle) than sarcastic. Try to be as specific and objective as possible, avoid generalizations. For conversations that are more difficult, for example to reject a PR, you can ask me (@tiangolo) to handle it directly. ## Edit PR Titles
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Mon Mar 23 13:59:26 GMT 2026 - 10.7K bytes - Click Count (0)