- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for LocalStorageInfo (0.2 sec)
-
cmd/admin-server-info.go
props.MinioEnvVars[key] = "*** EXISTS, REDACTED ***" continue } props.MinioEnvVars[key] = value } objLayer := newObjectLayerFn() if objLayer != nil { storageInfo := objLayer.LocalStorageInfo(GlobalContext, metrics) props.State = string(madmin.ItemOnline) props.Disks = storageInfo.Disks } else { props.State = string(madmin.ItemInitializing) props.Disks = getOfflineDisks("", globalEndpoints)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.8K bytes - Viewed (0) -
cmd/metrics-realtime.go
objLayer := newObjectLayerFn() if objLayer == nil { return nil } metrics := make(map[string]madmin.DiskMetric) storageInfo := objLayer.LocalStorageInfo(GlobalContext, true) for _, d := range storageInfo.Disks { if len(disks) != 0 { _, ok := disks[d.Endpoint] if !ok { continue } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 10 16:28:08 GMT 2024 - 6.1K bytes - Viewed (0) -
cmd/peer-rest-client.go
if err != nil || resp == nil { return nil, err } return *resp, nil } // LocalStorageInfo - fetch server information for a remote node. func (client *peerRESTClient) LocalStorageInfo(metrics bool) (info StorageInfo, err error) { resp, err := localStorageInfoRPC.Call(context.Background(), client.gridConn(), grid.NewMSSWith(map[string]string{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K 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 { index := index g.Go(func() error { storageInfos[index] = z.serverPools[index].LocalStorageInfo(ctx, metrics) return nil }, index) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K 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 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
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
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 16K bytes - Viewed (1) -
cmd/peer-rest-server.go
return nil, grid.NewRemoteErr(errServerNotInitialized) } metrics, err := strconv.ParseBool(mss.Get(peerRESTMetrics)) if err != nil { return nil, grid.NewRemoteErr(err) } info := objLayer.LocalStorageInfo(context.Background(), metrics) return madminStorageInfo.NewJSONWith(&info), nil } // ServerInfoHandler - returns Server Info
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
cmd/metrics-v3-cache.go
) loadDriveMetrics := func() (v storageMetrics, err error) { objLayer := newObjectLayerFn() if objLayer == nil { return } storageInfo := objLayer.LocalStorageInfo(GlobalContext, true) onlineDrives, offlineDrives := getOnlineOfflineDisksStats(storageInfo.Disks) totalDrives := onlineDrives.Merge(offlineDrives) v = storageMetrics{ storageInfo: storageInfo,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 7.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
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 17K bytes - Viewed (0) -
cmd/global-heal.go
healing := globalBackgroundHealState.getLocalHealingDisks() for _, disk := range healing { status.HealDisks = append(status.HealDisks, disk.Endpoint) } return status, true } si := o.LocalStorageInfo(ctx, true) indexed := make(map[string][]madmin.Disk) for _, disk := range si.Disks { setIdx := fmt.Sprintf("%d-%d", disk.PoolIndex, disk.SetIndex) indexed[setIdx] = append(indexed[setIdx], disk) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 15K bytes - Viewed (1)