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(bytesPerSecond int64) *Limiter
  • func (l *Limiter) NewReadSeeker(r io.ReadSeeker) io.ReadSeeker
  • func (l *Limiter) NewReader(r io.Reader) io.Reader
  • func (l *Limiter) NewWriter(r io.Writer) io.Writer
  • 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(bytesPerSecond int64) *Limiter

New 创建Limiter Usage: limiter := New(100*1024) limiter.NewReader(reader) limiter.NewWriter(writer) limiter.NewReadSeeker(readSeeker)

func (*Limiter) NewReadSeeker

func (l *Limiter) NewReadSeeker(r io.ReadSeeker) io.ReadSeeker

func (*Limiter) NewReader

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

func (*Limiter) NewWriter

func (l *Limiter) NewWriter(r io.Writer) io.Writer

func (*Limiter) Wait

func (l *Limiter) Wait(count int)

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