epoll

Documentation

Index

• type Epoll
  • func NewEpoll() (*Epoll, error)
  • func (e *Epoll) Add(conn net.Conn) error
  • func (e *Epoll) Remove(conn net.Conn) error
  • func (e *Epoll) Wait() ([]net.Conn, error)
• type HandlerConn
• type Workerpool
  • func NewPool(w int, t int, handler HandlerConn) *Workerpool
  • func (wp *Workerpool) AddTask(conn net.Conn)
  • func (wp *Workerpool) Close()
  • func (wp *Workerpool) Start()
  • func (wp *Workerpool) StartWorker()

Types

type Epoll

type Epoll struct {
	ConnSet *util.Set
	// contains filtered or unexported fields
}

func NewEpoll

func NewEpoll() (*Epoll, error)

func (*Epoll) Add

func (e *Epoll) Add(conn net.Conn) error

func (*Epoll) Remove

func (e *Epoll) Remove(conn net.Conn) error

func (*Epoll) Wait

func (e *Epoll) Wait() ([]net.Conn, error)

type HandlerConn

type HandlerConn func(conn net.Conn)

type Workerpool

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

func NewPool

func NewPool(w int, t int, handler HandlerConn) *Workerpool

func (*Workerpool) AddTask

func (wp *Workerpool) AddTask(conn net.Conn)

func (*Workerpool) Close

func (wp *Workerpool) Close()

func (*Workerpool) Start

func (wp *Workerpool) Start()

func (*Workerpool) StartWorker

func (wp *Workerpool) StartWorker()