nw_congestion

Documentation

Index

• func CurrentInitCongestionWindow() int
• func CurrentMaxCongestionWindow() int
• func CurrentMinCongestionWindow() int
• func EndRateLimit(hash, endpoint string, reset time.Time)
• func EndSuccess(hash, endpoint string)
• func EndTransportError(hash, endpoint string)
• func SetInitCongestionWindow(w int)
• func SetMaxCongestionWindow(w int, ignoreHardLimit bool)
• func Start(hash, endpoint string)
• type CongestionControl
  • func NewControl() CongestionControl

Functions

func CurrentInitCongestionWindow

func CurrentInitCongestionWindow() int

Initial congestion window size

func CurrentMaxCongestionWindow

func CurrentMaxCongestionWindow() int

Maximum congestion window size

func CurrentMinCongestionWindow

func CurrentMinCongestionWindow() int

Minimum congestion window size

func EndRateLimit

func EndRateLimit(hash, endpoint string, reset time.Time)

func EndSuccess

func EndSuccess(hash, endpoint string)

func EndTransportError

func EndTransportError(hash, endpoint string)

func SetInitCongestionWindow

func SetInitCongestionWindow(w int)

func SetMaxCongestionWindow

func SetMaxCongestionWindow(w int, ignoreHardLimit bool)

func Start

func Start(hash, endpoint string)

Types

type CongestionControl

type CongestionControl interface {
	// start and wait for QoS
	Start(hash, endpoint string)

	// mark transaction as success
	EndSuccess(hash, endpoint string)

	// mark transaction as transport error
	EndTransportError(hash, endpoint string)

	// mark transaction as failure and got a rate limit
	EndRateLimit(hash, endpoint string, reset time.Time)
}

func NewControl

func NewControl() CongestionControl