Versions in this module Expand all Collapse all v0 v0.0.2 Mar 24, 2020 v0.0.1 Mar 20, 2020 Changes in this version + type Connection interface + AsyncClose func() + AsyncWrite func(data []byte) + Close func() + GetContext func() interface{} + IsConnected func() bool + RemoteAddr func() net.Addr + SetContext func(ctx interface{}) + Write func(data []byte) + type IEventHandler interface + OnClose func(c Connection) + OnInited func() + OnNewConnect func(c Connection) + OnNewRead func(c Connection, decodeObj interface{}) + type IFrameReadCodec interface + CodecOneFrame func([]byte) (obj interface{}, usedBytes uint64) + type Option func(opts *Options) + func WithEventCoroutineNum(eventCoroutineNum int) Option + func WithFrameReadCodec(codec IFrameReadCodec) Option + type Options struct + WorkGoroutinesNum int + type Poller struct — linux/amd64 + func Create() (*Poller, error) + func (ep *Poller) AddRead(fd int) error + func (ep *Poller) AddWrite(fd int) error + func (ep *Poller) Delete(fd int) error + func (ep *Poller) ModRead(fd int) error + func (ep *Poller) ModReadWrite(fd int) error + func (ep *Poller) Poll(handler func(fd int, event int32)) + func (ep *Poller) Trigger(job internal.Job) error + type Server interface + Start func() error + Stop func() error + func NewServer(eventHandler IEventHandler, port int, opts ...Option) (obj Server, err error)