gaio

May 6, 2021

Changes in this version

+ var ErrCPUID = errors.New("no such core")

type Watcher — darwin/amd64, linux/amd64

+ func (w Watcher) SetLoopAffinity(cpuid int) (err error)

+ func (w Watcher) SetPollerAffinity(cpuid int) (err error)

Mar 31, 2021

Changes in this version

+ const EV_READ

+ const EV_WRITE

Feb 12, 2020

Changes in this version

type Watcher

+ func (w Watcher) ReadFull(ctx interface{}, conn net.Conn, buf []byte, deadline time.Time) error

Feb 8, 2020

Changes in this version

+ var ErrPollerClosed = errors.New("poller closed")

Feb 3, 2020

Changes in this version

type OpResult

+ IsSwapBuffer bool

Jan 31, 2020

Changes in this version

+ var ErrEmptyBuffer = errors.New("empty buffer")

Jan 31, 2020

Changes in this version

type Watcher

+ func NewWatcherSize(bufsize int) (*Watcher, error)

Jan 13, 2020

Changes in this version

+ func Free(conn net.Conn) error

type Watcher

+ func (w *Watcher) Free(conn net.Conn) error

Jan 13, 2020

Changes in this version

+ var ErrConnClosed = errors.New("connection closed")

+ func Release(conn net.Conn) error

type OpResult

+ Error error

+ Operation OpType

+ func WaitIO() (r OpResult, err error)

type Watcher

+ func (w *Watcher) Release(conn net.Conn) error

Jan 10, 2020

Changes in this version

+ var ErrUnsupported = errors.New("unsupported connection")

+ func Read(ctx interface{}, conn net.Conn, buf []byte) error

+ func ReadTimeout(ctx interface{}, conn net.Conn, buf []byte, deadline time.Time) error

+ func Write(ctx interface{}, conn net.Conn, buf []byte) error

+ func WriteTimeout(ctx interface{}, conn net.Conn, buf []byte, deadline time.Time) error

Jan 8, 2020

Changes in this version

type OpResult

+ Conn net.Conn

type Watcher

+ func NewWatcher(bufsize int) (*Watcher, error)

Jan 7, 2020

Changes in this version

+ var ErrNotWatched = errors.New("file descriptor is not being watched")

Jan 6, 2020

Changes in this version

type Watcher

+ func (w *Watcher) CloseConn(fd int) error

+ func (w *Watcher) NewConn(conn net.Conn) (fd int, err error)

Jan 6, 2020

Changes in this version

type Watcher

+ func (w *Watcher) ReadInternal(ctx interface{}, fd int) error

Jan 6, 2020

Changes in this version

+ const EPOLLET — linux/amd64

Jan 5, 2020

Changes in this version

+ var ErrDeadline = errors.New("operation exceeded deadline")

+ type TimedSched struct

+ var SystemTimedSched *TimedSched = NewTimedSched(runtime.NumCPU())

+ func NewTimedSched(parallel int) *TimedSched

+ func (ts *TimedSched) Close()

+ func (ts *TimedSched) Put(f func(), deadline time.Time)

type Watcher

+ func (w *Watcher) ReadTimeout(ctx interface{}, fd int, buf []byte, deadline time.Time) error

+ func (w *Watcher) WriteTimeout(ctx interface{}, fd int, buf []byte, deadline time.Time) error

Dec 31, 2019

Changes in this version

type OpResult

+ Op OpType

+ type OpType int

+ const OpRead

+ const OpWrite

type Watcher

+ func (w *Watcher) WaitIO() (r OpResult, err error)

Dec 30, 2019

Changes in this version

type OpResult

+ Context interface{}

Dec 24, 2019

Changes in this version

+ var ErrBufferedChan = errors.New("cannot use bufferd chan to notify")

+ var ErrNoRawConn = errors.New("net.Conn does implement net.RawConn")

+ var ErrWatcherClosed = errors.New("watcher closed")

+ type OpResult struct

+ Buffer []byte

+ Err error

+ Fd int

+ Size int

+ type Watcher struct

+ func CreateWatcher(bufsize int) (*Watcher, error)

+ func (w *Watcher) Close() (err error)

+ func (w *Watcher) Read(fd int, done chan OpResult) error

+ func (w *Watcher) StopWatch(fd int)

+ func (w *Watcher) Watch(conn net.Conn) (fd int, err error)

+ func (w *Watcher) Write(fd int, buf []byte, done chan OpResult) error