From a3b7ac5af6effd9b4eff40fffb0fbbb073d4d8a5 Mon Sep 17 00:00:00 2001 From: Noah Hilverling Date: Tue, 17 Sep 2019 13:47:03 +0200 Subject: [PATCH] Rename IcingaEventsBroker to IcingaHeartbeatListener --- ha/heartbeat.go | 4 ++-- ha/heartbeat_test.go | 4 ++-- main.go | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/ha/heartbeat.go b/ha/heartbeat.go index ae898216..3b380efb 100644 --- a/ha/heartbeat.go +++ b/ha/heartbeat.go @@ -21,8 +21,8 @@ func Sha1bytes(bytes []byte) []byte { return hash.Sum(nil) } -func IcingaEventsBroker(rdb *connection.RDBWrapper, chEnv chan *Environment) error { - log.Info("Starting Events broker") +func IcingaHeartbeatListener(rdb *connection.RDBWrapper, chEnv chan *Environment) error { + log.Info("Starting heartbeat listener") subscription := rdb.Subscribe() defer subscription.Close() diff --git a/ha/heartbeat_test.go b/ha/heartbeat_test.go index d91fd496..3b09575d 100644 --- a/ha/heartbeat_test.go +++ b/ha/heartbeat_test.go @@ -15,7 +15,7 @@ var icingastate = "{\"IcingaApplication\":" + "\"environment\": \"\"" + "}}}}, \"config_dump_in_progress\": false}" -func TestIcingaEventsBroker(t *testing.T) { +func TestIcingaHeartbeatListener(t *testing.T) { rdb, err := connection.NewRDBWrapper("10.77.27.16:6379") if err != nil { t.Fatal("This test needs a working Redis connection") @@ -24,7 +24,7 @@ func TestIcingaEventsBroker(t *testing.T) { chEnv := make(chan *Environment) go func() { - err := IcingaEventsBroker(rdb, chEnv) + err := IcingaHeartbeatListener(rdb, chEnv) assert.NoError(t, err, "redis connection error") }() diff --git a/main.go b/main.go index ab508ac6..a5022cdc 100644 --- a/main.go +++ b/main.go @@ -101,7 +101,7 @@ func main() { go haInstance.Run(chEnv) go func() { - super.ChErr <- ha.IcingaEventsBroker(redisConn, chEnv) + super.ChErr <- ha.IcingaHeartbeatListener(redisConn, chEnv) }() go jsondecoder.DecodePool(super.ChDecode, super.ChErr, 16)