udp

Documentation

Index

• Constants
• func NewListenConfig(multi bool) net.ListenConfig
• func NewUDPStatsEmitter(udpConns []Conn) func()
• func ParseIPAndPort(s string) (net.IP, uint16, error)
• type Addr
  • func NewAddr(ip net.IP, port uint16) *Addr
  • func NewAddrFromString(s string) *Addr
  • func (ua *Addr) Copy() *Addr
  • func (ua *Addr) Equals(t *Addr) bool
  • func (ua *Addr) MarshalJSON() ([]byte, error)
  • func (ua *Addr) String() string
• type AddrSlice
  • func (a AddrSlice) Equal(b AddrSlice) bool
• type Conn
  • func NewGenericListener(l *logrus.Logger, ip net.IP, port int, multi bool, batch int) (Conn, error)
  • func NewListener(l *logrus.Logger, ip net.IP, port int, multi bool, batch int) (Conn, error)
• type EncReader
• type GenericConn
  • func (u *GenericConn) ListenOut(r EncReader, lhf LightHouseHandlerFunc, cache *firewall.ConntrackCacheTicker, ...)
  • func (u *GenericConn) LocalAddr() (*Addr, error)
  • func (u *GenericConn) Rebind() error
  • func (u *GenericConn) ReloadConfig(c *config.C)
  • func (u *GenericConn) WriteTo(b []byte, addr *Addr) error
• type LightHouseHandlerFunc
• type NoopConn
  • func (NoopConn) Close() error
  • func (NoopConn) ListenOut(_ EncReader, _ LightHouseHandlerFunc, _ *firewall.ConntrackCacheTicker, _ int)
  • func (NoopConn) LocalAddr() (*Addr, error)
  • func (NoopConn) Rebind() error
  • func (NoopConn) ReloadConfig(_ *config.C)
  • func (NoopConn) WriteTo(_ []byte, _ *Addr) error
• type RIOConn
  • func NewRIOListener(l *logrus.Logger, ip net.IP, port int) (*RIOConn, error)
  • func (u *RIOConn) Close() error
  • func (u *RIOConn) ListenOut(r EncReader, lhf LightHouseHandlerFunc, cache *firewall.ConntrackCacheTicker, ...)
  • func (u *RIOConn) LocalAddr() (*Addr, error)
  • func (u *RIOConn) Rebind() error
  • func (u *RIOConn) ReloadConfig(*config.C)
  • func (u *RIOConn) WriteTo(buf []byte, addr *Addr) error

Constants

const MTU = 9001

Functions

func NewListenConfig

func NewListenConfig(multi bool) net.ListenConfig

func NewUDPStatsEmitter

func NewUDPStatsEmitter(udpConns []Conn) func()

func ParseIPAndPort

func ParseIPAndPort(s string) (net.IP, uint16, error)

Types

type Addr

type Addr struct {
	IP   net.IP
	Port uint16
}

func NewAddr

func NewAddr(ip net.IP, port uint16) *Addr

func NewAddrFromString

func NewAddrFromString(s string) *Addr

func (*Addr) Copy

func (ua *Addr) Copy() *Addr

func (*Addr) Equals

func (ua *Addr) Equals(t *Addr) bool

func (*Addr) MarshalJSON

func (ua *Addr) MarshalJSON() ([]byte, error)

func (*Addr) String

func (ua *Addr) String() string

type AddrSlice

type AddrSlice []*Addr

func (AddrSlice) Equal

func (a AddrSlice) Equal(b AddrSlice) bool

type Conn

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

func NewGenericListener

func NewGenericListener(l *logrus.Logger, ip net.IP, port int, multi bool, batch int) (Conn, error)

func NewListener

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

type EncReader

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

type GenericConn

type GenericConn struct {
	*net.UDPConn
	// contains filtered or unexported fields
}

func (*GenericConn) ListenOut

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

func (*GenericConn) LocalAddr

func (u *GenericConn) LocalAddr() (*Addr, error)

func (*GenericConn) Rebind

func (u *GenericConn) Rebind() error

func (*GenericConn) ReloadConfig

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

func (*GenericConn) WriteTo

func (u *GenericConn) WriteTo(b []byte, addr *Addr) error

type LightHouseHandlerFunc

type LightHouseHandlerFunc func(rAddr *Addr, vpnIp iputil.VpnIp, p []byte)

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() (*Addr, error)

func (NoopConn) Rebind

func (NoopConn) Rebind() error

func (NoopConn) ReloadConfig

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

func (NoopConn) WriteTo

func (NoopConn) WriteTo(_ []byte, _ *Addr) error

type RIOConn

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

func NewRIOListener

func NewRIOListener(l *logrus.Logger, ip net.IP, port int) (*RIOConn, error)

func (*RIOConn) Close

func (u *RIOConn) Close() error

func (*RIOConn) ListenOut

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

func (*RIOConn) LocalAddr

func (u *RIOConn) LocalAddr() (*Addr, error)

func (*RIOConn) Rebind

func (u *RIOConn) Rebind() error

func (*RIOConn) ReloadConfig

func (u *RIOConn) ReloadConfig(*config.C)

func (*RIOConn) WriteTo

func (u *RIOConn) WriteTo(buf []byte, addr *Addr) error