swap all interface{} to any

Author: oo-sleeper

config/component.go

@@ -15,15 +15,15 @@ package config
 type ComponentConfigurable interface {
 	// ProvideDefault returns a pointer to a structure that will be
 	// written with the decoded configuration.
-	ProvideDefault() (interface{}, error)
+	ProvideDefault() (any, error)
 }
 
 // ComponentCreator is the interface that wraps the Create method.
 type ComponentCreator interface {
 	// Create returns a pointer to an output structure given a pointer
 	// to an input structure. This interface is expected to be implemented
 	// by components that are creatable through a configuration.
-	Create(i interface{}) (interface{}, error)
+	Create(i any) (any, error)
 }
 
 // Pluggable is the interface that groups
@@ -35,17 +35,17 @@ type Pluggable interface {
 
 // decodingHandler is the type of any function that, given a ComponentConfigurable
 // and a Decoder, returns a pointer to a structure that was decoded.
-type decodingHandler func(c ComponentConfigurable, d Decoder) (interface{}, error)
+type decodingHandler func(c ComponentConfigurable, d Decoder) (any, error)
 
 // withDecoderOptions returns a decodingHandler closed over some DecoderOptions.
 func withDecoderOptions(opts *DecoderOptions) decodingHandler {
-	return func(c ComponentConfigurable, d Decoder) (interface{}, error) {
+	return func(c ComponentConfigurable, d Decoder) (any, error) {
 		return configure(c, d, opts)
 	}
 }
 
 // Configure returns the decoded target.
-func configure(c ComponentConfigurable, d Decoder, opts *DecoderOptions) (interface{}, error) {
+func configure(c ComponentConfigurable, d Decoder, opts *DecoderOptions) (any, error) {
 	target, err := c.ProvideDefault() // target is ptr
 	if err != nil {
 		return nil, err

config/component_test.go

@@ -30,7 +30,7 @@ func TestCreateTargetComponentHCL(t *testing.T) {
 	testCases := []struct {
 		File     string
 		Plug     Pluggable
-		Expected interface{}
+		Expected any
 	}{
 		{
 			File: "targets/sqs-minimal-example.hcl",
@@ -263,7 +263,7 @@ func TestCreateObserverComponentHCL(t *testing.T) {
 	testCases := []struct {
 		File     string
 		Plug     Pluggable
-		Expected interface{}
+		Expected any
 	}{
 		{
 			File: "observer.hcl",
@@ -313,7 +313,7 @@ func TestCreateObserverComponentHCL(t *testing.T) {
 // Test Helpers
 // SQS
 func testSQSTargetAdapter(f func(c *target.SQSTargetConfig) (*target.SQSTargetConfig, error)) target.SQSTargetAdapter {
-	return func(i interface{}) (interface{}, error) {
+	return func(i any) (any, error) {
 		cfg, ok := i.(*target.SQSTargetConfig)
 		if !ok {
 			return nil, errors.New("invalid input, expected SQSTargetConfig")
@@ -331,7 +331,7 @@ func testSQSTargetFunc(c *target.SQSTargetConfig) (*target.SQSTargetConfig, erro
 
 // EventHub
 func testEventHubTargetAdapter(f func(c *target.EventHubConfig) (*target.EventHubConfig, error)) target.EventHubTargetAdapter {
-	return func(i interface{}) (interface{}, error) {
+	return func(i any) (any, error) {
 		cfg, ok := i.(*target.EventHubConfig)
 		if !ok {
 			return nil, errors.New("invalid input, expected EventHubTargetConfig")
@@ -349,7 +349,7 @@ func testEventHubTargetFunc(c *target.EventHubConfig) (*target.EventHubConfig, e
 
 // HTTP
 func testHTTPTargetAdapter(f func(c *target.HTTPTargetConfig) (*target.HTTPTargetConfig, error)) target.HTTPTargetAdapter {
-	return func(i interface{}) (interface{}, error) {
+	return func(i any) (any, error) {
 		cfg, ok := i.(*target.HTTPTargetConfig)
 		if !ok {
 			return nil, errors.New("invalid input, expected HTTPTargetConfig")
@@ -367,7 +367,7 @@ func testHTTPTargetFunc(c *target.HTTPTargetConfig) (*target.HTTPTargetConfig, e
 
 // Kafka
 func testKafkaTargetAdapter(f func(c *target.KafkaConfig) (*target.KafkaConfig, error)) target.KafkaTargetAdapter {
-	return func(i interface{}) (interface{}, error) {
+	return func(i any) (any, error) {
 		cfg, ok := i.(*target.KafkaConfig)
 		if !ok {
 			return nil, errors.New("invalid input, expected KafkaTargetConfig")
@@ -385,7 +385,7 @@ func testKafkaTargetFunc(c *target.KafkaConfig) (*target.KafkaConfig, error) {
 
 // Kinesis
 func testKinesisTargetAdapter(f func(c *target.KinesisTargetConfig) (*target.KinesisTargetConfig, error)) target.KinesisTargetAdapter {
-	return func(i interface{}) (interface{}, error) {
+	return func(i any) (any, error) {
 		cfg, ok := i.(*target.KinesisTargetConfig)
 		if !ok {
 			return nil, errors.New("invalid input, expected KinesisTargetConfig")
@@ -403,7 +403,7 @@ func testKinesisTargetFunc(c *target.KinesisTargetConfig) (*target.KinesisTarget
 
 // PubSub
 func testPubSubTargetAdapter(f func(c *target.PubSubTargetConfig) (*target.PubSubTargetConfig, error)) target.PubSubTargetAdapter {
-	return func(i interface{}) (interface{}, error) {
+	return func(i any) (any, error) {
 		cfg, ok := i.(*target.PubSubTargetConfig)
 		if !ok {
 			return nil, errors.New("invalid input, expected PubSubTargetConfig")
@@ -421,7 +421,7 @@ func testPubSubTargetFunc(c *target.PubSubTargetConfig) (*target.PubSubTargetCon
 
 // StatsD
 func testStatsDAdapter(f func(c *statsreceiver.StatsDStatsReceiverConfig) (*statsreceiver.StatsDStatsReceiverConfig, error)) statsreceiver.StatsDStatsReceiverAdapter {
-	return func(i interface{}) (interface{}, error) {
+	return func(i any) (any, error) {
 		cfg, ok := i.(*statsreceiver.StatsDStatsReceiverConfig)
 		if !ok {
 			return nil, errors.New("invalid input, expected StatsDStatsReceiverConfig")

config/config.go

@@ -235,7 +235,7 @@ func NewHclConfig(fileContents []byte, filename string) (*Config, error) {
 }
 
 // CreateComponent creates a pluggable component given the Decoder options.
-func (c *Config) CreateComponent(p Pluggable, opts *DecoderOptions) (interface{}, error) {
+func (c *Config) CreateComponent(p Pluggable, opts *DecoderOptions) (any, error) {
 	componentConfigure := withDecoderOptions(opts)
 
 	decodedConfig, err := componentConfigure(p, c.Decoder)

config/decode.go

@@ -25,7 +25,7 @@ import (
 type Decoder interface {
 	// Decode decodes onto target given DecoderOptions.
 	// The target argument must be a pointer to an allocated structure.
-	Decode(opts *DecoderOptions, target interface{}) error
+	Decode(opts *DecoderOptions, target any) error
 }
 
 // DecoderOptions represent the options for a Decoder.
@@ -45,7 +45,7 @@ type hclDecoder struct {
 // The target argument must be a pointer to an allocated structure.
 // If the HCL input is nil, we assume there is nothing to do and the target
 // stays unaffected. If the target is nil, we assume is not decodable.
-func (h *hclDecoder) Decode(opts *DecoderOptions, target interface{}) error {
+func (h *hclDecoder) Decode(opts *DecoderOptions, target any) error {
 	// Decoder Options cannot be missing
 	if opts == nil {
 		return errors.New("missing DecoderOptions for hclDecoder")
@@ -155,6 +155,6 @@ type defaultsDecoder struct{}
 // Decode for defaultsDecoder leaves the target unaffected.
 // The target argument must be a pointer to an allocated structure.
 // If the target is nil, we assume is not decodable.
-func (d *defaultsDecoder) Decode(opts *DecoderOptions, target interface{}) error {
+func (d *defaultsDecoder) Decode(opts *DecoderOptions, target any) error {
 	return nil
 }

config/decode_test.go

@@ -41,8 +41,8 @@ test_string = "ateststring"
 	testCases := []struct {
 		TestName    string
 		DecoderOpts *DecoderOptions
-		Target      interface{}
-		Expected    interface{}
+		Target      any
+		Expected    any
 	}{
 		{
 			"nil_target",
@@ -114,8 +114,8 @@ test_int = env("TEST_INT")
 	testCases := []struct {
 		TestName    string
 		DecoderOpts *DecoderOptions
-		Target      interface{}
-		Expected    interface{}
+		Target      any
+		Expected    any
 	}{
 		{
 			"Hcl_eval_context_with_env_fun_and_var",

docs/common_test.go

@@ -33,7 +33,7 @@ func TestMain(m *testing.M) {
 
 var jsScriptPath = filepath.Join(assets.AssetsRootDir, "docs", "configuration", "transformations", "custom-scripts", "create-a-script-filter-example.js")
 
-func checkComponentForZeros(t *testing.T, component interface{}) {
+func checkComponentForZeros(t *testing.T, component any) {
 	assert := assert.New(t)
 
 	// Indirect dereferences the pointer for us

docs/configuration_source_docs_test.go

@@ -55,7 +55,7 @@ func testSourceConfig(t *testing.T, filepath string, fullExample bool) {
 
 	use := c.Data.Source.Use
 
-	var configObject interface{}
+	var configObject any
 	switch use.Name {
 	case "kafka":
 		configObject = &kafkasource.Configuration{}

docs/configuration_target_docs_test.go

@@ -74,7 +74,7 @@ func testFilterTargetConfig(t *testing.T, filepath string, fullExample bool) {
 
 func testTargetComponent(t *testing.T, name string, body hcl.Body, fullExample bool) {
 	assert := assert.New(t)
-	var configObject interface{}
+	var configObject any
 	switch name {
 	case "eventhub":
 		configObject = &target.EventHubConfig{}

docs/configuration_transformations_docs_test.go

@@ -141,7 +141,7 @@ func testTransformationConfig(t *testing.T, filepath string, fullExample bool) {
 		use := transformation.Use
 
 		// Pick the config to compare against
-		var configObject interface{}
+		var configObject any
 		switch use.Name {
 		case "spEnrichedFilter":
 			configObject = &filter.AtomicFilterConfig{}

pkg/source/inmemory/in_memory_source.go

@@ -44,20 +44,20 @@ func configfunction(messages chan []string) func(c *configuration) (sourceiface.
 	}
 }
 
-type adapter func(i interface{}) (interface{}, error)
+type adapter func(i any) (any, error)
 
-func (f adapter) Create(i interface{}) (interface{}, error) {
+func (f adapter) Create(i any) (any, error) {
 	return f(i)
 }
 
-func (f adapter) ProvideDefault() (interface{}, error) {
+func (f adapter) ProvideDefault() (any, error) {
 	cfg := &configuration{}
 
 	return cfg, nil
 }
 
 func adapterGenerator(f func(c *configuration) (sourceiface.Source, error)) adapter {
-	return func(i interface{}) (interface{}, error) {
+	return func(i any) (any, error) {
 		cfg, ok := i.(*configuration)
 		if !ok {
 			return nil, errors.New("invalid input")