tcp_epoll

Documentation

Index

• type ConnectionHandler
• type Epoll
  • func NewEpoll() (*Epoll, error)
  • func (e *Epoll) AddOrClose(c net.Conn) error
  • func (e *Epoll) Close(c *netConnItem) error
  • func (e *Epoll) CloseAll() (er error)
  • func (e *Epoll) Wait() (NetConns, error)
• type NetConns
• type Server
  • func NewServer() *Server
  • func (s *Server) Down() (err error)
  • func (s *Server) SetAddr(addr string)
  • func (s *Server) SetHandler(h ConnectionHandler)
  • func (s *Server) Up() (err error)

Types

type ConnectionHandler

type ConnectionHandler func([]byte, io.Writer) error

type Epoll

type Epoll struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewEpoll

func NewEpoll() (*Epoll, error)

func (*Epoll) AddOrClose

func (e *Epoll) AddOrClose(c net.Conn) error

func (*Epoll) Close

func (e *Epoll) Close(c *netConnItem) error

func (*Epoll) CloseAll

func (e *Epoll) CloseAll() (er error)

func (*Epoll) Wait

func (e *Epoll) Wait() (NetConns, error)

type NetConns

type NetConns []*netConnItem

type Server

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

func NewServer

func NewServer() *Server

func (*Server) Down

func (s *Server) Down() (err error)

func (*Server) SetAddr

func (s *Server) SetAddr(addr string)

func (*Server) SetHandler

func (s *Server) SetHandler(h ConnectionHandler)

func (*Server) Up

func (s *Server) Up() (err error)