ratelimit

Documentation

Index

• func StreamServerInterceptor(limiter Limiter) grpc.StreamServerInterceptor
• func UnaryServerInterceptor(limiter Limiter) grpc.UnaryServerInterceptor
• type Limiter

Functions

func StreamServerInterceptor

func StreamServerInterceptor(limiter Limiter) grpc.StreamServerInterceptor

StreamServerInterceptor returns a new stream server interceptor that performs rate limiting on the request.

func UnaryServerInterceptor

func UnaryServerInterceptor(limiter Limiter) grpc.UnaryServerInterceptor

UnaryServerInterceptor returns a new unary server interceptors that performs request rate limiting.

Types

type Limiter

type Limiter interface {
	Allow() bool
	AllowFor(timeout time.Duration) bool
	Put() bool
}