Merge pull request #67 from bugrakocabay/dev

bugrakocabay · web-flow · commit cb38a20e61cb · 2024-02-03T08:10:26.000+03:00
Dev
diff --git a/pkg/queue/kafka/kafka.go b/pkg/queue/kafka/kafka.go
@@ -2,9 +2,10 @@ package kafka
 
 import (
 	"context"
-	"github.com/bugrakocabay/konsume/pkg/config"
 	"log/slog"
 
+	"github.com/bugrakocabay/konsume/pkg/config"
+
 	"github.com/segmentio/kafka-go"
 )
 
diff --git a/pkg/requester/requester.go b/pkg/requester/requester.go
@@ -73,7 +73,7 @@ func (r *Requester) SendRequest(m *config.MetricsConfig, timeout time.Duration)
 	}
 	defer resp.Body.Close()
 
-	if m.Enabled {
+	if m != nil && m.Enabled {
 		metrics.HttpRequestsMade.Inc()
 		if resp.StatusCode >= m.ThresholdStatus {
 			metrics.HttpRequestsFailed.Inc()

Original file line number	Diff line number	Diff line change
`@@ -2,9 +2,10 @@ package kafka`
`2`	`2`
`3`	`3`	`import (`
`4`	`4`	`"context"`
`5`		`- "github.com/bugrakocabay/konsume/pkg/config"`
`6`	`5`	`"log/slog"`
`7`	`6`
	`7`	`+ "github.com/bugrakocabay/konsume/pkg/config"`
	`8`	`+`
`8`	`9`	`"github.com/segmentio/kafka-go"`
`9`	`10`	`)`
`10`	`11`
Original file line number	Diff line number	Diff line change
`@@ -73,7 +73,7 @@ func (r Requester) SendRequest(m config.MetricsConfig, timeout time.Duration)`
`73`	`73`	`}`
`74`	`74`	`defer resp.Body.Close()`
`75`	`75`
`76`		`- if m.Enabled {`
	`76`	`+ if m != nil && m.Enabled {`
`77`	`77`	`metrics.HttpRequestsMade.Inc()`
`78`	`78`	`if resp.StatusCode >= m.ThresholdStatus {`
`79`	`79`	`metrics.HttpRequestsFailed.Inc()`