Skip to content

Commit 98b7824

Browse files
authored
Use extension logger for collector (aws-observability#400)
This will cause the collector to use the same verbosity and JSON output format as the rest of the logs produced by the extension. Signed-off-by: Anthony J Mirabella <[email protected]> Signed-off-by: Anthony J Mirabella <[email protected]>
1 parent 60b6529 commit 98b7824

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

collector/collector.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@ import (
3030
"go.opentelemetry.io/collector/confmap/provider/yamlprovider"
3131
"go.opentelemetry.io/collector/otelcol"
3232
"go.uber.org/zap"
33+
"go.uber.org/zap/zapcore"
3334
)
3435

3536
var (
@@ -48,6 +49,7 @@ type Collector struct {
4849
svc *otelcol.Collector
4950
appDone chan struct{}
5051
stopped bool
52+
logger *zap.Logger
5153
}
5254

5355
func getConfig(logger *zap.Logger) string {
@@ -84,6 +86,7 @@ func NewCollector(logger *zap.Logger, factories component.Factories) *Collector
8486
col := &Collector{
8587
factories: factories,
8688
configProvider: cfgProvider,
89+
logger: logger,
8790
}
8891
return col
8992
}
@@ -97,6 +100,9 @@ func (c *Collector) Start(ctx context.Context) error {
97100
},
98101
ConfigProvider: c.configProvider,
99102
Factories: c.factories,
103+
LoggingOptions: []zap.Option{zap.WrapCore(func(_ zapcore.Core) zapcore.Core {
104+
return c.logger.Core()
105+
})},
100106
}
101107
var err error
102108
c.svc, err = otelcol.NewCollector(params)

0 commit comments

Comments
 (0)