[service] Make graph package public

.chloggen/mx-psi_graph.yaml

@@ -0,0 +1,16 @@
+# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
+change_type: enhancement
+
+# The name of the component, or a single word describing the area of concern, (e.g. otlpreceiver)
+component: service
+
+# A brief description of the change.  Surround your text with quotes ("") if it needs to start with a backtick (`).
+note: "Makes `graph` public to allow overrriding telemetry providers"
+
+# One or more tracking issues or pull requests related to the change
+issues: [4970]
+
+# (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.
+# Use pipe (|) for multiline entries.
+subtext:

service/internal/graph/graph.go → service/graph/graph.go

@@ -1,7 +1,7 @@
 // Copyright The OpenTelemetry Authors
 // SPDX-License-Identifier: Apache-2.0
 
-package graph // import "go.opentelemetry.io/collector/service/internal/graph"
+package graph // import "go.opentelemetry.io/collector/service/graph"
 
 import (
 	"context"
@@ -25,20 +25,27 @@ import (
 	"go.opentelemetry.io/collector/service/pipelines"
 )
 
-// Settings holds configuration for building builtPipelines.
+// Settings holds configuration for building a Graph.
 type Settings struct {
+	// Telemetry specifies the telemetry settings.
 	Telemetry component.TelemetrySettings
+	// BuildInfo provides collector start information.
 	BuildInfo component.BuildInfo
 
-	ReceiverBuilder  *receiver.Builder
+	// ReceiverBuilder is a helper struct that given a set of Configs and Factories helps with creating receivers.
+	ReceiverBuilder *receiver.Builder
+	// ProcessorBuilder is a helper struct that given a set of Configs and Factories helps with creating processors.
 	ProcessorBuilder *processor.Builder
-	ExporterBuilder  *exporter.Builder
+	// ExporterBuilder is a helper struct that given a set of Configs and Factories helps with creating exporters.
+	ExporterBuilder *exporter.Builder
+	// ConnectorBuilder is a helper struct that given a set of Configs and Factories helps with creating connectors.
 	ConnectorBuilder *connector.Builder
 
 	// PipelineConfigs is a map of component.ID to PipelineConfig.
 	PipelineConfigs pipelines.Config
 }
 
+// Graph of collector components.
 type Graph struct {
 	// All component instances represented as nodes, with directed edges indicating data flow.
 	componentGraph *simple.DirectedGraph
@@ -47,6 +54,7 @@ type Graph struct {
 	pipelines map[component.ID]*pipelineNodes
 }
 
+// Build a collector graph.
 func Build(ctx context.Context, set Settings) (*Graph, error) {
 	pipelines := &Graph{
 		componentGraph: simple.NewDirectedGraph(),
@@ -316,6 +324,7 @@ type pipelineNodes struct {
 	exporters map[int64]graph.Node
 }
 
+// StartAll components in the graph in topological order.
 func (g *Graph) StartAll(ctx context.Context, host component.Host) error {
 	nodes, err := topo.Sort(g.componentGraph)
 	if err != nil {
@@ -338,6 +347,7 @@ func (g *Graph) StartAll(ctx context.Context, host component.Host) error {
 	return nil
 }
 
+// ShutdownAll components in the graph in topological order.
 func (g *Graph) ShutdownAll(ctx context.Context) error {
 	nodes, err := topo.Sort(g.componentGraph)
 	if err != nil {

service/internal/graph/nodes.go → service/graph/nodes.go

@@ -1,7 +1,7 @@
 // Copyright The OpenTelemetry Authors
 // SPDX-License-Identifier: Apache-2.0
 
-package graph // import "go.opentelemetry.io/collector/service/internal/graph"
+package graph // import "go.opentelemetry.io/collector/service/graph"
 
 import (
 	"context"

service/internal/graph/zpages.go → service/graph/zpages.go

@@ -1,7 +1,7 @@
 // Copyright The OpenTelemetry Authors
 // SPDX-License-Identifier: Apache-2.0
 
-package graph // import "go.opentelemetry.io/collector/service/internal/graph"
+package graph // import "go.opentelemetry.io/collector/service/graph"
 
 import (
 	"net/http"
@@ -18,6 +18,7 @@ const (
 	zComponentKind = "componentkindz"
 )
 
+// HandleZPages handles ZPages requests for the zpages extension.
 func (g *Graph) HandleZPages(w http.ResponseWriter, r *http.Request) {
 	qValues := r.URL.Query()
 	pipelineName := qValues.Get(zPipelineName)

service/host.go

@@ -11,7 +11,7 @@ import (
 	"go.opentelemetry.io/collector/processor"
 	"go.opentelemetry.io/collector/receiver"
 	"go.opentelemetry.io/collector/service/extensions"
-	"go.opentelemetry.io/collector/service/internal/graph"
+	"go.opentelemetry.io/collector/service/graph"
 )
 
 var _ component.Host = (*serviceHost)(nil)

service/service.go

@@ -26,7 +26,7 @@ import (
 	"go.opentelemetry.io/collector/receiver"
 	semconv "go.opentelemetry.io/collector/semconv/v1.18.0"
 	"go.opentelemetry.io/collector/service/extensions"
-	"go.opentelemetry.io/collector/service/internal/graph"
+	"go.opentelemetry.io/collector/service/graph"
 	"go.opentelemetry.io/collector/service/internal/proctelemetry"
 	"go.opentelemetry.io/collector/service/telemetry"
 )