Function newInstrument

middleware/instrument_test.go:89–129

(registry *prometheus.Registry)

}

func newInstrument(registry *prometheus.Registry) Instrument {
	reg := promauto.With(registry)

	const throughputUnit = "unit"
	const LatencyCutoff = 100 * time.Millisecond

	return Instrument{
		Duration: reg.NewHistogramVec(prometheus.HistogramOpts{
			Name:    "request_duration_seconds",
			Help:    "Time (in seconds) spent serving HTTP requests.",
			Buckets: instrument.DefBuckets,
		}, []string{"method", "route", "status_code", "ws"}),
		PerTenantDuration: reg.NewHistogramVec(prometheus.HistogramOpts{
			Name:    "per_tenant_request_duration_seconds",
			Help:    "Time (in seconds) spent serving HTTP requests for a particular tenant.",
			Buckets: instrument.DefBuckets,
		}, []string{"method", "route", "status_code", "ws", "tenant"}),
		RequestBodySize: reg.NewHistogramVec(prometheus.HistogramOpts{
			Name:    "request_message_bytes",
			Help:    "Size (in bytes) of messages received in the request.",
			Buckets: BodySizeBuckets,
		}, []string{"method", "route"}),
		ResponseBodySize: reg.NewHistogramVec(prometheus.HistogramOpts{
			Name:    "response_message_bytes",
			Help:    "Size (in bytes) of messages sent in response.",
			Buckets: BodySizeBuckets,
		}, []string{"method", "route"}),
		InflightRequests: reg.NewGaugeVec(prometheus.GaugeOpts{
			Name: "inflight_requests",
			Help: "Current number of inflight requests.",
		}, []string{"method", "route"}),
		LatencyCutoff:  LatencyCutoff,
		ThroughputUnit: throughputUnit,
		RequestThroughput: reg.NewHistogramVec(prometheus.HistogramOpts{
			Name:        "request_throughput_" + throughputUnit,
			Help:        "Server throughput running requests.",
			ConstLabels: prometheus.Labels{"cutoff_ms": strconv.FormatInt(LatencyCutoff.Milliseconds(), 10)},
			Buckets:     []float64{1, 5, 10},
		}, []string{"method", "route"}),
	}
}

func TestExtractValueFromMultiValueHeader(t *testing.T) {
	tests := []struct {