- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 443 for Marker (0.05 sec)
-
docs/metrics/prometheus/list.md
| `minio_cluster_usage_version_total` | Total number of versions (includes delete marker) in a cluster | | `minio_cluster_usage_deletemarker_total` | Total number of delete markers in a cluster | | `minio_cluster_usage_total_bytes` | Total cluster usage in bytes |
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:48:51 UTC 2024 - 43.3K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
continue } // any object with only single DEL marker we don't need // to rebalance, just skip it, this also includes // any other versions that have already expired. remainingVersions := len(fivs.Versions) - expired if version.Deleted && remainingVersions == 1 { rebalanced++ stopFn(version.Size, errors.New("DELETE marked object with no other non-current versions will be skipped")) continue
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 13:20:19 UTC 2024 - 28.4K bytes - Viewed (0) -
cmd/erasure-healing_test.go
errFileNotFound, errFileNotFound, nil, }, dataErrs: nil, expectedMeta: ifi, expectedDangling: true, }, { name: "FileInfoDecided-case2-delete-marker", metaArr: []FileInfo{ {}, {}, {}, {Deleted: true}, }, errs: []error{ errFileNotFound, errFileNotFound, errFileNotFound, nil, },
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 49K bytes - Viewed (0) -
cmd/batch-rotate.go
if err != nil { return err } wk, err := workers.New(workerSize) if err != nil { // invalid worker size. return err } ctx, cancel := context.WithCancel(ctx) results := make(chan itemOrErr[ObjectInfo], 100) if err := api.Walk(ctx, r.Bucket, r.Prefix, results, WalkOptions{ Marker: lastObject, Filter: selectObj, }); err != nil { cancel()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 18 17:59:03 UTC 2024 - 14.7K bytes - Viewed (0) -
cmd/erasure-multipart.go
} sort.Ints(partNums) return partNums, nil } // ListObjectParts - lists all previously uploaded parts for a given // object and uploadID. Takes additional input of part-number-marker // to indicate where the listing should begin from. // // Implements S3 compatible ListObjectParts API. The resulting // ListPartsInfo structure is marshaled directly into XML and // replied back to the client.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 44.7K bytes - Viewed (0) -
cmd/bucket-replication-utils.go
func (d *DeletedObject) VersionPurgeStatus() VersionPurgeStatusType { return d.ReplicationState.CompositeVersionPurgeStatus() } // DeleteMarkerReplicationStatus return composite replication status of delete marker across targets func (d *DeletedObject) DeleteMarkerReplicationStatus() replication.StatusType { return d.ReplicationState.CompositeReplicationStatus() }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 26.3K bytes - Viewed (0) -
cmd/object-handlers.go
gopts.NoLock = true // We already have a lock, we can live with it. objInfo, err := getObjectInfo(ctx, bucket, object, gopts) if err != nil { // Versioning enabled quite possibly object is deleted might be delete-marker // if present set the headers, no idea why AWS S3 sets these headers. if objInfo.VersionID != "" && objInfo.DeleteMarker { w.Header()[xhttp.AmzVersionID] = []string{objInfo.VersionID}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 05 05:16:15 UTC 2024 - 117.4K bytes - Viewed (0) -
cmd/object_api_suite_test.go
} if result.Prefixes[0] != "this/" { t.Errorf("%s: Expected the prefix to be `%s`, but instead found `%s`", instanceType, "this/", result.Prefixes[0]) } } // check results with Marker. { result, err = obj.ListObjects(context.Background(), "bucket", "", "newPrefix", "", 3) if err != nil { t.Fatalf("%s: <ERROR> %s", instanceType, err) } if result.Objects[0].Name != "newPrefix2" {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 02 15:13:05 UTC 2024 - 33.3K bytes - Viewed (0) -
cmd/metacache-entries.go
// If separator is not found or is last entry, ok. return idx == -1 || idx == len(ext)-len(separator) } return false } // isLatestDeletemarker returns whether the latest version is a delete marker. // If metadata is NOT versioned false will always be returned. // If v2 and UNABLE to load metadata true will be returned. func (e *metaCacheEntry) isLatestDeletemarker() bool { if e.cached != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 08 15:29:58 UTC 2024 - 24.1K bytes - Viewed (0) -
src/archive/zip/zip_test.go
} func TestZip64EdgeCase(t *testing.T) { if testing.Short() { t.Skip("slow test; skipping") } t.Parallel() // Test a zip file with uncompressed size 0xFFFFFFFF. // That's the magic marker for a 64-bit file, so even though // it fits in a 32-bit field we must use the 64-bit field. // Go 1.5 and earlier got this wrong, // writing an invalid zip file.
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 19.6K bytes - Viewed (0)