l2

Documentation

Index

• type TrafficConfig
• type TrafficController
  • func NewTrafficController(cfg TrafficConfig) *TrafficController
  • func (p *TrafficController) GetThroughput() uint8
  • func (p *TrafficController) NewRWBucket() ratelimiter.RWRateQuota
  • func (p *TrafficController) SetLevel(level capacity.Level)
  • func (p *TrafficController) SetThroughput(percent uint8)
  • func (p *TrafficController) Start(ctx context.Context)

Types

type TrafficConfig

type TrafficConfig struct {
	TotalRead, TotalWrite int
	PeerRead, PeerWrite   int

	SamplingPeriod time.Duration
	BurstPeriods   int
}

type TrafficController

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

func NewTrafficController

func NewTrafficController(cfg TrafficConfig) *TrafficController

func (*TrafficController) GetThroughput

func (p *TrafficController) GetThroughput() uint8

func (*TrafficController) NewRWBucket

func (p *TrafficController) NewRWBucket() ratelimiter.RWRateQuota

func (*TrafficController) SetLevel

func (p *TrafficController) SetLevel(level capacity.Level)

func (*TrafficController) SetThroughput

func (p *TrafficController) SetThroughput(percent uint8)

func (*TrafficController) Start

func (p *TrafficController) Start(ctx context.Context)