in internal/processorexecutor.go [45:64]
func newProcessorExecutor[C any](factory processor.Factory) *processorExecutor[C] {
observedLogger, observedLogs := NewLogObserver(zap.DebugLevel, zap.NewDevelopmentEncoderConfig())
logger, _ := zap.NewDevelopmentConfig().Build(zap.WrapCore(func(z zapcore.Core) zapcore.Core {
return observedLogger
}))
telemetrySettings := componenttest.NewNopTelemetrySettings()
telemetrySettings.Logger = logger
settings := processor.Settings{
ID: component.MustNewIDWithName(factory.Type().String(), "ottl_playground"),
TelemetrySettings: telemetrySettings,
}
return &processorExecutor[C]{
factory: factory,
telemetrySettings: telemetrySettings,
settings: settings,
observedLogs: observedLogs,
}
}