plugin

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

type GatewayResponse struct {
	Code int    `json:"code"`
	Msg  string `json:"msg"`
	Data any    `json:"data"`
}

type Limiter struct {
	WhiteList                *Set[string]                // 白名单
	BlackList                *Set[string]                // 黑名单
	RejectList               *RejectList                 // 封禁名单
	AddToRejectList          bool                        // 超过阈值的IP加入到限制列表
	RejectTTL                int64                       // 限制访问的时间
	BlockSeconds             int64                       // 封禁时长，秒，0-不封禁
	RequestNumPerSecond      int                         // 限制请求数
	RequestNumPerSecondPerIp int                         // 限制请求数
	WindowsNum               int                         // 样本窗口个数
	Counter                  *WindowLeapArray            // 滑动时间窗口计数
	CounterMu                sync.Mutex                  // 全局锁
	IpCounter                map[string]*WindowLeapArray // 滑动时间窗口计数，基于IP
	IpCounterMu              []*sync.Mutex
}

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

type Router struct {
	LastUpdate            time.Time
	Expire                time.Duration
	ServiceStatus         uint8
	ServiceMap            ServiceMapType
	ServiceMapCache       ServiceMapType
	GetServiceNameFun     func(string) string
	TargetPathFunc        func(Service, string) (*url.URL, error)
	BalanceType           uint8
	BalanceTypeData       map[string]int // 负载均衡相关数据
	EnableServiceDiscover bool           // 启动服务发现
	// contains filtered or unexported fields
}

type Service struct {
	Host   string `json:"host"`
	Port   string `json:"port"`
	Weight int    `json:"weight"`
}

type ServiceMapType map[string][]Service

type Set[T comparable] struct {
	// contains filtered or unexported fields
}

type WindowLeapArray struct {
	Arr          []int // 窗口数据
	Front        int   // 游标
	FrontTime    int64 // 游标最新时间
	WindowStatus bool  // 窗口状态，true 为 拒绝访问
}