Skip to content

Commit f607cb4

Browse files
authored
[exporter/signalfx] Metadata updater lifecycle (#17977)
[exporter/signalfx] Make sure the metadata updater is tied to the exporter itself, so it can tack on the exporter lifecycle.
1 parent f6f6d89 commit f607cb4

File tree

4 files changed

+24
-8
lines changed

4 files changed

+24
-8
lines changed
Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
2+
change_type: bug_fix
3+
4+
# The name of the component, or a single word describing the area of concern, (e.g. filelogreceiver)
5+
component: signalfxexporter
6+
7+
# A brief description of the change. Surround your text with quotes ("") if it needs to start with a backtick (`).
8+
note: Make sure the metadata updater is tied to the exporter itself, so it can tack on the exporter lifecycle.
9+
10+
# One or more tracking issues related to the change
11+
issues: [17976]
12+
13+
# (Optional) One or more lines of additional information to render under the primary note.
14+
# These lines will be padded with 2 spaces and then inserted directly into the document.
15+
# Use pipe (|) for multiline entries.
16+
subtext:

exporter/signalfxexporter/exporter.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -54,11 +54,11 @@ type baseLogsExporter struct {
5454

5555
type signalfMetadataExporter struct {
5656
exporter.Metrics
57-
pushMetadata func(metadata []*metadata.MetadataUpdate) error
57+
exporter *signalfxExporter
5858
}
5959

6060
func (sme *signalfMetadataExporter) ConsumeMetadata(metadata []*metadata.MetadataUpdate) error {
61-
return sme.pushMetadata(metadata)
61+
return sme.exporter.pushMetadata(metadata)
6262
}
6363

6464
type signalfxExporter struct {

exporter/signalfxexporter/exporter_test.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -987,11 +987,11 @@ func TestConsumeMetadata(t *testing.T) {
987987
})
988988
dimClient.Start()
989989

990-
se := signalfxExporter{
990+
se := &signalfxExporter{
991991
pushMetadata: dimClient.PushMetadata,
992992
}
993993
sme := signalfMetadataExporter{
994-
pushMetadata: se.pushMetadata,
994+
exporter: se,
995995
}
996996

997997
err = sme.ConsumeMetadata(tt.args.metadata)
@@ -1294,11 +1294,11 @@ func TestTLSAPIConnection(t *testing.T) {
12941294
})
12951295
dimClient.Start()
12961296

1297-
se := signalfxExporter{
1297+
se := &signalfxExporter{
12981298
pushMetadata: dimClient.PushMetadata,
12991299
}
13001300
sme := signalfMetadataExporter{
1301-
pushMetadata: se.pushMetadata,
1301+
exporter: se,
13021302
}
13031303

13041304
err = sme.ConsumeMetadata(metadata)

exporter/signalfxexporter/factory.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -149,8 +149,8 @@ func createMetricsExporter(
149149
}
150150

151151
return &signalfMetadataExporter{
152-
Metrics: me,
153-
pushMetadata: exp.pushMetadata,
152+
Metrics: me,
153+
exporter: exp,
154154
}, nil
155155
}
156156

0 commit comments

Comments
 (0)