epoller

README

epoller

epoll implementation for connections in Linux, MacOS and windows.

Its target is implementing a simple epoll for connection, so you should see it only contains few methods:

type Poller interface {
	Add(conn net.Conn) error
	Remove(conn net.Conn) error
	Wait() ([]net.Conn, error)
	Close() error
}

Welcome any PRs for windows IOCompletePort.

Inspired by 1m-go-websockets.

Thanks @sunnyboy00 for providing windows implementation.

Documentation

Index

• func SocketFD(conn net.Conn) int
• type Poller
  • func NewPoller() (Poller, error)
  • func NewPollerWithBuffer(count int) (Poller, error)

Functions

func SocketFD

func SocketFD(conn net.Conn) int

Types

type Poller

type Poller interface {
	Add(conn net.Conn) (int, error)
	Remove(conn net.Conn) error
	Wait(count int) ([]net.Conn, error)
	WaitWithBuffer() ([]net.Conn, error)
	WaitChan(count int) <-chan []net.Conn
	GetConnectionByFD(fd int) (net.Conn, error)
	GetFDByConnection(conn net.Conn) (int, error)
	Close() error
}

func NewPoller

func NewPoller() (Poller, error)

func NewPollerWithBuffer

func NewPollerWithBuffer(count int) (Poller, error)