mirror of https://github.com/minio/minio.git
110 lines
2.8 KiB
Go
110 lines
2.8 KiB
Go
// Copyright (c) 2015-2022 MinIO, Inc.
|
|
//
|
|
// This file is part of MinIO Object Storage stack
|
|
//
|
|
// This program is free software: you can redistribute it and/or modify
|
|
// it under the terms of the GNU Affero General Public License as published by
|
|
// the Free Software Foundation, either version 3 of the License, or
|
|
// (at your option) any later version.
|
|
//
|
|
// This program is distributed in the hope that it will be useful
|
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
// GNU Affero General Public License for more details.
|
|
//
|
|
// You should have received a copy of the GNU Affero General Public License
|
|
// along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
package cmd
|
|
|
|
import (
|
|
"context"
|
|
"time"
|
|
|
|
"github.com/minio/madmin-go"
|
|
)
|
|
|
|
func collectLocalMetrics(types madmin.MetricType, hosts map[string]struct{}) (m madmin.RealtimeMetrics) {
|
|
if types == madmin.MetricsNone {
|
|
return
|
|
}
|
|
if len(hosts) > 0 {
|
|
if _, ok := hosts[globalMinioAddr]; !ok {
|
|
return
|
|
}
|
|
}
|
|
if types.Contains(madmin.MetricsScanner) {
|
|
metrics := globalScannerMetrics.report()
|
|
m.Aggregated.Scanner = &metrics
|
|
}
|
|
if types.Contains(madmin.MetricsDisk) && !globalIsGateway {
|
|
m.Aggregated.Disk = collectDiskMetrics()
|
|
}
|
|
if types.Contains(madmin.MetricsOS) {
|
|
metrics := globalOSMetrics.report()
|
|
m.Aggregated.OS = &metrics
|
|
}
|
|
// Add types...
|
|
|
|
// ByHost is a shallow reference, so careful about sharing.
|
|
m.ByHost = map[string]madmin.Metrics{globalMinioAddr: m.Aggregated}
|
|
m.Hosts = append(m.Hosts, globalMinioAddr)
|
|
|
|
return m
|
|
}
|
|
|
|
func collectDiskMetrics() *madmin.DiskMetric {
|
|
objLayer := newObjectLayerFn()
|
|
disks := madmin.DiskMetric{
|
|
CollectedAt: time.Now(),
|
|
}
|
|
|
|
if objLayer == nil {
|
|
return nil
|
|
}
|
|
// only need Disks information in server mode.
|
|
storageInfo, errs := objLayer.LocalStorageInfo(GlobalContext)
|
|
for _, err := range errs {
|
|
if err != nil {
|
|
disks.Merge(&madmin.DiskMetric{NDisks: 1, Offline: 1})
|
|
}
|
|
}
|
|
for i, disk := range storageInfo.Disks {
|
|
if errs[i] != nil {
|
|
continue
|
|
}
|
|
var d madmin.DiskMetric
|
|
d.NDisks = 1
|
|
if disk.Healing {
|
|
d.Healing++
|
|
}
|
|
if disk.Metrics != nil {
|
|
d.LifeTimeOps = make(map[string]uint64, len(disk.Metrics.APICalls))
|
|
for k, v := range disk.Metrics.APICalls {
|
|
if v != 0 {
|
|
d.LifeTimeOps[k] = v
|
|
}
|
|
}
|
|
d.LastMinute.Operations = make(map[string]madmin.TimedAction, len(disk.Metrics.APICalls))
|
|
for k, v := range disk.Metrics.LastMinute {
|
|
if v.Count != 0 {
|
|
d.LastMinute.Operations[k] = v
|
|
}
|
|
}
|
|
}
|
|
disks.Merge(&d)
|
|
}
|
|
return &disks
|
|
}
|
|
|
|
func collectRemoteMetrics(ctx context.Context, types madmin.MetricType, hosts map[string]struct{}) (m madmin.RealtimeMetrics) {
|
|
if !globalIsDistErasure {
|
|
return
|
|
}
|
|
all := globalNotificationSys.GetMetrics(ctx, types, hosts)
|
|
for _, remote := range all {
|
|
m.Merge(&remote)
|
|
}
|
|
return m
|
|
}
|