limiter

Nov 11, 2024

Changes in this version

+ type IPLimit struct

+ Enable bool

+ Expiry int

+ RedisAddr string

+ RedisDB int

+ RedisNetwork string

+ RedisPassword string

+ RedisUsername string

+ Timeout int

+ type InboundInfo struct

+ BucketHub *sync.Map

+ GlobalIPLimit struct{}

+ NodeSpeedLimit uint64

+ SubscriptionInfo *sync.Map

+ SubscriptionOnlineIP *sync.Map

+ Tag string

+ type Limiter struct

+ InboundInfo *sync.Map

+ func New() *Limiter

+ func (l *Limiter) AddInboundLimiter(tag string, nodeSpeedLimit uint64, serviceList *[]api.SubscriptionInfo, ...) error

+ func (l *Limiter) DeleteInboundLimiter(tag string) error

+ func (l *Limiter) GetOnlineDevice(tag string) (*[]api.OnlineIP, error)

+ func (l *Limiter) GetUserBucket(tag string, email string, ip string) (limiter *rate.Limiter, SpeedLimit bool, Reject bool)

+ func (l *Limiter) RateWriter(writer buf.Writer, limiter *rate.Limiter) buf.Writer

+ func (l *Limiter) UpdateInboundLimiter(tag string, updatedServiceList *[]api.SubscriptionInfo) error

+ type SubscriptionInfo struct

+ DeviceLimit int

+ SpeedLimit uint64

+ UID int

+ type Writer struct

+ func (w *Writer) Close() error

+ func (w *Writer) WriteMultiBuffer(mb buf.MultiBuffer) error