/
req_rate_limiting.go
44 lines (37 loc) ยท 1.06 KB
/
req_rate_limiting.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
package serverplugin
import (
"context"
"time"
"github.com/juju/ratelimit"
"github.com/smallnest/rpcx/protocol"
"github.com/smallnest/rpcx/server"
)
// ReqRateLimitingPlugin can limit requests per unit time
type ReqRateLimitingPlugin struct {
FillInterval time.Duration
Capacity int64
bucket *ratelimit.Bucket
block bool // blocks or return error if reach the limit
}
// NewReqRateLimitingPlugin creates a new RateLimitingPlugin
func NewReqRateLimitingPlugin(fillInterval time.Duration, capacity int64, block bool) *ReqRateLimitingPlugin {
tb := ratelimit.NewBucket(fillInterval, capacity)
return &ReqRateLimitingPlugin{
FillInterval: fillInterval,
Capacity: capacity,
bucket: tb,
block: block,
}
}
// PostReadRequest can limit request processing.
func (plugin *ReqRateLimitingPlugin) PostReadRequest(ctx context.Context, r *protocol.Message, e error) error {
if plugin.block {
plugin.bucket.Wait(1)
return nil
}
count := plugin.bucket.TakeAvailable(1)
if count == 1 {
return nil
}
return server.ErrReqReachLimit
}