myratelimit

Documentation

Index

• func WrapWithRateLimit(rw io.ReadWriter, readLimit, writeLimit int64) io.ReadWriter
• type RateLimitedConn
  • func (r *RateLimitedConn) Read(p []byte) (int, error)
  • func (c *RateLimitedConn) ReadFrom(r io.Reader) (int64, error)
  • func (r *RateLimitedConn) Write(p []byte) (int, error)
  • func (r *RateLimitedConn) WriteTo(w io.Writer) (int64, error)

Functions

func WrapWithRateLimit

func WrapWithRateLimit(rw io.ReadWriter, readLimit, writeLimit int64) io.ReadWriter

WrapWithRateLimit 包装 io.ReadWriter，为读写方向添加速率限制。 readLimit 和 writeLimit 单位是字节每秒（Byte/s），若 <= 0 表示该方向不限制。

Types

type RateLimitedConn

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

RateLimitedConn 封装后的限速器，实现 io.ReadWriter 接口

func (*RateLimitedConn) Read

func (r *RateLimitedConn) Read(p []byte) (int, error)

Read 调用限速后的 reader

func (*RateLimitedConn) ReadFrom

func (c *RateLimitedConn) ReadFrom(r io.Reader) (int64, error)

func (*RateLimitedConn) Write

func (r *RateLimitedConn) Write(p []byte) (int, error)

Write 调用限速后的 writer

func (*RateLimitedConn) WriteTo

func (r *RateLimitedConn) WriteTo(w io.Writer) (int64, error)