func()

in kafka/metrics.go [344:370]

• 27 lines of code
• 3 McCabe index (conditional complexity)

func (h *metricHooks) OnBrokerConnect(meta kgo.BrokerMetadata, _ time.Duration, _ net.Conn, err error) {
	attrs := make([]attribute.KeyValue, 0, 3)
	attrs = append(attrs, semconv.MessagingSystem("kafka"))
	if h.namespace != "" {
		attrs = append(attrs, attribute.String("namespace", h.namespace))
	}
	if err != nil {
		h.connectErrs.Add(
			context.Background(),
			1,
			metric.WithAttributeSet(attribute.NewSet(attrs...)),
		)
		attrs = append(attrs, attribute.String("outcome", "failure"))
		h.connects.Add(
			context.Background(),
			1,
			metric.WithAttributeSet(attribute.NewSet(attrs...)),
		)
		return
	}
	attrs = append(attrs, attribute.String("outcome", "success"))
	h.connects.Add(
		context.Background(),
		1,
		metric.WithAttributeSet(attribute.NewSet(attrs...)),
	)
}