|
@ -4,8 +4,7 @@ import ( |
|
|
"bytes" |
|
|
"bytes" |
|
|
"context" |
|
|
"context" |
|
|
"fmt" |
|
|
"fmt" |
|
|
|
|
|
|
|
|
"github.com/redis/go-redis/v9" |
|
|
|
|
|
|
|
|
"github.com/go-redis/redis/v8" |
|
|
"github.com/seaweedfs/seaweedfs/weed/util/skiplist" |
|
|
"github.com/seaweedfs/seaweedfs/weed/util/skiplist" |
|
|
) |
|
|
) |
|
|
|
|
|
|
|
@ -400,9 +399,9 @@ func (nl *ItemList) NodeSize(node *skiplist.SkipListElementReference) int { |
|
|
|
|
|
|
|
|
func (nl *ItemList) NodeAddMember(node *skiplist.SkipListElementReference, names ...string) error { |
|
|
func (nl *ItemList) NodeAddMember(node *skiplist.SkipListElementReference, names ...string) error { |
|
|
key := fmt.Sprintf("%s%dm", nl.prefix, node.ElementPointer) |
|
|
key := fmt.Sprintf("%s%dm", nl.prefix, node.ElementPointer) |
|
|
var members []redis.Z |
|
|
|
|
|
|
|
|
var members []*redis.Z |
|
|
for _, name := range names { |
|
|
for _, name := range names { |
|
|
members = append(members, redis.Z{ |
|
|
|
|
|
|
|
|
members = append(members, &redis.Z{ |
|
|
Score: 0, |
|
|
Score: 0, |
|
|
Member: name, |
|
|
Member: name, |
|
|
}) |
|
|
}) |
|
|