Versions in this module Expand all Collapse all v0 v0.0.1 Aug 31, 2019 Changes in this version + const EPOLLERR — linux/amd64 + const EPOLLET — linux/amd64 + const EPOLLHUP — linux/amd64 + const EPOLLIN — linux/amd64 + const EPOLLONESHOT — linux/amd64 + const EPOLLOUT — linux/amd64 + const EPOLLPRI — linux/amd64 + const EPOLLRDHUP — linux/amd64 + const EVFILT_AIO — darwin/amd64 + const EVFILT_PROC — darwin/amd64 + const EVFILT_READ — darwin/amd64 + const EVFILT_SIGNAL — darwin/amd64 + const EVFILT_TIMER — darwin/amd64 + const EVFILT_USER — darwin/amd64 + const EVFILT_VNODE — darwin/amd64 + const EVFILT_WRITE — darwin/amd64 + const EV_ADD — darwin/amd64 + const EV_CLEAR — darwin/amd64 + const EV_DELETE — darwin/amd64 + const EV_DISABLE — darwin/amd64 + const EV_DISPATCH — darwin/amd64 + const EV_ENABLE — darwin/amd64 + const EV_EOF — darwin/amd64 + const EV_ERROR — darwin/amd64 + const EV_ONESHOT — darwin/amd64 + const EV_RECEIPT — darwin/amd64 + const EventErr + const EventHup + const EventPollClosed + const EventReadHup + const EventWriteHup + var ErrClosed = fmt.Errorf("poller instance is closed") + var ErrNotFiler = fmt.Errorf("could not get file descriptor") + var ErrNotRegistered = fmt.Errorf("file descriptor was not registered before in poller instance") + var ErrRegistered = fmt.Errorf("file descriptor is already registered in poller instance") + type CallbackFn func(Event) + type Config struct + OnWaitError func(error) + type Desc struct + func Handle(conn net.Conn, event Event) (*Desc, error) + func HandleListener(ln net.Listener, event Event) (*Desc, error) + func HandleRead(conn net.Conn) (*Desc, error) + func HandleReadOnce(conn net.Conn) (*Desc, error) + func HandleReadWrite(conn net.Conn) (*Desc, error) + func HandleWrite(conn net.Conn) (*Desc, error) + func HandleWriteOnce(conn net.Conn) (*Desc, error) + func Must(desc *Desc, err error) *Desc + func NewDesc(fd uintptr, ev Event) (*Desc, error) + func (h *Desc) Close() error + func (h *Desc) Fd() int + type Epoll struct — linux/amd64 + func EpollCreate(c *EpollConfig) (*Epoll, error) + func (ep *Epoll) Add(fd int, events EpollEvent, cb func(EpollEvent)) (err error) + func (ep *Epoll) Close() (err error) + func (ep *Epoll) Del(fd int) (err error) + func (ep *Epoll) Mod(fd int, events EpollEvent) (err error) + type EpollConfig struct — linux/amd64 + OnWaitError func(error) + type EpollEvent uint32 — linux/amd64 + func (evt EpollEvent) String() (str string) + type Event uint16 + const EventEdgeTriggered + const EventOneShot + const EventRead + const EventWrite + func (ev Event) String() (str string) + type EventPoll interface + Resume func(*Desc) error + Start func(*Desc, CallbackFn) error + Stop func(*Desc) error + func New(*Config) (EventPoll, error) + func New(c *Config) (EventPoll, error) + type KEvent struct — darwin/amd64 + Data int64 + Fflags uint32 + Filter KeventFilter + Flags KeventFlag + type KEventHandler func(KEvent) — darwin/amd64 + type KEvents [8]KEvent — darwin/amd64 + type KQueue struct — darwin/amd64 + func KQueueCreate(c *KQueueConfig) (*KQueue, error) + func (k *KQueue) Add(fd int, events KEvents, n int, cb KEventHandler) error + func (k *KQueue) Close() error + func (k *KQueue) Del(fd int) error + func (k *KQueue) Mod(fd int, events KEvents, n int) error + type KQueueConfig struct — darwin/amd64 + OnWaitError func(error) + type KeventFilter int — darwin/amd64 + func (filter KeventFilter) String() (str string) + type KeventFlag int — darwin/amd64 + func (flag KeventFlag) String() (str string)
Go to main page