udp

Documentation

Index

• Constants
• Variables
• func BuildUdp(udpConfig config.UdpConfig)
• func ListenUdp(network, address string) (*net.UDPConn, error)
• func StartUdps()
• type EnhancePacketConn
  • func NewEnhancePacketConn(pc net.PacketConn) EnhancePacketConn
• type MmsgMapItem
• type MmsgTunnel
  • func (t *MmsgTunnel) Handle()
• type StdMapItem
• type StdTunnel
  • func (t *StdTunnel) Handle()
• type Tunnel
  • func NewMmsgTunnel(udpConfig config.UdpConfig) Tunnel
  • func NewStdTunnel(udpConfig config.UdpConfig) Tunnel

Constants

const BufferSize = 16 * 1024

const MaxUdpAge = 5 * time.Minute

Variables

var BufPool = sync.Pool{New: func() any { return make([]byte, BufferSize) }}

var ReadMsgsBufPool = sync.Pool{New: func() any {
	msgs := make([]ipv4.Message, batchSize)
	for i := range msgs {

		msgs[i].Buffers = make([][]byte, 1)
		msgs[i].Buffers[0] = BufPool.Get().([]byte)
	}
	return msgs
}}

var WriteMsgsBufPool = sync.Pool{New: func() any {
	msgs := make([]ipv4.Message, batchSize)
	for i := range msgs {

		msgs[i].Buffers = make([][]byte, 1)
	}
	return msgs
}}

Functions

func BuildUdp

func BuildUdp(udpConfig config.UdpConfig)

func ListenUdp

func ListenUdp(network, address string) (*net.UDPConn, error)

func StartUdps

func StartUdps()

Types

type EnhancePacketConn

type EnhancePacketConn interface {
	net.PacketConn
	WaitReadFrom() (data []byte, put func(), addr netip.AddrPort, err error)
}

func NewEnhancePacketConn

func NewEnhancePacketConn(pc net.PacketConn) EnhancePacketConn

type MmsgMapItem

type MmsgMapItem struct {
	net.Conn
	*ipv4.PacketConn
	sync.Mutex
}

type MmsgTunnel

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

func (*MmsgTunnel) Handle

func (t *MmsgTunnel) Handle()

type StdMapItem

type StdMapItem struct {
	net.Conn
	*ipv4.PacketConn
	sync.Mutex
}

type StdTunnel

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

func (*StdTunnel) Handle

func (t *StdTunnel) Handle()

type Tunnel

type Tunnel interface {
	Handle()
}

func NewMmsgTunnel

func NewMmsgTunnel(udpConfig config.UdpConfig) Tunnel

func NewStdTunnel

func NewStdTunnel(udpConfig config.UdpConfig) Tunnel