- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for metricsLogIf (0.09 sec)
-
cmd/metrics-v3-system-process.go
stat, err := p.Stat() if err != nil { metricsLogIf(ctx, err) } else { loadProcStatMetrics(ctx, stat, m) } io, err := p.IO() if err != nil { metricsLogIf(ctx, err) } else { loadProcIOMetrics(ctx, io, m) } l, err := p.Limits() if err != nil { metricsLogIf(ctx, err) } else { if l.OpenFiles > 0 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jun 20 17:55:03 UTC 2024 - 6.5K bytes - Viewed (0) -
cmd/metrics-v3-scanner.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 19:29:25 UTC 2024 - 2.8K bytes - Viewed (0) -
cmd/metrics-v3-cluster-usage.go
// // This is a `MetricsLoaderFn`. func loadClusterUsageObjectMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { dataUsageInfo, err := c.dataUsageInfo.Get() if err != nil { metricsLogIf(ctx, err) return nil } // data usage has not captured any data yet. if dataUsageInfo.LastUpdate.IsZero() { return nil } var ( clusterSize uint64
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Jul 14 18:11:42 UTC 2024 - 6.5K bytes - Viewed (0) -
cmd/metrics-v3-cluster-config.go
// such as standard and RRS parity. func loadClusterConfigMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { clusterDriveMetrics, err := c.clusterDriveMetrics.Get() if err != nil { metricsLogIf(ctx, err) } else { m.Set(configStandardParity, float64(clusterDriveMetrics.storageInfo.Backend.StandardSCParity)) m.Set(configRRSParity, float64(clusterDriveMetrics.storageInfo.Backend.RRSCParity)) } return nil
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 1.5K bytes - Viewed (0) -
cmd/metrics-v3-bucket-replication.go
if globalSiteReplicationSys.isEnabled() { return nil } dataUsageInfo, err := c.dataUsageInfo.Get() if err != nil { metricsLogIf(ctx, err) return nil } bucketReplStats := globalReplicationStats.Load().getAllLatest(dataUsageInfo.BucketsUsage) for _, bucket := range buckets { labels := []string{bucketL, bucket}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 8.1K bytes - Viewed (0) -
cmd/metrics-v3-handler.go
"github.com/prometheus/client_golang/prometheus" "github.com/prometheus/client_golang/prometheus/promhttp" ) type promLogger struct{} func (p promLogger) Println(v ...interface{}) { metricsLogIf(GlobalContext, fmt.Errorf("metrics handler error: %v", v)) } type metricsV3Server struct { registry *prometheus.Registry opts promhttp.HandlerOpts auth func(http.Handler) http.Handler
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 15 16:28:02 UTC 2024 - 7.8K bytes - Viewed (0) -
cmd/logging.go
logger.LogIf(ctx, "etcd", err, errKind...) } func etcdLogOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) { logger.LogOnceIf(ctx, "etcd", err, id, errKind...) } func metricsLogIf(ctx context.Context, err error, errKind ...interface{}) { logger.LogIf(ctx, "metrics", err, errKind...) } func s3LogIf(ctx context.Context, err error, errKind ...interface{}) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 03 18:49:48 UTC 2024 - 7.1K bytes - Viewed (0) -
cmd/metrics-v2.go
// metrics pertinent to site replication - overall roll up. if globalSiteReplicationSys.isEnabled() { m, err := globalSiteReplicationSys.getSiteMetrics(GlobalContext) if err != nil { metricsLogIf(GlobalContext, err) return ml } ml = append(ml, MetricV2{ Description: getRepReceivedBytesMD(clusterMetricNamespace), Value: float64(m.ReplicaSize), })
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 131.9K bytes - Viewed (0)