- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for volInfos (0.05 sec)
-
cmd/xl-storage_test.go
if err != nil { t.Fatalf("Unable to create xlStorage test setup, %s", err) } var volInfos []VolInfo // TestXLStorage empty list vols. if volInfos, err = xlStorage.ListVols(t.Context()); err != nil { t.Fatalf("expected: <nil>, got: %s", err) } else if len(volInfos) != 1 { t.Fatalf("expected: one entry, got: %v", volInfos) } // TestXLStorage non-empty list vols.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 66K bytes - Viewed (0) -
cmd/peer-s3-server.go
} } healBuckets.Range(func(_ string, volInfo VolInfo) bool { bi := BucketInfo{ Name: volInfo.Name, Created: volInfo.Created, } if vi, ok := deletedBuckets.Load(volInfo.Name); ok { bi.Deleted = vi.Created } buckets = append(buckets, bi) return true }) deletedBuckets.Range(func(_ string, v VolInfo) bool { if _, ok := healBuckets.Load(v.Name); !ok {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 8.2K bytes - Viewed (0) -
cmd/naughty-disk_test.go
} func (d *naughtyDisk) ListVols(ctx context.Context) (vols []VolInfo, err error) { if err := d.calcError(); err != nil { return nil, err } return d.disk.ListVols(ctx) } func (d *naughtyDisk) StatVol(ctx context.Context, volume string) (vol VolInfo, err error) { if err := d.calcError(); err != nil { return VolInfo{}, err } return d.disk.StatVol(ctx, volume) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 25 05:41:04 UTC 2025 - 10.1K bytes - Viewed (0) -
cmd/erasure-healing.go
return err } for _, volInfo := range volsInfo { // StorageAPI can send volume names which are // incompatible with buckets - these are // skipped, like the meta-bucket. if isReservedOrInvalidBucket(volInfo.Name, false) { continue } healBuckets.Compute(volInfo.Name, func(oldValue VolInfo, loaded bool) (newValue VolInfo, del bool) { if loaded {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 34.6K bytes - Viewed (0) -
cmd/storage-datatypes.go
type VolsInfo []VolInfo // VolInfo - represents volume stat information. // The above means that any added/deleted fields are incompatible. // //msgp:tuple VolInfo type VolInfo struct { // Name of the volume. Name string // Date and time when the volume was created. Created time.Time // total VolInfo counts count int
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 25 05:41:04 UTC 2025 - 17.4K bytes - Viewed (0) -
cmd/storage-interface.go
// Volume operations. MakeVol(ctx context.Context, volume string) (err error) MakeVolBulk(ctx context.Context, volumes ...string) (err error) ListVols(ctx context.Context) (vols []VolInfo, err error) StatVol(ctx context.Context, volume string) (vol VolInfo, err error) DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) // WalkDir will walk a directory on disk and return a metacache stream on wr.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 25 05:41:04 UTC 2025 - 5.3K bytes - Viewed (0) -
cmd/peer-s3-client.go
}) ctx, cancel := context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout()) defer cancel() volInfo, err := headBucketRPC.Call(ctx, conn, mss) if err != nil { return BucketInfo{}, toStorageErr(err) } return BucketInfo{ Name: volInfo.Name, Created: volInfo.Created, Deleted: volInfo.Deleted, }, nil } // MakeBucket creates bucket across all peers
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.6K bytes - Viewed (0) -
cmd/storage-datatypes_gen_test.go
} } func BenchmarkMarshalMsgVolInfo(b *testing.B) { v := VolInfo{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgVolInfo(b *testing.B) { v := VolInfo{} bts := make([]byte, 0, v.Msgsize()) bts, _ = v.MarshalMsg(bts[0:0]) b.SetBytes(int64(len(bts))) b.ReportAllocs()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Aug 12 08:38:15 UTC 2024 - 73.9K bytes - Viewed (0) -
cmd/xl-storage.go
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jun 13 11:33:47 UTC 2025 - 91.7K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
} func (p *xlStorageDiskIDCheck) ListVols(ctx context.Context) (vi []VolInfo, err error) { ctx, done, err := p.TrackDiskHealth(ctx, storageMetricListVols, "/") if err != nil { return nil, err } defer done(0, &err) return p.storage.ListVols(ctx) } func (p *xlStorageDiskIDCheck) StatVol(ctx context.Context, volume string) (vol VolInfo, err error) {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 25 05:41:04 UTC 2025 - 34.5K bytes - Viewed (0)