tyler.durden/icingabeat
1
0
Fork 0
mirror of https://github.com/Icinga/icingabeat.git synced 2025-07-30 17:24:13 +02:00
Code Issues Packages Projects Releases Wiki Activity

Cleanup styles according to goimports' style

Browse Source
This commit is contained in:
Blerim Sheqa 2018-12-20 16:49:15 +01:00
parent 62fcc54da6
commit 9f856fc765
2 changed files with 17 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
beater/eventstream.go
View File

@ -51,35 +51,35 @@ func BuildEventstreamEvent(e []byte) beat.Event {
event.Fields = common.MapStr{}
for key, value := range icingaEvent {
event.Fields.Put(target_key + key, value)
event.Fields.Put(target_key+key, value)
}
logp.Debug("icingabeat", "Type: %v", icingaEvent["type"])
switch icingaEvent["type"] {
case "CheckResult", "StateChange", "Notification":
checkResult := icingaEvent["check_result"].(map[string]interface{})
event.Fields.Put(target_key + "check_result.execution_start", FloatToTimestamp(checkResult["execution_start"].(float64)))
event.Fields.Put(target_key + "check_result.execution_end", FloatToTimestamp(checkResult["execution_end"].(float64)))
event.Fields.Put(target_key + "check_result.schedule_start", FloatToTimestamp(checkResult["schedule_start"].(float64)))
event.Fields.Put(target_key + "check_result.schedule_end", FloatToTimestamp(checkResult["schedule_end"].(float64)))
event.Fields.Put(target_key+"check_result.execution_start", FloatToTimestamp(checkResult["execution_start"].(float64)))
event.Fields.Put(target_key+"check_result.execution_end", FloatToTimestamp(checkResult["execution_end"].(float64)))
event.Fields.Put(target_key+"check_result.schedule_start", FloatToTimestamp(checkResult["schedule_start"].(float64)))
event.Fields.Put(target_key+"check_result.schedule_end", FloatToTimestamp(checkResult["schedule_end"].(float64)))
event.Fields.Delete("check_result.performance_data")
case "AcknowledgementSet":
event.Delete("comment")
event.Fields.Put(target_key + "comment.text", icingaEvent["comment"])
event.Fields.Put(target_key + "expiry", FloatToTimestamp(icingaEvent["expiry"].(float64)))
event.Fields.Put(target_key+"comment.text", icingaEvent["comment"])
event.Fields.Put(target_key+"expiry", FloatToTimestamp(icingaEvent["expiry"].(float64)))
case "CommentAdded", "CommentRemoved":
comment := icingaEvent["comment"].(map[string]interface{})
event.Fields.Put(target_key + "comment.entry_time", FloatToTimestamp(comment["entry_time"].(float64)))
event.Fields.Put(target_key + "comment.expire_time", FloatToTimestamp(comment["expire_time"].(float64)))
event.Fields.Put(target_key+"comment.entry_time", FloatToTimestamp(comment["entry_time"].(float64)))
event.Fields.Put(target_key+"comment.expire_time", FloatToTimestamp(comment["expire_time"].(float64)))
case "DowntimeAdded", "DowntimeRemoved", "DowntimeStarted", "DowntimeTriggered":
downtime := icingaEvent["downtime"].(map[string]interface{})
event.Fields.Put(target_key + "downtime.end_time", FloatToTimestamp(downtime["end_time"].(float64)))
event.Fields.Put(target_key + "downtime.entry_time", FloatToTimestamp(downtime["entry_time"].(float64)))
event.Fields.Put(target_key + "downtime.start_time", FloatToTimestamp(downtime["start_time"].(float64)))
event.Fields.Put(target_key + "downtime.trigger_time", FloatToTimestamp(downtime["trigger_time"].(float64)))
event.Fields.Put(target_key+"downtime.end_time", FloatToTimestamp(downtime["end_time"].(float64)))
event.Fields.Put(target_key+"downtime.entry_time", FloatToTimestamp(downtime["entry_time"].(float64)))
event.Fields.Put(target_key+"downtime.start_time", FloatToTimestamp(downtime["start_time"].(float64)))
event.Fields.Put(target_key+"downtime.trigger_time", FloatToTimestamp(downtime["trigger_time"].(float64)))
}
event.Fields.Put("type", "icingabeat.event."+strings.ToLower(icingaEvent["type"].(string)))

8
beater/statuspoller.go
View File

@ -65,11 +65,11 @@ func BuildStatusEvents(body []byte) []beat.Event {
delete(value.(map[string]interface{}), "zones")
}
}
event.Fields.Put(target_key + key, value)
event.Fields.Put(target_key+key, value)
}
default:
event.Fields.Put(target_key + key, value)
event.Fields.Put(target_key+key, value)
}
}
@ -83,7 +83,7 @@ func BuildStatusEvents(body []byte) []beat.Event {
case interface{}:
key = "perfdata." + perfdata.(map[string]interface{})["label"].(string)
value = perfdata
event.Fields.Put(target_key + key, value)
event.Fields.Put(target_key+key, value)
}
}
@ -93,7 +93,7 @@ func BuildStatusEvents(body []byte) []beat.Event {
event.Fields.Put("type", value)
default:
event.Fields.Put(target_key + key, value)
event.Fields.Put(target_key+key, value)
}
}