coreos/prometheus-operator
1
0
Fork 0
mirror of https://github.com/coreos/prometheus-operator.git synced 2026-02-05 06:45:27 +01:00
Code Issues Releases Wiki Activity

Cleanup of bindings for PrometheusRules in prometheus (#8024)

Browse Source
This commit is contained in:
Y@&h
2025-10-17 20:55:49 +05:30
committed by GitHub
parent 422103f159
commit 0ecdf47862
4 changed files with 140 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
test/framework/prometheus_rule.go
View File

@@ -179,3 +179,25 @@ func (f *Framework) WaitForRuleCondition(ctx context.Context, pr *monitoringv1.P
}
return current, nil
}
func (f *Framework) WaitForRuleWorkloadBindingCleanup(ctx context.Context, pm *monitoringv1.PrometheusRule, workload metav1.Object, resource string, timeout time.Duration) (*monitoringv1.PrometheusRule, error) {
var current *monitoringv1.PrometheusRule
if err := f.WaitForConfigResWorkloadBindingCleanup(
ctx,
func(ctx context.Context) ([]monitoringv1.WorkloadBinding, error) {
var err error
current, err = f.MonClientV1.PrometheusRules(pm.Namespace).Get(ctx, pm.Name, metav1.GetOptions{})
if err != nil {
return nil, err
}
return current.Status.Bindings, nil
},
workload,
resource,
timeout,
); err != nil {
return nil, fmt.Errorf("podMonitor status %v/%v failed to reach expected condition: %w", pm.Namespace, pm.Name, err)
}
return current, nil
}