ratelimit

type APIKeyExtractor struct{}

type Algorithm interface {
	// Allow checks if a request is allowed
	// Returns:
	//   - allowed: whether the request is allowed
	//   - remaining: remaining requests/tokens
	//   - resetTime: when the rate limit will reset
	//   - err: any error that occurred
	Allow(ctx context.Context, storage Storage, key string, limit int64, window time.Duration, burst int64) (allowed bool, remaining int64, resetTime time.Time, err error)
}

type AlgorithmFactory struct{}

type ClientIDExtractor struct{}

type ExtractorFactory struct{}

type FixedWindowAlgorithm struct{}

type HeaderExtractor struct {
	HeaderName string
}

type IPExtractor struct{}

type KeyExtractor interface {
	Extract(ctx *zoox.Context, req *http.Request) (string, error)
}

type LeakyBucketAlgorithm struct{}

type RateLimit struct {
	plugin.Plugin
	// contains filtered or unexported fields
}

type Storage interface {
	Allow(ctx context.Context, key string, limit int64, window time.Duration) (allowed bool, remaining int64, resetTime time.Time, err error)
	Reset(ctx context.Context, key string) error
	Close() error

	// LoadState / SaveState persist token-bucket and leaky-bucket state in Application.Cache().
	// kind is "tb" or "lb"; key is the same logical client key used by extractors.
	LoadState(ctx context.Context, kind, key string, dest interface{}) error
	SaveState(ctx context.Context, kind, key string, src interface{}, ttl time.Duration) error
}

type TokenBucketAlgorithm struct{}

type UserExtractor struct{}