trace

Documentation

Index

• Variables
• func GenerateQuicPayloadWithRandomIds() []byte
• func HopPrinter(h Hop)
• type Config
• type Hop
• type ICMPTracer
  • func (t *ICMPTracer) Execute() (*Result, error)
  • func (t *ICMPTracer) PrintFunc()
• type ICMPTracerv6
  • func (t *ICMPTracerv6) Execute() (*Result, error)
  • func (t *ICMPTracerv6) PrintFunc()
• type Method
• type PacketListener
  • func NewPacketListener(conn net.PacketConn, ctx context.Context) *PacketListener
  • func (l *PacketListener) Start()
• type ReceivedMessage
• type Result
  • func Traceroute(method Method, config Config) (*Result, error)
• type TCPTracer
  • func (t *TCPTracer) Execute() (*Result, error)
• type TCPTracerIPv6
  • func (t *TCPTracerIPv6) Execute() (*Result, error)
• type Tracer
• type UDPTracer
  • func (t *UDPTracer) Execute() (*Result, error)
• type UDPTracerIPv6
  • func (t *UDPTracerIPv6) Execute() (*Result, error)

Variables

var (
	ErrInvalidMethod      = errors.New("invalid method")
	ErrTracerouteExecuted = errors.New("traceroute already executed")
	ErrHopLimitTimeout    = errors.New("hop timeout")
)

Functions

func GenerateQuicPayloadWithRandomIds

func GenerateQuicPayloadWithRandomIds() []byte

func HopPrinter

func HopPrinter(h Hop)

Types

type Config

type Config struct {
	SrcAddr          string
	BeginHop         int
	MaxHops          int
	NumMeasurements  int
	ParallelRequests int
	Timeout          time.Duration
	DestIP           net.IP
	DestPort         int
	Quic             bool
	IPGeoSource      ipgeo.Source
	RDns             bool
	AlwaysWaitRDNS   bool
	PacketInterval   int
	TTLInterval      int
	Lang             string
	DN42             bool
	RealtimePrinter  func(res *Result, ttl int)
	AsyncPrinter     func(res *Result)
	PktSize          int
	Maptrace         bool
	DontFragment     bool
}

type Hop

type Hop struct {
	Success  bool
	Address  net.Addr
	Hostname string
	TTL      int
	RTT      time.Duration
	Error    error
	Geo      *ipgeo.IPGeoData
	Lang     string
	MPLS     []string
}

type ICMPTracer

type ICMPTracer struct {
	Config
	// contains filtered or unexported fields
}

func (*ICMPTracer) Execute

func (t *ICMPTracer) Execute() (*Result, error)

func (*ICMPTracer) PrintFunc

func (t *ICMPTracer) PrintFunc()

type ICMPTracerv6

type ICMPTracerv6 struct {
	Config
	// contains filtered or unexported fields
}

func (*ICMPTracerv6) Execute

func (t *ICMPTracerv6) Execute() (*Result, error)

func (*ICMPTracerv6) PrintFunc

func (t *ICMPTracerv6) PrintFunc()

type Method

type Method string

const (
	ICMPTrace Method = "icmp"
	UDPTrace  Method = "udp"
	TCPTrace  Method = "tcp"
)

type PacketListener

type PacketListener struct {
	Conn     net.PacketConn
	Messages chan ReceivedMessage
	// contains filtered or unexported fields
}

PacketListener 负责监听网络数据包并通过通道传递接收到的消息

func NewPacketListener

func NewPacketListener(conn net.PacketConn, ctx context.Context) *PacketListener

NewPacketListener 创建一个新的数据包监听器 conn: 用于接收数据包的连接 ctx: 用于控制监听器生命周期的上下文 返回初始化好的 PacketListener 实例

func (*PacketListener) Start

func (l *PacketListener) Start()

type ReceivedMessage

type ReceivedMessage struct {
	N    *int
	Peer net.Addr
	Msg  []byte
	Err  error
}

type Result

type Result struct {
	Hops [][]Hop

	TraceMapUrl string
	// contains filtered or unexported fields
}

func Traceroute

func Traceroute(method Method, config Config) (*Result, error)

type TCPTracer

type TCPTracer struct {
	Config

	SrcIP net.IP
	// contains filtered or unexported fields
}

func (*TCPTracer) Execute

func (t *TCPTracer) Execute() (*Result, error)

type TCPTracerIPv6

type TCPTracerIPv6 struct {
	Config

	SrcIP net.IP
	// contains filtered or unexported fields
}

func (*TCPTracerIPv6) Execute

func (t *TCPTracerIPv6) Execute() (*Result, error)

type Tracer

type Tracer interface {
	Execute() (*Result, error)
}

type UDPTracer

type UDPTracer struct {
	Config
	// contains filtered or unexported fields
}

func (*UDPTracer) Execute

func (t *UDPTracer) Execute() (*Result, error)

type UDPTracerIPv6

type UDPTracerIPv6 struct {
	Config
	// contains filtered or unexported fields
}

func (*UDPTracerIPv6) Execute

func (t *UDPTracerIPv6) Execute() (*Result, error)