simnet

package module
v0.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 22, 2025 License: BSD-3-Clause Imports: 12 Imported by: 1

README

simnet

A small Go library for simulating packet networks in-process. It provides drop-in net.PacketConn endpoints connected through configurable virtual links with bandwidth, latency, and MTU constraints. Useful for testing networking code without sockets or root privileges.

  • Drop-in API: implements net.PacketConn
  • Realistic links: per-direction bandwidth, latency, and MTU
  • Backpressure/buffering: bandwidth–delay product aware queues
  • Routers: perfect delivery, fixed-latency, simple firewall/NAT-like routing
  • Deterministic testing: opt-in synctest-based tests for time control

Install

go get github.com/marcopolo/simnet

Quick start: high-level Simnet

Create a simulated network and two endpoints. Each endpoint gets a bidirectional link with independent uplink/downlink settings. Start the network, then use the returned net.PacketConns as usual.

package main

import (
    "fmt"
    "net"
    "time"

    "github.com/marcopolo/simnet"
)

func main() {
    n := &simnet.Simnet{}
    settings := simnet.NodeBiDiLinkSettings{
        Downlink: simnet.LinkSettings{BitsPerSecond: 10 * simnet.Mibps},
        Uplink:   simnet.LinkSettings{BitsPerSecond: 10 * simnet.Mibps},
        Latency:  5 * time.Millisecond,
    }

    addrA := &net.UDPAddr{IP: net.ParseIP("1.0.0.1"), Port: 9001}
    addrB := &net.UDPAddr{IP: net.ParseIP("1.0.0.2"), Port: 9002}

    client := n.NewEndpoint(addrA, settings)
    server := n.NewEndpoint(addrB, settings)

    _ = n.Start()
    defer n.Close()

    // Echo server
    go func() {
        buf := make([]byte, 1024)
        server.SetReadDeadline(time.Now().Add(2 * time.Second))
        n, src, err := server.ReadFrom(buf)
        if err != nil { return }
        server.WriteTo(append([]byte("echo: "), buf[:n]...), src)
    }()

    client.SetReadDeadline(time.Now().Add(2 * time.Second))
    _, _ = client.WriteTo([]byte("ping"), addrB)

    buf := make([]byte, 1024)
    nRead, _, _ := client.ReadFrom(buf)
    fmt.Println(string(buf[:nRead]))
}

Configuration

  • LinkSettings
    • BitsPerSecond int: bandwidth cap (bits/sec)
    • MTU int: maximum packet size (bytes). Oversized packets are dropped
  • NodeBiDiLinkSettings
    • Downlink LinkSettings: settings for incoming traffic
    • Uplink LinkSettings: settings for outgoing traffic
    • Latency time.Duration: one-way latency for downlink packets
    • LatencyFunc func(Packet) time.Duration: optional function to compute variable latency per downlink packet
  • Use simnet.Mibps for convenience when computing bitrates

Routers

  • PerfectRouter: instant delivery, in-memory switch
  • FixedLatencyRouter: wraps perfect delivery with a fixed extra latency
  • SimpleFirewallRouter: NAT/firewall-like behavior. A node must first send to a peer before inbound from that peer is allowed. You can also mark addresses as publicly reachable:
fw := &simnet.SimpleFirewallRouter{}
fw.SetAddrPubliclyReachable(serverAddr)

Each endpoint created by Simnet sits behind a SimulatedLink that:

  • Rate-limits using a token bucket (via golang.org/x/time/rate)
  • Adds latency via a timed queue
  • Drops packets over MTU
  • Buffers up to the bandwidth–delay product

Deadlines and stats

  • SimConn implements SetDeadline, SetReadDeadline, SetWriteDeadline
    • Exceeded deadlines return simnet.ErrDeadlineExceeded
  • Stats() returns counts of bytes/packets sent/received

Testing

Run the standard test suite:

go test ./...

Some tests use Go's synctest experimental time control. Enable them with:

GOEXPERIMENT=synctest go test ./...

(requires Go 1.24+)

License

BSD-3

Documentation

Index

Constants

View Source
const Mibps = 1_000_000

Variables

View Source
var ErrDeadlineExceeded = errors.New("deadline exceeded")

Functions

func IntToPublicIPv4

func IntToPublicIPv4(n int) net.IP

Types

type ConnStats

type ConnStats struct {
	BytesSent   int
	BytesRcvd   int
	PacketsSent int
	PacketsRcvd int
}

type DelayedPacketReciever

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

func (*DelayedPacketReciever) RecvPacket

func (r *DelayedPacketReciever) RecvPacket(p Packet)

type FixedLatencyRouter

type FixedLatencyRouter struct {
	PerfectRouter
	// contains filtered or unexported fields
}

func (*FixedLatencyRouter) AddNode

func (r *FixedLatencyRouter) AddNode(addr net.Addr, conn PacketReceiver)

func (*FixedLatencyRouter) SendPacket

func (r *FixedLatencyRouter) SendPacket(p Packet) error

type LinkSettings

type LinkSettings struct {
	// BitsPerSecond specifies the bandwidth limit in bits per second
	BitsPerSecond int

	// MTU (Maximum Transmission Unit) specifies the maximum packet size in bytes
	MTU int
}

LinkSettings defines the network characteristics for a simulated link direction

type NodeBiDiLinkSettings

type NodeBiDiLinkSettings struct {
	// Downlink configures the settings for incoming traffic to this node
	Downlink LinkSettings
	// Uplink configures the settings for outgoing traffic from this node
	Uplink LinkSettings

	// Latency specifies a fixed network delay for downlink packets only
	// If both Latency and LatencyFunc are set, LatencyFunc takes precedence
	Latency time.Duration

	// LatencyFunc computes the network delay for each downlink packet
	// This allows variable latency based on packet source/destination
	// If nil, Latency field is used instead
	LatencyFunc func(Packet) time.Duration
}

NodeBiDiLinkSettings defines the bidirectional link settings for a network node. It specifies separate configurations for downlink (incoming) and uplink (outgoing) traffic, allowing asymmetric network conditions to be simulated.

type Packet

type Packet struct {
	To   net.Addr
	From net.Addr
	// contains filtered or unexported fields
}

type PacketReceiver

type PacketReceiver interface {
	RecvPacket(p Packet)
}

type PerfectRouter

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

PerfectRouter is a router that has no latency or jitter and can route to every node

func (*PerfectRouter) AddNode

func (r *PerfectRouter) AddNode(addr net.Addr, conn PacketReceiver)

func (*PerfectRouter) RemoveNode

func (r *PerfectRouter) RemoveNode(addr net.Addr)

func (*PerfectRouter) SendPacket

func (r *PerfectRouter) SendPacket(p Packet) error

SendPacket implements Router.

type Router

type Router interface {
	SendPacket(p Packet) error
	AddNode(addr net.Addr, receiver PacketReceiver)
}

Router handles routing of packets between simulated connections. Implementations are responsible for delivering packets to their destinations.

type SimConn

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

SimConn is a simulated network connection that implements net.PacketConn. It provides packet-based communication through a Router for testing and simulation purposes. All send/recv operations are handled through the Router's packet delivery mechanism.

func NewBlockingSimConn

func NewBlockingSimConn(addr *net.UDPAddr, rtr Router) *SimConn

NewBlockingSimConn creates a new simulated connection that blocks if the receive buffer is full. Does not drop packets.

func NewSimConn

func NewSimConn(addr *net.UDPAddr, rtr Router) *SimConn

NewSimConn creates a new simulated connection that drops packets if the receive buffer is full.

func (*SimConn) Close

func (c *SimConn) Close() error

Close implements net.PacketConn

func (*SimConn) LocalAddr

func (c *SimConn) LocalAddr() net.Addr

LocalAddr implements net.PacketConn

func (*SimConn) ReadFrom

func (c *SimConn) ReadFrom(p []byte) (n int, addr net.Addr, err error)

ReadFrom implements net.PacketConn

func (*SimConn) RecvPacket

func (c *SimConn) RecvPacket(p Packet)

func (*SimConn) SetDeadline

func (c *SimConn) SetDeadline(t time.Time) error

SetDeadline implements net.PacketConn

func (*SimConn) SetLocalAddr

func (c *SimConn) SetLocalAddr(addr net.Addr)

SetLocalAddr only changes what `.LocalAddr()` returns. Packets will still come From the initially configured addr.

func (*SimConn) SetReadBuffer

func (c *SimConn) SetReadBuffer(n int) error

SetReadBuffer only exists to quell the warning message from quic-go

func (*SimConn) SetReadDeadline

func (c *SimConn) SetReadDeadline(t time.Time) error

SetReadDeadline implements net.PacketConn

func (*SimConn) SetWriteBuffer

func (c *SimConn) SetWriteBuffer(n int) error

SetReadBuffer only exists to quell the warning message from quic-go

func (*SimConn) SetWriteDeadline

func (c *SimConn) SetWriteDeadline(t time.Time) error

SetWriteDeadline implements net.PacketConn

func (*SimConn) Stats

func (c *SimConn) Stats() ConnStats

func (*SimConn) UnicastAddr

func (c *SimConn) UnicastAddr() net.Addr

func (*SimConn) WriteTo

func (c *SimConn) WriteTo(p []byte, addr net.Addr) (n int, err error)

WriteTo implements net.PacketConn

type Simnet

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

Simnet is a simulated network that manages connections between nodes with configurable network conditions.

func (*Simnet) Close

func (n *Simnet) Close() error

func (*Simnet) NewEndpoint

func (n *Simnet) NewEndpoint(addr *net.UDPAddr, linkSettings NodeBiDiLinkSettings) *SimConn

func (*Simnet) Start

func (n *Simnet) Start() error

type SimpleFirewallRouter

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

func (*SimpleFirewallRouter) AddNode

func (r *SimpleFirewallRouter) AddNode(addr net.Addr, conn PacketReceiver)

func (*SimpleFirewallRouter) RemoveNode

func (r *SimpleFirewallRouter) RemoveNode(addr net.Addr)

func (*SimpleFirewallRouter) SendPacket

func (r *SimpleFirewallRouter) SendPacket(p Packet) error

func (*SimpleFirewallRouter) SetAddrPubliclyReachable

func (r *SimpleFirewallRouter) SetAddrPubliclyReachable(addr net.Addr)

func (*SimpleFirewallRouter) String

func (r *SimpleFirewallRouter) String() string
type SimulatedLink struct {

	// Configuration for link characteristics
	UplinkSettings   LinkSettings
	DownlinkSettings LinkSettings

	// Latency specifies a fixed network delay for downlink packets
	// If both Latency and LatencyFunc are set, LatencyFunc takes precedence
	Latency time.Duration

	// LatencyFunc computes the network delay for each downlink packet
	// This allows variable latency based on packet source/destination
	// If nil, Latency field is used instead
	LatencyFunc func(Packet) time.Duration

	// Packet routing interfaces
	UploadPacket Router
	// contains filtered or unexported fields
}

SimulatedLink simulates a bidirectional network link with variable latency, bandwidth limiting, and CoDel-based bufferbloat mitigation

func (*SimulatedLink) AddNode

func (l *SimulatedLink) AddNode(addr net.Addr, receiver PacketReceiver)

func (*SimulatedLink) Close

func (l *SimulatedLink) Close() error

func (*SimulatedLink) RecvPacket

func (l *SimulatedLink) RecvPacket(p Packet)

func (*SimulatedLink) SendPacket

func (l *SimulatedLink) SendPacket(p Packet) error

func (*SimulatedLink) Start

func (l *SimulatedLink) Start()

Directories

Path Synopsis
internal

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL