Searched refs:rawMetrics (Results 1 – 7 of 7) sorted by relevance
/dports/www/uchiwa/uchiwa-0.18.2/uchiwa/daemon/ |
H A D | metrics.go | 51 func rawMetricsToCoordinates(rawMetrics []*structs.SERawMetric) []*structs.SEMetric { 52 seMetrics := make([]*structs.SEMetric, len(rawMetrics)) 54 for i, metrics := range rawMetrics { 78 func rawMetricsToAggregatedCoordinates(rawMetrics []*structs.SERawMetric) *structs.SEMetric { 81 for _, metrics := range rawMetrics { 102 for _, metrics := range rawMetrics { 124 for _, metrics := range rawMetrics { 133 for _, metrics := range rawMetrics {
|
/dports/devel/etcd/etcd-2.3.8/Godeps/_workspace/src/github.com/spacejam/loghisto/ |
H A D | metrics.go | 484 rawMetrics *RawMetricSet) *ProcessedMetricSet { 487 for name, count := range rawMetrics.Counters { 491 for name, count := range rawMetrics.Rates { 495 for name, valuesToCounts := range rawMetrics.Histograms { 501 for name, value := range rawMetrics.Gauges { 505 return &ProcessedMetricSet{Time: rawMetrics.Time, Metrics: metrics} 560 rawMetrics := ms.collectRawMetrics() 568 case subscriber <- rawMetrics: 587 processedMetrics := ms.processMetrics(rawMetrics) 590 for name := range rawMetrics.Histograms { [all …]
|
H A D | metrics_test.go | 331 case rawMetrics := <-rawMetricStream: 332 if rawMetrics.Counters["counter2"] != 121 { 334 rawMetrics.Counters["counter2"]) 336 if rawMetrics.Rates["counter2"] != 121 { 338 rawMetrics.Counters["counter2"])
|
/dports/sysutils/kubectl/kubernetes-1.22.2/pkg/controller/podautoscaler/metrics/ |
H A D | client.go | 89 func getContainerMetrics(rawMetrics []metricsapi.PodMetrics, resource v1.ResourceName, container st… 90 res := make(PodMetricsInfo, len(rawMetrics)) 91 for _, m := range rawMetrics { 113 func getPodMetrics(rawMetrics []metricsapi.PodMetrics, resource v1.ResourceName) PodMetricsInfo { 114 res := make(PodMetricsInfo, len(rawMetrics)) 115 for _, m := range rawMetrics {
|
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/status/api/v1/ |
H A D | AllStagesResource.scala | 159 val rawMetrics = allTaskData.flatMap{_.metrics}.toSeq constant 162 Distribution(rawMetrics.map { d => f(d) }).get.getQuantiles(quantiles) 172 new MetricHelper[InternalInputMetrics, InputMetricDistributions](rawMetrics, quantiles) { 182 new MetricHelper[InternalOutputMetrics, OutputMetricDistributions](rawMetrics, quantiles) { 192 new MetricHelper[InternalShuffleReadMetrics, ShuffleReadMetricDistributions](rawMetrics, 209 new MetricHelper[InternalShuffleWriteMetrics, ShuffleWriteMetricDistributions](rawMetrics, 300 rawMetrics: Seq[InternalTaskMetrics], 307 val data: Seq[I] = rawMetrics.map(getSubmetrics)
|
/dports/www/miniflux/v2-2.0.35/vendor/github.com/mitchellh/go-server-timing/ |
H A D | header.go | 41 rawMetrics := header.ParseList(headerParams(input)) 46 metrics := make([]*Metric, 0, len(rawMetrics)) 47 for _, raw := range rawMetrics {
|
/dports/sysutils/kubectl/kubernetes-1.22.2/vendor/github.com/google/cadvisor/container/libcontainer/ |
H A D | handler.go | 328 rawMetrics := bytes.Split(bytes.TrimRight(contents, "\n"), []byte(" ")) 329 if len(rawMetrics) != 3 { 337 for i, rawMetric := range rawMetrics {
|