chore: rename function

VihasMakwana · Jul 18, 2024 · 908553d · 908553d
1 parent 51a7854
commit 908553d
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 6 deletions.
diff --git a/metricbeat/module/system/process/process.go b/metricbeat/module/system/process/process.go
@@ -111,7 +111,7 @@ func (m *MetricSet) Fetch(r mb.ReporterV2) error {
 	// monitor either a single PID, or the configured set of processes.
 	if m.setpid == 0 {
 		procs, roots, err := m.stats.Get()
-		if err != nil && !process.IsDegradable(err) {
+		if err != nil && !process.CanDegrade(err) {
 			return fmt.Errorf("process stats: %w", err)
 		}
 

diff --git a/metricbeat/module/system/process/process_test.go b/metricbeat/module/system/process/process_test.go
@@ -38,15 +38,15 @@ func TestFetch(t *testing.T) {
 	f := mbtest.NewReportingMetricSetV2Error(t, getConfig())
 	events, errs := mbtest.ReportingFetchV2Error(f)
 	for _, err := range errs {
-		assert.True(t, process.IsDegradable(err))
+		assert.True(t, process.CanDegrade(err))
 	}
 	assert.NotEmpty(t, events)
 
 	time.Sleep(2 * time.Second)
 
 	events, errs = mbtest.ReportingFetchV2Error(f)
 	for _, err := range errs {
-		assert.True(t, process.IsDegradable(err))
+		assert.True(t, process.CanDegrade(err))
 	}
 	assert.NotEmpty(t, events)
 

diff --git a/metricbeat/module/system/process_summary/process_summary.go b/metricbeat/module/system/process_summary/process_summary.go
@@ -69,7 +69,7 @@ func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
 func (m *MetricSet) Fetch(r mb.ReporterV2) error {
 
 	procList, degradeErr := process.ListStates(m.sys)
-	if degradeErr != nil && !process.IsDegradable(degradeErr) {
+	if degradeErr != nil && !process.CanDegrade(degradeErr) {
 		return fmt.Errorf("error fetching process list: %w", degradeErr)
 	}
 

diff --git a/metricbeat/module/system/process_summary/process_summary_test.go b/metricbeat/module/system/process_summary/process_summary_test.go
@@ -47,7 +47,7 @@ func TestFetch(t *testing.T) {
 	events, errs := mbtest.ReportingFetchV2Error(f)
 
 	for _, err := range errs {
-		assert.True(t, process.IsDegradable(err))
+		assert.True(t, process.CanDegrade(err))
 	}
 	require.NotEmpty(t, events)
 	event := events[0].BeatEvent("system", "process_summary").Fields
@@ -65,7 +65,7 @@ func TestStateNames(t *testing.T) {
 	events, errs := mbtest.ReportingFetchV2Error(f)
 
 	for _, err := range errs {
-		assert.True(t, process.IsDegradable(err))
+		assert.True(t, process.CanDegrade(err))
 	}
 	require.NotEmpty(t, events)
 	event := events[0].BeatEvent("system", "process_summary").Fields