Commitdc8bde6

committed

simplify retry state initialization in logQueuer

1 parent232e983 commitdc8bde6Copy full SHA for dc8bde6

File tree

-6

lines changed

-6

lines changed

Lines changed: 1 addition & 5 deletions

Original file line number	Diff line number	Diff line change
`@@ -592,14 +592,10 @@ type retryState struct {`
`592`	`592`	`timer*quartz.Timer`
`593`	`593`	`}`
`594`	`594`
`595`		`-func (l*logQueuer)ensureRetryMap() {`
	`595`	`+func (l*logQueuer)scheduleRetry(ctx context.Context,tokenstring) {`
`596`	`596`	`ifl.retries==nil {`
`597`	`597`	`l.retries=make(map[string]*retryState)`
`598`	`598`	`}`
`599`		`-}`
`600`		`-`
`601`		`-func (l*logQueuer)scheduleRetry(ctx context.Context,tokenstring) {`
`602`		`-l.ensureRetryMap()`
`603`	`599`
`604`	`600`	`rs:=l.retries[token]`
`605`	`601`	`ifrs==nil {`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -600,7 +600,7 @@ func Test_logQueuer(t *testing.T) {`
`600`	`600`	`token:="test-token"`
`601`	`601`
`602`	`602`	`// Set up a retry state with a large delay`
`603`		`-lq.ensureRetryMap()`
	`603`	`+lq.retries=make(map[string]*retryState)`
`604`	`604`	`lq.retries[token]=&retryState{delay:20*time.Second}`
`605`	`605`
`606`	`606`	`// Schedule a retry - should cap at 30 seconds`

Comments

(0)