throttle

Documentation

Index

• type Clock
• type SharedRateLimiter
  • func (srl *SharedRateLimiter) LimitRate(client string)
  • func (srl *SharedRateLimiter) Stop() error

Types

type Clock

type Clock interface {
	Now() time.Time
	After(d time.Duration) <-chan time.Time
}

Clock observes time

type SharedRateLimiter

type SharedRateLimiter struct {
	// Time is how this rate limiter observes time
	Time Clock
	// Limit is the total limit of throughput for all clients
	Limit int
	// InactivityTimeout is the inactivity time after which a client is pruned from memory
	InactivityTimeout time.Duration
	// contains filtered or unexported fields
}

func (*SharedRateLimiter) LimitRate

func (srl *SharedRateLimiter) LimitRate(client string)

func (*SharedRateLimiter) Stop

func (srl *SharedRateLimiter) Stop() error

Stop stops the shared rate limiter. Not thread safe.