From 7a58f718e85170ed138a93598ad68754f6422097 Mon Sep 17 00:00:00 2001 From: vivek-ng Date: Mon, 23 Nov 2020 11:27:46 -0600 Subject: [PATCH] update readme --- README.md | 12 +++++++++--- priority/priorityRateLimiter_test.go | 6 ++++-- rateLimiter_test.go | 3 ++- 3 files changed, 15 insertions(+), 6 deletions(-) diff --git a/README.md b/README.md index e08114b..f003d8b 100644 --- a/README.md +++ b/README.md @@ -25,7 +25,9 @@ chance to access the resource in the FIFO order. ### Limiter with Timeout ```go - nl := limiter.New(3).WithTimeout(10) + nl := limiter.New(3, + WithTimeout(10), + ) nl.Wait() Execute...... nl.Finish() @@ -48,7 +50,9 @@ given the maximum preference because it is of high priority. In the case of tie ### Priority Limiter with Dynamic priority ```go - nl := priority.NewLimiter(3).WithDynamicPriority(5) + nl := priority.NewLimiter(3, + WithDynamicPriority(5), + ) nl.Wait(priority.Low) Execute...... nl.Finish() @@ -58,7 +62,9 @@ In Dynamic Priority Limiter , the goroutines with lower priority will get their ### Priority Limiter with Timeout ```go - nl := priority.NewLimiter(3).WithTimeout(30) + nl := priority.NewLimiter(3, + WithTimeout(30), + ) nl.Wait(constants.High) Execute...... nl.Finish() diff --git a/priority/priorityRateLimiter_test.go b/priority/priorityRateLimiter_test.go index fc81e66..f30663e 100644 --- a/priority/priorityRateLimiter_test.go +++ b/priority/priorityRateLimiter_test.go @@ -37,7 +37,8 @@ func TestPriorityLimiter(t *testing.T) { func TestDynamicPriority(t *testing.T) { nl := NewLimiter(3, - WithDynamicPriority(10)) + WithDynamicPriority(10), + ) var wg sync.WaitGroup wg.Add(5) for i := 0; i < 5; i++ { @@ -61,7 +62,8 @@ func TestDynamicPriority(t *testing.T) { func TestPriorityLimiter_Timeout(t *testing.T) { nl := NewLimiter(3, - WithTimeout(100)) + WithTimeout(100), + ) var wg sync.WaitGroup wg.Add(5) for i := 0; i < 5; i++ { diff --git a/rateLimiter_test.go b/rateLimiter_test.go index 37b6e88..652ba7d 100644 --- a/rateLimiter_test.go +++ b/rateLimiter_test.go @@ -48,7 +48,8 @@ func TestConcurrentRateLimiterBlocking(t *testing.T) { func TestConcurrentRateLimiterTimeout(t *testing.T) { l := New(2, - WithTimeout(300)) + WithTimeout(300), + ) var wg sync.WaitGroup wg.Add(5)