- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for StorageInfo (0.17 sec)
-
cmd/erasure-sets.go
// coding objects func (s *erasureSets) ParityCount() int { return s.defaultParityCount } // StorageInfo - combines output of StorageInfo across all erasure coded object sets. func (s *erasureSets) StorageInfo(ctx context.Context) StorageInfo { var storageInfo madmin.StorageInfo storageInfos := make([]madmin.StorageInfo, len(s.sets)) g := errgroup.WithNErrs(len(s.sets)) for index := range s.sets { g.Go(func() error {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 37K bytes - Viewed (1) -
cmd/erasure.go
func getStorageInfo(disks []StorageAPI, endpoints []Endpoint, metrics bool) StorageInfo { disksInfo := getDisksInfo(disks, endpoints, metrics) // Sort so that the first element is the smallest. sort.Slice(disksInfo, func(i, j int) bool { return disksInfo[i].TotalSpace < disksInfo[j].TotalSpace }) storageInfo := StorageInfo{ Disks: disksInfo, } storageInfo.Backend.Type = madmin.Erasure return storageInfo }
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/metrics-v3-cache.go
objLayer := newObjectLayerFn() if objLayer == nil { return storageMetrics{}, nil } storageInfo := objLayer.StorageInfo(GlobalContext, true) onlineDrives, offlineDrives := getOnlineOfflineDisksStats(storageInfo.Disks) totalDrives := onlineDrives.Merge(offlineDrives) v = storageMetrics{ storageInfo: storageInfo, onlineDrives: onlineDrives.Sum(), offlineDrives: offlineDrives.Sum(),
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 8K bytes - Viewed (0) -
src/test/java/jcifs/dcerpc/msrpc/netdfsTest.java
assertEquals(storageInfo.state, decodedStorageInfo.state); assertEquals(storageInfo.server_name, decodedStorageInfo.server_name); assertEquals(storageInfo.share_name, decodedStorageInfo.share_name); } @Test void testDfsStorageInfo_EncodeDecode_NullStrings() throws NdrException { netdfs.DfsStorageInfo storageInfo = new netdfs.DfsStorageInfo();
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 30.9K bytes - Viewed (0) -
cmd/admin-handlers.go
}) } func validateObjPerfOptions(ctx context.Context, storageInfo madmin.StorageInfo, concurrent int, size int, autotune bool) (bool, bool, string) { capacityNeeded := uint64(concurrent * size) capacity := GetTotalUsableCapacityFree(storageInfo.Disks, storageInfo) if capacity < capacityNeeded {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 99.6K bytes - Viewed (0) -
cmd/object-api-datatypes.go
// Multi disk BackendErasure (single, distributed) backend. BackendErasure = BackendType(madmin.Erasure) // Add your own backend. ) // StorageInfo - represents total capacity of underlying storage. type StorageInfo = madmin.StorageInfo // objectHistogramInterval is an interval that will be // used to report the histogram of objects data sizes type objectHistogramInterval struct { name string
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 21.2K bytes - Viewed (0) -
cmd/notification.go
DiskIndex: ep.DiskIdx, }) } } } return offlineDisks } // StorageInfo returns disk information across all peers func (sys *NotificationSys) StorageInfo(ctx context.Context, objLayer ObjectLayer, metrics bool) StorageInfo { var storageInfo StorageInfo replies := make([]StorageInfo, len(sys.peerClients)) var wg sync.WaitGroup for i, client := range sys.peerClients {
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/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/metrics-v2.go
metrics = make([]MetricV2, 0, 10) storageInfo := objLayer.StorageInfo(ctx, true) onlineDrives, offlineDrives := getOnlineOfflineDisksStats(storageInfo.Disks) totalDrives := onlineDrives.Merge(offlineDrives) metrics = append(metrics, MetricV2{ Description: getClusterCapacityTotalBytesMD(), Value: float64(GetTotalCapacity(storageInfo.Disks)), }) metrics = append(metrics, MetricV2{
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 133.4K bytes - Viewed (0) -
cmd/erasure-server-pool.go
} // Wait for the go routines. g.Wait() storageInfo.Backend = z.BackendInfo() for _, lstorageInfo := range storageInfos { storageInfo.Disks = append(storageInfo.Disks, lstorageInfo.Disks...) } return storageInfo } func (z *erasureServerPools) StorageInfo(ctx context.Context, metrics bool) StorageInfo { return globalNotificationSys.StorageInfo(ctx, z, metrics) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 89.1K bytes - Viewed (0)