limiter_map

Dec 16, 2022

Changes in this version

+ type RateLimiterMap struct

+ func NewLimiterMap(ttl, cleanupInterval time.Duration) *RateLimiterMap

+ func (r *RateLimiterMap) Cleanup()

+ func (r *RateLimiterMap) CleanupLoop()

+ func (r *RateLimiterMap) Close()

+ func (r *RateLimiterMap) Get(peerID peer.ID) (*RateLimiterMetadata, bool)

+ func (r *RateLimiterMap) Remove(peerID peer.ID)

+ func (r *RateLimiterMap) Store(peerID peer.ID, lmtr *rate.Limiter)

+ func (r *RateLimiterMap) UpdateLastRateLimit(peerID peer.ID, lastRateLimit time.Time)

+ type RateLimiterMetadata struct

+ func (m *RateLimiterMetadata) LastAccessed() time.Time

+ func (m *RateLimiterMetadata) LastRateLimit() time.Time

+ func (m *RateLimiterMetadata) Limiter() *rate.Limiter

+ func (m *RateLimiterMetadata) SetLastAccessed(lastAccessed time.Time)

+ func (m *RateLimiterMetadata) SetLastRateLimit(lastRateLimit time.Time)