ratelimiter

Jun 16, 2022

Changes in this version

+ type Events struct

+ Hit *event.Event[*HitEvent]

+ type HitEvent struct

+ Peer *peer.Peer

+ RateLimit *RateLimit

type PeerRateLimiter

+ Events *Events

Feb 11, 2022

Changes in this version

+ type PeerRateLimiter struct

+ func NewPeerRateLimiter(interval time.Duration, baseLimit int, log *logger.Logger) (*PeerRateLimiter, error)

+ func (prl *PeerRateLimiter) Close()

+ func (prl *PeerRateLimiter) Count(p *peer.Peer)

+ func (prl *PeerRateLimiter) ExtendLimit(p *peer.Peer)

+ func (prl *PeerRateLimiter) HitEvent() *events.Event

+ func (prl *PeerRateLimiter) SetBaseLimit(limit int)

+ type RateLimit struct

+ Interval time.Duration

+ Limit int

+ func (rl RateLimit) String() string