Add logs scraper in factory

.chloggen/add-scraper-for-logs.yaml

@@ -10,7 +10,7 @@ component: receiver/scraperhelper
 note: Add scraper for logs
 
 # One or more tracking issues or pull requests related to the change
-issues: [11238]
+issues: [11799,11822]
 
 # (Optional) One or more lines of additional information to render under the primary note.
 # These lines will be padded with 2 spaces and then inserted directly into the document.

scraper/factory.go

@@ -35,9 +35,18 @@ type Factory interface {
 	// Implementers can assume `next` is never nil.
 	CreateMetrics(ctx context.Context, set Settings, cfg component.Config) (Metrics, error)
 
+	// CreateLogs creates a Logs scraper based on this config.
+	// If the scraper type does not support logs,
+	// this function returns the error [pipeline.ErrSignalNotSupported].
+	// Implementers can assume `next` is never nil.
+	CreateLogs(ctx context.Context, set Settings, cfg component.Config) (Logs, error)
+
 	// MetricsStability gets the stability level of the Metrics scraper.
 	MetricsStability() component.StabilityLevel
 
+	// LogsStability gets the stability level of the Logs scraper.
+	LogsStability() component.StabilityLevel
+
 	unexportedFactoryFunc()
 }
 
@@ -60,7 +69,9 @@ type factory struct {
 	cfgType component.Type
 	component.CreateDefaultConfigFunc
 	CreateMetricsFunc
+	CreateLogsFunc
 	metricsStabilityLevel component.StabilityLevel
+	logsStabilityLevel    component.StabilityLevel
 }
 
 func (f *factory) Type() component.Type {
@@ -73,9 +84,16 @@ func (f *factory) MetricsStability() component.StabilityLevel {
 	return f.metricsStabilityLevel
 }
 
+func (f *factory) LogsStability() component.StabilityLevel {
+	return f.logsStabilityLevel
+}
+
 // CreateMetricsFunc is the equivalent of Factory.CreateMetrics().
 type CreateMetricsFunc func(context.Context, Settings, component.Config) (Metrics, error)
 
+// CreateLogsFunc is the equivalent of Factory.CreateLogs().
+type CreateLogsFunc func(context.Context, Settings, component.Config) (Logs, error)
+
 // CreateMetrics implements Factory.CreateMetrics.
 func (f CreateMetricsFunc) CreateMetrics(ctx context.Context, set Settings, cfg component.Config) (Metrics, error) {
 	if f == nil {
@@ -84,6 +102,14 @@ func (f CreateMetricsFunc) CreateMetrics(ctx context.Context, set Settings, cfg
 	return f(ctx, set, cfg)
 }
 
+// CreateLogs implements Factory.CreateLogs.
+func (f CreateLogsFunc) CreateLogs(ctx context.Context, set Settings, cfg component.Config) (Logs, error) {
+	if f == nil {
+		return nil, pipeline.ErrSignalNotSupported
+	}
+	return f(ctx, set, cfg)
+}
+
 // WithMetrics overrides the default "error not supported" implementation for CreateMetrics and the default "undefined" stability level.
 func WithMetrics(createMetrics CreateMetricsFunc, sl component.StabilityLevel) FactoryOption {
 	return factoryOptionFunc(func(o *factory) {
@@ -92,6 +118,14 @@ func WithMetrics(createMetrics CreateMetricsFunc, sl component.StabilityLevel) F
 	})
 }
 
+// WithLogs overrides the default "error not supported" implementation for CreateLogs and the default "undefined" stability level.
+func WithLogs(createLogs CreateLogsFunc, sl component.StabilityLevel) FactoryOption {
+	return factoryOptionFunc(func(o *factory) {
+		o.logsStabilityLevel = sl
+		o.CreateLogsFunc = createLogs
+	})
+}
+
 // NewFactory returns a Factory.
 func NewFactory(cfgType component.Type, createDefaultConfig component.CreateDefaultConfigFunc, options ...FactoryOption) Factory {
 	f := &factory{

scraper/factory_test.go

@@ -32,6 +32,8 @@ func TestNewFactory(t *testing.T) {
 	assert.EqualValues(t, &defaultCfg, f.CreateDefaultConfig())
 	_, err := f.CreateMetrics(context.Background(), nopSettings(), &defaultCfg)
 	require.ErrorIs(t, err, pipeline.ErrSignalNotSupported)
+	_, err = f.CreateLogs(context.Background(), nopSettings(), &defaultCfg)
+	require.ErrorIs(t, err, pipeline.ErrSignalNotSupported)
 }
 
 func TestNewFactoryWithOptions(t *testing.T) {
@@ -40,13 +42,17 @@ func TestNewFactoryWithOptions(t *testing.T) {
 	f := NewFactory(
 		testType,
 		func() component.Config { return &defaultCfg },
-		WithMetrics(createMetrics, component.StabilityLevelAlpha))
+		WithMetrics(createMetrics, component.StabilityLevelAlpha),
+		WithLogs(createLogs, component.StabilityLevelAlpha))
 	assert.EqualValues(t, testType, f.Type())
 	assert.EqualValues(t, &defaultCfg, f.CreateDefaultConfig())
 
 	assert.Equal(t, component.StabilityLevelAlpha, f.MetricsStability())
+	assert.Equal(t, component.StabilityLevelAlpha, f.LogsStability())
 	_, err := f.CreateMetrics(context.Background(), Settings{}, &defaultCfg)
 	require.NoError(t, err)
+	_, err = f.CreateLogs(context.Background(), Settings{}, &defaultCfg)
+	require.NoError(t, err)
 }
 
 func TestMakeFactoryMap(t *testing.T) {
@@ -89,3 +95,7 @@ func TestMakeFactoryMap(t *testing.T) {
 func createMetrics(context.Context, Settings, component.Config) (Metrics, error) {
 	return NewMetrics(newTestScrapeMetricsFunc(nil))
 }
+
+func createLogs(context.Context, Settings, component.Config) (Logs, error) {
+	return NewLogs(newTestScrapeLogsFunc(nil))
+}