limiter

Documentation

Index

• func ClearOnlineIP() error
• func DeleteLimiter(tag string)
• func Init()
• func UpdateLimiter(tag string, added []panel.UserInfo, deleted []panel.UserInfo) error
• type ConnLimiter
  • func NewConnLimiter(conn int, ip int, realtime bool) *ConnLimiter
  • func (c *ConnLimiter) AddConnCount(user string, ip string, isTcp bool) (limit bool)
  • func (c *ConnLimiter) ClearOnlineIP()
  • func (c *ConnLimiter) DelConnCount(user string, ip string)
• type Limiter
  • func AddLimiter(tag string, l *conf.LimitConfig, users []panel.UserInfo) *Limiter
  • func GetLimiter(tag string) (info *Limiter, err error)
  • func (l *Limiter) AddDynamicSpeedLimit(tag string, userInfo *panel.UserInfo, limitNum int, expire int64) error
  • func (l *Limiter) CheckDomainRule(destination string) (reject bool)
  • func (l *Limiter) CheckLimit(email string, ip string, isTcp bool) (Bucket *ratelimit.Bucket, Reject bool)
  • func (l *Limiter) CheckProtocolRule(protocol string) (reject bool)
  • func (l *Limiter) UpdateRule(newRuleList []*regexp.Regexp) error
• type UserIpList
• type UserLimitInfo

Functions

func ClearOnlineIP

func ClearOnlineIP() error

func DeleteLimiter

func DeleteLimiter(tag string)

func Init

func Init()

func UpdateLimiter

func UpdateLimiter(tag string, added []panel.UserInfo, deleted []panel.UserInfo) error

Types

type ConnLimiter

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

func NewConnLimiter

func NewConnLimiter(conn int, ip int, realtime bool) *ConnLimiter

func (*ConnLimiter) AddConnCount

func (c *ConnLimiter) AddConnCount(user string, ip string, isTcp bool) (limit bool)

func (*ConnLimiter) ClearOnlineIP

func (c *ConnLimiter) ClearOnlineIP()

ClearOnlineIP Clear udp,icmp and other packet protocol online ip

func (*ConnLimiter) DelConnCount

func (c *ConnLimiter) DelConnCount(user string, ip string)

DelConnCount Delete tcp connection count, no tcp do not use

type Limiter

type Limiter struct {
	Rules         []*regexp.Regexp
	ProtocolRules []string
	SpeedLimit    int
	UserLimitInfo *sync.Map    // Key: Uid value: UserLimitInfo
	ConnLimiter   *ConnLimiter // Key: Uid value: ConnLimiter
	SpeedLimiter  *sync.Map    // key: Uid, value: *ratelimit.Bucket
}

func AddLimiter

func AddLimiter(tag string, l *conf.LimitConfig, users []panel.UserInfo) *Limiter

func GetLimiter

func GetLimiter(tag string) (info *Limiter, err error)

func (*Limiter) AddDynamicSpeedLimit

func (l *Limiter) AddDynamicSpeedLimit(tag string, userInfo *panel.UserInfo, limitNum int, expire int64) error

func (*Limiter) CheckDomainRule

func (l *Limiter) CheckDomainRule(destination string) (reject bool)

func (*Limiter) CheckLimit

func (l *Limiter) CheckLimit(email string, ip string, isTcp bool) (Bucket *ratelimit.Bucket, Reject bool)

func (*Limiter) CheckProtocolRule

func (l *Limiter) CheckProtocolRule(protocol string) (reject bool)

func (*Limiter) UpdateRule

func (l *Limiter) UpdateRule(newRuleList []*regexp.Regexp) error

type UserIpList

type UserIpList struct {
	Uid    int      `json:"Uid"`
	IpList []string `json:"Ips"`
}

type UserLimitInfo

type UserLimitInfo struct {
	UID               int
	SpeedLimit        int
	DynamicSpeedLimit int
	ExpireTime        int64
}