all: remove code that sending heartbeat

Previously, if no logs received after 15 seconds (or any interval user
defined in Config.ForwardInterval), the haminer process send an empty
halog to forwarders (empty halog is the one that use "-" for backend,
frontend, server name, and HTTP method).

This cause bogus traffic and need additional filter when analyzed.

2 files changed, 9 insertions, 17 deletions

diff --git a/halog.go b/halog.go
index fd3f432..b7ac16d 100644
--- a/halog.go
+++ b/halog.go
@@ -11,16 +11,6 @@ import (
 	"time"
 )
 
-// heartbeat of haminer, in case we want to monitor deadman from haminer.
-var heartbeat = &Halog{ // nolint: gochecknoglobals
-	Timestamp:    time.Now(),
-	FrontendName: "-",
-	BackendName:  "-",
-	ServerName:   "-",
-	tagHTTPURL:   "-",
-	HTTPMethod:   "-",
-}
-
 // Halog contains the mapping of haproxy HTTP log format to Go struct.
 //
 // Reference: https://cbonte.github.io/haproxy-dconv/1.7/configuration.html#8.2.3
diff --git a/haminer.go b/haminer.go
index 10209d3..7a54e84 100644
--- a/haminer.go
+++ b/haminer.go
@@ -88,6 +88,9 @@ func (h *Haminer) filter(halog *Halog) bool {
 	if halog == nil {
 		return false
 	}
+	if halog.BackendName == `-` {
+		return false
+	}
 	if len(h.cfg.AcceptBackend) == 0 {
 		return true
 	}
@@ -133,11 +136,6 @@ func (h *Haminer) consume() {
 }
 
 func (h *Haminer) forwards(halogs []*Halog) {
-	// Send heartbeat indicator, if logs is empty.
-	if len(halogs) == 0 {
-		heartbeat.Timestamp = time.Now()
-		halogs = append(halogs, heartbeat)
-	}
 	for _, fwder := range h.ff {
 		fwder.Forwards(halogs)
 	}
@@ -158,11 +156,15 @@ func (h *Haminer) produce() {
 		select {
 		case halog := <-h.chHalog:
 			h.preprocess(halog)
-
 			halogs = append(halogs, halog)
+
 		case <-ticker.C:
+			if len(halogs) == 0 {
+				continue
+			}
+
 			h.forwards(halogs)
-			halogs = nil
+			halogs = halogs[:0]
 		}
 	}
 }