Skip to content

Commit dc8bde6

Browse files
committed
simplify retry state initialization in logQueuer
1 parent 232e983 commit dc8bde6

File tree

2 files changed

+2
-6
lines changed

2 files changed

+2
-6
lines changed

logger.go

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -592,14 +592,10 @@ type retryState struct {
592592
timer *quartz.Timer
593593
}
594594

595-
func (l *logQueuer) ensureRetryMap() {
595+
func (l *logQueuer) scheduleRetry(ctx context.Context, token string) {
596596
if l.retries == nil {
597597
l.retries = make(map[string]*retryState)
598598
}
599-
}
600-
601-
func (l *logQueuer) scheduleRetry(ctx context.Context, token string) {
602-
l.ensureRetryMap()
603599

604600
rs := l.retries[token]
605601
if rs == nil {

logger_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -600,7 +600,7 @@ func Test_logQueuer(t *testing.T) {
600600
token := "test-token"
601601

602602
// Set up a retry state with a large delay
603-
lq.ensureRetryMap()
603+
lq.retries = make(map[string]*retryState)
604604
lq.retries[token] = &retryState{delay: 20 * time.Second}
605605

606606
// Schedule a retry - should cap at 30 seconds

0 commit comments

Comments
 (0)