simnet

package module
v0.0.1 Latest Latest
Warning

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

Go to latest
Published: Aug 13, 2025 License: BSD-3-Clause Imports: 11 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, Latency: 5 * time.Millisecond},
        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)
    • Latency time.Duration: one-way latency per packet
    • MTU int: maximum packet size (bytes). Oversized packets are dropped
  • Use simnet.Mibps for convenience when computing bitrates
  • NodeBiDiLinkSettings lets you set separate Downlink and Uplink

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

Examples

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.
	// This controls the rate at which data can be transmitted over the link.
	BitsPerSecond int

	// Latency specifies the network delay to add to each packet.
	// This simulates the time it takes for a packet to travel across the network.
	Latency time.Duration

	// MTU (Maximum Transmission Unit) specifies the maximum packet size in bytes.
	// Packets larger than this size will be dropped by the simulated link.
	MTU int
}

LinkSettings defines the network characteristics for a simulated link direction. These settings control bandwidth, latency, and MTU for either uplink or downlink traffic.

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
}

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.

Example (Echo)

Example showing a simple echo using Simnet and the returned net.PacketConn.

package main

import (
	"fmt"
	"net"
	"time"

	"github.com/marcopolo/simnet"
)

func main() {
	// Create the simulated network and two endpoints
	n := &simnet.Simnet{}
	settings := simnet.NodeBiDiLinkSettings{
		Downlink: simnet.LinkSettings{BitsPerSecond: 10 * simnet.Mibps, Latency: 5 * time.Millisecond},
		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()

	// Simple echo server using the returned PacketConn
	done := make(chan struct{})
	go func() {
		defer close(done)
		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 sends a message and waits for the echo response
	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]))

	<-done

}
Output:

echo: ping

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 // bandwidth, latency, MTU for uplink direction
	DownlinkSettings LinkSettings // bandwidth, latency, MTU for downlink direction

	// Packet routing interfaces
	UploadPacket Router // Handles packets sent out
	// contains filtered or unexported fields
}

SimulatedLink simulates a bidirectional network link with configurable bandwidth, latency, and MTU settings for both uplink and downlink directions.

The link provides realistic network behavior by:

  • Rate limiting packets based on bandwidth settings
  • Adding configurable latency to packet delivery
  • Enforcing MTU limits (dropping oversized packets)
  • Buffering packets up to the bandwidth-delay product

Usage:

link := &SimulatedLink{
    UplinkSettings:   LinkSettings{BitsPerSecond: 1000000, Latency: 50*time.Millisecond, MTU: 1400},
    DownlinkSettings: LinkSettings{BitsPerSecond: 1000000, Latency: 50*time.Millisecond, MTU: 1400},
    UploadPacket:     upstream,
    DownloadPacket:   downstream,
}
link.Start()
defer link.Close()

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