type MsgpackCodec struct { w io.Writer h codec.Handle } func NewMsgpackCodec() *MsgpackCodec { return &MsgpackCodec{ w: ioutil.Discard, h: new(codec.MsgpackHandle), } } func (c *MsgpackCodec) Encode(w io.Writer, v interface{}) error { // TODO encoder pool return codec.NewEncoder(w, c.h).Encode(v) } func (c *MsgpackCodec) Decode(r io.Reader, v interface{}) error { // TODO decoder pool return codec.NewDecoder(r, c.h).Decode(v) } .