twamplight

package

v0.8.0 Latest Latest Go to latest Published: Dec 2, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/malbeclabs/doublezero

Links

Open Source Insights

Documentation ¶

Rendered for

Index ¶

Constants
Variables
type BasicReflector
- func NewBasicReflector(log *slog.Logger, addr string, timeout time.Duration) (*BasicReflector, error)
- func (r *BasicReflector) Close() error
- func (r *BasicReflector) LocalAddr() *net.UDPAddr
- func (r *BasicReflector) Run(ctx context.Context) error
type BasicSender
- func NewBasicSender(ctx context.Context, log *slog.Logger, iface string, ...) (*BasicSender, error)
- func (s *BasicSender) Close() error
- func (s *BasicSender) LocalAddr() *net.UDPAddr
- func (s *BasicSender) Probe(ctx context.Context) (time.Duration, error)
type LinuxReflector
- func NewLinuxReflector(addr string, timeout time.Duration) (*LinuxReflector, error)
- func (r *LinuxReflector) Close() error
- func (r *LinuxReflector) LocalAddr() *net.UDPAddr
- func (r *LinuxReflector) Run(ctx context.Context) error
type LinuxSender
- func NewLinuxSender(ctx context.Context, iface string, local *net.UDPAddr, remote *net.UDPAddr) (*LinuxSender, error)
- func (s *LinuxSender) Close() error
- func (s *LinuxSender) LocalAddr() *net.UDPAddr
- func (s *LinuxSender) Probe(ctx context.Context) (time.Duration, error)
type Packet
- func NewPacket(seq uint32) *Packet
- func UnmarshalPacket(buf []byte) (*Packet, error)
- func (p *Packet) Marshal(buf []byte) error
type Reflector
- func NewReflector(log *slog.Logger, addr string, timeout time.Duration) (Reflector, error)
type Sender
- func NewSender(ctx context.Context, log *slog.Logger, iface string, ...) (Sender, error)

Constants ¶

View Source

const (
	PacketSize = 48
)

Variables ¶

View Source

var (
	ErrInvalidPacket        = errors.New("invalid packet format")
	ErrPlatformNotSupported = errors.New("platform not supported")
)

Functions ¶

This section is empty.

Types ¶

type BasicReflector ¶

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

Reflector listens for incoming TWAMP probe packets and reflects them back to the sender.

It runs a single-threaded event loop using a UDP socket with a read timeout. The reflector is designed for test environments or single-client usage and is not optimized for high concurrency.

Use Run(ctx) to start the reflector; it blocks until the context is cancelled. Use Close() to stop the reflector and release the socket.

Reflector is not safe for concurrent use.

func NewBasicReflector ¶

func NewBasicReflector(log *slog.Logger, addr string, timeout time.Duration) (*BasicReflector, error)

func (*BasicReflector) Close ¶

func (r *BasicReflector) Close() error

Close closes the TWAMP reflector by closing the listener connection.

func (*BasicReflector) LocalAddr ¶

func (r *BasicReflector) LocalAddr() *net.UDPAddr

LocalAddr returns the address the reflector is listening on.

func (*BasicReflector) Run ¶

func (r *BasicReflector) Run(ctx context.Context) error

Run starts the TWAMP reflector.

It listens on the configured UDP port and reflects back the received packets.

It's a blocking function that will run until the context is done.

type BasicSender ¶

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

func NewBasicSender ¶

func NewBasicSender(ctx context.Context, log *slog.Logger, iface string, localAddr, remoteAddr *net.UDPAddr) (*BasicSender, error)

func (*BasicSender) Close ¶

func (s *BasicSender) Close() error

func (*BasicSender) LocalAddr ¶

func (s *BasicSender) LocalAddr() *net.UDPAddr

LocalAddr returns the local address of the sender connection.

func (*BasicSender) Probe ¶

func (s *BasicSender) Probe(ctx context.Context) (time.Duration, error)

Probe sends a TWAMP probe packet to the given address and returns the RTT.

If the probe fails, it returns a zero duration and an error.

type LinuxReflector ¶

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

func NewLinuxReflector ¶

func NewLinuxReflector(addr string, timeout time.Duration) (*LinuxReflector, error)

func (*LinuxReflector) Close ¶

func (r *LinuxReflector) Close() error

func (*LinuxReflector) LocalAddr ¶

func (r *LinuxReflector) LocalAddr() *net.UDPAddr

func (*LinuxReflector) Run ¶

func (r *LinuxReflector) Run(ctx context.Context) error

type LinuxSender ¶

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

func NewLinuxSender ¶

func NewLinuxSender(ctx context.Context, iface string, local *net.UDPAddr, remote *net.UDPAddr) (*LinuxSender, error)

func (*LinuxSender) Close ¶

func (s *LinuxSender) Close() error

func (*LinuxSender) LocalAddr ¶

func (s *LinuxSender) LocalAddr() *net.UDPAddr

func (*LinuxSender) Probe ¶

func (s *LinuxSender) Probe(ctx context.Context) (time.Duration, error)

type Packet ¶

type Packet struct {
	Seq  uint32
	Sec  uint32
	Frac uint32
	Pad  [36]byte
}

func NewPacket ¶

func NewPacket(seq uint32) *Packet

func UnmarshalPacket ¶

func UnmarshalPacket(buf []byte) (*Packet, error)

func (*Packet) Marshal ¶

func (p *Packet) Marshal(buf []byte) error

type Reflector ¶

type Reflector interface {
	Run(ctx context.Context) error
	Close() error
	LocalAddr() *net.UDPAddr
}

func NewReflector ¶

func NewReflector(log *slog.Logger, addr string, timeout time.Duration) (Reflector, error)

type Sender ¶

type Sender interface {
	Probe(ctx context.Context) (time.Duration, error)
	Close() error
	LocalAddr() *net.UDPAddr
}

func NewSender ¶

func NewSender(ctx context.Context, log *slog.Logger, iface string, localAddr, remoteAddr *net.UDPAddr) (Sender, error)

Source Files ¶

View all Source files

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