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

Use new CreateStatefulSetOrPatchLabels() function in controllers

Browse Source 
Signed-off-by: Simon Pasquier <spasquie@redhat.com>
This commit is contained in:
Simon Pasquier
2026-01-30 15:30:11 +01:00
parent 5e26cd163d
commit 94e8bdedad
4 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/alertmanager/operator.go
View File

@@ -679,7 +679,7 @@ func (c *Operator) sync(ctx context.Context, key string) error {
if shouldCreate {
logger.Debug("no current statefulset found")
logger.Debug("creating statefulset")
if _, err := ssetClient.Create(ctx, sset, metav1.CreateOptions{}); err != nil {
if _, err := k8sutil.CreateStatefulSetOrPatchLabels(ctx, ssetClient, sset); err != nil {
return fmt.Errorf("creating statefulset failed: %w", err)
}
return nil

2
pkg/prometheus/agent/operator.go
View File

@@ -838,7 +838,7 @@ func (c *Operator) syncStatefulSet(ctx context.Context, key string, p *monitorin
if notFound {
logger.Debug("creating statefulset")
if _, err := ssetClient.Create(ctx, sset, metav1.CreateOptions{}); err != nil {
if _, err := k8sutil.CreateStatefulSetOrPatchLabels(ctx, ssetClient, sset); err != nil {
return fmt.Errorf("creating statefulset failed: %w", err)
}
continue

2
pkg/prometheus/server/operator.go
View File

@@ -993,7 +993,7 @@ func (c *Operator) sync(ctx context.Context, key string) error {
if notFound {
logger.Debug("creating statefulset")
if _, err := ssetClient.Create(ctx, sset, metav1.CreateOptions{}); err != nil {
if _, err := k8sutil.CreateStatefulSetOrPatchLabels(ctx, ssetClient, sset); err != nil {
return fmt.Errorf("creating statefulset failed: %w", err)
}
continue

2
pkg/thanos/operator.go
View File

@@ -589,7 +589,7 @@ func (o *Operator) sync(ctx context.Context, key string) error {
ssetClient := o.kclient.AppsV1().StatefulSets(tr.Namespace)
if shouldCreate {
logger.Debug("creating statefulset")
if _, err := ssetClient.Create(ctx, sset, metav1.CreateOptions{}); err != nil {
if _, err := k8sutil.CreateStatefulSetOrPatchLabels(ctx, ssetClient, sset); err != nil {
return fmt.Errorf("creating thanos statefulset failed: %w", err)
}