fastudp

README

fastudp

fast and more fast

Documentation

Index

• Variables
• type Handler
• type Server
  • func NewUDPServer(network, addr string, reusePort bool, listenerN int, mtu int, handler Handler) (*Server, error)
  • func (svr *Server) FillWriteQueue(mmsgs ...*netudp.Mmsg) (int, error)
  • func (svr *Server) Shutdown()
  • func (svr *Server) WriteTo(data []byte, addr *net.UDPAddr)
  • func (svr *Server) WriteToN(mmsgs ...*netudp.Mmsg) (int, error)

Variables

var (
	MsgHdrSize     = 128
	ReadEventSize  = 128
	WriteEventSize = 128
)

Types

type Handler

type Handler func([]byte, *net.UDPAddr)

type Server

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

func NewUDPServer

func NewUDPServer(network, addr string, reusePort bool, listenerN int, mtu int, handler Handler) (*Server, error)

func (*Server) FillWriteQueue

func (svr *Server) FillWriteQueue(mmsgs ...*netudp.Mmsg) (int, error)

func (*Server) Shutdown

func (svr *Server) Shutdown()

func (*Server) WriteTo

func (svr *Server) WriteTo(data []byte, addr *net.UDPAddr)

TODO: need load balancing?

func (*Server) WriteToN

func (svr *Server) WriteToN(mmsgs ...*netudp.Mmsg) (int, error)

直接发送