karmada-io
/
karmada
mirror of https://github.com/karmada-io/karmada.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2770 from Poor12/add-policy-event 

Add reflectStatusToWork and InterpretHealth event
This commit is contained in:
karmada-bot 2022-11-11 13:03:56 +08:00 committed by GitHub
parent 5c88cba7d6 840de4fc84
commit 60d8bcbe72
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
pkg/apis/work/v1alpha1/events.go
View File

@ -7,4 +7,16 @@ const (
// EventReasonSyncWorkSucceed indicates that Sync work succeed. // EventReasonSyncWorkSucceed indicates that Sync work succeed.
EventReasonSyncWorkSucceed = "SyncSucceed" EventReasonSyncWorkSucceed = "SyncSucceed"
// EventReasonReflectStatusSucceed indicates that reflect status to work succeed.
EventReasonReflectStatusSucceed = "ReflectStatusSucceed"
// EventReasonReflectStatusFailed indicates that reflect status to work failed.
EventReasonReflectStatusFailed = "ReflectStatusFailed"
// EventReasonInterpretHealthSucceed indicates that interpret health succeed.
EventReasonInterpretHealthSucceed = "InterpretHealthSucceed"
// EventReasonInterpretHealthFailed indicates that interpret health failed.
EventReasonInterpretHealthFailed = "InterpretHealthFailed"
) )

6
pkg/controllers/status/workstatus_controller.go
View File

@ -5,6 +5,7 @@ import (
"fmt" "fmt"
"reflect" "reflect"
corev1 "k8s.io/api/core/v1"
apierrors "k8s.io/apimachinery/pkg/api/errors" apierrors "k8s.io/apimachinery/pkg/api/errors"
"k8s.io/apimachinery/pkg/api/meta" "k8s.io/apimachinery/pkg/api/meta"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@ -288,8 +289,10 @@ func (c *WorkStatusController) reflectStatus(work *workv1alpha1.Work, clusterObj
if err != nil { if err != nil {
klog.Errorf("Failed to reflect status for object(%s/%s/%s) with resourceInterpreter.", klog.Errorf("Failed to reflect status for object(%s/%s/%s) with resourceInterpreter.",
clusterObj.GetKind(), clusterObj.GetNamespace(), clusterObj.GetName(), err) clusterObj.GetKind(), clusterObj.GetNamespace(), clusterObj.GetName(), err)
c.EventRecorder.Eventf(work, corev1.EventTypeWarning, workv1alpha1.EventReasonReflectStatusFailed, "Reflect status for object(%s/%s/%s) failed, err: %s.", clusterObj.GetKind(), clusterObj.GetNamespace(), clusterObj.GetName(), err.Error())
return err return err
} }
c.EventRecorder.Eventf(work, corev1.EventTypeNormal, workv1alpha1.EventReasonReflectStatusSucceed, "Reflect status for object(%s/%s/%s) succeed.", clusterObj.GetKind(), clusterObj.GetNamespace(), clusterObj.GetName())
if statusRaw == nil { if statusRaw == nil {
return nil return nil
@ -301,10 +304,13 @@ func (c *WorkStatusController) reflectStatus(work *workv1alpha1.Work, clusterObj
healthy, err := c.ResourceInterpreter.InterpretHealth(clusterObj) healthy, err := c.ResourceInterpreter.InterpretHealth(clusterObj)
if err != nil { if err != nil {
resourceHealth = workv1alpha1.ResourceUnknown resourceHealth = workv1alpha1.ResourceUnknown
c.EventRecorder.Eventf(work, corev1.EventTypeWarning, workv1alpha1.EventReasonInterpretHealthFailed, "Interpret health of object(%s/%s/%s) failed, err: %s.", clusterObj.GetKind(), clusterObj.GetNamespace(), clusterObj.GetName(), err.Error())
} else if healthy { } else if healthy {
resourceHealth = workv1alpha1.ResourceHealthy resourceHealth = workv1alpha1.ResourceHealthy
c.EventRecorder.Eventf(work, corev1.EventTypeNormal, workv1alpha1.EventReasonInterpretHealthSucceed, "Interpret health of object(%s/%s/%s) as healthy.", clusterObj.GetKind(), clusterObj.GetNamespace(), clusterObj.GetName())
} else { } else {
resourceHealth = workv1alpha1.ResourceUnhealthy resourceHealth = workv1alpha1.ResourceUnhealthy
c.EventRecorder.Eventf(work, corev1.EventTypeNormal, workv1alpha1.EventReasonInterpretHealthSucceed, "Interpret health of object(%s/%s/%s) as unhealthy.", clusterObj.GetKind(), clusterObj.GetNamespace(), clusterObj.GetName())
} }
identifier, err := c.buildStatusIdentifier(work, clusterObj) identifier, err := c.buildStatusIdentifier(work, clusterObj)