lib/telemetry: log the error from BulkForward on goroutine collector

We use mlog so the user of telemetry can have record of error.

1 files changed, 8 insertions, 1 deletions

diff --git a/lib/telemetry/agent.go b/lib/telemetry/agent.go
index 26631cb0..b4104717 100644
--- a/lib/telemetry/agent.go
+++ b/lib/telemetry/agent.go
@@ -9,6 +9,8 @@ import (
 	"fmt"
 	"log"
 	"time"
+
+	"github.com/shuLhan/share/lib/mlog"
 )
 
 const (
@@ -78,15 +80,20 @@ func (agent *Agent) collect() (all []Metric) {
 // collector collect the metrics on each interval and forward it.
 func (agent *Agent) collector() {
 	var (
+		logp    = `collector`
 		ticker  = time.NewTicker(agent.opts.Interval)
 		metrics []Metric
+		err     error
 	)
 
 	for {
 		select {
 		case <-ticker.C:
 			metrics = agent.collect()
-			agent.BulkForward(context.Background(), metrics)
+			err = agent.BulkForward(context.Background(), metrics)
+			if err != nil {
+				mlog.Errf(`%s: %s`, logp, err)
+			}
 
 		case <-agent.running:
 			ticker.Stop()