Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

congestion

package

Go to main page

Versions in this module

v0

v0.36.2

Jul 22, 2023

v0.36.1

Jul 22, 2023

v0.34.1

Jul 22, 2023

Changes in this version

+ type ByteCount protocol.ByteCount

+ type CongestionControl interface

+ CanSend func(bytesInFlight ByteCount) bool

+ GetCongestionWindow func() ByteCount

+ HasPacingBudget func() bool

+ InRecovery func() bool

+ InSlowStart func() bool

+ MaybeExitSlowStart func()

+ OnPacketAcked func(number PacketNumber, ackedBytes ByteCount, priorInFlight ByteCount, ...)

+ OnPacketLost func(number PacketNumber, lostBytes ByteCount, priorInFlight ByteCount)

+ OnPacketSent func(sentTime time.Time, bytesInFlight ByteCount, packetNumber PacketNumber, ...)

+ OnRetransmissionTimeout func(packetsRetransmitted bool)

+ SetMaxDatagramSize func(size ByteCount)

+ SetRTTStatsProvider func(provider RTTStatsProvider)

+ TimeUntilSend func(bytesInFlight ByteCount) time.Time

+ type PacketNumber protocol.PacketNumber

+ type RTTStatsProvider interface

+ ExpireSmoothedMetrics func()

+ LatestRTT func() time.Duration

+ MaxAckDelay func() time.Duration

+ MeanDeviation func() time.Duration

+ MinRTT func() time.Duration

+ OnConnectionMigration func()

+ PTO func(includeMaxAckDelay bool) time.Duration

+ SetInitialRTT func(t time.Duration)

+ SetMaxAckDelay func(mad time.Duration)

+ SmoothedRTT func() time.Duration

+ UpdateRTT func(sendDelta, ackDelay time.Duration, now time.Time)

v0.6.0

Dec 12, 2017

v0.5.0

Apr 11, 2017

Changes in this version

+ type Bandwidth uint64

+ const BitsPerSecond

+ const BytesPerSecond

+ func BandwidthFromDelta(bytes protocol.ByteCount, delta time.Duration) Bandwidth

+ type Clock interface

+ Now func() time.Time

+ type Cubic struct

+ func NewCubic(clock Clock) *Cubic

+ func (c *Cubic) CongestionWindowAfterAck(currentCongestionWindow protocol.PacketNumber, delayMin time.Duration) protocol.PacketNumber

+ func (c *Cubic) CongestionWindowAfterPacketLoss(currentCongestionWindow protocol.PacketNumber) protocol.PacketNumber

+ func (c *Cubic) OnApplicationLimited()

+ func (c *Cubic) Reset()

+ func (c *Cubic) SetNumConnections(n int)

+ type DefaultClock struct

+ func (DefaultClock) Now() time.Time

+ type HybridSlowStart struct

+ func (s *HybridSlowStart) IsEndOfRound(ack protocol.PacketNumber) bool

+ func (s *HybridSlowStart) OnPacketAcked(ackedPacketNumber protocol.PacketNumber)

+ func (s *HybridSlowStart) OnPacketSent(packetNumber protocol.PacketNumber)

+ func (s *HybridSlowStart) Restart()

+ func (s *HybridSlowStart) ShouldExitSlowStart(latestRTT time.Duration, minRTT time.Duration, ...) bool

+ func (s *HybridSlowStart) StartReceiveRound(lastSent protocol.PacketNumber)

+ func (s *HybridSlowStart) Started() bool

+ type PrrSender struct

+ func (p *PrrSender) OnPacketAcked(ackedBytes protocol.ByteCount)

+ func (p *PrrSender) OnPacketLost(bytesInFlight protocol.ByteCount)

+ func (p *PrrSender) OnPacketSent(sentBytes protocol.ByteCount)

+ func (p *PrrSender) TimeUntilSend(congestionWindow, bytesInFlight, slowstartThreshold protocol.ByteCount) time.Duration

+ type RTTStats struct

+ func NewRTTStats() *RTTStats

+ func (r *RTTStats) ExpireSmoothedMetrics()

+ func (r *RTTStats) GetHalfWindowRTT() time.Duration

+ func (r *RTTStats) GetQuarterWindowRTT() time.Duration

+ func (r *RTTStats) InitialRTTus() int64

+ func (r *RTTStats) LatestRTT() time.Duration

+ func (r *RTTStats) MeanDeviation() time.Duration

+ func (r *RTTStats) MinRTT() time.Duration

+ func (r *RTTStats) OnConnectionMigration()

+ func (r *RTTStats) RecentMinRTT() time.Duration

+ func (r *RTTStats) SampleNewRecentMinRTT(numSamples uint32)

+ func (r *RTTStats) SetRecentMinRTTwindow(recentMinRTTwindow time.Duration)

+ func (r *RTTStats) SmoothedRTT() time.Duration

+ func (r *RTTStats) UpdateRTT(sendDelta, ackDelay time.Duration, now time.Time)

+ type SendAlgorithm interface

+ GetCongestionWindow func() protocol.ByteCount

+ MaybeExitSlowStart func()

+ OnConnectionMigration func()

+ OnPacketAcked func(number protocol.PacketNumber, ackedBytes protocol.ByteCount, ...)

+ OnPacketLost func(number protocol.PacketNumber, lostBytes protocol.ByteCount, ...)

+ OnPacketSent func(sentTime time.Time, bytesInFlight protocol.ByteCount, ...) bool

+ OnRetransmissionTimeout func(packetsRetransmitted bool)

+ RetransmissionDelay func() time.Duration

+ SetNumEmulatedConnections func(n int)

+ SetSlowStartLargeReduction func(enabled bool)

+ TimeUntilSend func(now time.Time, bytesInFlight protocol.ByteCount) time.Duration

+ type SendAlgorithmWithDebugInfo interface

+ BandwidthEstimate func() Bandwidth

+ HybridSlowStart func() *HybridSlowStart

+ InRecovery func() bool

+ RenoBeta func() float32

+ SlowstartThreshold func() protocol.PacketNumber

+ func NewCubicSender(clock Clock, rttStats *RTTStats, reno bool, ...) SendAlgorithmWithDebugInfo