[exporter/signalfxexporter] Use configopaque for access_token field (#17304)

Use configopaque for access_token field

Link to tracking Issue: #17294

Author: atoulme

.chloggen/adopt-opaque-signalfx.yaml

@@ -0,0 +1,16 @@
+# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
+change_type: enhancement
+
+# The name of the component, or a single word describing the area of concern, (e.g. filelogreceiver)
+component: signalfxexporter
+
+# A brief description of the change.  Surround your text with quotes ("") if it needs to start with a backtick (`).
+note: Use configopaque for access_token field
+
+# One or more tracking issues related to the change
+issues: [17294]
+
+# (Optional) One or more lines of additional information to render under the primary note.
+# These lines will be padded with 2 spaces and then inserted directly into the document.
+# Use pipe (|) for multiline entries.
+subtext:

exporter/signalfxexporter/config.go

@@ -21,6 +21,7 @@ import (
 	"time"
 
 	"go.opentelemetry.io/collector/config/confighttp"
+	"go.opentelemetry.io/collector/config/configopaque"
 	"go.opentelemetry.io/collector/config/configtls"
 	"go.opentelemetry.io/collector/confmap"
 	"go.opentelemetry.io/collector/exporter/exporterhelper"
@@ -44,7 +45,7 @@ type Config struct {
 	confighttp.HTTPClientSettings `mapstructure:",squash"` // squash ensures fields are correctly decoded in embedded struct.
 
 	// AccessToken is the authentication token provided by SignalFx.
-	AccessToken string `mapstructure:"access_token"`
+	AccessToken configopaque.String `mapstructure:"access_token"`
 
 	// Realm is the SignalFx realm where data is going to be sent to.
 	Realm string `mapstructure:"realm"`

exporter/signalfxexporter/config_test.go

@@ -202,7 +202,7 @@ func TestConfig_getOptionsFromConfig(t *testing.T) {
 		return translator
 	}
 	type fields struct {
-		AccessToken      string
+		AccessToken      configopaque.String
 		Realm            string
 		IngestURL        string
 		APIURL           string

exporter/signalfxexporter/exporter.go

@@ -25,6 +25,7 @@ import (
 	"time"
 
 	"go.opentelemetry.io/collector/component"
+	"go.opentelemetry.io/collector/config/configopaque"
 	"go.opentelemetry.io/collector/config/configtls"
 	"go.opentelemetry.io/collector/consumer"
 	"go.opentelemetry.io/collector/exporter"
@@ -77,7 +78,7 @@ type exporterOptions struct {
 	apiURL            *url.URL
 	apiTLSSettings    configtls.TLSClientSetting
 	httpTimeout       time.Duration
-	token             string
+	token             configopaque.String
 	logDataPoints     bool
 	logDimUpdate      bool
 	metricTranslator  *translation.MetricTranslator
@@ -264,7 +265,7 @@ func buildHeaders(config *Config) map[string]string {
 	}
 
 	if config.AccessToken != "" {
-		headers[splunk.SFxAccessTokenHeader] = config.AccessToken
+		headers[splunk.SFxAccessTokenHeader] = string(config.AccessToken)
 	}
 
 	// Add any custom headers from the config. They will override the pre-defined

exporter/signalfxexporter/exporter_test.go

@@ -425,7 +425,7 @@ func TestConsumeMetricsWithAccessTokenPassthrough(t *testing.T) {
 				cfg.HTTPClientSettings.Headers[k] = configopaque.String(v)
 			}
 			cfg.HTTPClientSettings.Headers["test_header_"] = configopaque.String(tt.name)
-			cfg.AccessToken = fromHeaders
+			cfg.AccessToken = configopaque.String(fromHeaders)
 			cfg.AccessTokenPassthrough = tt.accessTokenPassthrough
 			sfxExp, err := NewFactory().CreateMetricsExporter(context.Background(), exportertest.NewNopCreateSettings(), cfg)
 			require.NoError(t, err)
@@ -682,7 +682,7 @@ func TestConsumeLogsDataWithAccessTokenPassthrough(t *testing.T) {
 			cfg.APIURL = server.URL
 			cfg.Headers = make(map[string]configopaque.String)
 			cfg.Headers["test_header_"] = configopaque.String(tt.name)
-			cfg.AccessToken = fromHeaders
+			cfg.AccessToken = configopaque.String(fromHeaders)
 			cfg.AccessTokenPassthrough = tt.accessTokenPassthrough
 			sfxExp, err := NewFactory().CreateLogsExporter(context.Background(), exportertest.NewNopCreateSettings(), cfg)
 			require.NoError(t, err)

exporter/signalfxexporter/internal/correlation/correlation.go

@@ -23,6 +23,7 @@ import (
 	"github.com/signalfx/signalfx-agent/pkg/apm/correlations"
 	"github.com/signalfx/signalfx-agent/pkg/apm/tracetracker"
 	"go.opentelemetry.io/collector/component"
+	"go.opentelemetry.io/collector/config/configopaque"
 	"go.opentelemetry.io/collector/exporter"
 	"go.opentelemetry.io/collector/pdata/ptrace"
 	"go.uber.org/zap"
@@ -40,7 +41,7 @@ type Tracker struct {
 	traceTracker *tracetracker.ActiveServiceTracker
 	pTicker      timeutils.TTicker
 	correlation  *correlationContext
-	accessToken  string
+	accessToken  configopaque.String
 }
 
 type correlationContext struct {
@@ -49,7 +50,7 @@ type correlationContext struct {
 }
 
 // NewTracker creates a new tracker instance for correlation.
-func NewTracker(cfg *Config, accessToken string, params exporter.CreateSettings) *Tracker {
+func NewTracker(cfg *Config, accessToken configopaque.String, params exporter.CreateSettings) *Tracker {
 	return &Tracker{
 		log:         params.Logger,
 		cfg:         cfg,
@@ -58,7 +59,7 @@ func NewTracker(cfg *Config, accessToken string, params exporter.CreateSettings)
 	}
 }
 
-func newCorrelationClient(cfg *Config, accessToken string, params exporter.CreateSettings, host component.Host) (
+func newCorrelationClient(cfg *Config, accessToken configopaque.String, params exporter.CreateSettings, host component.Host) (
 	*correlationContext, error,
 ) {
 	corrURL, err := url.Parse(cfg.HTTPClientSettings.Endpoint)
@@ -75,7 +76,7 @@ func newCorrelationClient(cfg *Config, accessToken string, params exporter.Creat
 
 	client, err := correlations.NewCorrelationClient(newZapShim(params.Logger), ctx, httpClient, correlations.ClientConfig{
 		Config:      cfg.Config,
-		AccessToken: accessToken,
+		AccessToken: string(accessToken),
 		URL:         corrURL,
 	})
 

exporter/signalfxexporter/internal/dimensions/dimclient.go

@@ -29,6 +29,7 @@ import (
 	"sync"
 	"time"
 
+	"go.opentelemetry.io/collector/config/configopaque"
 	"go.uber.org/zap"
 
 	"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/signalfxexporter/internal/translation"
@@ -42,7 +43,7 @@ import (
 type DimensionClient struct {
 	sync.RWMutex
 	ctx           context.Context
-	Token         string
+	Token         configopaque.String
 	APIURL        *url.URL
 	client        *http.Client
 	requestSender *ReqSender
@@ -72,7 +73,7 @@ type queuedDimension struct {
 }
 
 type DimensionClientOptions struct {
-	Token                 string
+	Token                 configopaque.String
 	APIURL                *url.URL
 	APITLSConfig          *tls.Config
 	LogUpdates            bool
@@ -320,7 +321,7 @@ func (dc *DimensionClient) makePatchRequest(dim *DimensionUpdate) (*http.Request
 	}
 
 	req.Header.Add("Content-Type", "application/json")
-	req.Header.Add("X-SF-TOKEN", dc.Token)
+	req.Header.Add("X-SF-TOKEN", string(dc.Token))
 
 	return req, nil
 }