udp

Documentation

Index

• Constants
• 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 Conn
  • func NewListener(l *logrus.Logger, ip string, port int, multi bool, batch int) (*Conn, error)
  • func (u *Conn) GetRecvBuffer() (int, error)
  • func (u *Conn) GetSendBuffer() (int, error)
  • func (u *Conn) ListenOut(r EncReader, lhf LightHouseHandlerFunc, cache *firewall.ConntrackCacheTicker, ...)
  • func (u *Conn) LocalAddr() (*Addr, error)
  • func (u *Conn) PrepareRawMessages(n int) ([]rawMessage, [][]byte, [][]byte)
  • func (u *Conn) ReadMulti(msgs []rawMessage) (int, error)
  • func (u *Conn) ReadSingle(msgs []rawMessage) (int, error)
  • func (u *Conn) Rebind() error
  • func (u *Conn) ReloadConfig(c *config.C)
  • func (u *Conn) SetRecvBuffer(n int) error
  • func (u *Conn) SetSendBuffer(n int) error
  • func (u *Conn) WriteTo(b []byte, addr *Addr) error
• type EncReader
• type EncWriter
• type LightHouseHandlerFunc

Constants

const MTU = 9001

Functions

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 Conn

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

func NewListener

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

func (*Conn) GetRecvBuffer

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

func (*Conn) GetSendBuffer

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

func (*Conn) ListenOut

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

func (*Conn) LocalAddr

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

func (*Conn) PrepareRawMessages

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

func (*Conn) ReadMulti

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

func (*Conn) ReadSingle

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

func (*Conn) Rebind

func (u *Conn) Rebind() error

func (*Conn) ReloadConfig

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

func (*Conn) SetRecvBuffer

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

func (*Conn) SetSendBuffer

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

func (*Conn) WriteTo

func (u *Conn) WriteTo(b []byte, addr *Addr) 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 EncWriter

type EncWriter interface {
	SendMessageToVpnIp(t header.MessageType, st header.MessageSubType, vpnIp iputil.VpnIp, p, nb, out []byte)
}

type LightHouseHandlerFunc

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