File tree Expand file tree Collapse file tree 2 files changed +2
-6
lines changed Expand file tree Collapse file tree 2 files changed +2
-6
lines changed Original file line number Diff line number Diff 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  {
Original file line number Diff line number Diff 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 
 
 
   
 
     
   
   
          
    
    
     
    
      
     
     
    You can’t perform that action at this time.
  
 
    
  
    
      
        
     
       
      
     
   
 
    
    
  
 
  
 
     
    
0 commit comments