add tests

Author: krisztianfekete

receiver/k8sobjectsreceiver/config_test.go

@@ -132,6 +132,7 @@ func TestValidate(t *testing.T) {
 		{
 			desc: "invalid mode",
 			cfg: &Config{
+				ErrorMode: PropagateError,
 				Objects: []*K8sObjectsConfig{
 					{
 						Name: "pods",
@@ -144,6 +145,7 @@ func TestValidate(t *testing.T) {
 		{
 			desc: "exclude watch type with pull mode",
 			cfg: &Config{
+				ErrorMode: PropagateError,
 				Objects: []*K8sObjectsConfig{
 					{
 						Name: "pods",
@@ -159,6 +161,7 @@ func TestValidate(t *testing.T) {
 		{
 			desc: "default mode is set",
 			cfg: &Config{
+				ErrorMode: PropagateError,
 				Objects: []*K8sObjectsConfig{
 					{
 						Name: "pods",
@@ -169,6 +172,7 @@ func TestValidate(t *testing.T) {
 		{
 			desc: "default interval for pull mode",
 			cfg: &Config{
+				ErrorMode: PropagateError,
 				Objects: []*K8sObjectsConfig{
 					{
 						Name: "pods",

receiver/k8sobjectsreceiver/factory_test.go

@@ -27,6 +27,7 @@ func TestDefaultConfig(t *testing.T) {
 		APIConfig: k8sconfig.APIConfig{
 			AuthType: k8sconfig.AuthTypeServiceAccount,
 		},
+		ErrorMode: PropagateError,
 	}, rCfg)
 }
 

receiver/k8sobjectsreceiver/receiver_test.go

@@ -18,13 +18,82 @@ import (
 	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/k8sobjectsreceiver/internal/metadata"
 )
 
+func TestErrorModes(t *testing.T) {
+	t.Parallel()
+
+	tests := []struct {
+		desc        string
+		errorMode   ErrorMode
+		expectError bool
+	}{
+		{
+			desc:        "propagate error mode returns error",
+			errorMode:   PropagateError,
+			expectError: true,
+		},
+		{
+			desc:        "ignore error mode logs and continues",
+			errorMode:   IgnoreError,
+			expectError: false,
+		},
+		{
+			desc:        "silent error mode continues without logging",
+			errorMode:   SilentError,
+			expectError: false,
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.desc, func(t *testing.T) {
+			mockClient := newMockDynamicClient()
+			rCfg := createDefaultConfig().(*Config)
+			rCfg.makeDynamicClient = mockClient.getMockDynamicClient
+			rCfg.makeDiscoveryClient = getMockDiscoveryClient
+			rCfg.ErrorMode = tt.errorMode
+			rCfg.Objects = []*K8sObjectsConfig{
+				{
+					Name: "nonexistent-resource",
+					Mode: PullMode,
+				},
+			}
+
+			r, err := newReceiver(
+				receivertest.NewNopSettings(metadata.Type),
+				rCfg,
+				consumertest.NewNop(),
+			)
+			require.NoError(t, err)
+			require.NotNil(t, r)
+			err = r.Start(context.Background(), componenttest.NewNopHost())
+			if tt.expectError {
+				assert.Error(t, err)
+			} else {
+				assert.NoError(t, err)
+			}
+		})
+	}
+}
+
 func TestNewReceiver(t *testing.T) {
 	t.Parallel()
 
 	mockClient := newMockDynamicClient()
+	mockClient.createPods(
+		generatePod("pod1", "default", map[string]any{
+			"environment": "production",
+		}, "1"),
+	)
+
 	rCfg := createDefaultConfig().(*Config)
 	rCfg.makeDynamicClient = mockClient.getMockDynamicClient
 	rCfg.makeDiscoveryClient = getMockDiscoveryClient
+	rCfg.ErrorMode = PropagateError
+	rCfg.Objects = []*K8sObjectsConfig{
+		{
+			Name: "pods",
+			Mode: PullMode,
+		},
+	}
 
 	r, err := newReceiver(
 		receivertest.NewNopSettings(metadata.Type),
@@ -57,6 +126,7 @@ func TestPullObject(t *testing.T) {
 	rCfg := createDefaultConfig().(*Config)
 	rCfg.makeDynamicClient = mockClient.getMockDynamicClient
 	rCfg.makeDiscoveryClient = getMockDiscoveryClient
+	rCfg.ErrorMode = PropagateError
 
 	rCfg.Objects = []*K8sObjectsConfig{
 		{