fix 'pod oom event' obj's type is pod

Author: 高强

pkg/exporters/k8sexporter/k8s_exporter.go

@@ -69,10 +69,10 @@ func NewExporterOrDie(npdo *options.NodeProblemDetectorOptions) types.Exporter {
 
 func (ke *k8sExporter) ExportProblems(status *types.Status) {
 	for _, event := range status.Events {
-		if event.ObjectType != "Pod"{
-			ke.client.Eventf(util.ConvertToAPIEventType(event.Severity), status.Source, event.Reason, event.Message)
-		}else {
+		if util.PodOOMRegex.MatchString(event.Message) {
 			ke.client.PodEventf(util.ConvertToAPIEventType(event.Severity), status.Source, event.Reason, event.Message)
+		} else {
+			ke.client.Eventf(util.ConvertToAPIEventType(event.Severity), status.Source, event.Reason, event.Message)
 		}
 	}
 	for _, cdt := range status.Conditions {

pkg/exporters/k8sexporter/problemclient/problem_client.go

@@ -120,7 +120,7 @@ func (c *nodeProblemClient) Eventf(eventType, source, reason, messageFmt string,
 	recorder.Eventf(c.nodeRef, eventType, reason, messageFmt, args...)
 }
 
-// PodEventf will send Pod type event
+
 func (c *nodeProblemClient) PodEventf(eventType, source, reason, messageFmt string, args ...interface{}) {
 	recorder, found := c.recorders[source]
 	if !found {

pkg/systemlogmonitor/log_monitor.go

@@ -225,7 +225,6 @@ func (l *logMonitor) generateStatus(logs []*logtypes.Log, rule systemlogtypes.Ru
 		// For temporary error only generate event
 		events = append(events, types.Event{
 			Severity:   types.Warn,
-			ObjectType: "Pod",
 			Timestamp:  timestamp,
 			Reason:     rule.Reason,
 			Message:    message,

pkg/types/types.go

@@ -77,8 +77,6 @@ type Event struct {
 	Reason string `json:"reason"`
 	// Message is a human readable message of why the event is generated.
 	Message string `json:"message"`
-	// ObjectType
-	ObjectType string `json:"object_type"`
 }
 
 // Status is the status other problem daemons should report to node problem detector.