Move service.[Collector|NewSvcHandler|CollectorSettings|State|NewComm…

…and] to collector package

Signed-off-by: Bogdan Drutu <bogdandrutu@gmail.com>

.chloggen/depcollector.yaml

@@ -0,0 +1,11 @@
+# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
+change_type: deprecation
+
+# 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: Deprecate service.[Collector|NewSvcHandler|CollectorSettings|State|NewCommand] in favor of collector package"
+
+# One or more tracking issues or pull requests related to the change
+issues: [6608]

collector/collector.go

@@ -0,0 +1,37 @@
+// Copyright The OpenTelemetry Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//       http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+// Package collector handles the command-line, configuration, and runs the
+// OpenTelemetry Collector.
+package collector // import "go.opentelemetry.io/collector/collector"
+
+import (
+	"go.opentelemetry.io/collector/service"
+)
+
+// State defines Collector's state.
+type State = service.State //nolint:staticcheck
+
+const (
+	StateStarting = service.StateStarting //nolint:staticcheck
+	StateRunning  = service.StateRunning  //nolint:staticcheck
+	StateClosing  = service.StateClosing  //nolint:staticcheck
+	StateClosed   = service.StateClosed   //nolint:staticcheck
+)
+
+// Collector represents a server providing the OpenTelemetry Collector service.
+type Collector = service.Collector //nolint:staticcheck
+
+// New creates and returns a new instance of Collector.
+var New = service.New //nolint:staticcheck

collector/collector_windows.go

@@ -0,0 +1,25 @@
+// Copyright The OpenTelemetry Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//       http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+//go:build windows
+// +build windows
+
+package collector // import "go.opentelemetry.io/collector/collector"
+
+import (
+	"go.opentelemetry.io/collector/service"
+)
+
+// NewSvcHandler constructs a new svc.Handler using the given CollectorSettings.
+var NewSvcHandler = service.NewSvcHandler //nolint:staticcheck

service/collector_windows_test.go → collector/collector_windows_test.go

@@ -15,7 +15,7 @@
 //go:build windows
 // +build windows
 
-package service
+package collector
 
 import (
 	"os"
@@ -38,7 +38,7 @@ func TestNewSvcHandler(t *testing.T) {
 	factories, err := componenttest.NopFactories()
 	require.NoError(t, err)
 
-	s := NewSvcHandler(CollectorSettings{BuildInfo: component.NewDefaultBuildInfo(), Factories: factories})
+	s := NewSvcHandler(Settings{BuildInfo: component.NewDefaultBuildInfo(), Factories: factories})
 
 	colDone := make(chan struct{})
 	requests := make(chan svc.ChangeRequest)

collector/command.go

@@ -0,0 +1,22 @@
+// Copyright The OpenTelemetry Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//       http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package collector // import "go.opentelemetry.io/collector/collector"
+
+import (
+	"go.opentelemetry.io/collector/service"
+)
+
+// NewCommand constructs a new cobra.Command using the given CollectorSettings.
+var NewCommand = service.NewCommand //nolint:staticcheck

service/command_test.go → collector/command_test.go

@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package service
+package collector
 
 import (
 	"path/filepath"
@@ -23,28 +23,38 @@ import (
 
 	"go.opentelemetry.io/collector/component"
 	"go.opentelemetry.io/collector/component/componenttest"
+	"go.opentelemetry.io/collector/confmap"
+	"go.opentelemetry.io/collector/confmap/converter/expandconverter"
+	"go.opentelemetry.io/collector/confmap/provider/fileprovider"
 )
 
 func TestNewCommandVersion(t *testing.T) {
-	cmd := NewCommand(CollectorSettings{BuildInfo: component.BuildInfo{Version: "test_version"}})
+	cmd := NewCommand(Settings{BuildInfo: component.BuildInfo{Version: "test_version"}})
 	assert.Equal(t, "test_version", cmd.Version)
 }
 
 func TestNewCommandNoConfigURI(t *testing.T) {
 	factories, err := componenttest.NopFactories()
 	require.NoError(t, err)
 
-	cmd := NewCommand(CollectorSettings{Factories: factories})
+	cmd := NewCommand(Settings{Factories: factories})
 	require.Error(t, cmd.Execute())
 }
 
 func TestNewCommandInvalidComponent(t *testing.T) {
 	factories, err := componenttest.NopFactories()
 	require.NoError(t, err)
 
-	cfgProvider, err := NewConfigProvider(newDefaultConfigProviderSettings([]string{filepath.Join("testdata", "otelcol-invalid.yaml")}))
+	cfgProvider, err := NewConfigProvider(
+		ConfigProviderSettings{
+			ResolverSettings: confmap.ResolverSettings{
+				URIs:       []string{filepath.Join("testdata", "otelcol-invalid.yaml")},
+				Providers:  map[string]confmap.Provider{"file": fileprovider.New()},
+				Converters: []confmap.Converter{expandconverter.New()},
+			},
+		})
 	require.NoError(t, err)
 
-	cmd := NewCommand(CollectorSettings{Factories: factories, ConfigProvider: cfgProvider})
+	cmd := NewCommand(Settings{Factories: factories, ConfigProvider: cfgProvider})
 	require.Error(t, cmd.Execute())
 }

collector/config_provider.go

@@ -0,0 +1,42 @@
+// Copyright The OpenTelemetry Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//       http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package collector // import "go.opentelemetry.io/collector/collector"
+
+import (
+	"go.opentelemetry.io/collector/service"
+)
+
+// ConfigProvider provides the service configuration.
+//
+// The typical usage is the following:
+//
+//	cfgProvider.Get(...)
+//	cfgProvider.Watch() // wait for an event.
+//	cfgProvider.Get(...)
+//	cfgProvider.Watch() // wait for an event.
+//	// repeat Get/Watch cycle until it is time to shut down the Collector process.
+//	cfgProvider.Shutdown()
+type ConfigProvider = service.ConfigProvider //nolint:staticcheck
+
+// ConfigProviderSettings are the settings to configure the behavior of the ConfigProvider.
+type ConfigProviderSettings = service.ConfigProviderSettings //nolint:staticcheck
+
+// NewConfigProvider returns a new ConfigProvider that provides the service configuration:
+// * Initially it resolves the "configuration map":
+//   - Retrieve the confmap.Conf by merging all retrieved maps from the given `locations` in order.
+//   - Then applies all the confmap.Converter in the given order.
+//
+// * Then unmarshalls the confmap.Conf into the service Config.
+var NewConfigProvider = service.NewConfigProvider //nolint:staticcheck

collector/settings.go

@@ -0,0 +1,22 @@
+// Copyright The OpenTelemetry Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//       http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package collector // import "go.opentelemetry.io/collector/collector"
+
+import (
+	"go.opentelemetry.io/collector/service"
+)
+
+// Settings holds configuration for creating a new Collector.
+type Settings = service.CollectorSettings //nolint:staticcheck

service/collector.go

@@ -33,13 +33,17 @@ import (
 	"go.opentelemetry.io/collector/service/internal/grpclog"
 )
 
-// State defines Collector's state.
+// Deprecated: [v0.66.0] use collector.State
 type State int
 
 const (
+	// Deprecated: [v0.66.0] use collector.StateStarting
 	StateStarting State = iota
+	// Deprecated: [v0.66.0] use collector.StateRunning
 	StateRunning
+	// Deprecated: [v0.66.0] use collector.StateClosing
 	StateClosing
+	// Deprecated: [v0.66.0] use collector.StateClosed
 	StateClosed
 )
 
@@ -68,7 +72,7 @@ func (s State) String() string {
 // - Upon shutdown, pipelines are notified, then pipelines and extensions are shut down.
 // - Users can call (*Collector).Shutdown anytime to shut down the collector.
 
-// Collector represents a server providing the OpenTelemetry Collector service.
+// Deprecated: [v0.66.0] use collector.Collector
 type Collector struct {
 	set CollectorSettings
 

service/collector_windows.go

@@ -39,7 +39,7 @@ type windowsService struct {
 	flags    *flag.FlagSet
 }
 
-// NewSvcHandler constructs a new svc.Handler using the given CollectorSettings.
+// Deprecated: [v0.66.0] use collector.NewSvcHandler
 func NewSvcHandler(set CollectorSettings) svc.Handler {
 	return &windowsService{settings: set, flags: flags()}
 }

service/command.go

@@ -22,7 +22,7 @@ import (
 	"go.opentelemetry.io/collector/featuregate"
 )
 
-// NewCommand constructs a new cobra.Command using the given CollectorSettings.
+// Deprecated: [v0.66.0] use collector.NewCommand
 func NewCommand(set CollectorSettings) *cobra.Command {
 	flagSet := flags()
 	rootCmd := &cobra.Command{

service/config_provider.go

@@ -27,16 +27,7 @@ import (
 	"go.opentelemetry.io/collector/confmap/provider/yamlprovider"
 )
 
-// ConfigProvider provides the service configuration.
-//
-// The typical usage is the following:
-//
-//	cfgProvider.Get(...)
-//	cfgProvider.Watch() // wait for an event.
-//	cfgProvider.Get(...)
-//	cfgProvider.Watch() // wait for an event.
-//	// repeat Get/Watch cycle until it is time to shut down the Collector process.
-//	cfgProvider.Shutdown()
+// Deprecated: [v0.66.0] use collector.ConfigProvider
 type ConfigProvider interface {
 	// Get returns the service configuration, or error otherwise.
 	//
@@ -65,7 +56,7 @@ type configProvider struct {
 	mapResolver *confmap.Resolver
 }
 
-// ConfigProviderSettings are the settings to configure the behavior of the ConfigProvider.
+// Deprecated: [v0.66.0] use collector.ConfigProviderSettings
 type ConfigProviderSettings struct {
 	// ResolverSettings are the settings to configure the behavior of the confmap.Resolver.
 	ResolverSettings confmap.ResolverSettings
@@ -81,12 +72,7 @@ func newDefaultConfigProviderSettings(uris []string) ConfigProviderSettings {
 	}
 }
 
-// NewConfigProvider returns a new ConfigProvider that provides the service configuration:
-// * Initially it resolves the "configuration map":
-//   - Retrieve the confmap.Conf by merging all retrieved maps from the given `locations` in order.
-//   - Then applies all the confmap.Converter in the given order.
-//
-// * Then unmarshalls the confmap.Conf into the service Config.
+// Deprecated: [v0.66.0] use collector.NewConfigProvider
 func NewConfigProvider(set ConfigProviderSettings) (ConfigProvider, error) {
 	mr, err := confmap.NewResolver(set.ResolverSettings)
 	if err != nil {

service/servicetest/configprovider.go

@@ -17,6 +17,7 @@ package servicetest // import "go.opentelemetry.io/collector/service/servicetest
 import (
 	"context"
 
+	"go.opentelemetry.io/collector/collector"
 	"go.opentelemetry.io/collector/component"
 	"go.opentelemetry.io/collector/confmap"
 	"go.opentelemetry.io/collector/confmap/converter/expandconverter"
@@ -30,7 +31,7 @@ import (
 // LoadConfig loads a config.Config  from file, and does NOT validate the configuration.
 func LoadConfig(fileName string, factories component.Factories) (*service.Config, error) {
 	// Read yaml config from file
-	provider, err := service.NewConfigProvider(service.ConfigProviderSettings{
+	provider, err := collector.NewConfigProvider(collector.ConfigProviderSettings{
 		ResolverSettings: confmap.ResolverSettings{
 			URIs:       []string{fileName},
 			Providers:  makeMapProvidersMap(fileprovider.New(), envprovider.New(), yamlprovider.New(), httpprovider.New()),

service/settings.go

@@ -41,7 +41,7 @@ type settings struct {
 	telemetry *telemetryInitializer
 }
 
-// CollectorSettings holds configuration for creating a new Collector.
+// Deprecated: [v0.66.0] use collector.Settings
 type CollectorSettings struct {
 	// Factories component factories.
 	Factories component.Factories