lint

Author: rolodato

backoff.go

@@ -10,19 +10,19 @@ const (
 	maxBackoff     = 30 * time.Second
 )
 
-// backoff handles exponential backoff with jitter
+// backoff handles exponential backoff with jitter.
 type backoff struct {
 	current time.Duration
 }
 
-// newBackoff creates a new backoff instance
+// newBackoff creates a new backoff instance.
 func newBackoff() *backoff {
 	return &backoff{
 		current: initialBackoff,
 	}
 }
 
-// next returns the next backoff duration and updates the current backoff
+// next returns the next backoff duration and updates the current backoff.
 func (b *backoff) next() time.Duration {
 	// Add jitter between 0-1s
 	backoff := b.current + time.Duration(time.Now().UnixNano()%1e9)
@@ -35,12 +35,12 @@ func (b *backoff) next() time.Duration {
 	return backoff
 }
 
-// reset resets the backoff to initial value
+// reset resets the backoff to initial value.
 func (b *backoff) reset() {
 	b.current = initialBackoff
 }
 
-// wait waits for the current backoff time, or until ctx is done
+// wait waits for the current backoff time, or until ctx is done.
 func (b *backoff) wait(ctx context.Context) {
 	select {
 	case <-ctx.Done():

client.go

@@ -113,7 +113,6 @@ func NewClient(apiKey string, options ...Option) *Client {
 			// Poll until we get the environment once
 			go c.pollThenStartRealtime(c.ctxLocalEval)
 		}
-
 	}
 	// Initialise analytics processor
 	if c.config.enableAnalytics {

client_test.go

@@ -1013,7 +1013,7 @@ func TestWithPollingWorksWithRealtime(t *testing.T) {
 	assert.Contains(t, logStr, "worker=realtime")
 }
 
-// writerFunc implements io.Writer
+// writerFunc implements io.Writer.
 type writerFunc func(p []byte) (n int, err error)
 
 func (f writerFunc) Write(p []byte) (n int, err error) {

realtime.go

@@ -14,18 +14,17 @@ import (
 	"github.com/Flagsmith/flagsmith-go-client/v4/flagengine/environments"
 )
 
-// realtime handles the SSE connection and reconnection logic
+// realtime handles the SSE connection and reconnection logic.
 type realtime struct {
-	client        *Client
-	ctx           context.Context
-	log           *slog.Logger
-	streamURL     string
-	envUpdatedAt  time.Time
-	backoff       *backoff
-	reconnectChan chan struct{}
+	client       *Client
+	ctx          context.Context
+	log          *slog.Logger
+	streamURL    string
+	envUpdatedAt time.Time
+	backoff      *backoff
 }
 
-// newRealtime creates a new realtime instance
+// newRealtime creates a new realtime instance.
 func newRealtime(client *Client, ctx context.Context, streamURL string, envUpdatedAt time.Time) *realtime {
 	return &realtime{
 		client: client,
@@ -40,7 +39,7 @@ func newRealtime(client *Client, ctx context.Context, streamURL string, envUpdat
 	}
 }
 
-// start begins the realtime connection process
+// start begins the realtime connection process.
 func (r *realtime) start() {
 	r.log.Debug("connecting to realtime")
 	defer func() {
@@ -59,7 +58,7 @@ func (r *realtime) start() {
 	}
 }
 
-// connect establishes and maintains the SSE connection
+// connect establishes and maintains the SSE connection.
 func (r *realtime) connect() error {
 	resp, err := http.Get(r.streamURL)
 	if err != nil {
@@ -96,7 +95,7 @@ func (r *realtime) connect() error {
 	return nil
 }
 
-// handleEvent processes a single SSE event
+// handleEvent processes a single SSE event.
 func (r *realtime) handleEvent(line string) error {
 	parsedTime, err := parseUpdatedAtFromSSE(line)
 	if err != nil {