toyframe

Index ¶

• Variables
• func DoWithInterruptor(job func(), interrupt_ch chan struct{}) error
• func InterruptableReader(reader io.Reader, interrupt_ch chan struct{}) io.Reader
• func InterruptableWriter(writer io.WriteCloser, interrupt_ch chan struct{}) io.WriteCloser
• func SetLogWriter(out io.Writer)
• type Context
• • func Call(network, addr, method string, dial dialer.DialFunc, ...) (*Context, error)
  • func CallWithInterruptor(network, addr, method string, dial dialer.DialFunc, ich chan struct{}, ...) (*Context, error)
  • func NewContext(conn net.Conn) *Context
• • func (c *Context) AddCloseHandler(cb func())
  • func (c *Context) Close() error
  • func (c *Context) LocalAddr() net.Addr
  • func (c *Context) ReadObj(obj msgp.Unmarshaler) error
  • func (c *Context) Reader() io.Reader
  • func (c *Context) RemoteAddr() net.Addr
  • func (c *Context) SetInterruptor(ich chan struct{})
  • func (c *Context) WriteObj(obj msgp.MarshalSizer) error
  • func (c *Context) Writer() io.Writer
• type Handler
• type NullWriter
• • func (w NullWriter) Write(data []byte) (int, error)
• type Server
• • func NewServer() Server