ratelimitedconn

Documentation

Index

• type Limiter
• type RateLimitedConn
  • func NewRateLimitedConn(conn net.Conn, bandwidthLimiter Limiter, logger commontypes.Logger) *RateLimitedConn
  • func (r *RateLimitedConn) EnableRateLimiting()
  • func (r *RateLimitedConn) Read(b []byte) (n int, err error)

Types

type Limiter

type Limiter interface {
	Allow(n int) bool
}

type RateLimitedConn

type RateLimitedConn struct {
	net.Conn
	// contains filtered or unexported fields
}

TODO: would it make sense to merge this with the connRateLimiter?

func NewRateLimitedConn

func NewRateLimitedConn(conn net.Conn, bandwidthLimiter Limiter, logger commontypes.Logger) *RateLimitedConn

func (*RateLimitedConn) EnableRateLimiting

func (r *RateLimitedConn) EnableRateLimiting()

EnableRateLimiting is not thread-safe!

func (*RateLimitedConn) Read

func (r *RateLimitedConn) Read(b []byte) (n int, err error)