Help us shape the future of Go! Take the 2026 Go Developer Survey

Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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
- API
  
  Reference documentation for the pkg.go.dev API
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

lossyconn

package module

Go to main page

Versions in this module

v1

v1.1.0

Nov 2, 2026

Changes in this version

+ type Config struct

+ BandwidthBytesPerSec uint64

+ BurstLength int

+ BurstLossRate float64

+ CorruptionRate float64

+ Delay time.Duration

+ DelayDeviation float64

+ DuplicateRate float64

+ MaxPacketSize int

+ MaxPendingPackets int

+ MaxQueueDelay time.Duration

+ MaxReorderDelay time.Duration

+ PacketLifetime time.Duration

+ QueueDelayPerPacket time.Duration

+ QueueSize int

+ RandomLossRate float64

+ ReorderRate float64

+ Seed int64

+ type LinkProfile struct

+ Config Config

+ Up bool

type LossyConn

+ func NewLossyPacketConn(loss float64, delay int) (*LossyConn, error)

+ func NewWithConfig(cfg Config) (*LossyConn, error)

+ func (conn *LossyConn) ClearPeerProfile(addr net.Addr) error

+ func (conn *LossyConn) ResetStats()

+ func (conn *LossyConn) SchedulePeerProfile(addr net.Addr, at time.Time, profile LinkProfile) error

+ func (conn *LossyConn) SetLinkState(up bool)

+ func (conn *LossyConn) SetPeerLinkState(addr net.Addr, up bool) error

+ func (conn *LossyConn) SetPeerProfile(addr net.Addr, profile LinkProfile) error

+ func (conn *LossyConn) Stats() Stats

+ type Stats struct

+ CorruptedPackets uint64

+ DelayedSends uint64

+ DropBurst uint64

+ DropExpired uint64

+ DropLinkDown uint64

+ DropOversize uint64

+ DropPendingQueue uint64

+ DropQueue uint64

+ DropRandom uint64

+ DuplicatedPackets uint64

+ MaxDelay time.Duration

+ QueueDelayedPackets uint64

+ RecvBytes uint64

+ RecvPackets uint64

+ Reordered uint64

+ SentBytes uint64

+ SentPackets uint64

type TimedSender

+ func (h *TimedSender) Close() error

v1.0.0

Feb 9, 2020

Changes in this version

+ type Address struct

+ func NewAddress() *Address

+ func (addr *Address) Network() string

+ func (addr *Address) String() string

+ type ConnectionManager struct

+ func NewConnectionManager() *ConnectionManager

+ func (mgr *ConnectionManager) Delete(conn *LossyConn)

+ func (mgr *ConnectionManager) Get(addr string) *LossyConn

+ func (mgr *ConnectionManager) Set(conn *LossyConn)

+ type LossyConn struct

+ func NewLossyConn(loss float64, delay int) (*LossyConn, error)

+ func (conn *LossyConn) Close() error

+ func (conn *LossyConn) LocalAddr() net.Addr

+ func (conn *LossyConn) Read(b []byte) (int, error)

+ func (conn *LossyConn) ReadFrom(p []byte) (n int, addr net.Addr, err error)

+ func (conn *LossyConn) RemoteAddr() net.Addr

+ func (conn *LossyConn) SetDeadline(t time.Time) error

+ func (conn *LossyConn) SetDelayDeviation(deviation float64)

+ func (conn *LossyConn) SetReadDeadline(t time.Time) error

+ func (conn *LossyConn) SetWriteDeadline(t time.Time) error

+ func (conn *LossyConn) String() string

+ func (conn *LossyConn) Write(p []byte) (n int, err error)

+ func (conn *LossyConn) WriteTo(p []byte, addr net.Addr) (n int, err error)

+ type Packet struct

+ type TimedSender struct

+ func NewTimedSender() *TimedSender

+ func (h *TimedSender) Len() int

+ func (h *TimedSender) Less(i, j int) bool

+ func (h *TimedSender) Pop() interface{}

+ func (h *TimedSender) Push(x interface{})

+ func (h *TimedSender) Send(conn *LossyConn, packet Packet, delay time.Duration)

+ func (h *TimedSender) Swap(i, j int)