zhangdeman/gopkg
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

更新类型处理

Browse Source
This commit is contained in:
白茶清欢 2021-08-15 21:00:01 +08:00
parent b0d67ca05a
commit f3170976fd
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
middleware/redis/client.go
View File

@ -9,6 +9,7 @@ package redis
import ( import (
"encoding/json" "encoding/json"
"fmt"
"strings" "strings"
"time" "time"
@ -219,7 +220,7 @@ func (c *Client) CommandProxy(ctx *Context, flag string, cmd string, param ...in
startTime := time.Now().Unix() startTime := time.Now().Unix()
cmdResult := realClient.Instance.Do(ctx.Ctx, redisCmd...) cmdResult := realClient.Instance.Do(ctx.Ctx, redisCmd...)
go c.log(ctx, realClient, cmdResult, startTime, time.Now().UnixNano()) go c.log(ctx, realClient, cmdResult, startTime, time.Now().UnixNano())
return cmdResult.String(), c.parseErrorFunc(cmdResult.Err()) return fmt.Sprintf("%v", cmdResult.Val()), c.parseErrorFunc(cmdResult.Err())
} }
// CommandProxyWithReceiver 执行命令,并解析结果 // CommandProxyWithReceiver 执行命令,并解析结果