diff --git a/pkg/controllers/cluster/service.go b/pkg/controllers/cluster/service.go index d1af9f5ba3b..7c52f90b474 100644 --- 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