Skip to content

Commit c4cd6f6

Browse files
rubvssimitt
andauthored
fix: properly initiate logger (#16864)
Co-authored-by: simitt <5555349+simitt@users.noreply.github.com>
1 parent 7b349ee commit c4cd6f6

File tree

1 file changed

+20
-4
lines changed

1 file changed

+20
-4
lines changed

internal/publish/pub_test.go

Lines changed: 20 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -140,18 +140,34 @@ func BenchmarkPublisher(b *testing.B) {
140140
srv := httptest.NewServer(mux)
141141
defer srv.Close()
142142

143-
supporter, err := idxmgmt.DefaultSupport(beat.Info{}, nil)
143+
supporter, err := idxmgmt.DefaultSupport(
144+
beat.Info{
145+
Logger: logptest.NewTestingLogger(b, "support"),
146+
},
147+
nil,
148+
)
144149
require.NoError(b, err)
145-
outputGroup, err := outputs.Load(supporter, beat.Info{}, nil, "elasticsearch", config.MustNewConfigFrom(map[string]interface{}{
146-
"hosts": []interface{}{srv.URL},
147-
}))
150+
151+
outputGroup, err := outputs.Load(
152+
supporter,
153+
beat.Info{
154+
Logger: logptest.NewTestingLogger(b, "output"),
155+
},
156+
nil,
157+
"elasticsearch",
158+
config.MustNewConfigFrom(map[string]interface{}{
159+
"hosts": []interface{}{srv.URL},
160+
}),
161+
)
148162
require.NoError(b, err)
163+
149164
conf, err := config.NewConfigFrom(map[string]interface{}{
150165
"mem.events": 4096,
151166
"mem.flush.min_events": 2048,
152167
"mem.flush.timeout": "1s",
153168
})
154169
require.NoError(b, err)
170+
155171
namespace := config.Namespace{}
156172
err = conf.Unpack(&namespace)
157173
require.NoError(b, err)

0 commit comments

Comments
 (0)