Versions in this module Expand all Collapse all v1 v1.4.0 Apr 19, 2026 Changes in this version + var ErrAlreadyRegistered = errors.New("celeris/eventloop: fd already registered") + var ErrLoopClosed = errors.New("celeris/eventloop: loop is closed") + func IsAsyncServer(sp ServerProvider) bool + func Release(provider engine.EventLoopProvider) + func Resolve(sp ServerProvider) (engine.EventLoopProvider, error) + type AsyncHandlerProvider interface + AsyncHandlers func() bool + type Loop struct + func New(workers int) (*Loop, error) + func (l *Loop) Close() error + func (l *Loop) NumWorkers() int + func (l *Loop) WorkerLoop(n int) engine.WorkerLoop + type ServerProvider interface + EventLoopProvider func() engine.EventLoopProvider + type SyncBusyRoundTripper interface — linux/amd64 + WriteAndPollBusy func(fd int, data []byte, rbuf []byte, onRecv func([]byte)) (ok bool, err error) + type SyncMultiRoundTripper interface — linux/amd64 + WriteAndPollMulti func(fd int, data []byte, rbuf []byte, onRecv func([]byte), isDone func() bool, ...) (ok bool, err error) + type SyncRoundTripper interface — linux/amd64 + WriteAndPoll func(fd int, data []byte, rbuf []byte, onRecv func([]byte)) (ok bool, err error)
Go to main page