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