chore: upgrade to Go 1.26 and modernize codebase with latest idioms

- Bump go.mod to Go 1.26, update Dockerfile.dev and docs
- Replace interface{} with any across all non-generated Go files
- Use strings.CutPrefix instead of HasPrefix+TrimPrefix patterns
- Use slices.SortFunc+cmp.Compare instead of sort.Slice
- Use slices.Equal instead of reflect.DeepEqual in tests
- Simplify C-style index loops to range expressions

Author: ravisuhag

Dockerfile.dev

@@ -1,4 +1,4 @@
-FROM golang:1.16-stretch as base
+FROM golang:1.26-bookworm AS base
 WORKDIR /build/
 COPY . .
 RUN ["make", "build-dev"]

agent/agent_test.go

@@ -34,12 +34,12 @@ var validRecipe = recipe.Recipe{
 		Name: "test-extractor",
 	},
 	Processors: []recipe.PluginRecipe{
-		{Name: "test-processor", Config: map[string]interface{}{
+		{Name: "test-processor", Config: map[string]any{
 			"proc-foo": "proc-bar",
 		}},
 	},
 	Sinks: []recipe.PluginRecipe{
-		{Name: "test-sink", Config: map[string]interface{}{
+		{Name: "test-sink", Config: map[string]any{
 			"url": "http://localhost:3000/data",
 		}},
 	},
@@ -919,14 +919,14 @@ func TestAgentRun(t *testing.T) {
 			Source: recipe.PluginRecipe{
 				Name:  "application_yaml",
 				Scope: "application-test",
-				Config: map[string]interface{}{
+				Config: map[string]any{
 					"file": "../plugins/extractors/application_yaml/testdata/application.detailed.yaml",
 				},
 			},
 			Processors: []recipe.PluginRecipe{
 				{
 					Name: "script",
-					Config: map[string]interface{}{
+					Config: map[string]any{
 						"engine": "tengo",
 						"script": heredoc.Doc(`
 							text := import("text")
@@ -936,13 +936,13 @@ func TestAgentRun(t *testing.T) {
 				},
 				{
 					Name: "labels",
-					Config: map[string]interface{}{
+					Config: map[string]any{
 						"labels": map[string]string{"field_a": "1"},
 					},
 				},
 			},
 			Sinks: []recipe.PluginRecipe{
-				{Name: "test-sink", Config: map[string]interface{}{}},
+				{Name: "test-sink", Config: map[string]any{}},
 			},
 		})
 		assert.NoError(t, run.Error)
@@ -953,13 +953,13 @@ func TestAgentRun(t *testing.T) {
 			Type:        "application",
 			Description: "My amazing project",
 			Properties: func() *structpb.Struct {
-				s, _ := structpb.NewStruct(map[string]interface{}{
+				s, _ := structpb.NewStruct(map[string]any{
 					"id":          "test-id",
 					"version":     "c23sdf6",
 					"url":         "http://company.com/myteam/test",
 					"create_time": "2006-01-02T15:04:05Z",
 					"update_time": "2006-01-02T15:04:05Z",
-					"labels":      map[string]interface{}{"field_a": "1", "x": "y"},
+					"labels":      map[string]any{"field_a": "1", "x": "y"},
 				})
 				return s
 			}(),
@@ -982,13 +982,13 @@ func TestAgentRun(t *testing.T) {
 			Source: recipe.PluginRecipe{
 				Name:  "application_yaml",
 				Scope: "application-test",
-				Config: map[string]interface{}{
+				Config: map[string]any{
 					"file": "../plugins/extractors/application_yaml/testdata/application.detailed.yaml",
 				},
 			},
 			Sinks: []recipe.PluginRecipe{{
 				Name: "file",
-				Config: map[string]interface{}{
+				Config: map[string]any{
 					"path":      "./application_yaml-sink[yaml].out",
 					"format":    "yaml",
 					"overwrite": true,
@@ -1081,22 +1081,22 @@ func TestValidate(t *testing.T) {
 			Name: "sample",
 			Source: recipe.PluginRecipe{
 				Name: "test-extractor",
-				Config: map[string]interface{}{
+				Config: map[string]any{
 					"proc-foo": "proc-bar",
 				},
 			},
 			Processors: []recipe.PluginRecipe{
 				{
 					Name: "test-processor",
-					Config: map[string]interface{}{
+					Config: map[string]any{
 						"proc-foo": "proc-bar",
 					},
 				},
 			},
 			Sinks: []recipe.PluginRecipe{
 				{
 					Name: "test-sink",
-					Config: map[string]interface{}{
+					Config: map[string]any{
 						"url": "http://localhost:3000/data",
 					},
 				},

docs/docs/guides/0_installation.md

@@ -40,7 +40,7 @@ $ docker run --rm raystack/meteor meteor list extractors
 
 ## Build from source
 
-Requires you to have `git` and `golang (version 1.16 or above)` installed.
+Requires you to have `git` and `golang (version 1.26 or above)` installed.
 
 ```bash
 #clone repo

generator/recipe.go

@@ -26,7 +26,7 @@ type TemplateData struct {
 	Processors map[string]string
 }
 
-var TemplateFuncs = map[string]interface{}{
+var TemplateFuncs = map[string]any{
 	"indent": indent,
 	"rawfmt": rawfmt,
 }

go.mod

@@ -1,6 +1,6 @@
 module github.com/raystack/meteor
 
-go 1.25.0
+go 1.26.0
 
 require (
 	cloud.google.com/go/bigquery v1.74.0

metrics/otelgrpc/otelgrpc.go

@@ -105,7 +105,7 @@ func (m *Monitor) RecordStream(ctx context.Context, start time.Time, method stri
 func (m *Monitor) UnaryClientInterceptor() grpc.UnaryClientInterceptor {
 	return func(ctx context.Context,
 		method string,
-		req, reply interface{},
+		req, reply any,
 		cc *grpc.ClientConn,
 		invoker grpc.UnaryInvoker,
 		opts ...grpc.CallOption,

metrics/otelgrpc/otelgrpc_test.go

@@ -3,7 +3,7 @@ package otelgrpc_test
 import (
 	"context"
 	"errors"
-	"reflect"
+	"slices"
 	"testing"
 	"time"
 
@@ -74,7 +74,7 @@ func Test_parseFullMethod(t *testing.T) {
 	}
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
-			if got := otelgrpc.ParseFullMethod(tt.args.fullMethod); !reflect.DeepEqual(got, tt.want) {
+			if got := otelgrpc.ParseFullMethod(tt.args.fullMethod); !slices.Equal(got, tt.want) {
 				t.Errorf("parseFullMethod() = %v, want %v", got, tt.want)
 			}
 		})

models/util.go

@@ -20,7 +20,7 @@ func NewURN(service, scope, kind, id string) string {
 // NewEntity creates an entity with properties from a map.
 // Values in props are sanitized to be compatible with structpb.NewStruct:
 // map[string]string is converted to map[string]interface{}, etc.
-func NewEntity(urn, typ, name, source string, props map[string]interface{}) *meteorv1beta1.Entity {
+func NewEntity(urn, typ, name, source string, props map[string]any) *meteorv1beta1.Entity {
 	var properties *structpb.Struct
 	if len(props) > 0 {
 		sanitized := sanitizeMap(props)
@@ -82,7 +82,7 @@ func RecordToJSON(r Record) ([]byte, error) {
 		edgesJSON = append(edgesJSON, b)
 	}
 
-	result := map[string]interface{}{
+	result := map[string]any{
 		"entity": json.RawMessage(entityJSON),
 	}
 	if len(edgesJSON) > 0 {
@@ -94,38 +94,38 @@ func RecordToJSON(r Record) ([]byte, error) {
 
 // sanitizeMap recursively converts typed maps (e.g., map[string]string) to
 // map[string]interface{} so they are compatible with structpb.NewStruct.
-func sanitizeMap(m map[string]interface{}) map[string]interface{} {
-	out := make(map[string]interface{}, len(m))
+func sanitizeMap(m map[string]any) map[string]any {
+	out := make(map[string]any, len(m))
 	for k, v := range m {
 		out[k] = sanitizeValue(v)
 	}
 	return out
 }
 
-func sanitizeValue(v interface{}) interface{} {
+func sanitizeValue(v any) any {
 	switch val := v.(type) {
 	case map[string]string:
-		out := make(map[string]interface{}, len(val))
+		out := make(map[string]any, len(val))
 		for k, v := range val {
 			out[k] = v
 		}
 		return out
-	case map[string]interface{}:
+	case map[string]any:
 		return sanitizeMap(val)
-	case []interface{}:
-		out := make([]interface{}, len(val))
+	case []any:
+		out := make([]any, len(val))
 		for i, item := range val {
 			out[i] = sanitizeValue(item)
 		}
 		return out
-	case []map[string]interface{}:
-		out := make([]interface{}, len(val))
+	case []map[string]any:
+		out := make([]any, len(val))
 		for i, item := range val {
 			out[i] = sanitizeMap(item)
 		}
 		return out
 	case []string:
-		out := make([]interface{}, len(val))
+		out := make([]any, len(val))
 		for i, item := range val {
 			out[i] = item
 		}

models/util_test.go

@@ -37,8 +37,8 @@ func TestNewURN(t *testing.T) {
 }
 
 func TestNewEntity(t *testing.T) {
-	entity := models.NewEntity("urn:test:s:table:t1", "table", "t1", "test", map[string]interface{}{
-		"columns": []interface{}{"id", "name"},
+	entity := models.NewEntity("urn:test:s:table:t1", "table", "t1", "test", map[string]any{
+		"columns": []any{"id", "name"},
 	})
 	assert.Equal(t, "urn:test:s:table:t1", entity.GetUrn())
 	assert.Equal(t, "table", entity.GetType())

plugins/base_extractor.go

@@ -7,7 +7,7 @@ type BaseExtractor struct {
 	BasePlugin
 }
 
-func NewBaseExtractor(info Info, configRef interface{}) BaseExtractor {
+func NewBaseExtractor(info Info, configRef any) BaseExtractor {
 	return BaseExtractor{
 		BasePlugin: NewBasePlugin(info, configRef),
 	}