fix event type json tag

yeo · Dec 11, 2019 · b11c43e · b11c43e
1 parent 80a7620
commit b11c43e
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 10 deletions.
diff --git a/extras/gaia/event.go b/extras/gaia/event.go
@@ -30,22 +30,22 @@ const (
 )
 
 type EventCheckInsert struct {
-	EventType EventType
+	EventType EventType `json:"event_type"`
 	*dao.Check
 }
 
 type EventCheckReplace struct {
-	EventType EventType
+	EventType EventType `json:"event_type"`
 	*dao.Check
 }
 
 type EventCheckDelete struct {
-	EventType EventType
+	EventType EventType `json:"event_type"`
 	*dao.Check
 }
 
 type EventCheckHTTPResult struct {
-	EventType EventType
+	EventType EventType `json:"event_type"`
 	ID        string
 	IP        string
 	Region    string
@@ -121,7 +121,7 @@ func (e *EventCheckTCPResult) CheckType() string {
 }
 
 type EventCheckBeat struct {
-	EventType EventType
+	EventType EventType `json:"event_type"`
 	ID        string
 	Action    string
 	BeatAt    time.Time
@@ -156,12 +156,12 @@ func (e *EventCheckBeat) MetricPayload() (map[string]interface{}, error) {
 }
 
 type EventRunCheck struct {
-	EventType EventType
+	EventType EventType `json:"event_type"`
 	ID        string
 }
 
 type EventPing struct {
-	EventType EventType
+	EventType EventType `json:"event_type"`
 	At        time.Time
 }
 

diff --git a/extras/gaia/eventbus.go b/extras/gaia/eventbus.go
@@ -6,11 +6,11 @@ import (
 )
 
 type EventWrapper struct {
-	EventType EventType
+	EventType EventType `json:"event_type"`
 }
 
 type GenericEvent struct {
-	EventType EventType
+	EventType EventType `json:"event_type"`
 	*EventCheckInsert
 	*EventCheckReplace
 	*EventCheckDelete

diff --git a/extras/gaia/sync.go b/extras/gaia/sync.go
@@ -210,7 +210,6 @@ func (s *Syncer) ListenFromAgent(name string, sink *Sink) error {
 		}
 		agent.Stats.LastReceivedFromClient = time.Now()
 
-		log.Printf("Receive raw event %v from agent %s\n", string(message), name)
 		var evt GenericEvent
 		if err = evt.UnmarshalJSON(message); err != nil {
 			log.Println("Cannot unmarshalJSON")