grpcx_ratelimit

Documentation

Index

• type KeyGetter
• type RateLimitInterceptor
  • func NewRateLimitInterceptor(options ...RateLimitInterceptorOption) *RateLimitInterceptor
  • func (r *RateLimitInterceptor) StreamServerInterceptor(keyGetter KeyGetter) grpc.StreamServerInterceptor
  • func (r *RateLimitInterceptor) UnaryServerInterceptor(keyGetter KeyGetter) grpc.UnaryServerInterceptor
• type RateLimitInterceptorOption
  • func WithMemoryStore(mstore *memrate.MemoryStore) RateLimitInterceptorOption
  • func WithRedisStore(rdb redisrate.Rediser, fn redisrate.LimitFn) RateLimitInterceptorOption

Types

type KeyGetter

type KeyGetter interface {
	GetKey(ctx context.Context, fullMethod string) string
}

type RateLimitInterceptor

type RateLimitInterceptor struct {
	// contains filtered or unexported fields
}

func NewRateLimitInterceptor

func NewRateLimitInterceptor(options ...RateLimitInterceptorOption) *RateLimitInterceptor

func (*RateLimitInterceptor) StreamServerInterceptor

func (r *RateLimitInterceptor) StreamServerInterceptor(keyGetter KeyGetter) grpc.StreamServerInterceptor

func (*RateLimitInterceptor) UnaryServerInterceptor

func (r *RateLimitInterceptor) UnaryServerInterceptor(keyGetter KeyGetter) grpc.UnaryServerInterceptor

type RateLimitInterceptorOption

type RateLimitInterceptorOption func(*RateLimitInterceptor)

func WithMemoryStore

func WithMemoryStore(mstore *memrate.MemoryStore) RateLimitInterceptorOption

func WithRedisStore

func WithRedisStore(rdb redisrate.Rediser, fn redisrate.LimitFn) RateLimitInterceptorOption