extern/gatus
1
0
Fork 0
mirror of https://github.com/TwiN/gatus.git synced 2024-12-23 15:18:55 +01:00
Code Issues Packages Projects Releases Wiki Activity

Publish metrics when monitoring

Browse Source
This commit is contained in:
TwinProduction 2019-11-16 15:47:28 -05:00
parent 3620e5306c
commit e162740654
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
watchdog/watchdog.go
View File

@ -3,6 +3,7 @@ package watchdog
import ( import (
"github.com/TwinProduction/gatus/config" "github.com/TwinProduction/gatus/config"
"github.com/TwinProduction/gatus/core" "github.com/TwinProduction/gatus/core"
"github.com/TwinProduction/gatus/metric"
"log" "log"
"sync" "sync"
"time" "time"
@ -20,9 +21,11 @@ func GetServiceResults() *map[string][]*core.Result {
func Monitor() { func Monitor() {
for _, service := range config.Get().Services { for _, service := range config.Get().Services {
go func(service *core.Service) { go func(service *core.Service) {
for { for {
log.Printf("[watchdog][Monitor] Monitoring serviceName=%s", service.Name) log.Printf("[watchdog][Monitor] Monitoring serviceName=%s", service.Name)
result := service.EvaluateConditions() result := service.EvaluateConditions()
metric.PublishMetricsForService(service, result)
rwLock.Lock() rwLock.Lock()
serviceResults[service.Name] = append(serviceResults[service.Name], result) serviceResults[service.Name] = append(serviceResults[service.Name], result)
if len(serviceResults[service.Name]) > 10 { if len(serviceResults[service.Name]) > 10 {