Refactor events

Signed-off-by: Aniruddha Basak <[email protected]>
syself · Oct 17, 2023 · 291176e · 291176e
1 parent cb8f745
commit 291176e
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/pkg/services/baremetal/remediation/remediation.go b/pkg/services/baremetal/remediation/remediation.go
@@ -158,8 +158,10 @@ func (s *Service) remediate(ctx context.Context, host infrav1.HetznerBareMetalHo
 	// add annotation to host so that it reboots
 	host.Annotations, err = addRebootAnnotation(host.Annotations)
 	if err != nil {
+		record.Warn(s.scope.BareMetalRemediation, "FailedAddingRebootAnnotation", err.Error())
 		return fmt.Errorf("failed to add reboot annotation: %w", err)
 	}
+	record.Event(s.scope.BareMetalRemediation, "AnnotationAdded", "Reboot annotation is added to the BareMetalHost")
 
 	if err := patchHelper.Patch(ctx, &host); err != nil {
 		return fmt.Errorf("failed to patch: %s %s/%s %w", host.Kind, host.Namespace, host.Name, err)

diff --git a/pkg/services/hcloud/remediation/remediation.go b/pkg/services/hcloud/remediation/remediation.go
@@ -93,8 +93,10 @@ func (s *Service) handlePhaseRunning(ctx context.Context, server *hcloud.Server)
 	if s.scope.HCloudRemediation.Status.LastRemediated == nil {
 		if err := s.scope.HCloudClient.RebootServer(ctx, server); err != nil {
 			hcloudutil.HandleRateLimitExceeded(s.scope.HCloudMachine, err, "RebootServer")
+			record.Warn(s.scope.HCloudRemediation, "FailedRebootServer", err.Error())
 			return res, fmt.Errorf("failed to reboot server %v: %w", server.ID, err)
 		}
+		record.Event(s.scope.HCloudRemediation, "ServerRebooted", "Server has been rebooted")
 
 		s.scope.HCloudRemediation.Status.LastRemediated = &now
 		s.scope.HCloudRemediation.Status.RetryCount++
@@ -119,8 +121,10 @@ func (s *Service) handlePhaseRunning(ctx context.Context, server *hcloud.Server)
 	// remediate now
 	if err := s.scope.HCloudClient.RebootServer(ctx, server); err != nil {
 		hcloudutil.HandleRateLimitExceeded(s.scope.HCloudMachine, err, "RebootServer")
+		record.Warn(s.scope.HCloudRemediation, "FailedRebootServer", err.Error())
 		return res, fmt.Errorf("failed to reboot server %v: %w", server.ID, err)
 	}
+	record.Event(s.scope.HCloudRemediation, "ServerRebooted", "Server has been rebooted")
 
 	s.scope.HCloudRemediation.Status.LastRemediated = &now
 	s.scope.HCloudRemediation.Status.RetryCount++