Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for AddAfter (0.16 sec)

  1. pkg/controller/garbagecollector/garbagecollector_test.go

    					}
    				}
    			}
    		},
    	}
    
    }
    
    // trackingWorkqueue implements RateLimitingInterface,
    // allows introspection of the items in the queue,
    // and treats AddAfter and AddRateLimited the same as Add
    // so they are always synchronous.
    type trackingWorkqueue[T comparable] struct {
    	limiter     workqueue.TypedRateLimitingInterface[T]
    	pendingList []T
    	pendingMap  map[T]struct{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.6K bytes
    - Viewed (0)
  2. pkg/controller/job/job_controller_test.go

    func (f *fakeRateLimitingQueue) Forget(item string) {
    	f.requeues = 0
    }
    func (f *fakeRateLimitingQueue) NumRequeues(item string) int {
    	return f.requeues
    }
    func (f *fakeRateLimitingQueue) AddAfter(item string, duration time.Duration) {
    	f.item = item
    	f.duration = duration
    }
    
    func TestJobBackoff(t *testing.T) {
    	_, ctx := ktesting.NewTestContext(t)
    	logger := klog.FromContext(ctx)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
Back to top