Versions in this module Expand all Collapse all v0 v0.1.0 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)
Go to main page