netest

Documentation

Index

• Constants
• Variables
• func Humanize(v float64) string
• type Connection
• type Packet
• type PacketHeader
• type PatternType
• type Sink
  • func NewTCPSink(laddr string) (*Sink, error)
  • func NewUDPSink(laddr string) (*Sink, error)
  • func (s *Sink) Close()
  • func (s *Sink) ReceiveMsg() *Packet
• type Source
  • func NewTCPSource(laddr, raddr string) (*Source, error)
  • func NewUDPSource(laddr, raddr string) (*Source, error)
  • func (s *Source) Close()
  • func (s *Source) SendMsg(payload []byte) (int, error)

Constants

const (
	Kilobyte = 1024.0
	Megabyte = 1048576.0
	Gigabyte = 1073741824.0
)

Variables

var MTU = 1500

var Patterns = [][]byte{
	[]byte{0xff},
	[]byte{0x00},
}

Functions

func Humanize

func Humanize(v float64) string

Types

type Connection

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

type Packet

type Packet struct {
	PacketHeader
	Payload []byte
}

type PacketHeader

type PacketHeader struct {
	Length   uint16
	Sequence uint16
}

type PatternType

type PatternType uint8

const (
	AllOnesPattern PatternType = iota
	AllZerosPattern
)

type Sink

type Sink struct {
	*Connection
	// contains filtered or unexported fields
}

func NewTCPSink

func NewTCPSink(laddr string) (*Sink, error)

func NewUDPSink

func NewUDPSink(laddr string) (*Sink, error)

func (*Sink) Close

func (s *Sink) Close()

func (*Sink) ReceiveMsg

func (s *Sink) ReceiveMsg() *Packet

type Source

type Source struct {
	*Connection
	// contains filtered or unexported fields
}

func NewTCPSource

func NewTCPSource(laddr, raddr string) (*Source, error)

func NewUDPSource

func NewUDPSource(laddr, raddr string) (*Source, error)

func (*Source) Close

func (s *Source) Close()

func (*Source) SendMsg

func (s *Source) SendMsg(payload []byte) (int, error)