rateio

Documentation

Overview

rate limit and traffic control

Index

• Variables
• func NewRateReader(r io.Reader, ratePerSecond int) io.ReadCloser
• func NewRateWriter(w io.Writer, ratePerSecond int) io.WriteCloser
• type Controller
  • func NewController(ratePerSecond int) *Controller
  • func (self *Controller) Close() error
  • func (self *Controller) GetRateLimit() int
  • func (self *Controller) Reader(underlying io.Reader) io.Reader
  • func (self *Controller) Writer(underlying io.Writer) io.Writer

Variables

var Window = 50 * time.Millisecond

Functions

func NewRateReader

func NewRateReader(r io.Reader, ratePerSecond int) io.ReadCloser

func NewRateWriter

func NewRateWriter(w io.Writer, ratePerSecond int) io.WriteCloser

Types

type Controller

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

Controller can limit multiple io.Reader(or io.Writer) within specific rate.

func NewController

func NewController(ratePerSecond int) *Controller

func (*Controller) Close

func (self *Controller) Close() error

func (*Controller) GetRateLimit

func (self *Controller) GetRateLimit() int

func (*Controller) Reader

func (self *Controller) Reader(underlying io.Reader) io.Reader

func (*Controller) Writer

func (self *Controller) Writer(underlying io.Writer) io.Writer