perf: use gob instaed of json

Author: ahuigo

cache-map-redis.go

@@ -1,7 +1,8 @@
 package gofnext
 
 import (
-	"encoding/json"
+	"bytes"
+	"encoding/gob"
 	"errors"
 	"hash/fnv"
 	"strconv"
@@ -108,26 +109,41 @@ func (m *redisMap) strkey(key any) string {
 	return r
 }
 
-func (m *redisMap) Store(key, value any, err error) {
+func (m *redisMap) Store(key, value any, err0 error) {
+	buf := &bytes.Buffer{}
+	if err := gob.NewEncoder(buf).Encode(value); err != nil {
+		slogger.Error("gofnext.redisMap", "err", err.Error())
+		return
+	}
+
 	pkey := m.strkey(key)
-	data, _ := json.Marshal(value)
+	// data, _ := json.Marshal(value)
 	cacheData := redisData{
-		Data: data,
+		Data: buf.Bytes(),
 		// TTL:  m.ttl,
 	}
-	if err != nil && m.errTtl <= 0 {
+	if err0 != nil && m.errTtl <= 0 {
+		// do not cache error
 		return
 	}
 	if m.ttl > 0 || m.errTtl >= 0 {
 		cacheData.CreatedAt = time.Now()
 	}
-	if err != nil {
-		cacheData.Err = []byte(err.Error())
+	if err0 != nil {
+		cacheData.Err = []byte(err0.Error())
 	}
-	val, _ := json.Marshal(cacheData)
-	err = m.redisClient.HSet(m.redisFuncKey, pkey, val).Err()
+
+	// encode value to bytes
+	buf = &bytes.Buffer{}
+	if err := gob.NewEncoder(buf).Encode(cacheData); err != nil {
+		slogger.Error("gofnext.redisMap", "err", err.Error())
+		return
+	}
+	// val, _ := json.Marshal(cacheData)
+	val := buf.Bytes()
+	err := m.redisClient.HSet(m.redisFuncKey, pkey, val).Err()
 	if err != nil {
-		slogger.Warn("gofnext.redisMap", "err", err.Error())
+		slogger.Error("gofnext.redisMap", "err", err.Error())
 	}
 }
 
@@ -145,10 +161,14 @@ func (m *redisMap) Load(key any) (value any, hasCache, alive bool, err error) {
 		return
 	}
 	cacheData := redisData{}
-	err = json.Unmarshal(val, &cacheData)
-	if err != nil {
+	if err = gob.NewDecoder(bytes.NewReader(val)).Decode(&cacheData); err != nil {
+		slogger.Error("gofnext.redisMap", "err", err.Error())
 		return
 	}
+	// err = json.Unmarshal(val, &cacheData)
+	// if err != nil {
+	// 	return
+	// }
 
 	value = cacheData.Data
 	if cacheData.Err != nil {

decorator.go

@@ -1,8 +1,9 @@
 package gofnext
 
 import (
+	"bytes"
 	"context"
-	"encoding/json"
+	"encoding/gob"
 	"reflect"
 	"sync"
 	"time"
@@ -352,7 +353,9 @@ checkCache:
 
 	// 3.1 check if marshal needed
 	if hasCache && c.cacheMap.NeedMarshal() {
-		err2 := json.Unmarshal(value.([]byte), &retv)
+		// err2 := json.Unmarshal(value.([]byte), &retv)
+		dec := gob.NewDecoder(bytes.NewBuffer(value.([]byte)))
+		err2 := dec.Decode(&retv)
 		if err == nil {
 			err = err2
 		}

gofnext_pg

@@ -1 +1 @@
-Subproject commit 9270418f130ea096097d96de86c8499360508ea5
+Subproject commit 0f8928923e78fb62f532747dba8ed62e335a3740

version

@@ -1 +1 @@
-v0.1.2
+v0.1.3