limiter

Documentation

Index

• func StreamServerInterceptor(limiter Limiter, matchers ...selector.Matcher) grpc.StreamServerInterceptor
• func UnaryServerInterceptor(limiter Limiter, matchers ...selector.Matcher) grpc.UnaryServerInterceptor
• type Limiter
  • func Chain(limiters ...Limiter) Limiter

Functions

func StreamServerInterceptor

func StreamServerInterceptor(limiter Limiter, matchers ...selector.Matcher) grpc.StreamServerInterceptor

StreamServerInterceptor returns a new streaming server interceptor that performs rate limiting on the request. If no matchers are provided, the limiter will apply to all requests. If matchers are provided, the limiter will only apply to requests that match at least one of the matchers.

func UnaryServerInterceptor

func UnaryServerInterceptor(limiter Limiter, matchers ...selector.Matcher) grpc.UnaryServerInterceptor

UnaryServerInterceptor returns a new unary server interceptor that performs rate limiting on the request. If no matchers are provided, the limiter will apply to all requests. If matchers are provided, the limiter will only apply to requests that match at least one of the matchers.

Types

type Limiter

type Limiter func(ctx context.Context) error

Limiter is a function that returns a context and error

func Chain

func Chain(limiters ...Limiter) Limiter

Chain returns a Limiter that executes each limiter in sequence. If any of the limiters returns an error, the chain stops executing and returns that error.