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
eb6ba7e3cd
commit
91ea5d1fe8
13
pkg/common/storage/cache/redis/msg_test.go
vendored
13
pkg/common/storage/cache/redis/msg_test.go
vendored
@ -94,6 +94,19 @@ func Test_msgCache_GetMessagesBySeq(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func Test_msgCache_GetMessagesBySeq2(t *testing.T) {
|
||||||
|
c := &msgCache{
|
||||||
|
rdb: redis.NewClient(&redis.Options{Addr: "localhost:16379", Password: "openIM123", DB: 0}),
|
||||||
|
}
|
||||||
|
gotSeqMsgs, gotFailedSeqs, err := c.GetMessagesBySeq(context.Background(), "cid", []int64{1, 2, 3})
|
||||||
|
if err != nil {
|
||||||
|
fmt.Println("Test_msgCache_GetMessagesBySeq2 error is ", err)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
fmt.Println("Test_msgCache_GetMessagesBySeq2 result is ", gotSeqMsgs, gotFailedSeqs)
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
func Test_msgCache_DeleteMessagesFromCache(t *testing.T) {
|
func Test_msgCache_DeleteMessagesFromCache(t *testing.T) {
|
||||||
type fields struct {
|
type fields struct {
|
||||||
rdb redis.UniversalClient
|
rdb redis.UniversalClient
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user