limiters

Documentation

Index

• Variables
• func NewDiskLimitReader(r io.Reader) io.Reader
• func NewNetworkLimitReader(r io.Reader) io.Reader
• type Reader
  • func NewReader(reader io.Reader, limiter *rate.Limiter) *Reader
  • func (r *Reader) Read(buf []byte) (int, error)

Variables

var DiskLimiter *rate.Limiter

var NetworkLimiter *rate.Limiter

Functions

func NewDiskLimitReader

func NewDiskLimitReader(r io.Reader) io.Reader

NewDiskLimitReader returns a reader that is rate limited by disk limiter

func NewNetworkLimitReader

func NewNetworkLimitReader(r io.Reader) io.Reader

NewNetworkLimitReader returns a reader that is rate limited by network limiter

Types

type Reader

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

func NewReader

func NewReader(reader io.Reader, limiter *rate.Limiter) *Reader

func (*Reader) Read

func (r *Reader) Read(buf []byte) (int, error)