Add ModuleInfo struct to extension package

Author: djaglowski

extension/extension.go

@@ -62,6 +62,15 @@ type StatusWatcher interface {
 	ComponentStatusChanged(source *component.InstanceID, event *component.StatusEvent)
 }
 
+// ModuleInfo describes the go module for each component.
+type ModuleInfo struct {
+	Receiver  map[component.Type]string
+	Processor map[component.Type]string
+	Exporter  map[component.Type]string
+	Extension map[component.Type]string
+	Connector map[component.Type]string
+}
+
 // Settings is passed to Factory.Create(...) function.
 type Settings struct {
 	// ID returns the ID of the component that will be created.
@@ -71,6 +80,8 @@ type Settings struct {
 
 	// BuildInfo can be used by components for informational purposes
 	BuildInfo component.BuildInfo
+
+	ModuleInfo ModuleInfo
 }
 
 // CreateFunc is the equivalent of Factory.Create(...) function.

otelcol/collector.go

@@ -185,13 +185,20 @@ func (col *Collector) setupConfigurationComponents(ctx context.Context) error {
 	}
 
 	col.service, err = service.New(ctx, service.Settings{
-		BuildInfo:         col.set.BuildInfo,
-		CollectorConf:     conf,
-		Receivers:         receiver.NewBuilder(cfg.Receivers, factories.Receivers),
-		Processors:        processor.NewBuilder(cfg.Processors, factories.Processors),
-		Exporters:         exporter.NewBuilder(cfg.Exporters, factories.Exporters),
-		Connectors:        connector.NewBuilder(cfg.Connectors, factories.Connectors),
-		Extensions:        extension.NewBuilder(cfg.Extensions, factories.Extensions),
+		BuildInfo:     col.set.BuildInfo,
+		CollectorConf: conf,
+		Receivers:     receiver.NewBuilder(cfg.Receivers, factories.Receivers),
+		Processors:    processor.NewBuilder(cfg.Processors, factories.Processors),
+		Exporters:     exporter.NewBuilder(cfg.Exporters, factories.Exporters),
+		Connectors:    connector.NewBuilder(cfg.Connectors, factories.Connectors),
+		Extensions:    extension.NewBuilder(cfg.Extensions, factories.Extensions),
+		ModuleInfo: extension.ModuleInfo{
+			Receiver:  factories.ReceiverModules,
+			Processor: factories.ProcessorModules,
+			Exporter:  factories.ExporterModules,
+			Extension: factories.ExtensionModules,
+			Connector: factories.ConnectorModules,
+		},
 		AsyncErrorChannel: col.asyncErrorChannel,
 		LoggingOptions:    col.set.LoggingOptions,
 	}, cfg.Service)

service/extensions/extensions.go

@@ -172,6 +172,7 @@ type Settings struct {
 
 	// Extensions builder for extensions.
 	Extensions *extension.Builder
+	ModuleInfo extension.ModuleInfo
 }
 
 type Option func(*Extensions)
@@ -205,6 +206,7 @@ func New(ctx context.Context, set Settings, cfg Config, options ...Option) (*Ext
 			ID:                extID,
 			TelemetrySettings: set.Telemetry,
 			BuildInfo:         set.BuildInfo,
+			ModuleInfo:        set.ModuleInfo,
 		}
 		extSet.TelemetrySettings.ReportStatus = status.NewReportStatusFunc(instanceID, exts.reporter.ReportStatus)
 		extSet.TelemetrySettings.Logger = components.ExtensionLogger(set.Telemetry.Logger, extID)

service/internal/graph/host.go

@@ -36,7 +36,8 @@ type Host struct {
 	Connectors        *connector.Builder
 	Extensions        *extension.Builder
 
-	BuildInfo component.BuildInfo
+	ModuleInfo extension.ModuleInfo
+	BuildInfo  component.BuildInfo
 
 	Pipelines         *Graph
 	ServiceExtensions *extensions.Extensions

service/service.go

@@ -58,6 +58,9 @@ type Settings struct {
 	// Extensions builder for extensions.
 	Extensions *extension.Builder
 
+	// ModuleInfo describes the go module for each component.
+	ModuleInfo extension.ModuleInfo
+
 	// AsyncErrorChannel is the channel that is used to report fatal errors.
 	AsyncErrorChannel chan error
 
@@ -87,6 +90,7 @@ func New(ctx context.Context, set Settings, cfg Config) (*Service, error) {
 			Exporters:         set.Exporters,
 			Connectors:        set.Connectors,
 			Extensions:        set.Extensions,
+			ModuleInfo:        set.ModuleInfo,
 			BuildInfo:         set.BuildInfo,
 			AsyncErrorChannel: set.AsyncErrorChannel,
 		},
@@ -283,6 +287,7 @@ func (srv *Service) initExtensions(ctx context.Context, cfg extensions.Config) e
 		Telemetry:  srv.telemetrySettings,
 		BuildInfo:  srv.buildInfo,
 		Extensions: srv.host.Extensions,
+		ModuleInfo: srv.host.ModuleInfo,
 	}
 	if srv.host.ServiceExtensions, err = extensions.New(ctx, extensionsSettings, cfg, extensions.WithReporter(srv.reporter)); err != nil {
 		return fmt.Errorf("failed to build extensions: %w", err)