func newProcessorExecutor[C any]()

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,
	}
}