fix: validate topology processor interval (#2076)

* validate interval * fix test
observIQ · Dec 19, 2024 · 669da71 · 669da71
1 parent 0c80959
commit 669da71
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 0 deletions.
diff --git a/processor/topologyprocessor/config.go b/processor/topologyprocessor/config.go
@@ -52,6 +52,10 @@ func (cfg Config) Validate() error {
 		return nil
 	}
 
+	if cfg.Interval < 10*time.Second {
+		return errors.New("`interval` must be at least 10 seconds")
+	}
+
 	if cfg.Configuration == "" {
 		return errors.New("`configuration` must be specified")
 	}

diff --git a/processor/topologyprocessor/config_test.go b/processor/topologyprocessor/config_test.go
@@ -16,6 +16,7 @@ package topologyprocessor
 
 import (
 	"testing"
+	"time"
 
 	"github.com/stretchr/testify/require"
 )
@@ -26,6 +27,18 @@ func TestConfigValidate(t *testing.T) {
 		require.NoError(t, err)
 	})
 
+	t.Run("interval too low", func(t *testing.T) {
+		cfg := Config{
+			Enabled:        true,
+			Interval:       8 * time.Second,
+			AccountID:      "myacct",
+			Configuration:  "myConfig",
+			OrganizationID: "myorg",
+		}
+		err := cfg.Validate()
+		require.Error(t, err)
+	})
+
 	t.Run("Empty configuration", func(t *testing.T) {
 		cfg := Config{
 			Enabled:        true,