TraefikRateLimiter

README

TraefikRateLimiter

URL-level fixed-window rate limiting middleware for Traefik (current implementation uses Redis).

English · 中文

---

Overview

TraefikRateLimiter is a Traefik middleware plugin that enforces URL-level fixed-window rate limits by path and client IP. The current code path uses a Redis counter backend and can optionally emit X-RateLimit-* headers for access log integration.

Current Configuration Constraints (Code-Accurate)

Field	Required	Notes
ipStrategy	Yes	Object is required; if header is empty, defaults to X-Forwarded-For
redis	Yes	Object is required; middleware init fails when missing
redis.addr	Yes	Redis address, e.g. 127.0.0.1:6379
redis.timeout	Yes	Go duration string, e.g. 1s
default	Yes	Fallback rate limit for unmatched requests
default.requests	Yes	Must be > 0
default.period	Yes	Go duration string and must be >= 1s
rules[]	No	Optional list; when present, each rule must be complete
rules[].name	Yes	Rule identifier, part of rate-limit key
rules[].path	Yes	Match path
rules[].matchType	Yes	exact or prefix
rules[].requests	Yes	Must be > 0
rules[].period	Yes	Go duration string and must be >= 1s
addHeaders	No	Default is false; set true to write rate-limit headers

Duration fields are parsed by time.ParseDuration. Use values like 1s, 1m, 1h.

Installation

Option A: Local Plugin

Place this repository in Traefik local plugin path:

/plugins-local/src/github.com/OVINC-CN/TraefikRateLimiter/

Register it in static Traefik config:

experimental:
  localPlugins:
    traefikratelimiter:
      moduleName: github.com/OVINC-CN/TraefikRateLimiter

Option B: Plugin Catalog

experimental:
  plugins:
    traefikratelimiter:
      moduleName: github.com/OVINC-CN/TraefikRateLimiter
      version: v0.1.0

Dynamic Configuration Example

http:
  middlewares:
    my-ratelimit:
      plugin:
        traefikratelimiter:
          addHeaders: true
          ipStrategy:
            header: "X-Forwarded-For"
            depth: 0
            trustedHeaders:
              - "X-Real-IP"
          redis:
            addr: "127.0.0.1:6379"
            password: ""
            db: 0
            keyPrefix: "rl:"
            timeout: "1s"
          default:
            requests: 100
            period: "1m"
          rules:
            - name: "login"
              path: "/api/v1/login"
              matchType: "exact"
              methods: ["POST"]
              requests: 5
              period: "1m"
            - name: "api-prefix"
              path: "/api/"
              matchType: "prefix"
              requests: 60
              period: "10s"

Rate-Limit Behavior

1. Rules are matched in order; the first matched rule is used.
2. If no rule matches, default is used.
3. Counter key format: {ruleName}|{ip}|{normalizedPath}|{windowIndex}.

normalizedPath reduces key cardinality by normalizing dynamic segments:

• /orders/123 -> /orders/:int
• /orders/18446744073709551615 -> /orders/:u64id
• /trace/550e8400-e29b-41d4-a716-446655440000 -> /trace/:uuid
• /token/<64-hex> -> /token/:hex64

Response Headers

Headers below are written only when addHeaders: true:

Header	Meaning
X-RateLimit-Used	Used requests in current window (integer)
X-RateLimit-Remaining	Remaining requests in current window (integer)
X-RateLimit-RetryAfter	Seconds until reset (integer)
X-RateLimit-Total	Window quota for current rule (integer)
X-RateLimit-Period	Rule period in seconds (integer)
X-RateLimit-Key	Full key used for this request

When limited, response is 429 with:

• Retry-After: <seconds>
• JSON body: {"error_code":"RATE_LIMITED","error_msg":"请求过于频繁，请 X 秒后重试"}

When Redis/store fails, response is 500:

{"error_code":"RATE_LIMIT_STORE_ERROR","error_msg":"限流异常，请稍后重试"}

Access Log Integration (Static Config)

accessLog:
  filePath: "/var/log/traefik/access.log"
  format: json
  fields:
    headers:
      defaultMode: drop
      names:
        X-RateLimit-Key: keep
        X-RateLimit-Used: keep
        X-RateLimit-Remaining: keep
        X-RateLimit-RetryAfter: keep
        X-RateLimit-Total: keep
        X-RateLimit-Period: keep

Development

go vet ./...
go build ./...
go test ./...

License

MIT © OVINC

Documentation

Index

• func CreateConfig() *config.Config
• func New(ctx context.Context, next http.Handler, cfg *config.Config, name string) (http.Handler, error)

Functions

func CreateConfig

func CreateConfig() *config.Config

func New

func New(ctx context.Context, next http.Handler, cfg *config.Config, name string) (http.Handler, error)