concurrent_limiter

Documentation

Index

• type ClientQueryLimiter
  • func NewClientQueryLimiter(maxQueries int) *ClientQueryLimiter
  • func (l *ClientQueryLimiter) Acquire(key string) bool
  • func (l *ClientQueryLimiter) Done(key string)
• type ConcurrentLimiter
  • func NewConcurrentLimiter(max int) *ConcurrentLimiter
  • func (l *ConcurrentLimiter) Available() int
  • func (l *ConcurrentLimiter) Done()
  • func (l *ConcurrentLimiter) Wait() <-chan struct{}

Types

type ClientQueryLimiter

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

func NewClientQueryLimiter

func NewClientQueryLimiter(maxQueries int) *ClientQueryLimiter

func (*ClientQueryLimiter) Acquire

func (l *ClientQueryLimiter) Acquire(key string) bool

func (*ClientQueryLimiter) Done

func (l *ClientQueryLimiter) Done(key string)

type ConcurrentLimiter

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

ConcurrentLimiter is a soft limiter.

func NewConcurrentLimiter

func NewConcurrentLimiter(max int) *ConcurrentLimiter

NewConcurrentLimiter returns a ConcurrentLimiter, max must > 0.

func (*ConcurrentLimiter) Available

func (l *ConcurrentLimiter) Available() int

func (*ConcurrentLimiter) Done

func (l *ConcurrentLimiter) Done()

func (*ConcurrentLimiter) Wait

func (l *ConcurrentLimiter) Wait() <-chan struct{}