Function InstrumentMetrics

extra/redisotel/metrics.go:27–103

InstrumentMetrics starts reporting OpenTelemetry Metrics. Based on https://github.com/open-telemetry/semantic-conventions/blob/main/docs/database/database-metrics.md

(rdb redis.UniversalClient, opts ...MetricsOption)

//
// Based on https://github.com/open-telemetry/semantic-conventions/blob/main/docs/database/database-metrics.md
func InstrumentMetrics(rdb redis.UniversalClient, opts ...MetricsOption) error {
	baseOpts := make([]baseOption, len(opts))
	for i, opt := range opts {
		baseOpts[i] = opt
	}
	conf := newConfig(baseOpts...)

	if conf.meter == nil {
		conf.meter = conf.mp.Meter(
			instrumName,
			metric.WithInstrumentationVersion("semver:"+redis.Version()),
		)
	}
	if conf.poolName == "" {
		switch rdb := rdb.(type) {
		case *redis.Client:
			conf.poolName = rdb.Options().Addr
		case *redis.ClusterClient:
			for _, addr := range rdb.Options().Addrs {
				conf.poolName = addr
				break
			}
		case *redis.Ring:
			for _, addr := range rdb.Options().Addrs {
				conf.poolName = addr
				break
			}
		default:
			return fmt.Errorf("redisotel: %T not supported", rdb)
		}
	}
	conf.attrs = append(conf.attrs, attribute.String("pool.name", conf.poolName))

	var state *metricsState
	if conf.closeChan != nil {
		state = &metricsState{
			registrations: make([]metric.Registration, 0),
			closed:        false,
			mutex:         sync.Mutex{},
		}

		go func() {
			<-conf.closeChan

			state.mutex.Lock()
			state.closed = true

			for _, registration := range state.registrations {
				if err := registration.Unregister(); err != nil {
					otel.Handle(err)
				}
			}
			state.mutex.Unlock()
		}()
	}

	switch rdb := rdb.(type) {
	case *redis.Client: