chore: add addServer and deleteServer Event recording in OBZone

oceanbase · Nov 9, 2023 · 8e55a12 · 8e55a12
1 parent e523d2b
commit 8e55a12
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/resource/obzone_task.go b/pkg/resource/obzone_task.go
@@ -138,6 +138,7 @@ func (m *OBZoneManager) CreateOBServer() error {
 			m.Logger.Error(err, "create observer failed", "server", serverName)
 			return errors.Wrap(err, "create observer")
 		}
+		m.Recorder.Event(m.OBZone, "CreateObServer", "CreateObserver", fmt.Sprintf("Create observer %s", serverName))
 	}
 	return nil
 }
@@ -157,6 +158,7 @@ func (m *OBZoneManager) DeleteOBServer() error {
 			if err != nil {
 				return errors.Wrapf(err, "Delete observer %s failed", observer.Name)
 			}
+			m.Recorder.Event(m.OBZone, "DeleteObServer", "DeleteObserver", fmt.Sprintf("Delete observer %+v", observer))
 			continue
 		}
 		observerCount++