Increase failure threshold for agent monitoring inputs from 2 to 5 (#6160) (#6165)

(cherry picked from commit 7190978)

Co-authored-by: Paolo Chilà <paolo.chila@elastic.co>

Author: mergify[bot]

internal/pkg/agent/application/monitoring/v1_monitor.go

@@ -64,8 +64,8 @@ const (
 	defaultMetricsCollectionInterval = 60 * time.Second
 
 	// metricset stream failure threshold before the stream is marked as DEGRADED
-	// to avoid marking the agent degraded for transient errors, we set the default threshold to 2
-	defaultMetricsStreamFailureThreshold = uint(2)
+	// to avoid marking the agent degraded for transient errors, we set the default threshold to 5
+	defaultMetricsStreamFailureThreshold = uint(5)
 )
 
 var (

internal/pkg/agent/application/monitoring/v1_monitor_test.go

@@ -263,7 +263,7 @@ func TestMonitoringConfigMetricsFailureThreshold(t *testing.T) {
 	agentInfo, err := info.NewAgentInfo(context.Background(), false)
 	require.NoError(t, err, "Error creating agent info")
 
-	sampleFiveErrorsStreamThreshold := uint(5)
+	sampleSevenErrorsStreamThreshold := uint(7)
 	sampleTenErrorsStreamThreshold := uint(10)
 
 	tcs := []struct {
@@ -307,7 +307,7 @@ func TestMonitoringConfigMetricsFailureThreshold(t *testing.T) {
 					HTTP: &monitoringcfg.MonitoringHTTPConfig{
 						Enabled: false,
 					},
-					FailureThreshold: &sampleFiveErrorsStreamThreshold,
+					FailureThreshold: &sampleSevenErrorsStreamThreshold,
 				},
 			},
 			policy: map[string]any{
@@ -323,7 +323,7 @@ func TestMonitoringConfigMetricsFailureThreshold(t *testing.T) {
 					"default": map[string]any{},
 				},
 			},
-			expectedThreshold: sampleFiveErrorsStreamThreshold,
+			expectedThreshold: sampleSevenErrorsStreamThreshold,
 		},
 		{
 			name: "policy failure threshold uint",
@@ -334,7 +334,7 @@ func TestMonitoringConfigMetricsFailureThreshold(t *testing.T) {
 					HTTP: &monitoringcfg.MonitoringHTTPConfig{
 						Enabled: false,
 					},
-					FailureThreshold: &sampleFiveErrorsStreamThreshold,
+					FailureThreshold: &sampleSevenErrorsStreamThreshold,
 				},
 			},
 			policy: map[string]any{
@@ -362,7 +362,7 @@ func TestMonitoringConfigMetricsFailureThreshold(t *testing.T) {
 					HTTP: &monitoringcfg.MonitoringHTTPConfig{
 						Enabled: false,
 					},
-					FailureThreshold: &sampleFiveErrorsStreamThreshold,
+					FailureThreshold: &sampleSevenErrorsStreamThreshold,
 				},
 			},
 			policy: map[string]any{
@@ -390,7 +390,7 @@ func TestMonitoringConfigMetricsFailureThreshold(t *testing.T) {
 					HTTP: &monitoringcfg.MonitoringHTTPConfig{
 						Enabled: false,
 					},
-					FailureThreshold: &sampleFiveErrorsStreamThreshold,
+					FailureThreshold: &sampleSevenErrorsStreamThreshold,
 				},
 			},
 			policy: map[string]any{