limiter

Documentation

Overview

https://juejin.cn/post/7056068978862456846

Index

• func LimitFlowAllow()
• func LimitFlowReserve()
• func LimitFlowWait()
• type Clock
• type FixedWindowLimiter
  • func NewFixWindowLimiter(limit int, window time.Duration) *FixedWindowLimiter
  • func (l *FixedWindowLimiter) TryAcquire() bool
• type LeakyBucketLimiter
  • func NewLeakyBucketLimit(peakLevel, currentVelocy int) *LeakyBucketLimiter
  • func (l *LeakyBucketLimiter) TryAcquire() bool
• type Limiter
• type Option
• type SlidingWindowLimiter
  • func NewSlidingWindowLimiter(limit int, window time.Duration, smallWindow time.Duration) (*SlidingWindowLimiter, error)
  • func (l *SlidingWindowLimiter) TryAcquire() bool
• type TokenBucketLimiter
  • func NewTokenBucketLimiter(capacity, rate int) *TokenBucketLimiter
  • func (l *TokenBucketLimiter) TryAcquire() bool

Functions

func LimitFlowAllow

func LimitFlowAllow()

limit flow golang rate

func LimitFlowReserve

func LimitFlowReserve()

func LimitFlowWait

func LimitFlowWait()

Types

type Clock

type Clock interface {
	Now() time.Time
	Sleep(time.Duration)
}

type FixedWindowLimiter

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

func NewFixWindowLimiter

func NewFixWindowLimiter(limit int, window time.Duration) *FixedWindowLimiter

func (*FixedWindowLimiter) TryAcquire

func (l *FixedWindowLimiter) TryAcquire() bool

type LeakyBucketLimiter

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

func NewLeakyBucketLimit

func NewLeakyBucketLimit(peakLevel, currentVelocy int) *LeakyBucketLimiter

func (*LeakyBucketLimiter) TryAcquire

func (l *LeakyBucketLimiter) TryAcquire() bool

type Limiter

type Limiter interface {
	Take() time.Time
}

type Option

type Option interface {
	// contains filtered or unexported methods
}

type SlidingWindowLimiter

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

func NewSlidingWindowLimiter

func NewSlidingWindowLimiter(limit int, window time.Duration, smallWindow time.Duration) (*SlidingWindowLimiter, error)

func (*SlidingWindowLimiter) TryAcquire

func (l *SlidingWindowLimiter) TryAcquire() bool

type TokenBucketLimiter

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

func NewTokenBucketLimiter

func NewTokenBucketLimiter(capacity, rate int) *TokenBucketLimiter

func (*TokenBucketLimiter) TryAcquire

func (l *TokenBucketLimiter) TryAcquire() bool