- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for fileInfoVersions (0.07 sec)
-
cmd/storage-datatypes.go
type FilesInfo struct { Files []FileInfo IsTruncated bool } // Size returns size of all versions for the object 'Name' func (f FileInfoVersions) Size() (size int64) { for _, v := range f.Versions { size += v.Size } return size } // FileInfoVersions represent a list of versions for a given file. // The above means that any added/deleted fields are incompatible. //Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 17.4K bytes - Viewed (0) -
cmd/storage-datatypes_gen_test.go
} } func BenchmarkMarshalMsgFileInfoVersions(b *testing.B) { v := FileInfoVersions{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgFileInfoVersions(b *testing.B) { v := FileInfoVersions{} bts := make([]byte, 0, v.Msgsize()) bts, _ = v.MarshalMsg(bts[0:0]) b.SetBytes(int64(len(bts)))
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 73.9K bytes - Viewed (0) -
cmd/metacache-server-pool.go
if o.Lifecycle != nil { act := evalActionFromLifecycle(ctx, *o.Lifecycle, o.Retention, o.Replication.Config, objInfo).Action skip = act.Delete() && !act.DeleteRestored() } } fiv, err := obj.fileInfoVersions(o.Bucket) if err != nil { return skip } // Expire all versions if needed, if not attempt to queue for replication. for _, version := range fiv.Versions {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 12.9K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
default: return false } } decommissionEntry := func(entry metaCacheEntry) { defer wk.Give() if entry.isDir() { return } fivs, err := entry.fileInfoVersions(bi.Name) if err != nil { return } // We need a reversed order for decommissioning, // to create the appropriate stack. versionsSorter(fivs.Versions).reverse()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 42.2K bytes - Viewed (1) -
cmd/erasure-server-pool.go
return } } continue } fivs, err := entry.fileInfoVersions(bucket) if err != nil { sendErr(err) return } // Note: entry.fileInfoVersions returns versions sorted in reverse chronological order based on ModTime if opts.VersionsSort == WalkVersionsSortAsc {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 89.2K bytes - Viewed (0) -
cmd/storage-rest-client.go
}) return toStorageErr(err) } // DeleteVersions - deletes list of specified versions if present func (client *storageRESTClient) DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) (errs []error) { if len(versions) == 0 { return errs } values := make(url.Values) values.Set(storageRESTVolume, volume)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 08 02:38:41 UTC 2025 - 30.4K bytes - Viewed (0) -
cmd/erasure-object.go
// storage class only needs to be honored for // Read() requests alone which we already do. writeQuorums[i] = len(storageDisks)/2 + 1 } versionsMap := make(map[string]FileInfoVersions, len(objects)) for i := range objects { // Construct the FileInfo data that needs to be preserved on the disk. vr := FileInfo{ Name: objects[i].ObjectName,
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Oct 24 04:05:31 UTC 2025 - 80.4K bytes - Viewed (0) -
cmd/storage-datatypes_gen.go
return } // DecodeMsg implements msgp.Decodable func (z *FileInfoVersions) DecodeMsg(dc *msgp.Reader) (err error) { var zb0001 uint32 zb0001, err = dc.ReadArrayHeader() if err != nil { err = msgp.WrapError(err) return } if zb0001 != 5 {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 151.7K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
defer wk.Give() if entry.isDir() { return } // rebalance on poolIdx has reached its goal if z.checkIfRebalanceDone(poolIdx) { return } fivs, err := entry.fileInfoVersions(bucket) if err != nil { return } // We need a reversed order for rebalance, // to create the appropriate stack. versionsSorter(fivs.Versions).reverse()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 28.7K bytes - Viewed (0) -
cmd/data-scanner.go
} if entry.isDir() { return } // We got an entry which we should be able to heal. fiv, err := entry.fileInfoVersions(bucket) if err != nil { err := bgSeq.queueHealTask(healSource{ bucket: bucket, object: entry.name, versionID: "", }, madmin.HealItemObject)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 45.5K bytes - Viewed (0)