evio

Oct 17, 2018

Changes in this version

+ type Conn interface

+ AddrIndex func() int

+ Context func() interface{}

+ LocalAddr func() net.Addr

+ RemoteAddr func() net.Addr

+ SetContext func(interface{})

+ Wake func()

type Events

+ LoadBalance LoadBalance

+ NumLoops int

+ PreWrite func()

+ type LoadBalance int

+ const LeastConnections

+ const Random

+ const RoundRobin

type Server

+ NumLoops int

Mar 21, 2018

Changes in this version

+ func NopConn(rw io.ReadWriter) net.Conn

+ func Serve(events Events, addr ...string) error

+ type Action int

+ const Close

+ const Detach

+ const None

+ const Shutdown

+ type Events struct

+ Closed func(id int, err error) (action Action)

+ Data func(id int, in []byte) (out []byte, action Action)

+ Detached func(id int, rwc io.ReadWriteCloser) (action Action)

+ Opened func(id int, info Info) (out []byte, opts Options, action Action)

+ Postwrite func(id int, amount, remaining int) (action Action)

+ Prewrite func(id int, amount int) (action Action)

+ Serving func(server Server) (action Action)

+ Tick func() (delay time.Duration, action Action)

+ func Translate(events Events, should func(id int, info Info) bool, ...) Events

+ type Info struct

+ AddrIndex int

+ Closing bool

+ LocalAddr net.Addr

+ RemoteAddr net.Addr

+ type InputStream struct

+ func (is *InputStream) Begin(packet []byte) (data []byte)

+ func (is *InputStream) End(data []byte)

+ type Options struct

+ ReuseInputBuffer bool

+ TCPKeepAlive time.Duration

+ type Server struct

+ Addrs []net.Addr

+ Dial func(addr string, timeout time.Duration) (id int)

+ Wake func(id int) (ok bool)