ratelimit

README

rate-limiter-grpc-go

grpc-go interceptor that can limit grpc requests both client and server. Limiter allow requests only if the number of requests per second is less than the specified number.

Usage

• client

// allow two requests per seconds
conn, err := grpc.Dial(address,grpc.WithUnaryInterceptor(ratelimit.UnaryClientInterceptor(ratelimit.NewLimiter(2))))
...
client := pb.NewService(conn)

• server

receive request at 1586597159
receive request at 1586597159
receive request at 1586597160
receive request at 1586597160
receive request at 1586597161
receive request at 1586597161
receive request at 1586597162
receive request at 1586597162
receive request at 1586597163
receive request at 1586597163

LICENSE

MIT

Documentation

Index

• func NewLimiter(count int) grpc_ratelimit.Limiter
• func StreamClientInterceptor(limiter grpc_ratelimit.Limiter) grpc.StreamClientInterceptor
• func StreamServerInterceptor(limiter grpc_ratelimit.Limiter) grpc.StreamServerInterceptor
• func UnaryClientInterceptor(limiter grpc_ratelimit.Limiter) grpc.UnaryClientInterceptor
• func UnaryServerInterceptor(limiter grpc_ratelimit.Limiter) grpc.UnaryServerInterceptor

Functions

func NewLimiter

func NewLimiter(count int) grpc_ratelimit.Limiter

NewLimiter return new go-grpc Limiter, specified the number of requests you want to limit as a counts per second.

func StreamClientInterceptor

func StreamClientInterceptor(limiter grpc_ratelimit.Limiter) grpc.StreamClientInterceptor

StreamServerInterceptor return stream server unary interceptor that limit requests.

func StreamServerInterceptor

func StreamServerInterceptor(limiter grpc_ratelimit.Limiter) grpc.StreamServerInterceptor

StreamServerInterceptor return stream server unary interceptor that limit requests.

func UnaryClientInterceptor

func UnaryClientInterceptor(limiter grpc_ratelimit.Limiter) grpc.UnaryClientInterceptor

UnaryServerInterceptor return server unary interceptor that limit requests.

func UnaryServerInterceptor

func UnaryServerInterceptor(limiter grpc_ratelimit.Limiter) grpc.UnaryServerInterceptor

UnaryServerInterceptor return server unary interceptor that limit requests.