summaryrefslogtreecommitdiff
path: root/vendor/google.golang.org/grpc/internal/stats
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/google.golang.org/grpc/internal/stats')
-rw-r--r--vendor/google.golang.org/grpc/internal/stats/labels.go42
-rw-r--r--vendor/google.golang.org/grpc/internal/stats/metrics_recorder_list.go105
2 files changed, 0 insertions, 147 deletions
diff --git a/vendor/google.golang.org/grpc/internal/stats/labels.go b/vendor/google.golang.org/grpc/internal/stats/labels.go
deleted file mode 100644
index fd33af51a..000000000
--- a/vendor/google.golang.org/grpc/internal/stats/labels.go
+++ /dev/null
@@ -1,42 +0,0 @@
-/*
- *
- * Copyright 2024 gRPC authors.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-// Package stats provides internal stats related functionality.
-package stats
-
-import "context"
-
-// Labels are the labels for metrics.
-type Labels struct {
- // TelemetryLabels are the telemetry labels to record.
- TelemetryLabels map[string]string
-}
-
-type labelsKey struct{}
-
-// GetLabels returns the Labels stored in the context, or nil if there is one.
-func GetLabels(ctx context.Context) *Labels {
- labels, _ := ctx.Value(labelsKey{}).(*Labels)
- return labels
-}
-
-// SetLabels sets the Labels in the context.
-func SetLabels(ctx context.Context, labels *Labels) context.Context {
- // could also append
- return context.WithValue(ctx, labelsKey{}, labels)
-}
diff --git a/vendor/google.golang.org/grpc/internal/stats/metrics_recorder_list.go b/vendor/google.golang.org/grpc/internal/stats/metrics_recorder_list.go
deleted file mode 100644
index 79044657b..000000000
--- a/vendor/google.golang.org/grpc/internal/stats/metrics_recorder_list.go
+++ /dev/null
@@ -1,105 +0,0 @@
-/*
- * Copyright 2024 gRPC authors.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package stats
-
-import (
- "fmt"
-
- estats "google.golang.org/grpc/experimental/stats"
- "google.golang.org/grpc/stats"
-)
-
-// MetricsRecorderList forwards Record calls to all of its metricsRecorders.
-//
-// It eats any record calls where the label values provided do not match the
-// number of label keys.
-type MetricsRecorderList struct {
- // metricsRecorders are the metrics recorders this list will forward to.
- metricsRecorders []estats.MetricsRecorder
-}
-
-// NewMetricsRecorderList creates a new metric recorder list with all the stats
-// handlers provided which implement the MetricsRecorder interface.
-// If no stats handlers provided implement the MetricsRecorder interface,
-// the MetricsRecorder list returned is a no-op.
-func NewMetricsRecorderList(shs []stats.Handler) *MetricsRecorderList {
- var mrs []estats.MetricsRecorder
- for _, sh := range shs {
- if mr, ok := sh.(estats.MetricsRecorder); ok {
- mrs = append(mrs, mr)
- }
- }
- return &MetricsRecorderList{
- metricsRecorders: mrs,
- }
-}
-
-func verifyLabels(desc *estats.MetricDescriptor, labelsRecv ...string) {
- if got, want := len(labelsRecv), len(desc.Labels)+len(desc.OptionalLabels); got != want {
- panic(fmt.Sprintf("Received %d labels in call to record metric %q, but expected %d.", got, desc.Name, want))
- }
-}
-
-// RecordInt64Count records the measurement alongside labels on the int
-// count associated with the provided handle.
-func (l *MetricsRecorderList) RecordInt64Count(handle *estats.Int64CountHandle, incr int64, labels ...string) {
- verifyLabels(handle.Descriptor(), labels...)
-
- for _, metricRecorder := range l.metricsRecorders {
- metricRecorder.RecordInt64Count(handle, incr, labels...)
- }
-}
-
-// RecordFloat64Count records the measurement alongside labels on the float
-// count associated with the provided handle.
-func (l *MetricsRecorderList) RecordFloat64Count(handle *estats.Float64CountHandle, incr float64, labels ...string) {
- verifyLabels(handle.Descriptor(), labels...)
-
- for _, metricRecorder := range l.metricsRecorders {
- metricRecorder.RecordFloat64Count(handle, incr, labels...)
- }
-}
-
-// RecordInt64Histo records the measurement alongside labels on the int
-// histo associated with the provided handle.
-func (l *MetricsRecorderList) RecordInt64Histo(handle *estats.Int64HistoHandle, incr int64, labels ...string) {
- verifyLabels(handle.Descriptor(), labels...)
-
- for _, metricRecorder := range l.metricsRecorders {
- metricRecorder.RecordInt64Histo(handle, incr, labels...)
- }
-}
-
-// RecordFloat64Histo records the measurement alongside labels on the float
-// histo associated with the provided handle.
-func (l *MetricsRecorderList) RecordFloat64Histo(handle *estats.Float64HistoHandle, incr float64, labels ...string) {
- verifyLabels(handle.Descriptor(), labels...)
-
- for _, metricRecorder := range l.metricsRecorders {
- metricRecorder.RecordFloat64Histo(handle, incr, labels...)
- }
-}
-
-// RecordInt64Gauge records the measurement alongside labels on the int
-// gauge associated with the provided handle.
-func (l *MetricsRecorderList) RecordInt64Gauge(handle *estats.Int64GaugeHandle, incr int64, labels ...string) {
- verifyLabels(handle.Descriptor(), labels...)
-
- for _, metricRecorder := range l.metricsRecorders {
- metricRecorder.RecordInt64Gauge(handle, incr, labels...)
- }
-}