gofmt

open-telemetry · Jul 9, 2024 · 42dfdfc · 42dfdfc
1 parent 5bfa79b
commit 42dfdfc
Show file tree

Hide file tree

Showing 3 changed files with 26 additions and 27 deletions.
diff --git a/exporter/exporterhelper/batch_sender.go b/exporter/exporterhelper/batch_sender.go
@@ -27,7 +27,7 @@ type batchSender struct {
 	mergeFunc      exporterbatcher.BatchMergeFunc[Request]
 	mergeSplitFunc exporterbatcher.BatchMergeSplitFunc[Request]
 
-	activeRequests   atomic.Int64
+	activeRequests atomic.Int64
 
 	mu          sync.Mutex
 	activeBatch *batch

diff --git a/exporter/exporterhelper/common.go b/exporter/exporterhelper/common.go
@@ -268,12 +268,12 @@ func newBaseExporter(set exporter.Settings, signal component.DataType, osf obsre
 	be := &baseExporter{
 		signal: signal,
 
-		concurrencySender:   &baseRequestSender{},
-		batchSender:   &baseRequestSender{},
-		queueSender:   &baseRequestSender{},
-		obsrepSender:  osf(obsReport),
-		retrySender:   &baseRequestSender{},
-		timeoutSender: &timeoutSender{cfg: NewDefaultTimeoutSettings()},
+		concurrencySender: &baseRequestSender{},
+		batchSender:       &baseRequestSender{},
+		queueSender:       &baseRequestSender{},
+		obsrepSender:      osf(obsReport),
+		retrySender:       &baseRequestSender{},
+		timeoutSender:     &timeoutSender{cfg: NewDefaultTimeoutSettings()},
 
 		set:    set,
 		obsrep: obsReport,

diff --git a/exporter/exporterhelper/concurrency_sender_test.go b/exporter/exporterhelper/concurrency_sender_test.go
@@ -40,29 +40,29 @@ func TestConcurrencySender(t *testing.T) {
 	}
 
 	tests := []struct {
-		name          string
-		batcherOption Option
+		name              string
+		batcherOption     Option
 		concurrencyOption Option
-		numRequests int
-		numItems int
-		hasError bool
-		errString string
+		numRequests       int
+		numItems          int
+		hasError          bool
+		errString         string
 	}{
 		{
-			name:          "success",
-			batcherOption: WithBatcher(batcherCfg, WithRequestBatchFuncs(fakeBatchMergeFunc, fakeBatchMergeSplitFunc)),
+			name:              "success",
+			batcherOption:     WithBatcher(batcherCfg, WithRequestBatchFuncs(fakeBatchMergeFunc, fakeBatchMergeSplitFunc)),
 			concurrencyOption: WithConcurrency(cfg),
-			numRequests: cfg.Concurrency + 1,
-			numItems: 100,
+			numRequests:       cfg.Concurrency + 1,
+			numItems:          100,
 		},
 		{
-			name:          "canceled_context",
-			batcherOption: WithBatcher(batcherCfg, WithRequestBatchFuncs(fakeBatchMergeFunc, fakeBatchMergeSplitFunc)),
+			name:              "canceled_context",
+			batcherOption:     WithBatcher(batcherCfg, WithRequestBatchFuncs(fakeBatchMergeFunc, fakeBatchMergeSplitFunc)),
 			concurrencyOption: WithConcurrency(cfg),
-			numRequests: cfg.Concurrency + 1,
-			numItems: 100,
-			hasError: true,
-			errString: "context canceled",
+			numRequests:       cfg.Concurrency + 1,
+			numItems:          100,
+			hasError:          true,
+			errString:         "context canceled",
 		},
 	}
 	for _, tt := range tests {
@@ -162,15 +162,14 @@ func TestConcurrencySender_RequestError(t *testing.T) {
 	assert.ErrorContains(t, errs, errStr)
 }
 
-
 type blockingSender struct {
 	baseRequestSender
-	blockCh        chan struct{} 
+	blockCh chan struct{}
 }
 
 func newBlockingSender(*ObsReport) requestSender {
 	return &blockingSender{
-		blockCh:        make(chan struct{}), 
+		blockCh: make(chan struct{}),
 	}
 }
 
@@ -183,4 +182,4 @@ func (bs *blockingSender) send(ctx context.Context, req ...Request) error {
 
 func (bs *blockingSender) unblock() {
 	close(bs.blockCh)
-}
+}