lwnet

type Connection interface {
	Write(data []byte)
	IsConnected() bool
	RemoteAddr() net.Addr
	Close()
	GetSysFd() int
	SetContext(ctx interface{})
	GetContext() interface{}
}

type EventHandler interface {
	OnNewConnect(c Connection)
	OnNewRead(c Connection, readBuffer *ringbuffer.RingBuffer)
	OnClose(c Connection)
}

type Option func(opts *Options)

type Options struct {
	AcceptCoroutineNum int
	EventCoroutineNum  int

	RingBufSize int

	// ReusePort indicates whether to set up the SO_REUSEPORT option.
	ReusePort bool
}

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