controller: log when member service is being created/updated

scylladb · Nov 20, 2020 · b9839f2 · b9839f2
1 parent 73665d0
commit b9839f2
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/pkg/controllers/cluster/service.go b/pkg/controllers/cluster/service.go
@@ -44,10 +44,16 @@ func (cc *ClusterReconciler) syncMemberServices(ctx context.Context, c *scyllav1
 		}
 		for _, pod := range podlist.Items {
 			memberService := resource.MemberServiceForPod(&pod, c)
-			_, err := controllerutil.CreateOrUpdate(ctx, cc.Client, memberService, serviceMutateFn(ctx, memberService, cc.Client))
+			op, err := controllerutil.CreateOrUpdate(ctx, cc.Client, memberService, serviceMutateFn(ctx, memberService, cc.Client))
 			if err != nil {
 				return errors.Wrapf(err, "error syncing member service %s", memberService.Name)
 			}
+			switch op {
+			case controllerutil.OperationResultCreated:
+				cc.Logger.Info(ctx, "Member service created", "member", memberService.Name, "labels", memberService.Labels)
+			case controllerutil.OperationResultUpdated:
+				cc.Logger.Info(ctx, "Member service updated", "member", memberService.Name, "labels", memberService.Labels)
+			}
 		}
 	}
 	return nil