[extension/solarwindsapmsettingsextension] Added part one of the concrete implementation of solarwindsapmsettingsextension

.chloggen/feature_solarwindsapmsettingsextension-concreteimpl.yaml

@@ -0,0 +1,27 @@
+# Use this changelog template to create an entry for release notes.
+
+# 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. filelogreceiver)
+component: solarwindsapmsettingsextension
+
+# A brief description of the change.  Surround your text with quotes ("") if it needs to start with a backtick (`).
+note: Added the first part of concrete implementation of solarwindsapmsettingsextension
+
+# Mandatory: One or more tracking issues related to the change. You can use the PR number here if no issue exists.
+issues: [27668]
+
+# (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:
+
+# If your change doesn't affect end users or the exported elements of any package,
+# you should instead start your pull request title with [chore] or use the "Skip Changelog" label.
+# Optional: The change log or logs in which this entry should be included.
+# e.g. '[user]' or '[user, api]'
+# Include 'user' if the change is relevant to end users.
+# Include 'api' if there is a change to a library API.
+# Default: '[user]'
+change_logs: []

cmd/otelcontribcol/go.mod

@@ -614,6 +614,7 @@ require (
 	github.com/sirupsen/logrus v1.9.3 // indirect
 	github.com/snowflakedb/gosnowflake v1.7.2 // indirect
 	github.com/soheilhy/cmux v0.1.5 // indirect
+	github.com/solarwindscloud/apm-proto v0.0.0-20231107001908-432e697887b6 // indirect
 	github.com/sourcegraph/conc v0.3.0 // indirect
 	github.com/spaolacci/murmur3 v1.1.0 // indirect
 	github.com/spf13/afero v1.11.0 // indirect

extension/solarwindsapmsettingsextension/README.md

@@ -23,16 +23,22 @@ extensions:
   solarwindsapmsettings:
     endpoint: "<endpoint>"
     key: "<token>:<name>"
-    interval: 1m
+    interval: 10s
 ```
 
 ### endpoint (Required)
-The APM collector endpoint which this extension calls `getSettings`. See [here](https://documentation.solarwinds.com/en/success_center/observability/content/system_requirements/endpoints.htm) for our APM collector endpoints.
+The APM collector endpoint which this extension calls `getSettings`. See [here](https://documentation.solarwinds.com/en/success_center/observability/content/system_requirements/endpoints.htm) for our APM collector endpoints. The endpoint is in format `<host>:<port>`.
 
 ### key (Required)
 The service key in format `<token>:<name>` for `getSettings` from Solarwinds APM collector. See [here](https://documentation.solarwinds.com/en/success_center/observability/content/configure/configure-services.htm) for configuring a service key.
 
 ### interval (Optional)
 Periodic interval to get Solarwinds APM specific settings from Solarwinds APM collector.
 
-Default: `1m`
+Minimum value: `5s`
+
+Maximum value: `60s`
+
+Value that is outside the boundary will be bounded to either the minimum or maximum value.
+
+Default: `10s`

extension/solarwindsapmsettingsextension/config.go

@@ -2,40 +2,10 @@
 // SPDX-License-Identifier: Apache-2.0
 
 package solarwindsapmsettingsextension // import "github.com/open-telemetry/opentelemetry-collector-contrib/extension/solarwindsapmsettingsextension"
-
-import (
-	"errors"
-	"strconv"
-	"strings"
-	"time"
-)
+import "time"
 
 type Config struct {
-	Endpoint string `mapstructure:"endpoint"`
-	Key      string `mapstructure:"key"`
-	Interval string `mapstructure:"interval"`
-}
-
-func (cfg *Config) Validate() error {
-	if len(cfg.Endpoint) == 0 {
-		return errors.New("endpoint must not be empty")
-	}
-	endpointArr := strings.Split(cfg.Endpoint, ":")
-	if len(endpointArr) != 2 {
-		return errors.New("endpoint should be in \"<host>:<port>\" format")
-	}
-	if _, err := strconv.Atoi(endpointArr[1]); err != nil {
-		return errors.New("the <port> portion of endpoint has to be an integer")
-	}
-	if len(cfg.Key) == 0 {
-		return errors.New("key must not be empty")
-	}
-	keyArr := strings.Split(cfg.Key, ":")
-	if len(keyArr) != 2 {
-		return errors.New("key should be in \"<token>:<service_name>\" format")
-	}
-	if _, err := time.ParseDuration(cfg.Interval); err != nil {
-		return errors.New("interval has to be a duration string. Valid time units are \"ns\", \"us\" (or \"µs\"), \"ms\", \"s\", \"m\", \"h\"")
-	}
-	return nil
+	Endpoint string        `mapstructure:"endpoint"`
+	Key      string        `mapstructure:"key"`
+	Interval time.Duration `mapstructure:"interval"`
 }

extension/solarwindsapmsettingsextension/config_test.go

@@ -4,63 +4,57 @@
 package solarwindsapmsettingsextension
 
 import (
-	"errors"
+	"path/filepath"
 	"testing"
+	"time"
 
+	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
+	"go.opentelemetry.io/collector/component"
+	"go.opentelemetry.io/collector/confmap/confmaptest"
+
+	"github.com/open-telemetry/opentelemetry-collector-contrib/extension/solarwindsapmsettingsextension/internal/metadata"
 )
 
-func TestValidate(t *testing.T) {
+func TestLoadConfig(t *testing.T) {
+	t.Parallel()
+
 	tests := []struct {
-		name string
-		cfg  *Config
-		err  error
+		id       component.ID
+		expected component.Config
 	}{
 		{
-			name: "nothing",
-			cfg:  &Config{},
-			err:  errors.New("endpoint must not be empty"),
-		},
-		{
-			name: "empty key",
-			cfg: &Config{
-				Endpoint: "host:12345",
-			},
-			err: errors.New("key must not be empty"),
-		},
-		{
-			name: "invalid endpoint",
-			cfg: &Config{
-				Endpoint: "invalid",
-				Key:      "token:name",
-			},
-			err: errors.New("endpoint should be in \"<host>:<port>\" format"),
+			id:       component.NewID(metadata.Type),
+			expected: NewFactory().CreateDefaultConfig(),
 		},
 		{
-			name: "invalid endpoint format but port is not an integer",
-			cfg: &Config{
-				Endpoint: "host:abc",
-				Key:      "token:name",
+			id: component.NewIDWithName(metadata.Type, "1"),
+			expected: &Config{
+				Endpoint: "0.0.0.0:1234",
+				Key:      "something",
+				Interval: time.Duration(10) * time.Second,
 			},
-			err: errors.New("the <port> portion of endpoint has to be an integer"),
 		},
 		{
-			name: "invalid key",
-			cfg: &Config{
-				Endpoint: "host:12345",
-				Key:      "invalid",
+			id: component.NewIDWithName(metadata.Type, "2"),
+			expected: &Config{
+				Endpoint: "0.0.0.0:1234",
+				Key:      "something",
+				Interval: time.Duration(10) * time.Second,
 			},
-			err: errors.New("key should be in \"<token>:<service_name>\" format"),
 		},
 	}
-	for _, tc := range tests {
-		t.Run(tc.name, func(t *testing.T) {
-			err := tc.cfg.Validate()
-			if tc.err != nil {
-				require.EqualError(t, err, tc.err.Error())
-			} else {
-				require.NoError(t, err)
-			}
+	for _, tt := range tests {
+		t.Run(tt.id.String(), func(t *testing.T) {
+			cm, err := confmaptest.LoadConf(filepath.Join("testdata", "config.yaml"))
+			require.NoError(t, err)
+			factory := NewFactory()
+			cfg := factory.CreateDefaultConfig()
+			sub, err := cm.Sub(tt.id.String())
+			require.NoError(t, err)
+			require.NoError(t, component.UnmarshalConfig(sub, cfg))
+			assert.NoError(t, component.ValidateConfig(cfg))
+			assert.Equal(t, tt.expected, cfg)
 		})
 	}
 }

extension/solarwindsapmsettingsextension/extension.go

@@ -5,16 +5,23 @@ package solarwindsapmsettingsextension // import "github.com/open-telemetry/open
 
 import (
 	"context"
+	"crypto/tls"
+	"time"
 
+	"github.com/solarwindscloud/apm-proto/go/collectorpb"
 	"go.opentelemetry.io/collector/component"
 	"go.opentelemetry.io/collector/extension"
 	"go.uber.org/zap"
+	"google.golang.org/grpc"
+	"google.golang.org/grpc/credentials"
 )
 
 type solarwindsapmSettingsExtension struct {
 	logger *zap.Logger
 	config *Config
 	cancel context.CancelFunc
+	conn   *grpc.ClientConn
+	client collectorpb.TraceCollectorClient
 }
 
 func newSolarwindsApmSettingsExtension(extensionCfg *Config, logger *zap.Logger) (extension.Extension, error) {
@@ -25,13 +32,63 @@ func newSolarwindsApmSettingsExtension(extensionCfg *Config, logger *zap.Logger)
 	return settingsExtension, nil
 }
 
-func (extension *solarwindsapmSettingsExtension) Start(_ context.Context, _ component.Host) error {
+func (extension *solarwindsapmSettingsExtension) Start(ctx context.Context, _ component.Host) error {
 	extension.logger.Debug("Starting up solarwinds apm settings extension")
-	_, extension.cancel = context.WithCancel(context.Background())
+	ctx, extension.cancel = context.WithCancel(ctx)
+	configOk := validateSolarwindsApmSettingsExtensionConfiguration(extension.config, extension.logger)
+	if configOk {
+		extension.conn, _ = grpc.Dial(extension.config.Endpoint, grpc.WithTransportCredentials(credentials.NewTLS(&tls.Config{})))
+		extension.logger.Info("Dailed to " + extension.config.Endpoint)
+		extension.client = collectorpb.NewTraceCollectorClient(extension.conn)
+		go func() {
+			ticker := newTicker(extension.config.Interval)
+			defer ticker.Stop()
+			for {
+				select {
+				case <-ticker.C:
+					refresh(extension)
+				case <-ctx.Done():
+					extension.logger.Debug("Received ctx.Done() from ticker")
+					return
+				}
+			}
+		}()
+	} else {
+		extension.logger.Warn("solarwindsapmsettingsextension is in noop. Please check config")
+	}
 	return nil
 }
 
 func (extension *solarwindsapmSettingsExtension) Shutdown(_ context.Context) error {
 	extension.logger.Debug("Shutting down solarwinds apm settings extension")
+	if extension.conn != nil {
+		return extension.conn.Close()
+	}
 	return nil
 }
+
+func validateSolarwindsApmSettingsExtensionConfiguration(_ *Config, _ *zap.Logger) bool {
+	// Concrete implementation will be available in later PR
+	return true
+}
+
+func refresh(extension *solarwindsapmSettingsExtension) {
+	// Concrete implementation will be available in later PR
+	extension.logger.Info("refresh task")
+}
+
+// Start ticking immediately.
+// Ref: https://stackoverflow.com/questions/32705582/how-to-get-time-tick-to-tick-immediately
+func newTicker(repeat time.Duration) *time.Ticker {
+	ticker := time.NewTicker(repeat)
+	oc := ticker.C
+	nc := make(chan time.Time, 1)
+	go func() {
+		nc <- time.Now()
+		for tm := range oc {
+			nc <- tm
+		}
+	}()
+	ticker.C = nc
+	return ticker
+}

extension/solarwindsapmsettingsextension/extension_test.go

@@ -6,40 +6,41 @@ package solarwindsapmsettingsextension
 import (
 	"context"
 	"testing"
+	"time"
 
 	"github.com/stretchr/testify/require"
 	"go.opentelemetry.io/collector/extension"
 	"go.uber.org/zap"
 )
 
 func TestCreateExtension(t *testing.T) {
-	conf := &Config{
-		Endpoint: "apm-testcollector.click:443",
-		Key:      "valid:unittest",
-		Interval: "1s",
-	}
-	ex := createAnExtension(conf, t)
-	require.NoError(t, ex.Shutdown(context.TODO()))
-}
+	t.Parallel()
 
-func TestCreateExtensionWrongEndpoint(t *testing.T) {
-	conf := &Config{
-		Endpoint: "apm-testcollector.nothing:443",
-		Key:      "valid:unittest",
-		Interval: "1s",
+	tests := []struct {
+		name string
+		cfg  *Config
+	}{
+		{
+			name: "default",
+			cfg: &Config{
+				Interval: time.Duration(10) * time.Second,
+			},
+		},
+		{
+			name: "anything",
+			cfg: &Config{
+				Endpoint: "0.0.0.0:1234",
+				Key:      "something",
+				Interval: time.Duration(10) * time.Second,
+			},
+		},
 	}
-	ex := createAnExtension(conf, t)
-	require.NoError(t, ex.Shutdown(context.TODO()))
-}
-
-func TestCreateExtensionWrongKey(t *testing.T) {
-	conf := &Config{
-		Endpoint: "apm-testcollector.click:443",
-		Key:      "invalid",
-		Interval: "1s",
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			ex := createAnExtension(tt.cfg, t)
+			require.NoError(t, ex.Shutdown(context.TODO()))
+		})
 	}
-	ex := createAnExtension(conf, t)
-	require.NoError(t, ex.Shutdown(context.TODO()))
 }
 
 // create extension

extension/solarwindsapmsettingsextension/factory.go

@@ -5,6 +5,7 @@ package solarwindsapmsettingsextension // import "github.com/open-telemetry/open
 
 import (
 	"context"
+	"time"
 
 	"go.opentelemetry.io/collector/component"
 	"go.opentelemetry.io/collector/extension"
@@ -13,7 +14,7 @@ import (
 )
 
 const (
-	DefaultInterval = "1m"
+	DefaultInterval = time.Duration(10) * time.Second
 )
 
 func createDefaultConfig() component.Config {