unistack-org/micro-wrapper-ratelimiter-uber
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 1 Wiki Activity

wrapper/ratelimiter/uber: export options

Browse Source
This commit is contained in:
maru 2019-03-14 20:19:22 +08:00 committed by Vasiliy Tolstov
parent c021f5b9e8
commit 6806ee4db2
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
uber.go
View File

@ -19,8 +19,8 @@ func (c *clientWrapper) Call(ctx context.Context, req client.Request, rsp interf
} }
// NewClientWrapper creates a blocking side rate limiter // NewClientWrapper creates a blocking side rate limiter
func NewClientWrapper(rate int) client.Wrapper { func NewClientWrapper(rate int, opts ...ratelimit.Option) client.Wrapper {
r := ratelimit.New(rate) r := ratelimit.New(rate, opts...)
return func(c client.Client) client.Client { return func(c client.Client) client.Client {
return &clientWrapper{r, c} return &clientWrapper{r, c}
@ -28,8 +28,8 @@ func NewClientWrapper(rate int) client.Wrapper {
} }
// NewHandlerWrapper creates a blocking server side rate limiter // NewHandlerWrapper creates a blocking server side rate limiter
func NewHandlerWrapper(rate int) server.HandlerWrapper { func NewHandlerWrapper(rate int, opts ...ratelimit.Option) server.HandlerWrapper {
r := ratelimit.New(rate) r := ratelimit.New(rate, opts...)
return func(h server.HandlerFunc) server.HandlerFunc { return func(h server.HandlerFunc) server.HandlerFunc {
return func(ctx context.Context, req server.Request, rsp interface{}) error { return func(ctx context.Context, req server.Request, rsp interface{}) error {