Add back check and add time.Time as type

Author: irisgve

confmap/provider.go

@@ -6,6 +6,7 @@ package confmap // import "go.opentelemetry.io/collector/confmap"
 import (
 	"context"
 	"fmt"
+	"time"
 
 	"go.uber.org/zap"
 	"gopkg.in/yaml.v3"
@@ -165,6 +166,9 @@ func NewRetrievedFromYAML(yamlBytes []byte, opts ...RetrievedOption) (*Retrieved
 //   - []any;
 //   - map[string]any;
 func NewRetrieved(rawConf any, opts ...RetrievedOption) (*Retrieved, error) {
+	if err := checkRawConfType(rawConf); err != nil {
+		return nil, err
+	}
 	set := retrievedSettings{}
 	for _, opt := range opts {
 		opt.apply(&set)
@@ -226,3 +230,17 @@ func (r *Retrieved) Close(ctx context.Context) error {
 
 // CloseFunc a function equivalent to Retrieved.Close.
 type CloseFunc func(context.Context) error
+
+func checkRawConfType(rawConf any) error {
+	if rawConf == nil {
+		return nil
+	}
+	switch rawConf.(type) {
+	case int, int32, int64, float32, float64, bool, string, []any, map[string]any, time.Time:
+		return nil
+	default:
+		return fmt.Errorf(
+			"unsupported type=%T for retrieved config,"+
+				" ensure that values are wrapped in quotes", rawConf)
+	}
+}

confmap/provider_test.go

@@ -32,6 +32,11 @@ func TestNewRetrievedWithOptions(t *testing.T) {
 	assert.Equal(t, want, ret.Close(context.Background()))
 }
 
+func TestNewRetrievedUnsupportedType(t *testing.T) {
+	_, err := NewRetrieved(errors.New("my error"))
+	require.Error(t, err)
+}
+
 func TestNewRetrievedFromYAML(t *testing.T) {
 	ret, err := NewRetrievedFromYAML([]byte{})
 	require.NoError(t, err)