- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for LocalStorageInfo (1.04 sec)
-
cmd/erasure.go
disks := er.getDisks() endpoints := er.getEndpoints() return getStorageInfo(disks, endpoints, true) } // LocalStorageInfo - returns underlying local storage statistics. func (er erasureObjects) LocalStorageInfo(ctx context.Context, metrics bool) StorageInfo { disks := er.getDisks() endpoints := er.getEndpoints() var localDisks []StorageAPI var localEndpoints []Endpoint
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 16.1K bytes - Viewed (0) -
cmd/erasure-sets.go
func (s *erasureSets) LocalStorageInfo(ctx context.Context, metrics bool) StorageInfo { var storageInfo StorageInfo storageInfos := make([]StorageInfo, len(s.sets)) g := errgroup.WithNErrs(len(s.sets)) for index := range s.sets { g.Go(func() error { storageInfos[index] = s.sets[index].LocalStorageInfo(ctx, metrics) return nil }, index) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 37K bytes - Viewed (1) -
cmd/object-api-interface.go
BackendInfo() madmin.BackendInfo Legacy() bool // Only returns true for deployments which use CRCMOD as its object distribution algorithm. StorageInfo(ctx context.Context, metrics bool) StorageInfo LocalStorageInfo(ctx context.Context, metrics bool) StorageInfo // Bucket operations. MakeBucket(ctx context.Context, bucket string, opts MakeBucketOptions) error
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 17.5K bytes - Viewed (0) -
cmd/notification.go
defer wg.Done() info, err := client.LocalStorageInfo(ctx, metrics) if err != nil { info.Disks = getOfflineDisks(client.host.String(), globalEndpoints) } replies[idx] = info }(client, i) } wg.Wait() // Add local to this server. replies = append(replies, objLayer.LocalStorageInfo(ctx, metrics)) storageInfo.Backend = objLayer.BackendInfo()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 45.9K bytes - Viewed (0) -
cmd/erasure-server-pool.go
return } func (z *erasureServerPools) LocalStorageInfo(ctx context.Context, metrics bool) StorageInfo { var storageInfo StorageInfo storageInfos := make([]StorageInfo, len(z.serverPools)) g := errgroup.WithNErrs(len(z.serverPools)) for index := range z.serverPools { g.Go(func() error { storageInfos[index] = z.serverPools[index].LocalStorageInfo(ctx, metrics) return nil }, index) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 89.1K bytes - Viewed (0) -
cmd/metrics-v2.go
metricsGroupOpts: opts, } mg.RegisterRead(func(ctx context.Context) (metrics []MetricV2) { objLayer := newObjectLayerFn() metrics = make([]MetricV2, 0, 50) storageInfo := objLayer.LocalStorageInfo(ctx, true) onlineDrives, offlineDrives := getOnlineOfflineDisksStats(storageInfo.Disks) totalDrives := onlineDrives.Merge(offlineDrives) for _, disk := range storageInfo.Disks {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 133.4K bytes - Viewed (0)