udp

Documentation

Index

• Constants
• Variables
• func IPToBin(ip net.IP) string
• func New(g *config.Group) (d dispatcher.Dispatcher)
• type IPMTUTrie
  • func NewIPMTUTrieFromInterfaces() (*IPMTUTrie, error)
  • func (t *IPMTUTrie) GetMTU(ip net.IP) int
• type UDP
  • func (d *UDP) Auth(buf []byte, data []byte, userContext *config.UserContext) (hit *config.Server, content []byte)
  • func (d *UDP) Close() (err error)
  • func (d *UDP) GetOrBuildUCPConn(laddr net.Addr, data []byte) (rc *net.UDPConn, err error)
  • func (d *UDP) Listen() (err error)
  • func (d *UDP) UpdateGroup(group *config.Group)
• type UDPConn
  • func NewUDPConn(conn *net.UDPConn) *UDPConn
• type UDPConnMapping
  • func NewUDPConnMapping() *UDPConnMapping
  • func (m *UDPConnMapping) Get(key string) (conn *UDPConn, ok bool)
  • func (m *UDPConnMapping) Insert(key string, val *net.UDPConn) *UDPConn
  • func (m *UDPConnMapping) Remove(key string)

Constants

const (
	MTU               = 65535
	BasicLen          = 32
	DefaultNatTimeout = 3 * time.Minute
	DnsQueryTimeout   = 17 * time.Second // RFC 5452
)

Variables

var AuthFailedErr = fmt.Errorf("auth failed")

Functions

func IPToBin

func IPToBin(ip net.IP) string

func New

func New(g *config.Group) (d dispatcher.Dispatcher)

Types

type IPMTUTrie

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

var MTUTrie *IPMTUTrie

func NewIPMTUTrieFromInterfaces

func NewIPMTUTrieFromInterfaces() (*IPMTUTrie, error)

func (*IPMTUTrie) GetMTU

func (t *IPMTUTrie) GetMTU(ip net.IP) int

type UDP

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

func (*UDP) Auth

func (d *UDP) Auth(buf []byte, data []byte, userContext *config.UserContext) (hit *config.Server, content []byte)

func (*UDP) Close

func (d *UDP) Close() (err error)

func (*UDP) GetOrBuildUCPConn

func (d *UDP) GetOrBuildUCPConn(laddr net.Addr, data []byte) (rc *net.UDPConn, err error)

connTimeout is the timeout of connection to build if not exists

func (*UDP) Listen

func (d *UDP) Listen() (err error)

func (*UDP) UpdateGroup

func (d *UDP) UpdateGroup(group *config.Group)

type UDPConn

type UDPConn struct {
	Establishing chan struct{}

	*net.UDPConn
	// contains filtered or unexported fields
}

func NewUDPConn

func NewUDPConn(conn *net.UDPConn) *UDPConn

type UDPConnMapping

type UDPConnMapping struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewUDPConnMapping

func NewUDPConnMapping() *UDPConnMapping

func (*UDPConnMapping) Get

func (m *UDPConnMapping) Get(key string) (conn *UDPConn, ok bool)

func (*UDPConnMapping) Insert

func (m *UDPConnMapping) Insert(key string, val *net.UDPConn) *UDPConn

pass val=nil for stating it is establishing

func (*UDPConnMapping) Remove

func (m *UDPConnMapping) Remove(key string)