proto

Oct 10, 2019

Changes in this version

+ var ErrClientClosed = errors.New("client closed")

Oct 10, 2019

Changes in this version

+ func ListenAndServe(network, addr string, p Proto, connHandler ConnHandler) (rerr error)

+ func Serve(lis net.Listener, p Proto, connHandler ConnHandler) (err error)

+ type ConnHandler interface

+ MessageHandler func() MessageHandler

+ type ConnHandlerFunc func() MessageHandler

+ func (h ConnHandlerFunc) MessageHandler() MessageHandler

+ type MessageHandler interface

+ HandleMessage func(interface{}) interface{}

+ type MessageHandlerFunc func(interface{}) interface

+ func (h MessageHandlerFunc) HandleMessage(msg interface{}) interface{}

+ type Msizer interface

+ P9Msize func() uint32

Oct 10, 2019

Changes in this version

+ const NoTag

+ var ErrLargeMessage = errors.New("message larger than msize")

+ func Read(r io.Reader, v interface{}) error

+ func Size(v interface{}) (uint32, error)

+ func Write(w io.Writer, v interface{}) error

+ type Client struct

+ func Dial(p Proto, network, addr string) (*Client, error)

+ func NewClient(p Proto, c net.Conn) *Client

+ func (c *Client) Close() error

+ func (c *Client) Msize() uint32

+ func (c *Client) Send(msg interface{}) (interface{}, error)

+ func (c *Client) SetMsize(size uint32)

+ type Decoder interface

+ P9Decode func(r io.Reader) error

+ type Encoder interface

+ P9Encode func() ([]byte, error)

+ type P9NoTag interface

+ P9NoTag func()

+ type Proto struct

+ func NewProto(mapping map[uint8]reflect.Type) Proto

+ func (p Proto) IDFromType(t reflect.Type) (uint8, bool)

+ func (p Proto) Receive(r io.Reader, msize uint32) (msg interface{}, tag uint16, err error)

+ func (p Proto) Send(w io.Writer, tag uint16, msg interface{}) (err error)

+ func (p Proto) TypeFromID(id uint8) reflect.Type