Skip to content

Commit 3fc38f3

Browse files
mx-psimx-psi
authored
[chore] Un-embed configgrpc config structs (#49795)
<!--Ex. Fixing a bug - Describe the bug and how this fixes the issue. Ex. Adding a feature - Explain what this achieves.--> #### Description Stops embedding `configgrpc.ClientConfig` / `configgrpc.ServerConfig` fields. This was fully generated with Opus 4.8 following open-telemetry/opentelemetry-collector#12718. The bulk of it was done by running this script https://gist.github.com/mx-psi/c5243da22050b763f041a491ce339ea3, with manual (AI) edits afterwards. <!-- Issue number (e.g. #1234) or full URL to issue, if applicable. --> #### Link to tracking issue Possible solution for open-telemetry/opentelemetry-collector/pull/15308 <!--Authorship attestation. See AGENTS.md for details. AI agents must not check this box on behalf of the user; the human author must check it themselves before the PR is ready for review.--> #### Authorship - [x] I, a human, wrote this pull request description myself. <!--Please delete paragraphs that you did not use before submitting.-->
1 parent 8db3460 commit 3fc38f3

43 files changed

Lines changed: 171 additions & 169 deletions

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎exporter/coralogixexporter/config.go‎

Lines changed: 47 additions & 47 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ const (
3535
// TransportConfig extends configgrpc.ClientConfig with additional HTTP-specific settings
3636
type TransportConfig struct {
3737
// Embed the gRPC configuration to ensure backward compatibility
38-
configgrpc.ClientConfig `mapstructure:",squash"`
38+
ClientConfig configgrpc.ClientConfig `mapstructure:",squash"`
3939

4040
// The following fields are only used when protocol is "http"
4141
ProxyURL string `mapstructure:"proxy_url,omitempty"` // Used only if protocol is http
@@ -47,20 +47,20 @@ type TransportConfig struct {
4747
}
4848

4949
func (c *TransportConfig) ToHTTPClient(ctx context.Context, host component.Host, settings component.TelemetrySettings) (*http.Client, error) {
50-
c.Headers.Set("Content-Type", "application/x-protobuf")
50+
c.ClientConfig.Headers.Set("Content-Type", "application/x-protobuf")
5151

5252
httpClientConfig := confighttp.NewDefaultClientConfig()
5353
// TODO: See https://github.com/open-telemetry/opentelemetry-collector-contrib/issues/49316.
5454
httpClientConfig.MaxIdleConns = 0
5555
httpClientConfig.IdleConnTimeout = 0
5656
httpClientConfig.ForceAttemptHTTP2 = false
5757
httpClientConfig.ProxyURL = c.ProxyURL
58-
httpClientConfig.TLS = c.TLS
59-
httpClientConfig.ReadBufferSize = c.ReadBufferSize
60-
httpClientConfig.WriteBufferSize = c.WriteBufferSize
58+
httpClientConfig.TLS = c.ClientConfig.TLS
59+
httpClientConfig.ReadBufferSize = c.ClientConfig.ReadBufferSize
60+
httpClientConfig.WriteBufferSize = c.ClientConfig.WriteBufferSize
6161
httpClientConfig.Timeout = c.Timeout
62-
httpClientConfig.Headers = c.Headers
63-
httpClientConfig.Compression = c.Compression
62+
httpClientConfig.Headers = c.ClientConfig.Headers
63+
httpClientConfig.Compression = c.ClientConfig.Compression
6464
return httpClientConfig.ToClient(ctx, host.GetExtensions(), settings)
6565
}
6666

@@ -138,43 +138,43 @@ func (c *Config) Unmarshal(conf *confmap.Conf) error {
138138
_ = setDomainGrpcSettings(c)
139139
var err error
140140

141-
if !isEmpty(c.Domain) && isEmpty(c.Metrics.Endpoint) {
141+
if !isEmpty(c.Domain) && isEmpty(c.Metrics.ClientConfig.Endpoint) {
142142
c.Metrics, err = setMergedTransportConfigWithConf(conf, c, "metrics", &c.Metrics)
143143
if err != nil {
144144
return err
145145
}
146146
}
147147

148-
if isEmpty(c.Metrics.Endpoint) {
149-
c.Metrics.Endpoint = ensureHTTPScheme(c.DomainSettings.Endpoint)
148+
if isEmpty(c.Metrics.ClientConfig.Endpoint) {
149+
c.Metrics.ClientConfig.Endpoint = ensureHTTPScheme(c.DomainSettings.ClientConfig.Endpoint)
150150
} else if c.Protocol == httpProtocol {
151-
c.Metrics.Endpoint = ensureHTTPScheme(c.Metrics.Endpoint)
151+
c.Metrics.ClientConfig.Endpoint = ensureHTTPScheme(c.Metrics.ClientConfig.Endpoint)
152152
}
153153

154-
if !isEmpty(c.Domain) && isEmpty(c.Traces.Endpoint) {
154+
if !isEmpty(c.Domain) && isEmpty(c.Traces.ClientConfig.Endpoint) {
155155
c.Traces, err = setMergedTransportConfigWithConf(conf, c, "traces", &c.Traces)
156156
if err != nil {
157157
return err
158158
}
159159
}
160160

161-
if isEmpty(c.Traces.Endpoint) {
162-
c.Traces.Endpoint = ensureHTTPScheme(c.DomainSettings.Endpoint)
161+
if isEmpty(c.Traces.ClientConfig.Endpoint) {
162+
c.Traces.ClientConfig.Endpoint = ensureHTTPScheme(c.DomainSettings.ClientConfig.Endpoint)
163163
} else if c.Protocol == httpProtocol {
164-
c.Traces.Endpoint = ensureHTTPScheme(c.Traces.Endpoint)
164+
c.Traces.ClientConfig.Endpoint = ensureHTTPScheme(c.Traces.ClientConfig.Endpoint)
165165
}
166166

167-
if !isEmpty(c.Domain) && isEmpty(c.Logs.Endpoint) {
167+
if !isEmpty(c.Domain) && isEmpty(c.Logs.ClientConfig.Endpoint) {
168168
c.Logs, err = setMergedTransportConfigWithConf(conf, c, "logs", &c.Logs)
169169
if err != nil {
170170
return err
171171
}
172172
}
173173

174-
if isEmpty(c.Logs.Endpoint) {
175-
c.Logs.Endpoint = ensureHTTPScheme(c.DomainSettings.Endpoint)
174+
if isEmpty(c.Logs.ClientConfig.Endpoint) {
175+
c.Logs.ClientConfig.Endpoint = ensureHTTPScheme(c.DomainSettings.ClientConfig.Endpoint)
176176
} else if c.Protocol == httpProtocol {
177-
c.Logs.Endpoint = ensureHTTPScheme(c.Logs.Endpoint)
177+
c.Logs.ClientConfig.Endpoint = ensureHTTPScheme(c.Logs.ClientConfig.Endpoint)
178178
}
179179

180180
// Only auto-populate profiles endpoint if protocol is not HTTP (profiles only support gRPC)
@@ -188,8 +188,8 @@ func (c *Config) Unmarshal(conf *confmap.Conf) error {
188188

189189
// Only set profiles endpoint fallback if protocol is not HTTP and we have something to fallback to
190190
// This avoid validation issues
191-
if c.Protocol != httpProtocol && isEmpty(c.Profiles.Endpoint) && !isEmpty(c.DomainSettings.Endpoint) {
192-
c.Profiles.Endpoint = ensureHTTPScheme(c.DomainSettings.Endpoint)
191+
if c.Protocol != httpProtocol && isEmpty(c.Profiles.Endpoint) && !isEmpty(c.DomainSettings.ClientConfig.Endpoint) {
192+
c.Profiles.Endpoint = ensureHTTPScheme(c.DomainSettings.ClientConfig.Endpoint)
193193
}
194194
return nil
195195
}
@@ -214,9 +214,9 @@ func (c *Config) Validate() error {
214214

215215
// validate that at least one endpoint is set up correctly
216216
if isEmpty(c.Domain) &&
217-
isEmpty(c.Traces.Endpoint) &&
218-
isEmpty(c.Metrics.Endpoint) &&
219-
isEmpty(c.Logs.Endpoint) &&
217+
isEmpty(c.Traces.ClientConfig.Endpoint) &&
218+
isEmpty(c.Metrics.ClientConfig.Endpoint) &&
219+
isEmpty(c.Logs.ClientConfig.Endpoint) &&
220220
isEmpty(c.Profiles.Endpoint) {
221221
return errors.New("`domain` or `traces.endpoint` or `metrics.endpoint` or `logs.endpoint` or `profiles.endpoint` not specified, please fix the configuration")
222222
}
@@ -376,51 +376,51 @@ func setMergedTransportConfig(c *Config, merged *TransportConfig, signalSub *con
376376
}
377377

378378
if signalSub != nil && signalSub.IsSet("compression") {
379-
merged.Compression = signalConfig.Compression
379+
merged.ClientConfig.Compression = signalConfig.ClientConfig.Compression
380380
}
381381
if signalSub != nil && signalSub.IsSet("accept_encoding") {
382382
merged.AcceptEncoding = signalConfig.AcceptEncoding
383383
}
384-
if signalConfig.TLS.Insecure || signalConfig.TLS.InsecureSkipVerify || signalConfig.TLS.CAFile != "" {
385-
merged.TLS = signalConfig.TLS
384+
if signalConfig.ClientConfig.TLS.Insecure || signalConfig.ClientConfig.TLS.InsecureSkipVerify || signalConfig.ClientConfig.TLS.CAFile != "" {
385+
merged.ClientConfig.TLS = signalConfig.ClientConfig.TLS
386386
}
387-
if len(signalConfig.Headers) > 0 {
387+
if len(signalConfig.ClientConfig.Headers) > 0 {
388388
// MapList.Set copies the backing array, so this does not mutate c.DomainSettings
389-
for k, v := range signalConfig.Headers.Iter {
390-
merged.Headers.Set(k, v)
389+
for k, v := range signalConfig.ClientConfig.Headers.Iter {
390+
merged.ClientConfig.Headers.Set(k, v)
391391
}
392392
}
393-
if signalConfig.WriteBufferSize > 0 {
394-
merged.WriteBufferSize = signalConfig.WriteBufferSize
393+
if signalConfig.ClientConfig.WriteBufferSize > 0 {
394+
merged.ClientConfig.WriteBufferSize = signalConfig.ClientConfig.WriteBufferSize
395395
}
396-
if signalConfig.ReadBufferSize > 0 {
397-
merged.ReadBufferSize = signalConfig.ReadBufferSize
396+
if signalConfig.ClientConfig.ReadBufferSize > 0 {
397+
merged.ClientConfig.ReadBufferSize = signalConfig.ClientConfig.ReadBufferSize
398398
}
399-
if signalConfig.WaitForReady {
400-
merged.WaitForReady = signalConfig.WaitForReady
399+
if signalConfig.ClientConfig.WaitForReady {
400+
merged.ClientConfig.WaitForReady = signalConfig.ClientConfig.WaitForReady
401401
}
402-
if signalConfig.BalancerName != "" {
403-
merged.BalancerName = signalConfig.BalancerName
402+
if signalConfig.ClientConfig.BalancerName != "" {
403+
merged.ClientConfig.BalancerName = signalConfig.ClientConfig.BalancerName
404404
}
405-
if signalConfig.Keepalive.HasValue() {
406-
merged.Keepalive = signalConfig.Keepalive
405+
if signalConfig.ClientConfig.Keepalive.HasValue() {
406+
merged.ClientConfig.Keepalive = signalConfig.ClientConfig.Keepalive
407407
}
408-
if signalConfig.Auth.HasValue() {
409-
merged.Auth = signalConfig.Auth
408+
if signalConfig.ClientConfig.Auth.HasValue() {
409+
merged.ClientConfig.Auth = signalConfig.ClientConfig.Auth
410410
}
411411

412-
if isEmpty(signalConfig.Endpoint) {
413-
merged.Endpoint = setDomainGrpcSettings(c)
412+
if isEmpty(signalConfig.ClientConfig.Endpoint) {
413+
merged.ClientConfig.Endpoint = setDomainGrpcSettings(c)
414414
} else {
415-
merged.Endpoint = signalConfig.Endpoint
415+
merged.ClientConfig.Endpoint = signalConfig.ClientConfig.Endpoint
416416
}
417417

418418
return merged
419419
}
420420

421421
func applyTransportDefaults(cfg *TransportConfig) {
422-
if cfg.Compression == "" {
423-
cfg.Compression = configcompression.TypeGzip
422+
if cfg.ClientConfig.Compression == "" {
423+
cfg.ClientConfig.Compression = configcompression.TypeGzip
424424
}
425425
if cfg.AcceptEncoding == "" {
426426
cfg.AcceptEncoding = gzip.Name

‎exporter/coralogixexporter/config_test.go‎

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -301,17 +301,17 @@ func TestHTTPProtocolDoesNotAutoPopulateProfilesEndpoint(t *testing.T) {
301301

302302
assert.Equal(t, "http", oCfg.Protocol)
303303
assert.True(t, isEmpty(oCfg.Profiles.Endpoint), "profiles endpoint should not be auto-populated when using HTTP protocol")
304-
assert.False(t, isEmpty(oCfg.Logs.Endpoint), "logs endpoint should be auto-populated")
305-
assert.False(t, isEmpty(oCfg.Metrics.Endpoint), "metrics endpoint should be auto-populated")
306-
assert.False(t, isEmpty(oCfg.Traces.Endpoint), "traces endpoint should be auto-populated")
304+
assert.False(t, isEmpty(oCfg.Logs.ClientConfig.Endpoint), "logs endpoint should be auto-populated")
305+
assert.False(t, isEmpty(oCfg.Metrics.ClientConfig.Endpoint), "metrics endpoint should be auto-populated")
306+
assert.False(t, isEmpty(oCfg.Traces.ClientConfig.Endpoint), "traces endpoint should be auto-populated")
307307

308-
assert.Contains(t, oCfg.Logs.Endpoint, "https://", "logs endpoint should have https:// scheme")
309-
assert.Contains(t, oCfg.Metrics.Endpoint, "https://", "metrics endpoint should have https:// scheme")
310-
assert.Contains(t, oCfg.Traces.Endpoint, "https://", "traces endpoint should have https:// scheme")
308+
assert.Contains(t, oCfg.Logs.ClientConfig.Endpoint, "https://", "logs endpoint should have https:// scheme")
309+
assert.Contains(t, oCfg.Metrics.ClientConfig.Endpoint, "https://", "metrics endpoint should have https:// scheme")
310+
assert.Contains(t, oCfg.Traces.ClientConfig.Endpoint, "https://", "traces endpoint should have https:// scheme")
311311

312-
assert.Equal(t, "https://ingress.coralogix.com:443", oCfg.Traces.Endpoint)
313-
assert.Equal(t, "https://ingress.coralogix.com:443", oCfg.Metrics.Endpoint)
314-
assert.Equal(t, "https://ingress.coralogix.com:443", oCfg.Logs.Endpoint)
312+
assert.Equal(t, "https://ingress.coralogix.com:443", oCfg.Traces.ClientConfig.Endpoint)
313+
assert.Equal(t, "https://ingress.coralogix.com:443", oCfg.Metrics.ClientConfig.Endpoint)
314+
assert.Equal(t, "https://ingress.coralogix.com:443", oCfg.Logs.ClientConfig.Endpoint)
315315

316316
assert.NoError(t, oCfg.Validate())
317317

@@ -796,9 +796,9 @@ func TestDomainSettingsCompressionMerge(t *testing.T) {
796796
cfg := createDefaultConfig().(*Config)
797797
require.NoError(t, cfg.Unmarshal(conf))
798798

799-
assert.Equal(t, tt.wantLogsCompression, cfg.Logs.Compression)
800-
assert.Equal(t, tt.wantMetricsCompression, cfg.Metrics.Compression)
801-
assert.Equal(t, tt.wantTracesCompression, cfg.Traces.Compression)
799+
assert.Equal(t, tt.wantLogsCompression, cfg.Logs.ClientConfig.Compression)
800+
assert.Equal(t, tt.wantMetricsCompression, cfg.Metrics.ClientConfig.Compression)
801+
assert.Equal(t, tt.wantTracesCompression, cfg.Traces.ClientConfig.Compression)
802802
assert.Equal(t, tt.wantProfilesCompression, cfg.Profiles.Compression)
803803
assert.Equal(t, tt.wantLogsAcceptEncoding, cfg.Logs.AcceptEncoding)
804804
assert.Equal(t, tt.wantMetricsAcceptEncoding, cfg.Metrics.AcceptEncoding)

‎exporter/coralogixexporter/factory_test.go‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ func TestCreateDefaultConfig(t *testing.T) {
3838
func TestCreateMetrics(t *testing.T) {
3939
factory := NewFactory()
4040
cfg := factory.CreateDefaultConfig().(*Config)
41-
cfg.Metrics.Endpoint = testutil.GetAvailableLocalAddress(t)
41+
cfg.Metrics.ClientConfig.Endpoint = testutil.GetAvailableLocalAddress(t)
4242

4343
set := exportertest.NewNopSettings(metadata.Type)
4444
oexp, err := factory.CreateMetrics(t.Context(), set, cfg)
@@ -61,7 +61,7 @@ func TestCreateMetricsWithDomain(t *testing.T) {
6161
func TestCreateLogs(t *testing.T) {
6262
factory := NewFactory()
6363
cfg := factory.CreateDefaultConfig().(*Config)
64-
cfg.Logs.Endpoint = testutil.GetAvailableLocalAddress(t)
64+
cfg.Logs.ClientConfig.Endpoint = testutil.GetAvailableLocalAddress(t)
6565

6666
set := exportertest.NewNopSettings(metadata.Type)
6767
oexp, err := factory.CreateLogs(t.Context(), set, cfg)
@@ -247,7 +247,7 @@ func TestCreateLogsWithDomainAndEndpoint(t *testing.T) {
247247
cfg := factory.CreateDefaultConfig().(*Config)
248248
cfg.Domain = " bad domain"
249249

250-
cfg.Logs.Endpoint = testutil.GetAvailableLocalAddress(t)
250+
cfg.Logs.ClientConfig.Endpoint = testutil.GetAvailableLocalAddress(t)
251251

252252
set := exportertest.NewNopSettings(metadata.Type)
253253
consumer, err := factory.CreateLogs(t.Context(), set, cfg)

‎exporter/coralogixexporter/http_exporter.go‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ func newHTTPLogsExporter(client *http.Client, config *Config) httpLogsExporter {
4848
return httpLogsExporter{
4949
httpExporter: httpExporter{
5050
Client: client,
51-
Endpoint: config.Logs.Endpoint,
51+
Endpoint: config.Logs.ClientConfig.Endpoint,
5252
},
5353
}
5454
}
@@ -57,7 +57,7 @@ func newHTTPMetricsExporter(client *http.Client, config *Config) httpMetricsExpo
5757
return httpMetricsExporter{
5858
httpExporter: httpExporter{
5959
Client: client,
60-
Endpoint: config.Metrics.Endpoint,
60+
Endpoint: config.Metrics.ClientConfig.Endpoint,
6161
},
6262
}
6363
}
@@ -66,7 +66,7 @@ func newHTTPTracesExporter(client *http.Client, config *Config) httpTracesExport
6666
return httpTracesExporter{
6767
httpExporter: httpExporter{
6868
Client: client,
69-
Endpoint: config.Traces.Endpoint,
69+
Endpoint: config.Traces.ClientConfig.Endpoint,
7070
},
7171
}
7272
}

‎exporter/coralogixexporter/logs_client.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ func newLogsExporter(cfg component.Config, set exp.Settings) (*logsExporter, err
2020
return nil, fmt.Errorf("invalid config exporter, expect type: %T, got: %T", &Config{}, cfg)
2121
}
2222

23-
signalExporter, err := newSignalExporter(oCfg, set, oCfg.Logs.Endpoint, oCfg.Logs.Headers)
23+
signalExporter, err := newSignalExporter(oCfg, set, oCfg.Logs.ClientConfig.Endpoint, oCfg.Logs.ClientConfig.Headers)
2424
if err != nil {
2525
return nil, err
2626
}

‎exporter/coralogixexporter/logs_client_test.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ func TestLogsExporter_Start(t *testing.T) {
9191
require.NoError(t, err)
9292
assert.NotNil(t, exp.clientConn)
9393
assert.NotNil(t, exp.grpcLogsExporter)
94-
_, ok := exp.config.Logs.Headers.Get("Authorization")
94+
_, ok := exp.config.Logs.ClientConfig.Headers.Get("Authorization")
9595
assert.True(t, ok)
9696

9797
// Test shutdown

‎exporter/coralogixexporter/metrics_client.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ func newMetricsExporter(cfg component.Config, set exporter.Settings) (*metricsEx
2020
return nil, fmt.Errorf("invalid config exporter, expect type: %T, got: %T", &Config{}, cfg)
2121
}
2222

23-
signalExporter, err := newSignalExporter(oCfg, set, oCfg.Metrics.Endpoint, oCfg.Metrics.Headers)
23+
signalExporter, err := newSignalExporter(oCfg, set, oCfg.Metrics.ClientConfig.Endpoint, oCfg.Metrics.ClientConfig.Headers)
2424
if err != nil {
2525
return nil, err
2626
}

‎exporter/coralogixexporter/metrics_client_test.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ func TestMetricsExporter_Start(t *testing.T) {
9191
require.NoError(t, err)
9292
assert.NotNil(t, exp.clientConn)
9393
assert.NotNil(t, exp.grpcMetricsExporter)
94-
_, ok := exp.config.Metrics.Headers.Get("Authorization")
94+
_, ok := exp.config.Metrics.ClientConfig.Headers.Get("Authorization")
9595
assert.True(t, ok)
9696

9797
// Test shutdown

‎exporter/coralogixexporter/signals.go‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -38,19 +38,19 @@ type signalConfigWrapper struct {
3838
}
3939

4040
func (w *signalConfigWrapper) ToClientConn(ctx context.Context, host component.Host, settings component.TelemetrySettings, opts ...configgrpc.ToClientConnOption) (*grpc.ClientConn, error) {
41-
return w.config.ToClientConn(ctx, host.GetExtensions(), settings, opts...)
41+
return w.config.ClientConfig.ToClientConn(ctx, host.GetExtensions(), settings, opts...)
4242
}
4343

4444
func (w *signalConfigWrapper) ToHTTPClient(ctx context.Context, host component.Host, settings component.TelemetrySettings) (*http.Client, error) {
4545
return w.config.ToHTTPClient(ctx, host, settings)
4646
}
4747

4848
func (w *signalConfigWrapper) GetWaitForReady() bool {
49-
return w.config.WaitForReady
49+
return w.config.ClientConfig.WaitForReady
5050
}
5151

5252
func (w *signalConfigWrapper) GetEndpoint() string {
53-
return w.config.Endpoint
53+
return w.config.ClientConfig.Endpoint
5454
}
5555

5656
func (w *signalConfigWrapper) GetAcceptEncoding() string {
@@ -126,9 +126,9 @@ func (e *signalExporter) enhanceContext(ctx context.Context) context.Context {
126126

127127
func (e *signalExporter) startSignalExporter(ctx context.Context, host component.Host, signalConfig signalConfig) (err error) {
128128
if signalConfigWrapper, ok := signalConfig.(*signalConfigWrapper); ok {
129-
signalConfigWrapper.config.Headers.Set("Authorization", configopaque.String("Bearer "+string(e.config.PrivateKey)))
129+
signalConfigWrapper.config.ClientConfig.Headers.Set("Authorization", configopaque.String("Bearer "+string(e.config.PrivateKey)))
130130
if e.config.Protocol != httpProtocol {
131-
for k, v := range signalConfigWrapper.config.Headers.Iter {
131+
for k, v := range signalConfigWrapper.config.ClientConfig.Headers.Iter {
132132
e.metadata.Set(k, string(v))
133133
}
134134
}
@@ -145,7 +145,7 @@ func (e *signalExporter) startSignalExporter(ctx context.Context, host component
145145
return err
146146
}
147147
} else {
148-
if e.clientConn, err = signalConfigWrapper.config.ToClientConn(ctx, host.GetExtensions(), e.settings, configgrpc.WithGrpcDialOption(grpc.WithUserAgent(e.userAgent))); err != nil {
148+
if e.clientConn, err = signalConfigWrapper.config.ClientConfig.ToClientConn(ctx, host.GetExtensions(), e.settings, configgrpc.WithGrpcDialOption(grpc.WithUserAgent(e.userAgent))); err != nil {
149149
return err
150150
}
151151
callOptions := []grpc.CallOption{

0 commit comments

Comments
 (0)