Home
last modified time | relevance | path

Searched refs:rawMetrics (Results 1 – 7 of 7) sorted by relevance

/dports/www/uchiwa/uchiwa-0.18.2/uchiwa/daemon/
H A Dmetrics.go51 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 Dmetrics.go484 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 Dmetrics_test.go331 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 Dclient.go89 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 DAllStagesResource.scala159 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 Dheader.go41 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 Dhandler.go328 rawMetrics := bytes.Split(bytes.TrimRight(contents, "\n"), []byte(" "))
329 if len(rawMetrics) != 3 {
337 for i, rawMetric := range rawMetrics {