mirror of https://github.com/go-redis/redis.git
Merge branch 'master' of https://github.com/redis/go-redis into os-add-ts-insertion-filters
This commit is contained in:
commit
187a478936
|
@ -57,4 +57,5 @@ url
|
||||||
variadic
|
variadic
|
||||||
RedisStack
|
RedisStack
|
||||||
RedisGears
|
RedisGears
|
||||||
RedisTimeseries
|
RedisTimeseries
|
||||||
|
RediSearch
|
||||||
|
|
|
@ -8,7 +8,7 @@ jobs:
|
||||||
- name: Checkout
|
- name: Checkout
|
||||||
uses: actions/checkout@v4
|
uses: actions/checkout@v4
|
||||||
- name: Check Spelling
|
- name: Check Spelling
|
||||||
uses: rojopolis/spellcheck-github-actions@0.36.0
|
uses: rojopolis/spellcheck-github-actions@0.38.0
|
||||||
with:
|
with:
|
||||||
config_path: .github/spellcheck-settings.yml
|
config_path: .github/spellcheck-settings.yml
|
||||||
task_name: Markdown
|
task_name: Markdown
|
||||||
|
|
2
Makefile
2
Makefile
|
@ -31,7 +31,7 @@ build:
|
||||||
|
|
||||||
testdata/redis:
|
testdata/redis:
|
||||||
mkdir -p $@
|
mkdir -p $@
|
||||||
wget -qO- https://download.redis.io/releases/redis-7.2.1.tar.gz | tar xvz --strip-components=1 -C $@
|
wget -qO- https://download.redis.io/releases/redis-7.4-rc1.tar.gz | tar xvz --strip-components=1 -C $@
|
||||||
|
|
||||||
testdata/redis/src/redis-server: testdata/redis
|
testdata/redis/src/redis-server: testdata/redis
|
||||||
cd $< && make all
|
cd $< && make all
|
||||||
|
|
66
command.go
66
command.go
|
@ -573,6 +573,10 @@ func (cmd *StatusCmd) Result() (string, error) {
|
||||||
return cmd.val, cmd.err
|
return cmd.val, cmd.err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (cmd *StatusCmd) Bytes() ([]byte, error) {
|
||||||
|
return util.StringToBytes(cmd.val), cmd.err
|
||||||
|
}
|
||||||
|
|
||||||
func (cmd *StatusCmd) String() string {
|
func (cmd *StatusCmd) String() string {
|
||||||
return cmdString(cmd, cmd.val)
|
return cmdString(cmd, cmd.val)
|
||||||
}
|
}
|
||||||
|
@ -3783,6 +3787,65 @@ func (cmd *MapStringStringSliceCmd) readReply(rd *proto.Reader) error {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// -----------------------------------------------------------------------
|
||||||
|
// MapStringInterfaceCmd represents a command that returns a map of strings to interface{}.
|
||||||
|
type MapMapStringInterfaceCmd struct {
|
||||||
|
baseCmd
|
||||||
|
val map[string]interface{}
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewMapMapStringInterfaceCmd(ctx context.Context, args ...interface{}) *MapMapStringInterfaceCmd {
|
||||||
|
return &MapMapStringInterfaceCmd{
|
||||||
|
baseCmd: baseCmd{
|
||||||
|
ctx: ctx,
|
||||||
|
args: args,
|
||||||
|
},
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (cmd *MapMapStringInterfaceCmd) String() string {
|
||||||
|
return cmdString(cmd, cmd.val)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (cmd *MapMapStringInterfaceCmd) SetVal(val map[string]interface{}) {
|
||||||
|
cmd.val = val
|
||||||
|
}
|
||||||
|
|
||||||
|
func (cmd *MapMapStringInterfaceCmd) Result() (map[string]interface{}, error) {
|
||||||
|
return cmd.val, cmd.err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (cmd *MapMapStringInterfaceCmd) Val() map[string]interface{} {
|
||||||
|
return cmd.val
|
||||||
|
}
|
||||||
|
|
||||||
|
func (cmd *MapMapStringInterfaceCmd) readReply(rd *proto.Reader) (err error) {
|
||||||
|
n, err := rd.ReadArrayLen()
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
data := make(map[string]interface{}, n/2)
|
||||||
|
for i := 0; i < n; i += 2 {
|
||||||
|
_, err := rd.ReadArrayLen()
|
||||||
|
if err != nil {
|
||||||
|
cmd.err = err
|
||||||
|
}
|
||||||
|
key, err := rd.ReadString()
|
||||||
|
if err != nil {
|
||||||
|
cmd.err = err
|
||||||
|
}
|
||||||
|
value, err := rd.ReadString()
|
||||||
|
if err != nil {
|
||||||
|
cmd.err = err
|
||||||
|
}
|
||||||
|
data[key] = value
|
||||||
|
}
|
||||||
|
|
||||||
|
cmd.val = data
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
//-----------------------------------------------------------------------
|
//-----------------------------------------------------------------------
|
||||||
|
|
||||||
type MapStringInterfaceSliceCmd struct {
|
type MapStringInterfaceSliceCmd struct {
|
||||||
|
@ -4997,6 +5060,7 @@ type ClientInfo struct {
|
||||||
PSub int // number of pattern matching subscriptions
|
PSub int // number of pattern matching subscriptions
|
||||||
SSub int // redis version 7.0.3, number of shard channel subscriptions
|
SSub int // redis version 7.0.3, number of shard channel subscriptions
|
||||||
Multi int // number of commands in a MULTI/EXEC context
|
Multi int // number of commands in a MULTI/EXEC context
|
||||||
|
Watch int // redis version 7.4 RC1, number of keys this client is currently watching.
|
||||||
QueryBuf int // qbuf, query buffer length (0 means no query pending)
|
QueryBuf int // qbuf, query buffer length (0 means no query pending)
|
||||||
QueryBufFree int // qbuf-free, free space of the query buffer (0 means the buffer is full)
|
QueryBufFree int // qbuf-free, free space of the query buffer (0 means the buffer is full)
|
||||||
ArgvMem int // incomplete arguments for the next command (already extracted from query buffer)
|
ArgvMem int // incomplete arguments for the next command (already extracted from query buffer)
|
||||||
|
@ -5149,6 +5213,8 @@ func parseClientInfo(txt string) (info *ClientInfo, err error) {
|
||||||
info.SSub, err = strconv.Atoi(val)
|
info.SSub, err = strconv.Atoi(val)
|
||||||
case "multi":
|
case "multi":
|
||||||
info.Multi, err = strconv.Atoi(val)
|
info.Multi, err = strconv.Atoi(val)
|
||||||
|
case "watch":
|
||||||
|
info.Watch, err = strconv.Atoi(val)
|
||||||
case "qbuf":
|
case "qbuf":
|
||||||
info.QueryBuf, err = strconv.Atoi(val)
|
info.QueryBuf, err = strconv.Atoi(val)
|
||||||
case "qbuf-free":
|
case "qbuf-free":
|
||||||
|
|
|
@ -220,6 +220,7 @@ type Cmdable interface {
|
||||||
ProbabilisticCmdable
|
ProbabilisticCmdable
|
||||||
PubSubCmdable
|
PubSubCmdable
|
||||||
ScriptingFunctionsCmdable
|
ScriptingFunctionsCmdable
|
||||||
|
SearchCmdable
|
||||||
SetCmdable
|
SetCmdable
|
||||||
SortedSetCmdable
|
SortedSetCmdable
|
||||||
StringCmdable
|
StringCmdable
|
||||||
|
|
275
commands_test.go
275
commands_test.go
|
@ -193,6 +193,40 @@ var _ = Describe("Commands", func() {
|
||||||
Expect(r.Val()).To(Equal(int64(0)))
|
Expect(r.Val()).To(Equal(int64(0)))
|
||||||
})
|
})
|
||||||
|
|
||||||
|
It("should ClientKillByFilter with MAXAGE", Label("NonRedisEnterprise"), func() {
|
||||||
|
var s []string
|
||||||
|
started := make(chan bool)
|
||||||
|
done := make(chan bool)
|
||||||
|
|
||||||
|
go func() {
|
||||||
|
defer GinkgoRecover()
|
||||||
|
|
||||||
|
started <- true
|
||||||
|
blpop := client.BLPop(ctx, 0, "list")
|
||||||
|
Expect(blpop.Val()).To(Equal(s))
|
||||||
|
done <- true
|
||||||
|
}()
|
||||||
|
<-started
|
||||||
|
|
||||||
|
select {
|
||||||
|
case <-done:
|
||||||
|
Fail("BLPOP is not blocked.")
|
||||||
|
case <-time.After(2 * time.Second):
|
||||||
|
// ok
|
||||||
|
}
|
||||||
|
|
||||||
|
killed := client.ClientKillByFilter(ctx, "MAXAGE", "1")
|
||||||
|
Expect(killed.Err()).NotTo(HaveOccurred())
|
||||||
|
Expect(killed.Val()).To(SatisfyAny(Equal(int64(2)), Equal(int64(3))))
|
||||||
|
|
||||||
|
select {
|
||||||
|
case <-done:
|
||||||
|
// ok
|
||||||
|
case <-time.After(time.Second):
|
||||||
|
Fail("BLPOP is still blocked.")
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
It("should ClientID", func() {
|
It("should ClientID", func() {
|
||||||
err := client.ClientID(ctx).Err()
|
err := client.ClientID(ctx).Err()
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
@ -1100,6 +1134,26 @@ var _ = Describe("Commands", func() {
|
||||||
|
|
||||||
keys, cursor, err := client.HScan(ctx, "myhash", 0, "", 0).Result()
|
keys, cursor, err := client.HScan(ctx, "myhash", 0, "", 0).Result()
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
// If we don't get at least two items back, it's really strange.
|
||||||
|
Expect(cursor).To(BeNumerically(">=", 2))
|
||||||
|
Expect(len(keys)).To(BeNumerically(">=", 2))
|
||||||
|
Expect(keys[0]).To(HavePrefix("key"))
|
||||||
|
Expect(keys[1]).To(Equal("hello"))
|
||||||
|
})
|
||||||
|
|
||||||
|
It("should HScan without values", Label("NonRedisEnterprise"), func() {
|
||||||
|
for i := 0; i < 1000; i++ {
|
||||||
|
sadd := client.HSet(ctx, "myhash", fmt.Sprintf("key%d", i), "hello")
|
||||||
|
Expect(sadd.Err()).NotTo(HaveOccurred())
|
||||||
|
}
|
||||||
|
|
||||||
|
keys, cursor, err := client.HScanNoValues(ctx, "myhash", 0, "", 0).Result()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
// If we don't get at least two items back, it's really strange.
|
||||||
|
Expect(cursor).To(BeNumerically(">=", 2))
|
||||||
|
Expect(len(keys)).To(BeNumerically(">=", 2))
|
||||||
|
Expect(keys[0]).To(HavePrefix("key"))
|
||||||
|
Expect(keys[1]).To(HavePrefix("key"))
|
||||||
Expect(keys).NotTo(BeEmpty())
|
Expect(keys).NotTo(BeEmpty())
|
||||||
Expect(cursor).NotTo(BeZero())
|
Expect(cursor).NotTo(BeZero())
|
||||||
})
|
})
|
||||||
|
@ -2430,6 +2484,155 @@ var _ = Describe("Commands", func() {
|
||||||
Equal([]redis.KeyValue{{Key: "key2", Value: "hello2"}}),
|
Equal([]redis.KeyValue{{Key: "key2", Value: "hello2"}}),
|
||||||
))
|
))
|
||||||
})
|
})
|
||||||
|
|
||||||
|
It("should HExpire", Label("hash-expiration", "NonRedisEnterprise"), func() {
|
||||||
|
res, err := client.HExpire(ctx, "no_such_key", 10, "field1", "field2", "field3").Result()
|
||||||
|
Expect(err).To(BeNil())
|
||||||
|
for i := 0; i < 100; i++ {
|
||||||
|
sadd := client.HSet(ctx, "myhash", fmt.Sprintf("key%d", i), "hello")
|
||||||
|
Expect(sadd.Err()).NotTo(HaveOccurred())
|
||||||
|
}
|
||||||
|
|
||||||
|
res, err = client.HExpire(ctx, "myhash", 10, "key1", "key2", "key200").Result()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
Expect(res).To(Equal([]int64{1, 1, -2}))
|
||||||
|
})
|
||||||
|
|
||||||
|
It("should HPExpire", Label("hash-expiration", "NonRedisEnterprise"), func() {
|
||||||
|
_, err := client.HPExpire(ctx, "no_such_key", 10, "field1", "field2", "field3").Result()
|
||||||
|
Expect(err).To(BeNil())
|
||||||
|
for i := 0; i < 100; i++ {
|
||||||
|
sadd := client.HSet(ctx, "myhash", fmt.Sprintf("key%d", i), "hello")
|
||||||
|
Expect(sadd.Err()).NotTo(HaveOccurred())
|
||||||
|
}
|
||||||
|
|
||||||
|
res, err := client.HPExpire(ctx, "myhash", 10, "key1", "key2", "key200").Result()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
Expect(res).To(Equal([]int64{1, 1, -2}))
|
||||||
|
})
|
||||||
|
|
||||||
|
It("should HExpireAt", Label("hash-expiration", "NonRedisEnterprise"), func() {
|
||||||
|
|
||||||
|
_, err := client.HExpireAt(ctx, "no_such_key", time.Now().Add(10*time.Second), "field1", "field2", "field3").Result()
|
||||||
|
Expect(err).To(BeNil())
|
||||||
|
for i := 0; i < 100; i++ {
|
||||||
|
sadd := client.HSet(ctx, "myhash", fmt.Sprintf("key%d", i), "hello")
|
||||||
|
Expect(sadd.Err()).NotTo(HaveOccurred())
|
||||||
|
}
|
||||||
|
|
||||||
|
res, err := client.HExpireAt(ctx, "myhash", time.Now().Add(10*time.Second), "key1", "key2", "key200").Result()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
Expect(res).To(Equal([]int64{1, 1, -2}))
|
||||||
|
})
|
||||||
|
|
||||||
|
It("should HPExpireAt", Label("hash-expiration", "NonRedisEnterprise"), func() {
|
||||||
|
|
||||||
|
_, err := client.HPExpireAt(ctx, "no_such_key", time.Now().Add(10*time.Second), "field1", "field2", "field3").Result()
|
||||||
|
Expect(err).To(BeNil())
|
||||||
|
for i := 0; i < 100; i++ {
|
||||||
|
sadd := client.HSet(ctx, "myhash", fmt.Sprintf("key%d", i), "hello")
|
||||||
|
Expect(sadd.Err()).NotTo(HaveOccurred())
|
||||||
|
}
|
||||||
|
|
||||||
|
res, err := client.HPExpireAt(ctx, "myhash", time.Now().Add(10*time.Second), "key1", "key2", "key200").Result()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
Expect(res).To(Equal([]int64{1, 1, -2}))
|
||||||
|
})
|
||||||
|
|
||||||
|
It("should HPersist", Label("hash-expiration", "NonRedisEnterprise"), func() {
|
||||||
|
|
||||||
|
_, err := client.HPersist(ctx, "no_such_key", "field1", "field2", "field3").Result()
|
||||||
|
Expect(err).To(BeNil())
|
||||||
|
for i := 0; i < 100; i++ {
|
||||||
|
sadd := client.HSet(ctx, "myhash", fmt.Sprintf("key%d", i), "hello")
|
||||||
|
Expect(sadd.Err()).NotTo(HaveOccurred())
|
||||||
|
}
|
||||||
|
|
||||||
|
res, err := client.HPersist(ctx, "myhash", "key1", "key2", "key200").Result()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
Expect(res).To(Equal([]int64{-1, -1, -2}))
|
||||||
|
|
||||||
|
res, err = client.HExpire(ctx, "myhash", 10, "key1", "key200").Result()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
Expect(res).To(Equal([]int64{1, -2}))
|
||||||
|
|
||||||
|
res, err = client.HPersist(ctx, "myhash", "key1", "key2", "key200").Result()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
Expect(res).To(Equal([]int64{1, -1, -2}))
|
||||||
|
})
|
||||||
|
|
||||||
|
It("should HExpireTime", Label("hash-expiration", "NonRedisEnterprise"), func() {
|
||||||
|
|
||||||
|
_, err := client.HExpireTime(ctx, "no_such_key", "field1", "field2", "field3").Result()
|
||||||
|
Expect(err).To(BeNil())
|
||||||
|
for i := 0; i < 100; i++ {
|
||||||
|
sadd := client.HSet(ctx, "myhash", fmt.Sprintf("key%d", i), "hello")
|
||||||
|
Expect(sadd.Err()).NotTo(HaveOccurred())
|
||||||
|
}
|
||||||
|
|
||||||
|
res, err := client.HExpire(ctx, "myhash", 10, "key1", "key200").Result()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
Expect(res).To(Equal([]int64{1, -2}))
|
||||||
|
|
||||||
|
res, err = client.HExpireTime(ctx, "myhash", "key1", "key2", "key200").Result()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
Expect(res[0]).To(BeNumerically("~", time.Now().Add(10*time.Second).Unix(), 1))
|
||||||
|
})
|
||||||
|
|
||||||
|
It("should HPExpireTime", Label("hash-expiration", "NonRedisEnterprise"), func() {
|
||||||
|
|
||||||
|
_, err := client.HPExpireTime(ctx, "no_such_key", "field1", "field2", "field3").Result()
|
||||||
|
Expect(err).To(BeNil())
|
||||||
|
for i := 0; i < 100; i++ {
|
||||||
|
sadd := client.HSet(ctx, "myhash", fmt.Sprintf("key%d", i), "hello")
|
||||||
|
Expect(sadd.Err()).NotTo(HaveOccurred())
|
||||||
|
}
|
||||||
|
|
||||||
|
expireAt := time.Now().Add(10 * time.Second)
|
||||||
|
res, err := client.HPExpireAt(ctx, "myhash", expireAt, "key1", "key200").Result()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
Expect(res).To(Equal([]int64{1, -2}))
|
||||||
|
|
||||||
|
res, err = client.HPExpireTime(ctx, "myhash", "key1", "key2", "key200").Result()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
Expect(res).To(BeEquivalentTo([]int64{expireAt.UnixMilli(), -1, -2}))
|
||||||
|
})
|
||||||
|
|
||||||
|
It("should HTTL", Label("hash-expiration", "NonRedisEnterprise"), func() {
|
||||||
|
|
||||||
|
_, err := client.HTTL(ctx, "no_such_key", "field1", "field2", "field3").Result()
|
||||||
|
Expect(err).To(BeNil())
|
||||||
|
for i := 0; i < 100; i++ {
|
||||||
|
sadd := client.HSet(ctx, "myhash", fmt.Sprintf("key%d", i), "hello")
|
||||||
|
Expect(sadd.Err()).NotTo(HaveOccurred())
|
||||||
|
}
|
||||||
|
|
||||||
|
res, err := client.HExpire(ctx, "myhash", 10, "key1", "key200").Result()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
Expect(res).To(Equal([]int64{1, -2}))
|
||||||
|
|
||||||
|
res, err = client.HTTL(ctx, "myhash", "key1", "key2", "key200").Result()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
Expect(res).To(Equal([]int64{10, -1, -2}))
|
||||||
|
})
|
||||||
|
|
||||||
|
It("should HPTTL", Label("hash-expiration", "NonRedisEnterprise"), func() {
|
||||||
|
|
||||||
|
_, err := client.HPTTL(ctx, "no_such_key", "field1", "field2", "field3").Result()
|
||||||
|
Expect(err).To(BeNil())
|
||||||
|
for i := 0; i < 100; i++ {
|
||||||
|
sadd := client.HSet(ctx, "myhash", fmt.Sprintf("key%d", i), "hello")
|
||||||
|
Expect(sadd.Err()).NotTo(HaveOccurred())
|
||||||
|
}
|
||||||
|
|
||||||
|
res, err := client.HExpire(ctx, "myhash", 10, "key1", "key200").Result()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
Expect(res).To(Equal([]int64{1, -2}))
|
||||||
|
|
||||||
|
res, err = client.HPTTL(ctx, "myhash", "key1", "key2", "key200").Result()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
Expect(res[0]).To(BeNumerically("~", 10*time.Second.Milliseconds(), 1))
|
||||||
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
Describe("hyperloglog", func() {
|
Describe("hyperloglog", func() {
|
||||||
|
@ -5686,6 +5889,78 @@ var _ = Describe("Commands", func() {
|
||||||
Expect(err).To(Equal(redis.Nil))
|
Expect(err).To(Equal(redis.Nil))
|
||||||
})
|
})
|
||||||
|
|
||||||
|
It("should XRead LastEntry", Label("NonRedisEnterprise"), func() {
|
||||||
|
res, err := client.XRead(ctx, &redis.XReadArgs{
|
||||||
|
Streams: []string{"stream"},
|
||||||
|
Count: 2, // we expect 1 message
|
||||||
|
ID: "+",
|
||||||
|
}).Result()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
Expect(res).To(Equal([]redis.XStream{
|
||||||
|
{
|
||||||
|
Stream: "stream",
|
||||||
|
Messages: []redis.XMessage{
|
||||||
|
{ID: "3-0", Values: map[string]interface{}{"tres": "troix"}},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
}))
|
||||||
|
})
|
||||||
|
|
||||||
|
It("should XRead LastEntry from two streams", Label("NonRedisEnterprise"), func() {
|
||||||
|
res, err := client.XRead(ctx, &redis.XReadArgs{
|
||||||
|
Streams: []string{"stream", "stream"},
|
||||||
|
ID: "+",
|
||||||
|
}).Result()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
Expect(res).To(Equal([]redis.XStream{
|
||||||
|
{
|
||||||
|
Stream: "stream",
|
||||||
|
Messages: []redis.XMessage{
|
||||||
|
{ID: "3-0", Values: map[string]interface{}{"tres": "troix"}},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
Stream: "stream",
|
||||||
|
Messages: []redis.XMessage{
|
||||||
|
{ID: "3-0", Values: map[string]interface{}{"tres": "troix"}},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
}))
|
||||||
|
})
|
||||||
|
|
||||||
|
It("should XRead LastEntry blocks", Label("NonRedisEnterprise"), func() {
|
||||||
|
start := time.Now()
|
||||||
|
go func() {
|
||||||
|
defer GinkgoRecover()
|
||||||
|
|
||||||
|
time.Sleep(100 * time.Millisecond)
|
||||||
|
id, err := client.XAdd(ctx, &redis.XAddArgs{
|
||||||
|
Stream: "empty",
|
||||||
|
ID: "4-0",
|
||||||
|
Values: map[string]interface{}{"quatro": "quatre"},
|
||||||
|
}).Result()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
Expect(id).To(Equal("4-0"))
|
||||||
|
}()
|
||||||
|
|
||||||
|
res, err := client.XRead(ctx, &redis.XReadArgs{
|
||||||
|
Streams: []string{"empty"},
|
||||||
|
Block: 500 * time.Millisecond,
|
||||||
|
ID: "+",
|
||||||
|
}).Result()
|
||||||
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
// Ensure that the XRead call with LastEntry option blocked for at least 100ms.
|
||||||
|
Expect(time.Since(start)).To(BeNumerically(">=", 100*time.Millisecond))
|
||||||
|
Expect(res).To(Equal([]redis.XStream{
|
||||||
|
{
|
||||||
|
Stream: "empty",
|
||||||
|
Messages: []redis.XMessage{
|
||||||
|
{ID: "4-0", Values: map[string]interface{}{"quatro": "quatre"}},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
}))
|
||||||
|
})
|
||||||
|
|
||||||
Describe("group", func() {
|
Describe("group", func() {
|
||||||
BeforeEach(func() {
|
BeforeEach(func() {
|
||||||
err := client.XGroupCreate(ctx, "stream", "group", "0").Err()
|
err := client.XGroupCreate(ctx, "stream", "group", "0").Err()
|
||||||
|
|
|
@ -5,7 +5,7 @@ go 1.18
|
||||||
replace github.com/redis/go-redis/v9 => ../..
|
replace github.com/redis/go-redis/v9 => ../..
|
||||||
|
|
||||||
require (
|
require (
|
||||||
github.com/redis/go-redis/v9 v9.5.1
|
github.com/redis/go-redis/v9 v9.5.3
|
||||||
go.uber.org/zap v1.24.0
|
go.uber.org/zap v1.24.0
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
github.com/benbjohnson/clock v1.1.0 h1:Q92kusRqC1XV2MjkWETPvjJVqKetz1OzxZB7mHJLju8=
|
github.com/benbjohnson/clock v1.1.0 h1:Q92kusRqC1XV2MjkWETPvjJVqKetz1OzxZB7mHJLju8=
|
||||||
github.com/bsm/ginkgo/v2 v2.7.0 h1:ItPMPH90RbmZJt5GtkcNvIRuGEdwlBItdNVoyzaNQao=
|
github.com/bsm/ginkgo/v2 v2.12.0 h1:Ny8MWAHyOepLGlLKYmXG4IEkioBysk6GpaRTLC8zwWs=
|
||||||
github.com/bsm/gomega v1.26.0 h1:LhQm+AFcgV2M0WyKroMASzAzCAJVpAxQXv4SaI9a69Y=
|
github.com/bsm/gomega v1.27.10 h1:yeMWxP2pV2fG3FgAODIY8EiRE3dy0aeFYt4l7wh6yKA=
|
||||||
github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44=
|
github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44=
|
||||||
github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
|
github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
|
||||||
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
|
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
|
||||||
|
|
|
@ -4,7 +4,7 @@ go 1.18
|
||||||
|
|
||||||
replace github.com/redis/go-redis/v9 => ../..
|
replace github.com/redis/go-redis/v9 => ../..
|
||||||
|
|
||||||
require github.com/redis/go-redis/v9 v9.5.1
|
require github.com/redis/go-redis/v9 v9.5.3
|
||||||
|
|
||||||
require (
|
require (
|
||||||
github.com/cespare/xxhash/v2 v2.2.0 // indirect
|
github.com/cespare/xxhash/v2 v2.2.0 // indirect
|
||||||
|
|
|
@ -1,5 +1,5 @@
|
||||||
github.com/bsm/ginkgo/v2 v2.7.0 h1:ItPMPH90RbmZJt5GtkcNvIRuGEdwlBItdNVoyzaNQao=
|
github.com/bsm/ginkgo/v2 v2.12.0 h1:Ny8MWAHyOepLGlLKYmXG4IEkioBysk6GpaRTLC8zwWs=
|
||||||
github.com/bsm/gomega v1.26.0 h1:LhQm+AFcgV2M0WyKroMASzAzCAJVpAxQXv4SaI9a69Y=
|
github.com/bsm/gomega v1.27.10 h1:yeMWxP2pV2fG3FgAODIY8EiRE3dy0aeFYt4l7wh6yKA=
|
||||||
github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44=
|
github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44=
|
||||||
github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
|
github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
|
||||||
github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
|
github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
|
||||||
|
|
|
@ -4,7 +4,7 @@ go 1.18
|
||||||
|
|
||||||
replace github.com/redis/go-redis/v9 => ../..
|
replace github.com/redis/go-redis/v9 => ../..
|
||||||
|
|
||||||
require github.com/redis/go-redis/v9 v9.5.1
|
require github.com/redis/go-redis/v9 v9.5.3
|
||||||
|
|
||||||
require (
|
require (
|
||||||
github.com/cespare/xxhash/v2 v2.2.0 // indirect
|
github.com/cespare/xxhash/v2 v2.2.0 // indirect
|
||||||
|
|
|
@ -1,5 +1,5 @@
|
||||||
github.com/bsm/ginkgo/v2 v2.7.0 h1:ItPMPH90RbmZJt5GtkcNvIRuGEdwlBItdNVoyzaNQao=
|
github.com/bsm/ginkgo/v2 v2.12.0 h1:Ny8MWAHyOepLGlLKYmXG4IEkioBysk6GpaRTLC8zwWs=
|
||||||
github.com/bsm/gomega v1.26.0 h1:LhQm+AFcgV2M0WyKroMASzAzCAJVpAxQXv4SaI9a69Y=
|
github.com/bsm/gomega v1.27.10 h1:yeMWxP2pV2fG3FgAODIY8EiRE3dy0aeFYt4l7wh6yKA=
|
||||||
github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44=
|
github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44=
|
||||||
github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
|
github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
|
||||||
github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
|
github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
|
||||||
|
|
|
@ -9,8 +9,8 @@ replace github.com/redis/go-redis/extra/redisotel/v9 => ../../extra/redisotel
|
||||||
replace github.com/redis/go-redis/extra/rediscmd/v9 => ../../extra/rediscmd
|
replace github.com/redis/go-redis/extra/rediscmd/v9 => ../../extra/rediscmd
|
||||||
|
|
||||||
require (
|
require (
|
||||||
github.com/redis/go-redis/extra/redisotel/v9 v9.5.1
|
github.com/redis/go-redis/extra/redisotel/v9 v9.5.3
|
||||||
github.com/redis/go-redis/v9 v9.5.1
|
github.com/redis/go-redis/v9 v9.5.3
|
||||||
github.com/uptrace/uptrace-go v1.21.0
|
github.com/uptrace/uptrace-go v1.21.0
|
||||||
go.opentelemetry.io/otel v1.22.0
|
go.opentelemetry.io/otel v1.22.0
|
||||||
)
|
)
|
||||||
|
@ -23,7 +23,7 @@ require (
|
||||||
github.com/go-logr/stdr v1.2.2 // indirect
|
github.com/go-logr/stdr v1.2.2 // indirect
|
||||||
github.com/golang/protobuf v1.5.3 // indirect
|
github.com/golang/protobuf v1.5.3 // indirect
|
||||||
github.com/grpc-ecosystem/grpc-gateway/v2 v2.19.0 // indirect
|
github.com/grpc-ecosystem/grpc-gateway/v2 v2.19.0 // indirect
|
||||||
github.com/redis/go-redis/extra/rediscmd/v9 v9.5.1 // indirect
|
github.com/redis/go-redis/extra/rediscmd/v9 v9.5.3 // indirect
|
||||||
go.opentelemetry.io/contrib/instrumentation/runtime v0.46.1 // indirect
|
go.opentelemetry.io/contrib/instrumentation/runtime v0.46.1 // indirect
|
||||||
go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetricgrpc v0.44.0 // indirect
|
go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetricgrpc v0.44.0 // indirect
|
||||||
go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.21.0 // indirect
|
go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.21.0 // indirect
|
||||||
|
@ -34,8 +34,8 @@ require (
|
||||||
go.opentelemetry.io/otel/sdk/metric v1.21.0 // indirect
|
go.opentelemetry.io/otel/sdk/metric v1.21.0 // indirect
|
||||||
go.opentelemetry.io/otel/trace v1.22.0 // indirect
|
go.opentelemetry.io/otel/trace v1.22.0 // indirect
|
||||||
go.opentelemetry.io/proto/otlp v1.0.0 // indirect
|
go.opentelemetry.io/proto/otlp v1.0.0 // indirect
|
||||||
golang.org/x/net v0.20.0 // indirect
|
golang.org/x/net v0.23.0 // indirect
|
||||||
golang.org/x/sys v0.16.0 // indirect
|
golang.org/x/sys v0.18.0 // indirect
|
||||||
golang.org/x/text v0.14.0 // indirect
|
golang.org/x/text v0.14.0 // indirect
|
||||||
google.golang.org/genproto v0.0.0-20240108191215-35c7eff3a6b1 // indirect
|
google.golang.org/genproto v0.0.0-20240108191215-35c7eff3a6b1 // indirect
|
||||||
google.golang.org/genproto/googleapis/api v0.0.0-20240108191215-35c7eff3a6b1 // indirect
|
google.golang.org/genproto/googleapis/api v0.0.0-20240108191215-35c7eff3a6b1 // indirect
|
||||||
|
|
|
@ -46,10 +46,10 @@ go.opentelemetry.io/otel/trace v1.22.0/go.mod h1:RbbHXVqKES9QhzZq/fE5UnOSILqRt40
|
||||||
go.opentelemetry.io/proto/otlp v1.0.0 h1:T0TX0tmXU8a3CbNXzEKGeU5mIVOdf0oykP+u2lIVU/I=
|
go.opentelemetry.io/proto/otlp v1.0.0 h1:T0TX0tmXU8a3CbNXzEKGeU5mIVOdf0oykP+u2lIVU/I=
|
||||||
go.opentelemetry.io/proto/otlp v1.0.0/go.mod h1:Sy6pihPLfYHkr3NkUbEhGHFhINUSI/v80hjKIs5JXpM=
|
go.opentelemetry.io/proto/otlp v1.0.0/go.mod h1:Sy6pihPLfYHkr3NkUbEhGHFhINUSI/v80hjKIs5JXpM=
|
||||||
go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
|
go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
|
||||||
golang.org/x/net v0.20.0 h1:aCL9BSgETF1k+blQaYUBx9hJ9LOGP3gAVemcZlf1Kpo=
|
golang.org/x/net v0.23.0 h1:7EYJ93RZ9vYSZAIb2x3lnuvqO5zneoD6IvWjuhfxjTs=
|
||||||
golang.org/x/net v0.20.0/go.mod h1:z8BVo6PvndSri0LbOE3hAn0apkU+1YvI6E70E9jsnvY=
|
golang.org/x/net v0.23.0/go.mod h1:JKghWKKOSdJwpW2GEx0Ja7fmaKnMsbu+MWVZTokSYmg=
|
||||||
golang.org/x/sys v0.16.0 h1:xWw16ngr6ZMtmxDyKyIgsE93KNKz5HKmMa3b8ALHidU=
|
golang.org/x/sys v0.18.0 h1:DBdB3niSjOA/O0blCZBqDefyWNYveAYMNF1Wum0DYQ4=
|
||||||
golang.org/x/sys v0.16.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
|
golang.org/x/sys v0.18.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
|
||||||
golang.org/x/text v0.14.0 h1:ScX5w1eTa3QqT8oi6+ziP7dTV1S2+ALU0bI+0zXKWiQ=
|
golang.org/x/text v0.14.0 h1:ScX5w1eTa3QqT8oi6+ziP7dTV1S2+ALU0bI+0zXKWiQ=
|
||||||
golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
|
golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
|
||||||
golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
|
golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
|
||||||
|
|
|
@ -4,7 +4,7 @@ go 1.18
|
||||||
|
|
||||||
replace github.com/redis/go-redis/v9 => ../..
|
replace github.com/redis/go-redis/v9 => ../..
|
||||||
|
|
||||||
require github.com/redis/go-redis/v9 v9.5.1
|
require github.com/redis/go-redis/v9 v9.5.3
|
||||||
|
|
||||||
require (
|
require (
|
||||||
github.com/cespare/xxhash/v2 v2.2.0 // indirect
|
github.com/cespare/xxhash/v2 v2.2.0 // indirect
|
||||||
|
|
|
@ -1,5 +1,5 @@
|
||||||
github.com/bsm/ginkgo/v2 v2.7.0 h1:ItPMPH90RbmZJt5GtkcNvIRuGEdwlBItdNVoyzaNQao=
|
github.com/bsm/ginkgo/v2 v2.12.0 h1:Ny8MWAHyOepLGlLKYmXG4IEkioBysk6GpaRTLC8zwWs=
|
||||||
github.com/bsm/gomega v1.26.0 h1:LhQm+AFcgV2M0WyKroMASzAzCAJVpAxQXv4SaI9a69Y=
|
github.com/bsm/gomega v1.27.10 h1:yeMWxP2pV2fG3FgAODIY8EiRE3dy0aeFYt4l7wh6yKA=
|
||||||
github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44=
|
github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44=
|
||||||
github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
|
github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
|
||||||
github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
|
github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
|
||||||
|
|
|
@ -6,7 +6,7 @@ replace github.com/redis/go-redis/v9 => ../..
|
||||||
|
|
||||||
require (
|
require (
|
||||||
github.com/davecgh/go-spew v1.1.1
|
github.com/davecgh/go-spew v1.1.1
|
||||||
github.com/redis/go-redis/v9 v9.5.1
|
github.com/redis/go-redis/v9 v9.5.3
|
||||||
)
|
)
|
||||||
|
|
||||||
require (
|
require (
|
||||||
|
|
|
@ -1,5 +1,5 @@
|
||||||
github.com/bsm/ginkgo/v2 v2.7.0 h1:ItPMPH90RbmZJt5GtkcNvIRuGEdwlBItdNVoyzaNQao=
|
github.com/bsm/ginkgo/v2 v2.12.0 h1:Ny8MWAHyOepLGlLKYmXG4IEkioBysk6GpaRTLC8zwWs=
|
||||||
github.com/bsm/gomega v1.26.0 h1:LhQm+AFcgV2M0WyKroMASzAzCAJVpAxQXv4SaI9a69Y=
|
github.com/bsm/gomega v1.27.10 h1:yeMWxP2pV2fG3FgAODIY8EiRE3dy0aeFYt4l7wh6yKA=
|
||||||
github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44=
|
github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44=
|
||||||
github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
|
github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
|
||||||
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
|
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
|
||||||
|
|
|
@ -7,8 +7,8 @@ replace github.com/redis/go-redis/v9 => ../..
|
||||||
replace github.com/redis/go-redis/extra/rediscmd/v9 => ../rediscmd
|
replace github.com/redis/go-redis/extra/rediscmd/v9 => ../rediscmd
|
||||||
|
|
||||||
require (
|
require (
|
||||||
github.com/redis/go-redis/extra/rediscmd/v9 v9.5.1
|
github.com/redis/go-redis/extra/rediscmd/v9 v9.5.3
|
||||||
github.com/redis/go-redis/v9 v9.5.1
|
github.com/redis/go-redis/v9 v9.5.3
|
||||||
go.opencensus.io v0.24.0
|
go.opencensus.io v0.24.0
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
|
@ -7,7 +7,7 @@ replace github.com/redis/go-redis/v9 => ../..
|
||||||
require (
|
require (
|
||||||
github.com/bsm/ginkgo/v2 v2.12.0
|
github.com/bsm/ginkgo/v2 v2.12.0
|
||||||
github.com/bsm/gomega v1.27.10
|
github.com/bsm/gomega v1.27.10
|
||||||
github.com/redis/go-redis/v9 v9.5.1
|
github.com/redis/go-redis/v9 v9.5.3
|
||||||
)
|
)
|
||||||
|
|
||||||
require (
|
require (
|
||||||
|
|
|
@ -7,8 +7,8 @@ replace github.com/redis/go-redis/v9 => ../..
|
||||||
replace github.com/redis/go-redis/extra/rediscmd/v9 => ../rediscmd
|
replace github.com/redis/go-redis/extra/rediscmd/v9 => ../rediscmd
|
||||||
|
|
||||||
require (
|
require (
|
||||||
github.com/redis/go-redis/extra/rediscmd/v9 v9.5.1
|
github.com/redis/go-redis/extra/rediscmd/v9 v9.5.3
|
||||||
github.com/redis/go-redis/v9 v9.5.1
|
github.com/redis/go-redis/v9 v9.5.3
|
||||||
go.opentelemetry.io/otel v1.22.0
|
go.opentelemetry.io/otel v1.22.0
|
||||||
go.opentelemetry.io/otel/metric v1.22.0
|
go.opentelemetry.io/otel/metric v1.22.0
|
||||||
go.opentelemetry.io/otel/sdk v1.22.0
|
go.opentelemetry.io/otel/sdk v1.22.0
|
||||||
|
|
|
@ -6,7 +6,7 @@ replace github.com/redis/go-redis/v9 => ../..
|
||||||
|
|
||||||
require (
|
require (
|
||||||
github.com/prometheus/client_golang v1.14.0
|
github.com/prometheus/client_golang v1.14.0
|
||||||
github.com/redis/go-redis/v9 v9.5.1
|
github.com/redis/go-redis/v9 v9.5.3
|
||||||
)
|
)
|
||||||
|
|
||||||
require (
|
require (
|
||||||
|
|
265
hash_commands.go
265
hash_commands.go
|
@ -1,6 +1,9 @@
|
||||||
package redis
|
package redis
|
||||||
|
|
||||||
import "context"
|
import (
|
||||||
|
"context"
|
||||||
|
"time"
|
||||||
|
)
|
||||||
|
|
||||||
type HashCmdable interface {
|
type HashCmdable interface {
|
||||||
HDel(ctx context.Context, key string, fields ...string) *IntCmd
|
HDel(ctx context.Context, key string, fields ...string) *IntCmd
|
||||||
|
@ -16,6 +19,7 @@ type HashCmdable interface {
|
||||||
HMSet(ctx context.Context, key string, values ...interface{}) *BoolCmd
|
HMSet(ctx context.Context, key string, values ...interface{}) *BoolCmd
|
||||||
HSetNX(ctx context.Context, key, field string, value interface{}) *BoolCmd
|
HSetNX(ctx context.Context, key, field string, value interface{}) *BoolCmd
|
||||||
HScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd
|
HScan(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd
|
||||||
|
HScanNoValues(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd
|
||||||
HVals(ctx context.Context, key string) *StringSliceCmd
|
HVals(ctx context.Context, key string) *StringSliceCmd
|
||||||
HRandField(ctx context.Context, key string, count int) *StringSliceCmd
|
HRandField(ctx context.Context, key string, count int) *StringSliceCmd
|
||||||
HRandFieldWithValues(ctx context.Context, key string, count int) *KeyValueSliceCmd
|
HRandFieldWithValues(ctx context.Context, key string, count int) *KeyValueSliceCmd
|
||||||
|
@ -172,3 +176,262 @@ func (c cmdable) HScan(ctx context.Context, key string, cursor uint64, match str
|
||||||
_ = c(ctx, cmd)
|
_ = c(ctx, cmd)
|
||||||
return cmd
|
return cmd
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (c cmdable) HScanNoValues(ctx context.Context, key string, cursor uint64, match string, count int64) *ScanCmd {
|
||||||
|
args := []interface{}{"hscan", key, cursor}
|
||||||
|
if match != "" {
|
||||||
|
args = append(args, "match", match)
|
||||||
|
}
|
||||||
|
if count > 0 {
|
||||||
|
args = append(args, "count", count)
|
||||||
|
}
|
||||||
|
args = append(args, "novalues")
|
||||||
|
cmd := NewScanCmd(ctx, c, args...)
|
||||||
|
_ = c(ctx, cmd)
|
||||||
|
return cmd
|
||||||
|
}
|
||||||
|
|
||||||
|
type HExpireArgs struct {
|
||||||
|
NX bool
|
||||||
|
XX bool
|
||||||
|
GT bool
|
||||||
|
LT bool
|
||||||
|
}
|
||||||
|
|
||||||
|
// HExpire - Sets the expiration time for specified fields in a hash in seconds.
|
||||||
|
// The command constructs an argument list starting with "HEXPIRE", followed by the key, duration, any conditional flags, and the specified fields.
|
||||||
|
// For more information - https://redis.io/commands/hexpire/
|
||||||
|
func (c cmdable) HExpire(ctx context.Context, key string, expiration time.Duration, fields ...string) *IntSliceCmd {
|
||||||
|
args := []interface{}{"HEXPIRE", key, expiration, "FIELDS", len(fields)}
|
||||||
|
|
||||||
|
for _, field := range fields {
|
||||||
|
args = append(args, field)
|
||||||
|
}
|
||||||
|
cmd := NewIntSliceCmd(ctx, args...)
|
||||||
|
_ = c(ctx, cmd)
|
||||||
|
return cmd
|
||||||
|
}
|
||||||
|
|
||||||
|
// HExpire - Sets the expiration time for specified fields in a hash in seconds.
|
||||||
|
// It requires a key, an expiration duration, a struct with boolean flags for conditional expiration settings (NX, XX, GT, LT), and a list of fields.
|
||||||
|
// The command constructs an argument list starting with "HEXPIRE", followed by the key, duration, any conditional flags, and the specified fields.
|
||||||
|
// For more information - https://redis.io/commands/hexpire/
|
||||||
|
func (c cmdable) HExpireWithArgs(ctx context.Context, key string, expiration time.Duration, expirationArgs HExpireArgs, fields ...string) *IntSliceCmd {
|
||||||
|
args := []interface{}{"HEXPIRE", key, expiration}
|
||||||
|
|
||||||
|
// only if one argument is true, we can add it to the args
|
||||||
|
// if more than one argument is true, it will cause an error
|
||||||
|
if expirationArgs.NX {
|
||||||
|
args = append(args, "NX")
|
||||||
|
} else if expirationArgs.XX {
|
||||||
|
args = append(args, "XX")
|
||||||
|
} else if expirationArgs.GT {
|
||||||
|
args = append(args, "GT")
|
||||||
|
} else if expirationArgs.LT {
|
||||||
|
args = append(args, "LT")
|
||||||
|
}
|
||||||
|
|
||||||
|
args = append(args, "FIELDS", len(fields))
|
||||||
|
|
||||||
|
for _, field := range fields {
|
||||||
|
args = append(args, field)
|
||||||
|
}
|
||||||
|
cmd := NewIntSliceCmd(ctx, args...)
|
||||||
|
_ = c(ctx, cmd)
|
||||||
|
return cmd
|
||||||
|
}
|
||||||
|
|
||||||
|
// HPExpire - Sets the expiration time for specified fields in a hash in milliseconds.
|
||||||
|
// Similar to HExpire, it accepts a key, an expiration duration in milliseconds, a struct with expiration condition flags, and a list of fields.
|
||||||
|
// The command modifies the standard time.Duration to milliseconds for the Redis command.
|
||||||
|
// For more information - https://redis.io/commands/hpexpire/
|
||||||
|
func (c cmdable) HPExpire(ctx context.Context, key string, expiration time.Duration, fields ...string) *IntSliceCmd {
|
||||||
|
args := []interface{}{"HPEXPIRE", key, formatMs(ctx, expiration), "FIELDS", len(fields)}
|
||||||
|
|
||||||
|
for _, field := range fields {
|
||||||
|
args = append(args, field)
|
||||||
|
}
|
||||||
|
cmd := NewIntSliceCmd(ctx, args...)
|
||||||
|
_ = c(ctx, cmd)
|
||||||
|
return cmd
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c cmdable) HPExpireWithArgs(ctx context.Context, key string, expiration time.Duration, expirationArgs HExpireArgs, fields ...string) *IntSliceCmd {
|
||||||
|
args := []interface{}{"HPEXPIRE", key, formatMs(ctx, expiration)}
|
||||||
|
|
||||||
|
// only if one argument is true, we can add it to the args
|
||||||
|
// if more than one argument is true, it will cause an error
|
||||||
|
if expirationArgs.NX {
|
||||||
|
args = append(args, "NX")
|
||||||
|
} else if expirationArgs.XX {
|
||||||
|
args = append(args, "XX")
|
||||||
|
} else if expirationArgs.GT {
|
||||||
|
args = append(args, "GT")
|
||||||
|
} else if expirationArgs.LT {
|
||||||
|
args = append(args, "LT")
|
||||||
|
}
|
||||||
|
|
||||||
|
args = append(args, "FIELDS", len(fields))
|
||||||
|
|
||||||
|
for _, field := range fields {
|
||||||
|
args = append(args, field)
|
||||||
|
}
|
||||||
|
cmd := NewIntSliceCmd(ctx, args...)
|
||||||
|
_ = c(ctx, cmd)
|
||||||
|
return cmd
|
||||||
|
}
|
||||||
|
|
||||||
|
// HExpireAt - Sets the expiration time for specified fields in a hash to a UNIX timestamp in seconds.
|
||||||
|
// Takes a key, a UNIX timestamp, a struct of conditional flags, and a list of fields.
|
||||||
|
// The command sets absolute expiration times based on the UNIX timestamp provided.
|
||||||
|
// For more information - https://redis.io/commands/hexpireat/
|
||||||
|
func (c cmdable) HExpireAt(ctx context.Context, key string, tm time.Time, fields ...string) *IntSliceCmd {
|
||||||
|
|
||||||
|
args := []interface{}{"HEXPIREAT", key, tm.Unix(), "FIELDS", len(fields)}
|
||||||
|
|
||||||
|
for _, field := range fields {
|
||||||
|
args = append(args, field)
|
||||||
|
}
|
||||||
|
cmd := NewIntSliceCmd(ctx, args...)
|
||||||
|
_ = c(ctx, cmd)
|
||||||
|
return cmd
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c cmdable) HExpireAtWithArgs(ctx context.Context, key string, tm time.Time, expirationArgs HExpireArgs, fields ...string) *IntSliceCmd {
|
||||||
|
args := []interface{}{"HEXPIREAT", key, tm.Unix()}
|
||||||
|
|
||||||
|
// only if one argument is true, we can add it to the args
|
||||||
|
// if more than one argument is true, it will cause an error
|
||||||
|
if expirationArgs.NX {
|
||||||
|
args = append(args, "NX")
|
||||||
|
} else if expirationArgs.XX {
|
||||||
|
args = append(args, "XX")
|
||||||
|
} else if expirationArgs.GT {
|
||||||
|
args = append(args, "GT")
|
||||||
|
} else if expirationArgs.LT {
|
||||||
|
args = append(args, "LT")
|
||||||
|
}
|
||||||
|
|
||||||
|
args = append(args, "FIELDS", len(fields))
|
||||||
|
|
||||||
|
for _, field := range fields {
|
||||||
|
args = append(args, field)
|
||||||
|
}
|
||||||
|
cmd := NewIntSliceCmd(ctx, args...)
|
||||||
|
_ = c(ctx, cmd)
|
||||||
|
return cmd
|
||||||
|
}
|
||||||
|
|
||||||
|
// HPExpireAt - Sets the expiration time for specified fields in a hash to a UNIX timestamp in milliseconds.
|
||||||
|
// Similar to HExpireAt but for timestamps in milliseconds. It accepts the same parameters and adjusts the UNIX time to milliseconds.
|
||||||
|
// For more information - https://redis.io/commands/hpexpireat/
|
||||||
|
func (c cmdable) HPExpireAt(ctx context.Context, key string, tm time.Time, fields ...string) *IntSliceCmd {
|
||||||
|
args := []interface{}{"HPEXPIREAT", key, tm.UnixNano() / int64(time.Millisecond), "FIELDS", len(fields)}
|
||||||
|
|
||||||
|
for _, field := range fields {
|
||||||
|
args = append(args, field)
|
||||||
|
}
|
||||||
|
cmd := NewIntSliceCmd(ctx, args...)
|
||||||
|
_ = c(ctx, cmd)
|
||||||
|
return cmd
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c cmdable) HPExpireAtWithArgs(ctx context.Context, key string, tm time.Time, expirationArgs HExpireArgs, fields ...string) *IntSliceCmd {
|
||||||
|
args := []interface{}{"HPEXPIREAT", key, tm.UnixNano() / int64(time.Millisecond)}
|
||||||
|
|
||||||
|
// only if one argument is true, we can add it to the args
|
||||||
|
// if more than one argument is true, it will cause an error
|
||||||
|
if expirationArgs.NX {
|
||||||
|
args = append(args, "NX")
|
||||||
|
} else if expirationArgs.XX {
|
||||||
|
args = append(args, "XX")
|
||||||
|
} else if expirationArgs.GT {
|
||||||
|
args = append(args, "GT")
|
||||||
|
} else if expirationArgs.LT {
|
||||||
|
args = append(args, "LT")
|
||||||
|
}
|
||||||
|
|
||||||
|
args = append(args, "FIELDS", len(fields))
|
||||||
|
|
||||||
|
for _, field := range fields {
|
||||||
|
args = append(args, field)
|
||||||
|
}
|
||||||
|
cmd := NewIntSliceCmd(ctx, args...)
|
||||||
|
_ = c(ctx, cmd)
|
||||||
|
return cmd
|
||||||
|
}
|
||||||
|
|
||||||
|
// HPersist - Removes the expiration time from specified fields in a hash.
|
||||||
|
// Accepts a key and the fields themselves.
|
||||||
|
// This command ensures that each field specified will have its expiration removed if present.
|
||||||
|
// For more information - https://redis.io/commands/hpersist/
|
||||||
|
func (c cmdable) HPersist(ctx context.Context, key string, fields ...string) *IntSliceCmd {
|
||||||
|
args := []interface{}{"HPERSIST", key, "FIELDS", len(fields)}
|
||||||
|
|
||||||
|
for _, field := range fields {
|
||||||
|
args = append(args, field)
|
||||||
|
}
|
||||||
|
cmd := NewIntSliceCmd(ctx, args...)
|
||||||
|
_ = c(ctx, cmd)
|
||||||
|
return cmd
|
||||||
|
}
|
||||||
|
|
||||||
|
// HExpireTime - Retrieves the expiration time for specified fields in a hash as a UNIX timestamp in seconds.
|
||||||
|
// Requires a key and the fields themselves to fetch their expiration timestamps.
|
||||||
|
// This command returns the expiration times for each field or error/status codes for each field as specified.
|
||||||
|
// For more information - https://redis.io/commands/hexpiretime/
|
||||||
|
func (c cmdable) HExpireTime(ctx context.Context, key string, fields ...string) *IntSliceCmd {
|
||||||
|
args := []interface{}{"HEXPIRETIME", key, "FIELDS", len(fields)}
|
||||||
|
|
||||||
|
for _, field := range fields {
|
||||||
|
args = append(args, field)
|
||||||
|
}
|
||||||
|
cmd := NewIntSliceCmd(ctx, args...)
|
||||||
|
_ = c(ctx, cmd)
|
||||||
|
return cmd
|
||||||
|
}
|
||||||
|
|
||||||
|
// HPExpireTime - Retrieves the expiration time for specified fields in a hash as a UNIX timestamp in milliseconds.
|
||||||
|
// Similar to HExpireTime, adjusted for timestamps in milliseconds. It requires the same parameters.
|
||||||
|
// Provides the expiration timestamp for each field in milliseconds.
|
||||||
|
// For more information - https://redis.io/commands/hexpiretime/
|
||||||
|
func (c cmdable) HPExpireTime(ctx context.Context, key string, fields ...string) *IntSliceCmd {
|
||||||
|
args := []interface{}{"HPEXPIRETIME", key, "FIELDS", len(fields)}
|
||||||
|
|
||||||
|
for _, field := range fields {
|
||||||
|
args = append(args, field)
|
||||||
|
}
|
||||||
|
cmd := NewIntSliceCmd(ctx, args...)
|
||||||
|
_ = c(ctx, cmd)
|
||||||
|
return cmd
|
||||||
|
}
|
||||||
|
|
||||||
|
// HTTL - Retrieves the remaining time to live for specified fields in a hash in seconds.
|
||||||
|
// Requires a key and the fields themselves. It returns the TTL for each specified field.
|
||||||
|
// This command fetches the TTL in seconds for each field or returns error/status codes as appropriate.
|
||||||
|
// For more information - https://redis.io/commands/httl/
|
||||||
|
func (c cmdable) HTTL(ctx context.Context, key string, fields ...string) *IntSliceCmd {
|
||||||
|
args := []interface{}{"HTTL", key, "FIELDS", len(fields)}
|
||||||
|
|
||||||
|
for _, field := range fields {
|
||||||
|
args = append(args, field)
|
||||||
|
}
|
||||||
|
cmd := NewIntSliceCmd(ctx, args...)
|
||||||
|
_ = c(ctx, cmd)
|
||||||
|
return cmd
|
||||||
|
}
|
||||||
|
|
||||||
|
// HPTTL - Retrieves the remaining time to live for specified fields in a hash in milliseconds.
|
||||||
|
// Similar to HTTL, but returns the TTL in milliseconds. It requires a key and the specified fields.
|
||||||
|
// This command provides the TTL in milliseconds for each field or returns error/status codes as needed.
|
||||||
|
// For more information - https://redis.io/commands/hpttl/
|
||||||
|
func (c cmdable) HPTTL(ctx context.Context, key string, fields ...string) *IntSliceCmd {
|
||||||
|
args := []interface{}{"HPTTL", key, "FIELDS", len(fields)}
|
||||||
|
|
||||||
|
for _, field := range fields {
|
||||||
|
args = append(args, field)
|
||||||
|
}
|
||||||
|
cmd := NewIntSliceCmd(ctx, args...)
|
||||||
|
_ = c(ctx, cmd)
|
||||||
|
return cmd
|
||||||
|
}
|
||||||
|
|
|
@ -3,6 +3,7 @@ package internal
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"net"
|
"net"
|
||||||
|
"strconv"
|
||||||
"strings"
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
@ -81,3 +82,47 @@ func GetAddr(addr string) string {
|
||||||
}
|
}
|
||||||
return net.JoinHostPort(addr[:ind], addr[ind+1:])
|
return net.JoinHostPort(addr[:ind], addr[ind+1:])
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func ToInteger(val interface{}) int {
|
||||||
|
switch v := val.(type) {
|
||||||
|
case int:
|
||||||
|
return v
|
||||||
|
case int64:
|
||||||
|
return int(v)
|
||||||
|
case string:
|
||||||
|
i, _ := strconv.Atoi(v)
|
||||||
|
return i
|
||||||
|
default:
|
||||||
|
return 0
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func ToFloat(val interface{}) float64 {
|
||||||
|
switch v := val.(type) {
|
||||||
|
case float64:
|
||||||
|
return v
|
||||||
|
case string:
|
||||||
|
f, _ := strconv.ParseFloat(v, 64)
|
||||||
|
return f
|
||||||
|
default:
|
||||||
|
return 0.0
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func ToString(val interface{}) string {
|
||||||
|
if str, ok := val.(string); ok {
|
||||||
|
return str
|
||||||
|
}
|
||||||
|
return ""
|
||||||
|
}
|
||||||
|
|
||||||
|
func ToStringSlice(val interface{}) []string {
|
||||||
|
if arr, ok := val.([]interface{}); ok {
|
||||||
|
result := make([]string, len(arr))
|
||||||
|
for i, v := range arr {
|
||||||
|
result[i] = ToString(v)
|
||||||
|
}
|
||||||
|
return result
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
|
@ -96,6 +96,22 @@ var _ = Describe("ScanIterator", func() {
|
||||||
Expect(vals).To(HaveLen(71 * 2))
|
Expect(vals).To(HaveLen(71 * 2))
|
||||||
Expect(vals).To(ContainElement("K01"))
|
Expect(vals).To(ContainElement("K01"))
|
||||||
Expect(vals).To(ContainElement("K71"))
|
Expect(vals).To(ContainElement("K71"))
|
||||||
|
Expect(vals).To(ContainElement("x"))
|
||||||
|
})
|
||||||
|
|
||||||
|
It("should hscan without values across multiple pages", Label("NonRedisEnterprise"), func() {
|
||||||
|
Expect(hashSeed(71)).NotTo(HaveOccurred())
|
||||||
|
|
||||||
|
var vals []string
|
||||||
|
iter := client.HScanNoValues(ctx, hashKey, 0, "", 10).Iterator()
|
||||||
|
for iter.Next(ctx) {
|
||||||
|
vals = append(vals, iter.Val())
|
||||||
|
}
|
||||||
|
Expect(iter.Err()).NotTo(HaveOccurred())
|
||||||
|
Expect(vals).To(HaveLen(71))
|
||||||
|
Expect(vals).To(ContainElement("K01"))
|
||||||
|
Expect(vals).To(ContainElement("K71"))
|
||||||
|
Expect(vals).NotTo(ContainElement("x"))
|
||||||
})
|
})
|
||||||
|
|
||||||
It("should scan to page borders", func() {
|
It("should scan to page borders", func() {
|
||||||
|
|
|
@ -242,18 +242,18 @@ var _ = Describe("JSON Commands", Label("json"), func() {
|
||||||
Expect(cmd.Val()).To(Equal("OK"))
|
Expect(cmd.Val()).To(Equal("OK"))
|
||||||
})
|
})
|
||||||
|
|
||||||
It("should JSONGet", Label("json.get", "json"), func() {
|
It("should JSONGet", Label("json.get", "json", "NonRedisEnterprise"), func() {
|
||||||
res, err := client.JSONSet(ctx, "get3", "$", `{"a": 1, "b": 2}`).Result()
|
res, err := client.JSONSet(ctx, "get3", "$", `{"a": 1, "b": 2}`).Result()
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
Expect(res).To(Equal("OK"))
|
Expect(res).To(Equal("OK"))
|
||||||
|
|
||||||
res, err = client.JSONGetWithArgs(ctx, "get3", &redis.JSONGetArgs{Indent: "-"}).Result()
|
res, err = client.JSONGetWithArgs(ctx, "get3", &redis.JSONGetArgs{Indent: "-"}).Result()
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
Expect(res).To(Equal(`[-{--"a":1,--"b":2-}]`))
|
Expect(res).To(Equal(`{-"a":1,-"b":2}`))
|
||||||
|
|
||||||
res, err = client.JSONGetWithArgs(ctx, "get3", &redis.JSONGetArgs{Indent: "-", Newline: `~`, Space: `!`}).Result()
|
res, err = client.JSONGetWithArgs(ctx, "get3", &redis.JSONGetArgs{Indent: "-", Newline: `~`, Space: `!`}).Result()
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
Expect(res).To(Equal(`[~-{~--"a":!1,~--"b":!2~-}~]`))
|
Expect(res).To(Equal(`{~-"a":!1,~-"b":!2~}`))
|
||||||
})
|
})
|
||||||
|
|
||||||
It("should JSONMerge", Label("json.merge", "json"), func() {
|
It("should JSONMerge", Label("json.merge", "json"), func() {
|
||||||
|
|
|
@ -61,6 +61,12 @@ type Options struct {
|
||||||
// before reconnecting. It should return the current username and password.
|
// before reconnecting. It should return the current username and password.
|
||||||
CredentialsProvider func() (username string, password string)
|
CredentialsProvider func() (username string, password string)
|
||||||
|
|
||||||
|
// CredentialsProviderContext is an enhanced parameter of CredentialsProvider,
|
||||||
|
// done to maintain API compatibility. In the future,
|
||||||
|
// there might be a merge between CredentialsProviderContext and CredentialsProvider.
|
||||||
|
// There will be a conflict between them; if CredentialsProviderContext exists, we will ignore CredentialsProvider.
|
||||||
|
CredentialsProviderContext func(ctx context.Context) (username string, password string, err error)
|
||||||
|
|
||||||
// Database to be selected after connecting to the server.
|
// Database to be selected after connecting to the server.
|
||||||
DB int
|
DB int
|
||||||
|
|
||||||
|
|
|
@ -62,10 +62,11 @@ type ClusterOptions struct {
|
||||||
|
|
||||||
OnConnect func(ctx context.Context, cn *Conn) error
|
OnConnect func(ctx context.Context, cn *Conn) error
|
||||||
|
|
||||||
Protocol int
|
Protocol int
|
||||||
Username string
|
Username string
|
||||||
Password string
|
Password string
|
||||||
CredentialsProvider func() (username string, password string)
|
CredentialsProvider func() (username string, password string)
|
||||||
|
CredentialsProviderContext func(ctx context.Context) (username string, password string, err error)
|
||||||
|
|
||||||
MaxRetries int
|
MaxRetries int
|
||||||
MinRetryBackoff time.Duration
|
MinRetryBackoff time.Duration
|
||||||
|
@ -272,10 +273,11 @@ func (opt *ClusterOptions) clientOptions() *Options {
|
||||||
Dialer: opt.Dialer,
|
Dialer: opt.Dialer,
|
||||||
OnConnect: opt.OnConnect,
|
OnConnect: opt.OnConnect,
|
||||||
|
|
||||||
Protocol: opt.Protocol,
|
Protocol: opt.Protocol,
|
||||||
Username: opt.Username,
|
Username: opt.Username,
|
||||||
Password: opt.Password,
|
Password: opt.Password,
|
||||||
CredentialsProvider: opt.CredentialsProvider,
|
CredentialsProvider: opt.CredentialsProvider,
|
||||||
|
CredentialsProviderContext: opt.CredentialsProviderContext,
|
||||||
|
|
||||||
MaxRetries: opt.MaxRetries,
|
MaxRetries: opt.MaxRetries,
|
||||||
MinRetryBackoff: opt.MinRetryBackoff,
|
MinRetryBackoff: opt.MinRetryBackoff,
|
||||||
|
|
11
redis.go
11
redis.go
|
@ -283,8 +283,13 @@ func (c *baseClient) initConn(ctx context.Context, cn *pool.Conn) error {
|
||||||
}
|
}
|
||||||
cn.Inited = true
|
cn.Inited = true
|
||||||
|
|
||||||
|
var err error
|
||||||
username, password := c.opt.Username, c.opt.Password
|
username, password := c.opt.Username, c.opt.Password
|
||||||
if c.opt.CredentialsProvider != nil {
|
if c.opt.CredentialsProviderContext != nil {
|
||||||
|
if username, password, err = c.opt.CredentialsProviderContext(ctx); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
} else if c.opt.CredentialsProvider != nil {
|
||||||
username, password = c.opt.CredentialsProvider()
|
username, password = c.opt.CredentialsProvider()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -300,7 +305,7 @@ func (c *baseClient) initConn(ctx context.Context, cn *pool.Conn) error {
|
||||||
|
|
||||||
// for redis-server versions that do not support the HELLO command,
|
// for redis-server versions that do not support the HELLO command,
|
||||||
// RESP2 will continue to be used.
|
// RESP2 will continue to be used.
|
||||||
if err := conn.Hello(ctx, protocol, username, password, "").Err(); err == nil {
|
if err = conn.Hello(ctx, protocol, username, password, "").Err(); err == nil {
|
||||||
auth = true
|
auth = true
|
||||||
} else if !isRedisError(err) {
|
} else if !isRedisError(err) {
|
||||||
// When the server responds with the RESP protocol and the result is not a normal
|
// When the server responds with the RESP protocol and the result is not a normal
|
||||||
|
@ -313,7 +318,7 @@ func (c *baseClient) initConn(ctx context.Context, cn *pool.Conn) error {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
_, err := conn.Pipelined(ctx, func(pipe Pipeliner) error {
|
_, err = conn.Pipelined(ctx, func(pipe Pipeliner) error {
|
||||||
if !auth && password != "" {
|
if !auth && password != "" {
|
||||||
if username != "" {
|
if username != "" {
|
||||||
pipe.AuthACL(ctx, username, password)
|
pipe.AuthACL(ctx, username, password)
|
||||||
|
|
|
@ -60,9 +60,6 @@ do
|
||||||
done
|
done
|
||||||
|
|
||||||
sed --in-place "s/\(return \)\"[^\"]*\"/\1\"${TAG#v}\"/" ./version.go
|
sed --in-place "s/\(return \)\"[^\"]*\"/\1\"${TAG#v}\"/" ./version.go
|
||||||
sed --in-place "s/\(\"version\": \)\"[^\"]*\"/\1\"${TAG#v}\"/" ./package.json
|
|
||||||
|
|
||||||
conventional-changelog -p angular -i CHANGELOG.md -s
|
|
||||||
|
|
||||||
git checkout -b release/${TAG} master
|
git checkout -b release/${TAG} master
|
||||||
git add -u
|
git add -u
|
||||||
|
|
File diff suppressed because it is too large
Load Diff
File diff suppressed because it is too large
Load Diff
|
@ -137,10 +137,11 @@ type XReadArgs struct {
|
||||||
Streams []string // list of streams and ids, e.g. stream1 stream2 id1 id2
|
Streams []string // list of streams and ids, e.g. stream1 stream2 id1 id2
|
||||||
Count int64
|
Count int64
|
||||||
Block time.Duration
|
Block time.Duration
|
||||||
|
ID string
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c cmdable) XRead(ctx context.Context, a *XReadArgs) *XStreamSliceCmd {
|
func (c cmdable) XRead(ctx context.Context, a *XReadArgs) *XStreamSliceCmd {
|
||||||
args := make([]interface{}, 0, 6+len(a.Streams))
|
args := make([]interface{}, 0, 2*len(a.Streams)+6)
|
||||||
args = append(args, "xread")
|
args = append(args, "xread")
|
||||||
|
|
||||||
keyPos := int8(1)
|
keyPos := int8(1)
|
||||||
|
@ -159,6 +160,11 @@ func (c cmdable) XRead(ctx context.Context, a *XReadArgs) *XStreamSliceCmd {
|
||||||
for _, s := range a.Streams {
|
for _, s := range a.Streams {
|
||||||
args = append(args, s)
|
args = append(args, s)
|
||||||
}
|
}
|
||||||
|
if a.ID != "" {
|
||||||
|
for range a.Streams {
|
||||||
|
args = append(args, a.ID)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
cmd := NewXStreamSliceCmd(ctx, args...)
|
cmd := NewXStreamSliceCmd(ctx, args...)
|
||||||
if a.Block >= 0 {
|
if a.Block >= 0 {
|
||||||
|
|
|
@ -2,5 +2,5 @@ package redis
|
||||||
|
|
||||||
// Version is the current release version.
|
// Version is the current release version.
|
||||||
func Version() string {
|
func Version() string {
|
||||||
return "9.5.1"
|
return "9.5.3"
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue