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

Eat env and print id

Browse source
This commit is contained in:
Jean Flach 2019-03-08 10:56:29 +01:00
parent 0682265a0f
commit 84746c2ebf
1 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
ha.go
View file

@ -34,7 +34,7 @@ const (
type HA struct {
ourUUID uuid.UUID
ourEnv *Environment
ourEnv *Environment
icinga2MTime int64
// responsibility tells whether we're responsible for our environment.
responsibility int32
@ -195,7 +195,7 @@ func (h *HA) run(rdb *icingadb_connection.RDBWrapper, dbw *icingadb_connection.D
log.WithFields(log.Fields{
"context": "HA",
"uuid": h.ourUUID.String(),
"env": h.ourEnv.Name,
"env": h.ourEnv.ID,
}).Info("Received environment from Icinga 2")
everySecond := time.NewTicker(time.Second)
@ -335,7 +335,7 @@ func (h *HA) run(rdb *icingadb_connection.RDBWrapper, dbw *icingadb_connection.D
if h.setResponsibility(resp_TakeoverSync) == resp_TakeoverNoSync {
log.WithFields(log.Fields{
"context": "HA",
"env": h.ourEnv.Name,
"env": h.ourEnv.ID,
"their_uuid": theirUUID.String(),
}).Info("Taking over")
}
@ -350,7 +350,7 @@ func (h *HA) run(rdb *icingadb_connection.RDBWrapper, dbw *icingadb_connection.D
if !justTakenOver {
log.WithFields(log.Fields{
"context": "HA",
"env": h.ourEnv.Name,
"env": h.ourEnv.ID,
"their_uuid": theirUUID.String(),
}).Info("Other instance is responsible")
}
@ -388,7 +388,7 @@ func (h *HA) run(rdb *icingadb_connection.RDBWrapper, dbw *icingadb_connection.D
log.WithFields(log.Fields{
"context": "HA",
"env": h.ourEnv.Name,
"env": h.ourEnv.ID,
}).Info("Other instance is responsible. Ceasing operations.")
h.responsibleSince = time.Time{}
@ -401,6 +401,7 @@ func (h *HA) run(rdb *icingadb_connection.RDBWrapper, dbw *icingadb_connection.D
return nil
}
h.Icinga2HeartBeat()
<-everySecond.C
case <-everySecond.C:
break