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 AddrSlice
  • func (a AddrSlice) Equal(b AddrSlice) bool
• type Conn
  • func NewListener(l *logrus.Logger, ip net.IP, 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() (*Addr, error)
  • func (NoopConn) Rebind() error
  • func (NoopConn) ReloadConfig(_ *config.C)
  • func (NoopConn) WriteTo(_ []byte, _ *Addr) 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() (*Addr, 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, addr *Addr) error

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