udp

Documentation

Index

• Constants
• func NewUDPStatsEmitter(udpConns []Conn) func()
• type Conn
  • func NewListener(l *logrus.Logger, ip netip.Addr, port int, multi bool, batch int) (Conn, error)
• type EncReader
• type LightHouseHandlerFunc
• type NoopConn
  • func (NoopConn) Close() error
  • func (NoopConn) ListenOut(_ EncReader, _ LightHouseHandlerFunc, _ *firewall.ConntrackCacheTicker, _ int)
  • func (NoopConn) LocalAddr() (netip.AddrPort, error)
  • func (NoopConn) Rebind() error
  • func (NoopConn) ReloadConfig(_ *config.C)
  • func (NoopConn) WriteTo(_ []byte, _ netip.AddrPort) error
• type StdConn
  • func (u *StdConn) Close() error
  • func (u *StdConn) GetRecvBuffer() (int, error)
  • func (u *StdConn) GetSendBuffer() (int, error)
  • func (u *StdConn) ListenOut(r EncReader, lhf LightHouseHandlerFunc, cache *firewall.ConntrackCacheTicker, ...)
  • func (u *StdConn) LocalAddr() (netip.AddrPort, error)
  • func (u *StdConn) PrepareRawMessages(n int) ([]rawMessage, [][]byte, [][]byte)
  • func (u *StdConn) ReadMulti(msgs []rawMessage) (int, error)
  • func (u *StdConn) ReadSingle(msgs []rawMessage) (int, error)
  • func (u *StdConn) Rebind() error
  • func (u *StdConn) ReloadConfig(c *config.C)
  • func (u *StdConn) SetRecvBuffer(n int) error
  • func (u *StdConn) SetSendBuffer(n int) error
  • func (u *StdConn) WriteTo(b []byte, ip netip.AddrPort) error

Constants

const MTU = 9001

Functions

func NewUDPStatsEmitter

func NewUDPStatsEmitter(udpConns []Conn) func()

Types

type Conn

type Conn interface {
	Rebind() error
	LocalAddr() (netip.AddrPort, error)
	ListenOut(r EncReader, lhf LightHouseHandlerFunc, cache *firewall.ConntrackCacheTicker, q int)
	WriteTo(b []byte, addr netip.AddrPort) error
	ReloadConfig(c *config.C)
	Close() error
}

func NewListener

func NewListener(l *logrus.Logger, ip netip.Addr, port int, multi bool, batch int) (Conn, error)

type EncReader

type EncReader func(
	addr netip.AddrPort,
	out []byte,
	packet []byte,
	header *header.H,
	fwPacket *firewall.Packet,
	lhh LightHouseHandlerFunc,
	nb []byte,
	q int,
	localCache firewall.ConntrackCache,
)

type LightHouseHandlerFunc

type LightHouseHandlerFunc func(rAddr netip.AddrPort, vpnIp netip.Addr, p []byte)

TODO: IPV6-WORK this can likely be removed now

type NoopConn

type NoopConn struct{}

func (NoopConn) Close

func (NoopConn) Close() error

func (NoopConn) ListenOut

func (NoopConn) ListenOut(_ EncReader, _ LightHouseHandlerFunc, _ *firewall.ConntrackCacheTicker, _ int)

func (NoopConn) LocalAddr

func (NoopConn) LocalAddr() (netip.AddrPort, error)

func (NoopConn) Rebind

func (NoopConn) Rebind() error

func (NoopConn) ReloadConfig

func (NoopConn) ReloadConfig(_ *config.C)

func (NoopConn) WriteTo

func (NoopConn) WriteTo(_ []byte, _ netip.AddrPort) error

type StdConn

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

func (*StdConn) Close

func (u *StdConn) Close() error

func (*StdConn) GetRecvBuffer

func (u *StdConn) GetRecvBuffer() (int, error)

func (*StdConn) GetSendBuffer

func (u *StdConn) GetSendBuffer() (int, error)

func (*StdConn) ListenOut

func (u *StdConn) ListenOut(r EncReader, lhf LightHouseHandlerFunc, cache *firewall.ConntrackCacheTicker, q int)

func (*StdConn) LocalAddr

func (u *StdConn) LocalAddr() (netip.AddrPort, error)

func (*StdConn) PrepareRawMessages

func (u *StdConn) PrepareRawMessages(n int) ([]rawMessage, [][]byte, [][]byte)

func (*StdConn) ReadMulti

func (u *StdConn) ReadMulti(msgs []rawMessage) (int, error)

func (*StdConn) ReadSingle

func (u *StdConn) ReadSingle(msgs []rawMessage) (int, error)

func (*StdConn) Rebind

func (u *StdConn) Rebind() error

func (*StdConn) ReloadConfig

func (u *StdConn) ReloadConfig(c *config.C)

func (*StdConn) SetRecvBuffer

func (u *StdConn) SetRecvBuffer(n int) error

func (*StdConn) SetSendBuffer

func (u *StdConn) SetSendBuffer(n int) error

func (*StdConn) WriteTo

func (u *StdConn) WriteTo(b []byte, ip netip.AddrPort) error