ratelimit

Documentation

Index

• func StreamServerInterceptor(cfg *Config, cache *ristretto.Cache, limiterID LimiterID) grpc.StreamServerInterceptor
• func UnaryServerInterceptor(cfg *Config, cache *ristretto.Cache, limiterID LimiterID) grpc.UnaryServerInterceptor
• type Config
• type LimiterID

Functions

func StreamServerInterceptor

func StreamServerInterceptor(cfg *Config, cache *ristretto.Cache, limiterID LimiterID) grpc.StreamServerInterceptor

StreamServerInterceptor for ratelimit.

func UnaryServerInterceptor

func UnaryServerInterceptor(cfg *Config, cache *ristretto.Cache, limiterID LimiterID) grpc.UnaryServerInterceptor

UnaryServerInterceptor for ratelimit.

Types

type Config

type Config struct {
	Every time.Duration `yaml:"every"`
	Burst uint          `yaml:"burst"`
	TTL   time.Duration `yaml:"ttl"`
}

Config for ratelimit.

type LimiterID

type LimiterID func(ctx context.Context) string

LimiterID to find the correct limiter. This way we can segment limiters by different ids.