Update endpoint in TestExample

Author: pkcll

pkg/promotel/forwarder.go

@@ -16,8 +16,8 @@ import (
 )
 
 const (
-	period              = 15 * time.Second
 	heartbeatMetricName = "promotel_heartbeat"
+	hearbeatInterval    = 15 * time.Second
 	scopeName           = "PromOTELForwarder"
 )
 
@@ -118,15 +118,15 @@ func (f *Forwarder) startMetricExporter(ctx context.Context) {
 }
 
 func (f *Forwarder) reportHeartbeatMetric(ctx context.Context) {
-	ticker := time.NewTicker(period)
+	ticker := time.NewTicker(hearbeatInterval)
 	defer ticker.Stop()
 	for {
+		f.heartbeat.Inc()
+		f.lggr.Debug("Heartbeat promotel")
 		select {
 		case <-ctx.Done():
 			return
 		case <-ticker.C:
-			f.heartbeat.Inc()
-			f.lggr.Debug("Heartbeat promotel")
 		}
 	}
 }

pkg/promotel/forwarder_test.go

@@ -2,7 +2,6 @@ package promotel_test
 
 import (
 	"context"
-	"net/http/httptest"
 	"strings"
 	"testing"
 	"time"
@@ -47,10 +46,8 @@ func TestExample(t *testing.T) {
 		}
 	}()
 
-	srv := httptest.NewServer(nil)
-	// TODO: add mocked GRPC endpoint for exporter
 	forwarder, err := promotel.NewForwarder(g, r, lggr, promotel.ForwarderOptions{
-		Endpoint:    srv.URL,
+		Endpoint:    "localhost:4317",
 		TLSInsecure: true,
 		Interval:    interval,
 		Verbose:     true,