mirror of
https://github.com/openimsdk/open-im-server.git
synced 2025-11-05 03:42:08 +08:00
refactor: delete message and message batch use lua.
This commit is contained in:
parent
625244e5f7
commit
af2757ed47
2
pkg/common/storage/cache/redis/lua_script.go
vendored
2
pkg/common/storage/cache/redis/lua_script.go
vendored
@ -50,8 +50,8 @@ func callLua(ctx context.Context, rdb redis.Scripter, script *redis.Script, keys
|
|||||||
if redis.HasErrorPrefix(r.Err(), "NOSCRIPT") {
|
if redis.HasErrorPrefix(r.Err(), "NOSCRIPT") {
|
||||||
if err := script.Load(ctx, rdb).Err(); err != nil {
|
if err := script.Load(ctx, rdb).Err(); err != nil {
|
||||||
r = script.Eval(ctx, rdb, keys, args)
|
r = script.Eval(ctx, rdb, keys, args)
|
||||||
|
} else {
|
||||||
r = script.EvalSha(ctx, rdb, keys, args)
|
r = script.EvalSha(ctx, rdb, keys, args)
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
v, err := r.Result()
|
v, err := r.Result()
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user