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

v3

v3.8.0

Nov 13, 2024

v3.7.0

Oct 12, 2024

v3.6.0

Oct 7, 2024

v3.5.1

Oct 1, 2024

Changes in this version

+ const StartupAfterLossGain

+ func BandwidthFromBytesAndTimeDelta(bytes int64, duration time.Duration) int64

+ func MaxFilter[T mathext.Number](lhs, rhs T) int

+ func MinFilter[T mathext.Number](lhs, rhs T) int

+ type AckedPacketInfo struct

+ BytesAcked int64

+ PacketNumber int64

+ ReceiveTimestamp time.Time

+ func (i AckedPacketInfo) String() string

+ type BBRSender struct

+ func NewBBRSender(loggingContext string, rttStats *RTTStats) *BBRSender

+ func (b *BBRSender) BandwidthEstimate() int64

+ func (b *BBRSender) CanSend(bytesInFlight, bytes int64) bool

+ func (b *BBRSender) OnApplicationLimited(bytesInFlight int64)

+ func (b *BBRSender) OnCongestionEvent(priorInFlight int64, eventTime time.Time, ackedPackets []AckedPacketInfo, ...)

+ func (b *BBRSender) OnPacketSent(sentTime time.Time, bytesInFlight int64, packetNumber int64, bytes int64, ...)

+ type BandwidthSample struct

+ func (bs BandwidthSample) String() string

+ type BandwidthSampler struct

+ func (bs *BandwidthSampler) EndOfAppLimitedPhase() int64

+ func (bs *BandwidthSampler) IsAppLimited() bool

+ func (bs *BandwidthSampler) OnAppLimited()

+ func (bs *BandwidthSampler) OnPacketAcknowledged(ackTime time.Time, packetNumber int64) BandwidthSample

+ func (bs *BandwidthSampler) OnPacketLost(packetNumber int64)

+ func (bs *BandwidthSampler) OnPacketSent(sentTime time.Time, packetNumber int64, bytes int64, bytesInFlight int64, ...)

+ func (bs *BandwidthSampler) RemoveObsoletePackets(leastUnacked int64)

+ func (bs *BandwidthSampler) TotalBytesAcked() int64

+ type BandwidthSamplerInterface interface

+ EndOfAppLimitedPhase func() int64

+ IsAppLimited func() bool

+ OnAppLimited func()

+ OnPacketAcknowledged func(ackTime time.Time, packetNumber int64) BandwidthSample

+ OnPacketLost func(packetNumber int64)

+ OnPacketSent func(sentTime time.Time, packetNumber, bytes, bytesInFlight int64, ...)

+ RemoveObsoletePackets func(leastUnacked int64)

+ TotalBytesAcked func() int64

+ func NewBandwidthSampler() BandwidthSamplerInterface

+ type ConnectionStateOnSentPacket struct

+ func NewConnectionStateOnSentPacketFromSampler(sendTime time.Time, size int64, sampler *BandwidthSampler) ConnectionStateOnSentPacket

+ type CubicSendAlgorithm struct

+ func NewCubicSendAlgorithm(minWindowSize, maxWindowSize uint32) *CubicSendAlgorithm

+ func (c *CubicSendAlgorithm) CongestionWindowSize() uint32

+ func (c *CubicSendAlgorithm) InSlowStart() bool

+ func (c *CubicSendAlgorithm) OnAck() uint32

+ func (c *CubicSendAlgorithm) OnLoss() uint32

+ func (c *CubicSendAlgorithm) OnTimeout() uint32

+ type EntryWrapper struct

+ type LostPacketInfo struct

+ BytesLost int64

+ PacketNumber int64

+ func (i LostPacketInfo) String() string

+ type Pacer struct

+ func NewPacer(initialBudget, maxBudget, minPacingRate int64) *Pacer

+ func (p *Pacer) Budget(now time.Time, pacingRate int64) int64

+ func (p *Pacer) CanSend(now time.Time, bytes, pacingRate int64) bool

+ func (p *Pacer) OnPacketSent(sentTime time.Time, bytes, pacingRate int64)

+ type PacketNumberIndexedQueue struct

+ func NewPacketNumberIndexedQueue[T any]() *PacketNumberIndexedQueue[T]

+ func (p *PacketNumberIndexedQueue[T]) Emplace(packetNumber int64, args T) bool

+ func (p *PacketNumberIndexedQueue[T]) FirstPacket() int64

+ func (p *PacketNumberIndexedQueue[T]) GetEntry(packetNumber int64) *T

+ func (p *PacketNumberIndexedQueue[T]) IsEmpty() bool

+ func (p *PacketNumberIndexedQueue[T]) LastPacket() int64

+ func (p *PacketNumberIndexedQueue[T]) Remove(packetNumber int64) bool

+ type RTTStats struct

+ func NewRTTStats() *RTTStats

+ func (r *RTTStats) ExpireSmoothedMetrics()

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

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

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

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

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

+ func (r *RTTStats) Reset()

+ func (r *RTTStats) SetInitialRTT(t time.Duration)

+ func (r *RTTStats) SetMaxAckDelay(mad time.Duration)

+ func (r *RTTStats) SetRTOMultiplier(n float64)

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

+ func (r *RTTStats) UpdateRTT(sample time.Duration)

+ type Sample struct

+ type WindowedFilter struct

+ func NewWindowedFilter[V mathext.Number](windowLength int64, zeroValue V, compare func(V, V) int) *WindowedFilter[V]

+ func (wf *WindowedFilter[T]) GetBest() T

+ func (wf *WindowedFilter[T]) GetSecondBest() T

+ func (wf *WindowedFilter[T]) GetThirdBest() T

+ func (wf *WindowedFilter[T]) Reset(newSample T, newTime int64)

+ func (wf *WindowedFilter[V]) SetWindowLength(windowLength int64)

+ func (wf *WindowedFilter[V]) Update(newSample V, newTime int64)

Other modules containing this package

github.com/enfein/mieru