address comments

obsreport/obsreport_pipeline.go

@@ -23,12 +23,12 @@ import (
 )
 
 const (
-	// PipelineKey is the name of the pipeline
-	PipelineKey = "pipeline"
+	// pipelineKey is the name of the pipeline
+	pipelineKey = "pipeline"
 )
 
 var (
-	tagKeyPipeline, _ = tag.NewKey(PipelineKey)
+	tagKeyPipeline, _ = tag.NewKey(pipelineKey)
 	// mPipelineProcessingMetrics records the an observation for each
 	// received batch each time it is exported. For example, a pipeline with
 	// one receiver and two exporters will record two observations for each

processor/batchprocessor/batch_processor.go

@@ -181,7 +181,9 @@ func (bp *batchProcessor) sendItems(triggerMeasure *stats.Int64Measure) {
 	if err := bp.batch.export(bp.exportCtx, bp.sendBatchMaxSize); err != nil {
 		bp.logger.Warn("Sender failed", zap.Error(err))
 	}
-	// Reset the context
+	// The accumulated b.exportCtx was associated with the batch of telemetry
+	// we just exported.  Clear the context so that the next bacth is sent only
+	// with contexts used when constructing it.
 	bp.exportCtx = context.Background()
 }