ratelimit

Documentation

Index

• func ReadSeeker(rs io.ReadSeeker, l *Limiter) io.ReadSeeker
• func Reader(r io.Reader, l *Limiter) io.Reader
• func Writer(w io.Writer, l *Limiter) io.Writer
• type Limiter
  • func New(rate int64) *Limiter
  • func (l *Limiter) Wait(count int)

Functions

func ReadSeeker

func ReadSeeker(rs io.ReadSeeker, l *Limiter) io.ReadSeeker

ReadSeeker 返回一个带有Limiter的io.ReadSeeker

func Reader

func Reader(r io.Reader, l *Limiter) io.Reader

Reader 返回一个带有Limiter的io.Reader

func Writer

func Writer(w io.Writer, l *Limiter) io.Writer

Writer 返回一个带有Limiter的io.Writer

Types

type Limiter

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

Limiter 速度限制器

func New

func New(rate int64) *Limiter

New New rate 速度，rate/每秒

func (*Limiter) Wait

func (l *Limiter) Wait(count int)

Wait 传入需要处理的数量，计算并等待需要经过的时间