Skip to content

Commit 4262f74

Browse files
addressed PR comments
1 parent 943127e commit 4262f74

File tree

2 files changed

+9
-8
lines changed

2 files changed

+9
-8
lines changed

docker-compose.yml

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
services:
44
redis:
5-
image: ${CLIENT_LIBS_TEST_IMAGE:-redislabs/client-libs-test:8.2-RC1-pre}
5+
image: ${CLIENT_LIBS_TEST_IMAGE:-redislabs/client-libs-test:rs-7.4.0-v2}
66
platform: linux/amd64
77
container_name: redis-standalone
88
environment:
@@ -23,7 +23,7 @@ services:
2323
- all
2424

2525
osscluster:
26-
image: ${CLIENT_LIBS_TEST_IMAGE:-redislabs/client-libs-test:8.2-RC1-pre}
26+
image: ${CLIENT_LIBS_TEST_IMAGE:-redislabs/client-libs-test:rs-7.4.0-v2}
2727
platform: linux/amd64
2828
container_name: redis-osscluster
2929
environment:
@@ -40,7 +40,7 @@ services:
4040
- all
4141

4242
sentinel-cluster:
43-
image: ${CLIENT_LIBS_TEST_IMAGE:-redislabs/client-libs-test:8.2-RC1-pre}
43+
image: ${CLIENT_LIBS_TEST_IMAGE:-redislabs/client-libs-test:rs-7.4.0-v2}
4444
platform: linux/amd64
4545
container_name: redis-sentinel-cluster
4646
network_mode: "host"
@@ -60,7 +60,7 @@ services:
6060
- all
6161

6262
sentinel:
63-
image: ${CLIENT_LIBS_TEST_IMAGE:-redislabs/client-libs-test:8.2-RC1-pre}
63+
image: ${CLIENT_LIBS_TEST_IMAGE:-redislabs/client-libs-test:rs-7.4.0-v2}
6464
platform: linux/amd64
6565
container_name: redis-sentinel
6666
depends_on:
@@ -84,7 +84,7 @@ services:
8484
- all
8585

8686
ring-cluster:
87-
image: ${CLIENT_LIBS_TEST_IMAGE:-redislabs/client-libs-test:8.2-RC1-pre}
87+
image: ${CLIENT_LIBS_TEST_IMAGE:-redislabs/client-libs-test:rs-7.4.0-v2}
8888
platform: linux/amd64
8989
container_name: redis-ring-cluster
9090
environment:

stream_commands.go

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@ package redis
22

33
import (
44
"context"
5-
"strconv"
65
"time"
76
)
87

@@ -107,7 +106,7 @@ func (c cmdable) XAdd(ctx context.Context, a *XAddArgs) *StringCmd {
107106
}
108107

109108
func (c cmdable) XAckDel(ctx context.Context, stream string, group string, mode string, ids ...string) *SliceCmd {
110-
args := []interface{}{"xackdel", stream, group, mode, "ids", strconv.Itoa(len(ids))}
109+
args := []interface{}{"xackdel", stream, group, mode, "ids", ids}
111110
for _, id := range ids {
112111
args = append(args, id)
113112
}
@@ -127,7 +126,7 @@ func (c cmdable) XDel(ctx context.Context, stream string, ids ...string) *IntCmd
127126
}
128127

129128
func (c cmdable) XDelEx(ctx context.Context, stream string, mode string, ids ...string) *SliceCmd {
130-
args := []interface{}{"xdelex", stream, mode, "ids", strconv.Itoa(len(ids))}
129+
args := []interface{}{"xdelex", stream, mode, "ids", ids}
131130
for _, id := range ids {
132131
args = append(args, id)
133132
}
@@ -408,6 +407,8 @@ func xClaimArgs(a *XClaimArgs) []interface{} {
408407
return args
409408
}
410409

410+
// TODO: refactor xTrim, xTrimMode and the wrappers over the functions
411+
411412
// xTrim If approx is true, add the "~" parameter, otherwise it is the default "=" (redis default).
412413
// example:
413414
//

0 commit comments

Comments
 (0)