limit

Documentation

Overview

Example

Index

• func MultiLimiter(limiters ...RateLimiter) *multiLimiter
• func Per(eventCount int, duration time.Duration) rate.Limit
• type RateLimiter

Examples

• Package
• MultiLimiter

Functions

func MultiLimiter

func MultiLimiter(limiters ...RateLimiter) *multiLimiter

MultiLimiter 混合多个限流桶

Example

defer log.Println("Done")
apiConn := Open()
var wg sync.WaitGroup
wg.Add(20)
for i := 0; i < 10; i++ {
	go func() {
		defer wg.Done()
		if err := apiConn.ReadFile(context.Background()); err != nil {
			log.Println("cannot read file:", err)
			return
		}
		log.Println("read file")
	}()
}
for i := 0; i < 10; i++ {
	go func() {
		defer wg.Done()
		if err := apiConn.ResolveAddress(context.Background()); err != nil {
			log.Println("cannot resolve address:", err)
			return
		}
		log.Println("ResolveAddress")
	}()
}
wg.Wait()

func Per

func Per(eventCount int, duration time.Duration) rate.Limit

Per 返回速率为 每duration,eventCount个请求

Types

type RateLimiter

type RateLimiter interface {
	Wait(ctx context.Context) error // 阻塞等待
	Limit() rate.Limit
}

RateLimiter 限流接口