netpoll

package

Go to main page

Versions in this module

v0

v0.1.12

Jun 16, 2020

v0.1.10

Jun 16, 2020

v0.1.9

Jun 15, 2020

v0.1.8

Jun 15, 2020

v0.1.7

Jun 11, 2020

v0.1.6

Jun 11, 2020

v0.1.5

Jun 11, 2020

v0.1.4

Jun 11, 2020

v0.1.3

Jun 11, 2020

v0.1.2

Jun 10, 2020

v0.1.1

Jun 10, 2020

v0.1.0

Jun 10, 2020

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 EventPollerClosed

+ 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

+ func (h *Desc) Close() error

+ 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 Kevent struct — darwin/amd64

+ Data int64

+ Fflags uint32

+ Filter KeventFilter

+ Flags KeventFlag

+ type KeventFilter int — darwin/amd64

+ func (filter KeventFilter) String() (str string)

+ type KeventFlag int — darwin/amd64

+ func (flag KeventFlag) String() (str string)

+ 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 Poller interface

+ Resume func(*Desc) error

+ Start func(*Desc, CallbackFn) error

+ Stop func(*Desc) error

+ func New(*Config) (Poller, error)

+ func New(c *Config) (Poller, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL