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

Clean up function

Browse source
This commit is contained in:
Jean Flach 2019-02-21 14:23:45 +01:00
parent be976dc22a
commit a77527fffd
1 changed files with 21 additions and 22 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

43
ha.go
View file

@ -5,9 +5,9 @@ import (
"git.icinga.com/icingadb-connection"
"github.com/go-redis/redis"
"github.com/google/uuid"
log "github.com/sirupsen/logrus"
"sync/atomic"
"time"
log "github.com/sirupsen/logrus"
)
// responsibility tells whether we're responsible for our environment.
@ -92,37 +92,36 @@ func (h *HA) Run(rdb *redis.Client, dbw *icingadb_connection.DBWrapper, chEnv ch
// cleanUpInstancesAsync cleans up icingadb_instance periodically.
func cleanUpInstancesAsync(dbw *icingadb_connection.DBWrapper, chErr chan error) {
if errCI := cleanUpInstances(dbw); errCI != nil {
chErr <- errCI
}
}
// cleanUpInstances cleans up icingadb_instance periodically.
func cleanUpInstances(dbw *icingadb_connection.DBWrapper) error {
every5m := time.NewTicker(5 * time.Minute)
defer every5m.Stop()
for {
<-every5m.C
log.WithFields(log.Fields{"context": "HA"}).Info("Cleaning up icingadb_instance")
errTx := dbw.SqlTransaction(true, true, func(tx *sql.Tx) error {
_, errExec := dbw.SqlExec(
tx,
"delete from icingadb_instance by heartbeat",
`DELETE FROM icingadb_instance WHERE ? - heartbeat >= 30`,
time.Now().Unix(),
)
return errExec
})
if errTx != nil {
return errTx
if errCI := cleanUpInstances(dbw); errCI != nil {
chErr <- errCI
}
}
}
// cleanUpInstances cleans up icingadb_instance periodically.
func cleanUpInstances(dbw *icingadb_connection.DBWrapper) error {
log.WithFields(log.Fields{"context": "HA"}).Info("Cleaning up icingadb_instance")
errTx := dbw.SqlTransaction(true, true, func(tx *sql.Tx) error {
_, errExec := dbw.SqlExec(
tx,
"delete from icingadb_instance by heartbeat",
`DELETE FROM icingadb_instance WHERE ? - heartbeat >= 30`,
time.Now().Unix(),
)
return errExec
})
return errTx
}
func (h *HA) run(rdb *redis.Client, dbw *icingadb_connection.DBWrapper, chEnv chan *icingadb_connection.Environment) error {
log.WithFields(log.Fields{"context": "HA"}).Info("Waiting for Icinga 2 to tell us its environment")