instrumentation: add Enabled checks to OTLP log metrics

Author: itssaharsh

exporters/otlp/otlplog/otlploggrpc/internal/observ/instrumentation.go

@@ -160,19 +160,22 @@ func NewInstrumentation(id int64, target string) (*Instrumentation, error) {
 // ExportLogs method returns.
 func (i *Instrumentation) ExportLogs(ctx context.Context, count int64) ExportOp {
 	start := time.Now()
-	addOpt := get[metric.AddOption](addOpPool)
-	defer put(addOpPool, addOpt)
-
-	*addOpt = append(*addOpt, i.addOpt)
-
-	i.logInflightMetric.Add(ctx, count, *addOpt...)
-
-	return ExportOp{
+	ext := ExportOp{
 		nLogs: count,
 		ctx:   ctx,
 		start: start,
 		inst:  i,
 	}
+	if(i.logInflightMetric.Enabled(ctx)){
+		addOpt := get[metric.AddOption](addOpPool)
+		defer put(addOpPool, addOpt)
+
+		*addOpt = append(*addOpt, i.addOpt)
+
+		i.logInflightMetric.Add(ctx, count, *addOpt...)
+	}
+
+	return ext;
 }
 
 // ExportOp tracks the operation being observed by [Instrumentation.ExportLogs].
@@ -193,33 +196,50 @@ type ExportOp struct {
 // of successfully exported logs will be determined by inspecting the
 // RejectedItems field of the PartialSuccess.
 func (e ExportOp) End(err error) {
-	addOpt := get[metric.AddOption](addOpPool)
-	defer put(addOpPool, addOpt)
-	*addOpt = append(*addOpt, e.inst.addOpt)
-
-	e.inst.logInflightMetric.Add(e.ctx, -e.nLogs, *addOpt...)
-	success := successful(e.nLogs, err)
-	e.inst.logExportedMetric.Add(e.ctx, success, *addOpt...)
-
-	if err != nil {
-		// Add the error.type attribute to the attribute set.
-		attrs := get[attribute.KeyValue](attrsPool)
-		defer put(attrsPool, attrs)
-		*attrs = append(*attrs, e.inst.presetAttrs...)
-		*attrs = append(*attrs, semconv.ErrorType(err))
-
-		o := metric.WithAttributeSet(attribute.NewSet(*attrs...))
-
-		// Reset addOpt with new attribute set
-		*addOpt = append((*addOpt)[:0], o)
-
-		e.inst.logExportedMetric.Add(e.ctx, e.nLogs-success, *addOpt...)
+	logInflightMetricEnabled := e.inst.logInflightMetric.Enabled(e.ctx)
+	logExportedMetricEnabled := e.inst.logExportedMetric.Enabled(e.ctx)
+	logExportedDurationMetricEnabled := e.inst.logExportedDurationMetric.Enabled(e.ctx)
+	
+	var addOpt *[]metric.AddOption
+	if logInflightMetricEnabled || logExportedMetricEnabled {
+		success := successful(e.nLogs, err)
+		addOpt = get[metric.AddOption](addOpPool)
+		defer put(addOpPool, addOpt)
+		*addOpt = append(*addOpt, e.inst.addOpt)
+		
+		if logInflightMetricEnabled {
+			e.inst.logInflightMetric.Add(e.ctx, -e.nLogs, *addOpt...)
+		}
+		
+		success := successful(e.nLogs, err)
+		if logExportedMetricEnabled {
+			e.inst.logExportedMetric.Add(e.ctx, success, *addOpt...)
+		}
+		
+		if err != nil && logExportedMetricEnabled {
+			// Add the error.type attribute to the attribute set.
+			attrs := get[attribute.KeyValue](attrsPool)
+			defer put(attrsPool, attrs)
+			*attrs = append(*attrs, e.inst.presetAttrs...)
+			*attrs = append(*attrs, semconv.ErrorType(err))
+
+			o := metric.WithAttributeSet(attribute.NewSet(*attrs...))
+
+			// Reset addOpt with new attribute set
+			// Note: addOpt is guaranteed non-nil here because it was 
+			// initialized in the parent if-block.
+			*addOpt = append((*addOpt)[:0], o)
+
+			e.inst.logExportedMetric.Add(e.ctx, e.nLogs-success, *addOpt...)
+		}
 	}
 
-	recordOpt := get[metric.RecordOption](recordOptPool)
-	defer put(recordOptPool, recordOpt)
-	*recordOpt = append(*recordOpt, e.inst.recordOption(err))
-	e.inst.logExportedDurationMetric.Record(e.ctx, time.Since(e.start).Seconds(), *recordOpt...)
+	if logExportedDurationMetricEnabled {
+		recordOpt := get[metric.RecordOption](recordOptPool)
+		defer put(recordOptPool, recordOpt)
+		*recordOpt = append(*recordOpt, e.inst.recordOption(err))
+		e.inst.logExportedDurationMetric.Record(e.ctx, time.Since(e.start).Seconds(), *recordOpt...)
+	}
 }
 
 func (i *Instrumentation) recordOption(err error) metric.RecordOption {