common

Documentation

Index

• type Pacer
  • func NewPacer(getBandwidth func() congestion.ByteCount) *Pacer
  • func (p *Pacer) Budget(now time.Time) congestion.ByteCount
  • func (p *Pacer) SentPacket(sendTime time.Time, size congestion.ByteCount)
  • func (p *Pacer) SetMaxDatagramSize(s congestion.ByteCount)
  • func (p *Pacer) TimeUntilSend() time.Time

Types

type Pacer

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

Pacer implements a token bucket pacing algorithm.

func NewPacer

func NewPacer(getBandwidth func() congestion.ByteCount) *Pacer

func (*Pacer) Budget

func (p *Pacer) Budget(now time.Time) congestion.ByteCount

func (*Pacer) SentPacket

func (p *Pacer) SentPacket(sendTime time.Time, size congestion.ByteCount)

func (*Pacer) SetMaxDatagramSize

func (p *Pacer) SetMaxDatagramSize(s congestion.ByteCount)

func (*Pacer) TimeUntilSend

func (p *Pacer) TimeUntilSend() time.Time

TimeUntilSend returns when the next packet should be sent. It returns the zero value of time.Time if a packet can be sent immediately.