Use new HA

This commit is contained in:
Jean Flach 2019-03-22 14:13:19 +01:00 committed by Noah Hilverling
parent f8bfc79f13
commit 45be5c7d47

View file

@ -45,8 +45,12 @@ func main() {
}
chEnv := make(chan *icingadb_ha.Environment)
ha := icingadb_ha.NewHA(&super)
go ha.Run(super.Rdbw, super.Dbw, chEnv, super.ChErr)
ha, err := icingadb_ha.NewHA(&super)
if err != nil {
log.Fatal(err)
}
go ha.Run(chEnv)
go func() {
super.ChErr <- icingadb_ha.IcingaEventsBroker(redisConn, chEnv)
}()