moonlibs / sync

97%

master: 97%

LAST BUILD ON BRANCH refs/tags/0.11.0

branch: refs/tags/0.11.0

CHANGE BRANCH

x

Reset

• refs/tags/0.11.0
• 4-syncpool-failed-at-terminating
• feat/ratelimit
• fix-infinite-rate
• fix-readme
• fix-timeout-0
• master
• refs/pull/5/merge
• refs/pull/6/merge
• refs/pull/7/merge
• refs/pull/8/merge
• refs/pull/9/merge
• refs/tags/0.10.1
• refs/tags/0.10.2
• refs/tags/0.11.1
• refs/tags/0.12.0

Build # 5209733927

Build Type

push

github

Committed by web-flow

Commit Message

sync/rate: implements golang-like rate limiter (#7)

* sync/rate: implements golang-like rate limiter

	* sync/rate implements classic TokenBucket ratelimiter
	* client may create ratelimiter with passing limit and burst
	* rate limiter can have at most burst bucket
	* rate limiter is refilled with token at rate `limit` tokens per
	  second (can be fractional)
	* ratelimit exposes 3 public methods:
		- rate:wait([timeout=now, [n=1]]) awaits for n tokens
		  within timeout seconds (can be fractional)
		- rate:reserve([timestamp=now(), [n=1]]) creates
		  reservation for n tokens which will be consumed at
		  timestamp (non expired reservations can be cancelled)
		- rate:allow([timestamp=now(), [n=1]]) autoreserves n
		  token to be consumed at time `timestamp` (don't think
		  someone need this method at all)

* rate: adds README and tests

* rate: fixes namings and error format

---------

Co-authored-by: Vladislav Grubov <orangechaton@gmail.com>

Run Details

508 of 526 relevant lines covered (96.58%)

15.62 hits per line