EncodeMsgPack writes an encoded object to a new bytes buffer.
(in interface{})
| 51 | |
| 52 | // EncodeMsgPack writes an encoded object to a new bytes buffer. |
| 53 | func EncodeMsgPack(in interface{}) (*bytes.Buffer, error) { |
| 54 | buf := bytes.NewBuffer(nil) |
| 55 | enc := codec.NewEncoder(buf, msgPackHandle) |
| 56 | err := enc.Encode(in) |
| 57 | return buf, err |
| 58 | } |
| 59 | |
| 60 | // GetMsgPackServerCodec returns msgpack server codec for connection. |
| 61 | func GetMsgPackServerCodec(c io.ReadWriteCloser) rpc.ServerCodec { |
no outgoing calls