client-go/util/workqueue
Antonio Ojea 374e3638f2 workqueue unit tests to assert collapsing behaviors
Change-Id: If4bf54c3af603c17de49055960f9a76e7d38aab3

Kubernetes-commit: 8a31bb6786c2d3600bade49de7a64a026802bd6d
2023-09-21 10:48:01 +00:00
..
default_rate_limiters_test.go Changes to fix the flake test case in ratelimiter 2021-09-28 12:23:27 +05:30
default_rate_limiters.go client-go bucket rate limiter add maxDelay 2021-08-29 17:45:58 +08:00
delaying_queue_test.go Unify queue constructors, deprecate current constructors 2023-03-10 17:46:26 -05:00
delaying_queue.go Allow custom metric provider for retry metrics 2023-03-10 17:48:10 -05:00
doc.go Generate and format files 2022-07-19 20:54:13 -04:00
main_test.go Cleanup math/rand package usage 2018-11-17 16:45:36 +11:00
metrics_test.go Unify queue constructors, deprecate current constructors 2023-03-10 17:46:26 -05:00
metrics.go Allow custom metric provider for retry metrics 2023-03-10 17:48:10 -05:00
parallelizer_test.go Use sqrt(n) chunk size in pod affinity and core scheduler 2020-03-16 14:12:11 -04:00
parallelizer.go Add chunk size option to ParallelizeUntil 2020-03-11 17:13:55 -04:00
queue_test.go workqueue unit tests to assert collapsing behaviors 2023-09-21 10:48:01 +00:00
queue.go Fix a race where a call to Shutdown was happening after ShutDownWithDrain() had performed the check q.isProcessing() && q.shouldDrain() and before waitForProcessing() has reached its Wait(). This is because waitForProcessing() is only checking the length part of the condition instead of both the length and whether we still need to drain. 2023-07-24 22:40:54 +01:00
rate_limiting_queue_test.go Allow custom metric provider for retry metrics 2023-03-10 17:48:10 -05:00
rate_limiting_queue.go Unify queue constructors, deprecate current constructors 2023-03-10 17:46:26 -05:00