upstream/icingadb
1
0
Fork 0
mirror of https://github.com/Icinga/icingadb.git synced 2026-05-28 04:35:54 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Add history entry counters

Browse source
This commit is contained in:
Noah Hilverling 2019-11-04 12:39:08 +01:00
parent 7ceef4fc62
commit 3914bd068e
1 changed files with 31 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
configobject/history/history.go
View file

@ -10,6 +10,7 @@ import (
"github.com/prometheus/client_golang/prometheus"
log "github.com/sirupsen/logrus"
"strconv"
"sync"
"time"
)
@ -25,11 +26,32 @@ var mysqlObservers = func() (mysqlObservers map[string]prometheus.Observer) {
return
}()
var historyCounter = make(map[string]int)
var historyCounterLock = sync.Mutex{}
var emptyUUID = uuid.MustParse("00000000-0000-0000-0000-000000000000")
var emptyID = []byte{
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
}
//Logs the amount of history entries added every 20 seconds
func logHistoryCounters() {
every20s := time.NewTicker(time.Second * 20)
defer every20s.Stop()
for {
<-every20s.C
for _, historyType := range [5]string{"state", "notification", "downtime", "comment", "flapping"} {
if historyCounter[historyType] > 0 {
log.Infof("Added %d %s history entries in the last 20 seconds", historyCounter[historyType], historyType)
historyCounterLock.Lock()
historyCounter[historyType] = 0
historyCounterLock.Unlock()
}
}
}
}
func StartHistoryWorkers(super *supervisor.Supervisor) {
workers := []func(supervisor2 *supervisor.Supervisor){
notificationHistoryWorker,
@ -47,6 +69,8 @@ func StartHistoryWorkers(super *supervisor.Supervisor) {
}
}()
}
go logHistoryCounters()
}
func notificationHistoryWorker(super *supervisor.Supervisor) {
@ -450,7 +474,13 @@ func historyWorker(super *supervisor.Supervisor, historyType string, preparedSta
//Delete synced entries from redis stream
super.Rdbw.XDel("icinga:history:stream:"+historyType, storedEntryIds...)
log.Debugf("%d %s history entries synced", len(storedEntryIds)-brokenEntries, historyType)
count := len(storedEntryIds) - brokenEntries
historyCounterLock.Lock()
historyCounter[historyType]++
historyCounterLock.Unlock()
log.Debugf("%d %s history entries synced", count, historyType)
log.Debugf("%d %s history entries broken", brokenEntries, historyType)
}