middleware

Documentation

Index

• Constants
• Variables
• func BlacklistChecker(c *fiber.Ctx) bool
• func CacheStats() map[string]any
• func CheckBlacklist(asAPI bool) fiber.Handler
• func CheckPathOr404() fiber.Handler
• func CheckWhitelist(asAPI bool) fiber.Handler
• func CheckWhitelistAnd(checker ForbiddenChecker, asAPI bool) fiber.Handler
• func CheckWhitelistOr(checker ForbiddenChecker, asAPI bool) fiber.Handler
• func CounterStats() map[string]any
• func DefaultLogCondition(c *fiber.Ctx, elapsed time.Duration) bool
• func HTTPCounter(name string) fiber.Handler
• func PurgeBlacklistCache()
• func PurgeWhitelistCache()
• func RecoverLogger() fiber.Handler
• func ResetStatistics()
• func UseBlacklistCache(capacity, lifetime uint32) error
• func UseWhitelistCache(capacity, lifetime uint32) error
• func WebLogger(cond LogCondition) fiber.Handler
• func WhitelistChecker(c *fiber.Ctx) bool
• func WithTimeout(dur time.Duration, timeoutErrors ...error) fiber.Handler
• func WithTimeoutDefault(timeoutErrors ...error) fiber.Handler
• type ForbiddenChecker
• type LogCondition
• type RequestsLimiter
  • func NewDefaultRequestsLimiter() *RequestsLimiter
  • func NewRequestsLimiter(limit int32, limitReached fiber.Handler) *RequestsLimiter
  • func (r *RequestsLimiter) Allow() bool
  • func (r *RequestsLimiter) Handler() fiber.Handler
  • func (r *RequestsLimiter) Limit() int32
  • func (r *RequestsLimiter) Limited() uint64
  • func (r *RequestsLimiter) Remaining() int32
  • func (r *RequestsLimiter) Running() int32
  • func (r *RequestsLimiter) SetLimit(n int32)
  • func (r *RequestsLimiter) Stats() map[string]int

Constants

const (
	XRateLimitLimit     = "X-RateLimit-Limit"
	XRateLimitRemaining = "X-RateLimit-Remaining"
	XRateLimitReset     = "X-RateLimit-Reset"
)

Variables

var (
	// DefaultLimitMessage 触发限制时的 429 消息
	DefaultLimitMessage = "处理中的请求数过多"

	// DefaultLimitReached 达到限制时执行的 Hook
	DefaultLimitReached = func(c *fiber.Ctx) error {
		return response.APIException(c, http.StatusTooManyRequests, DefaultLimitMessage, nil)
	}
)

Functions

func BlacklistChecker

func BlacklistChecker(c *fiber.Ctx) bool

BlacklistChecker 是否存在于黑名单, true 是黑名单 (黑名单为空时: 放过, false)

func CacheStats

func CacheStats() map[string]any

func CheckBlacklist

func CheckBlacklist(asAPI bool) fiber.Handler

CheckBlacklist 接口黑名单检查

func CheckPathOr404

func CheckPathOr404() fiber.Handler

CheckPathOr404 检查 URL 是否为配置中的路由

func CheckWhitelist

func CheckWhitelist(asAPI bool) fiber.Handler

CheckWhitelist 接口白名单检查

func CheckWhitelistAnd

func CheckWhitelistAnd(checker ForbiddenChecker, asAPI bool) fiber.Handler

CheckWhitelistAnd 同时校验接口白名单和自定义检查器

func CheckWhitelistOr

func CheckWhitelistOr(checker ForbiddenChecker, asAPI bool) fiber.Handler

CheckWhitelistOr 校验接口白名单或自定义检查器

func CounterStats

func CounterStats() map[string]any

func DefaultLogCondition

func DefaultLogCondition(c *fiber.Ctx, elapsed time.Duration) bool

func HTTPCounter

func HTTPCounter(name string) fiber.Handler

HTTPCounter 请求简单计数

func PurgeBlacklistCache

func PurgeBlacklistCache()

PurgeBlacklistCache 配置项变化时需要清空缓存, 由应用端在 Runtime() 调用

func PurgeWhitelistCache

func PurgeWhitelistCache()

PurgeWhitelistCache 配置项变化时需要清空缓存, 由应用端在 Runtime() 调用

func RecoverLogger

func RecoverLogger() fiber.Handler

RecoverLogger Recover 并记录日志

func ResetStatistics

func ResetStatistics()

ResetStatistics 重置统计数据

func UseBlacklistCache

func UseBlacklistCache(capacity, lifetime uint32) error

UseBlacklistCache 重新设置黑名单检查时缓存, 配置变化时可选再次调用, 由应用端 Start() Runtime() 调用

func UseWhitelistCache

func UseWhitelistCache(capacity, lifetime uint32) error

UseWhitelistCache 重新设置白名单检查时缓存, 配置变化时可选再次调用, 由应用端 Start() Runtime() 调用

func WebLogger

func WebLogger(cond LogCondition) fiber.Handler

WebLogger Web 日志

func WhitelistChecker

func WhitelistChecker(c *fiber.Ctx) bool

WhitelistChecker 是否通过了白名单检查, true 是白名单 (白名单为空时: 通过, true)

func WithTimeout

func WithTimeout(dur time.Duration, timeoutErrors ...error) fiber.Handler

WithTimeout 附加超时上下文, Handler 需要使用 <-ctx.UserContext().Done

func WithTimeoutDefault

func WithTimeoutDefault(timeoutErrors ...error) fiber.Handler

Types

type ForbiddenChecker

type ForbiddenChecker = func(*fiber.Ctx) bool

type LogCondition

type LogCondition func(c *fiber.Ctx, elapsed time.Duration) bool

LogCondition 日志记录条件计算器

type RequestsLimiter

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

RequestsLimiter 同时处理的请求数限制 请求处理中 +1, 请求已返回: -1 请求超限返回 429 错误

func NewDefaultRequestsLimiter

func NewDefaultRequestsLimiter() *RequestsLimiter

NewDefaultRequestsLimiter 使用配置文件参数创建限制器 app.Use(middleware.NewDefaultRequestsLimiter().Handler())

func NewRequestsLimiter

func NewRequestsLimiter(limit int32, limitReached fiber.Handler) *RequestsLimiter

func (*RequestsLimiter) Allow

func (r *RequestsLimiter) Allow() bool

func (*RequestsLimiter) Handler

func (r *RequestsLimiter) Handler() fiber.Handler

func (*RequestsLimiter) Limit

func (r *RequestsLimiter) Limit() int32

func (*RequestsLimiter) Limited

func (r *RequestsLimiter) Limited() uint64

func (*RequestsLimiter) Remaining

func (r *RequestsLimiter) Remaining() int32

func (*RequestsLimiter) Running

func (r *RequestsLimiter) Running() int32

func (*RequestsLimiter) SetLimit

func (r *RequestsLimiter) SetLimit(n int32)

func (*RequestsLimiter) Stats

func (r *RequestsLimiter) Stats() map[string]int