lxg пре 4 година
родитељ
комит
4d51588e91
2 измењених фајлова са 25 додато и 2 уклоњено
  1. 1 2
      gateway/rpc/codec/codec.go
  2. 24 0
      gateway/rpc/codec/json_codec.go

+ 1 - 2
gateway/rpc/codec/codec.go

@@ -2,9 +2,8 @@ package codec
 
 import "io"
 
-
 var (
-	DefaultCodec = &GobCodec{}
+	DefaultCodec = &JsonCodec{}
 )
 
 type Codec interface {

+ 24 - 0
gateway/rpc/codec/json_codec.go

@@ -0,0 +1,24 @@
+package codec
+
+import (
+	"encoding/json"
+	"io"
+)
+
+type JsonCodec struct{}
+
+func (codec *JsonCodec) EncodeTo(w io.Writer, i interface{}) (err error) {
+	return json.NewEncoder(w).Encode(i)
+}
+
+func (codec *JsonCodec) DecodeFrom(r io.Reader, i interface{}) (err error) {
+	return json.NewDecoder(r).Decode(i)
+}
+
+func (codec *JsonCodec) Encode(i interface{}) (b []byte, err error) {
+	return json.Marshal(i)
+}
+
+func (codec *JsonCodec) Decode(b []byte, i interface{}) (err error) {
+	return json.Unmarshal(b, i)
+}