Versions in this module Expand all Collapse all v1 v1.1.0 Nov 13, 2022 v1.0.1 Nov 12, 2022 Changes in this version type Poller + AsyncReadWriteFd bool + ErrForStop chan error v1.0.0 Nov 11, 2022 Changes in this version + var PollTaskPool = sync.Pool + func PutTask(t *PollTask) + type PollTask struct + Arg iface.PollTaskArg + Go iface.PollTaskFunc + func GetTask() *PollTask + type Poller struct + Eloop iface.IELoop + ErrInfoChan chan error + Pool *ants.Pool + ReadBufferSize int + func New() (p *Poller, err error) + func (that *Poller) AddPriorTask(f iface.PollTaskFunc, arg iface.PollTaskArg) (err error) + func (that *Poller) AddRead(fd iface.IFd) error + func (that *Poller) AddReadWrite(fd iface.IFd) error + func (that *Poller) AddTask(f iface.PollTaskFunc, arg iface.PollTaskArg) (err error) + func (that *Poller) AddWrite(fd iface.IFd) error + func (that *Poller) Close() error + func (that *Poller) GetFd() int + func (that *Poller) GetPollEvFd() int + func (that *Poller) ModRead(fd iface.IFd) error + func (that *Poller) ModReadWrite(fd iface.IFd) error + func (that *Poller) ModWrite(fd iface.IFd) error + func (that *Poller) RemoveFd(fd iface.IFd) error + func (that *Poller) Start(callback iface.IPollCallback) error
Go to main page