timewindow

Documentation

Index

• func NewSlideTimeWindowLimiter(throughput int, duration time.Duration, windowBuckets int) (ratelimit.Limiter, error)
• type SlideTimeWindowLimiter
  • func (s *SlideTimeWindowLimiter) Count() int
  • func (s *SlideTimeWindowLimiter) Take(ctx context.Context) (bool, error)
  • func (r *SlideTimeWindowLimiter) Wait(ctx context.Context) (err error)

Functions

func NewSlideTimeWindowLimiter

func NewSlideTimeWindowLimiter(throughput int, duration time.Duration, windowBuckets int) (ratelimit.Limiter, error)

Types

type SlideTimeWindowLimiter

type SlideTimeWindowLimiter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

nolint: govet

func (*SlideTimeWindowLimiter) Count

func (s *SlideTimeWindowLimiter) Count() int

func (*SlideTimeWindowLimiter) Take

func (s *SlideTimeWindowLimiter) Take(ctx context.Context) (bool, error)

func (*SlideTimeWindowLimiter) Wait

func (r *SlideTimeWindowLimiter) Wait(ctx context.Context) (err error)

wait until take a token or timeout