middleware

Documentation

Index

• Variables
• func AsynqTaskTracerMiddleware(h asynq.Handler) asynq.Handler
• type RedisIPRateLimiter
  • func NewRedisIPRateLimiter(redisClient *redis.Client, rate limiter.Rate, excludedIPs []string, ...) (redisLimiter RedisIPRateLimiter, err error)
  • func (r RedisIPRateLimiter) Limit() echo.MiddlewareFunc

Variables

var PrivateIPAddressRegex = regexp.MustCompile(`(10(?:\\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)){3}$)|(192\\.168(?:\\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)){2}$)|(172\\.(?:1[6-9]|2\\d|3[0-1])(?:\\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)){2}$)`)

PrivateIPAddressRegex for detects a valid IP address

Functions

func AsynqTaskTracerMiddleware

func AsynqTaskTracerMiddleware(h asynq.Handler) asynq.Handler

AsynqTaskTracerMiddleware tracer for asynq task, place this middleware on mux

Types

type RedisIPRateLimiter

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

RedisIPRateLimiter is the redis store that implements IP Based rate limiter

func NewRedisIPRateLimiter

func NewRedisIPRateLimiter(redisClient *redis.Client, rate limiter.Rate, excludedIPs []string, excludedUserAgents []string) (redisLimiter RedisIPRateLimiter, err error)

NewRedisIPRateLimiter initializes RedisIPRateLimiter

func (RedisIPRateLimiter) Limit

func (r RedisIPRateLimiter) Limit() echo.MiddlewareFunc

Limit limit request by IP