redis/go-redis
1
0
Fork 0
mirror of https://github.com/redis/go-redis.git synced 2025-09-08 19:52:07 +03:00
Code Activity

fixed command return type

Browse Source
This commit is contained in:
Hristo Temelski
2025-07-29 11:00:32 +03:00
parent 44f9add5e8
commit 8756eda4d3
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
stream_commands.go
View File

@@ -8,9 +8,9 @@ import (
type StreamCmdable interface {
XAdd(ctx context.Context, a *XAddArgs) *StringCmd
XAckDel(ctx context.Context, stream string, group string, mode string, ids ...string) *IntCmd
XAckDel(ctx context.Context, stream string, group string, mode string, ids ...string) *SliceCmd
XDel(ctx context.Context, stream string, ids ...string) *IntCmd
XDelEx(ctx context.Context, stream string, mode string, ids ...string) *IntCmd
XDelEx(ctx context.Context, stream string, mode string, ids ...string) *SliceCmd
XLen(ctx context.Context, stream string) *IntCmd
XRange(ctx context.Context, stream, start, stop string) *XMessageSliceCmd
XRangeN(ctx context.Context, stream, start, stop string, count int64) *XMessageSliceCmd
@@ -106,12 +106,12 @@ func (c cmdable) XAdd(ctx context.Context, a *XAddArgs) *StringCmd {
return cmd
}
func (c cmdable) XAckDel(ctx context.Context, stream string, group string, mode string, ids ...string) *IntCmd {
func (c cmdable) XAckDel(ctx context.Context, stream string, group string, mode string, ids ...string) *SliceCmd {
args := []interface{}{"xackdel", stream, group, mode, "ids", strconv.Itoa(len(ids))}
for _, id := range ids {
args = append(args, id)
}
cmd := NewIntCmd(ctx, args...)
cmd := NewSliceCmd(ctx, args...)
_ = c(ctx, cmd)
return cmd
}
@@ -126,12 +126,12 @@ func (c cmdable) XDel(ctx context.Context, stream string, ids ...string) *IntCmd
return cmd
}
func (c cmdable) XDelEx(ctx context.Context, stream string, mode string, ids ...string) *IntCmd {
func (c cmdable) XDelEx(ctx context.Context, stream string, mode string, ids ...string) *SliceCmd {
args := []interface{}{"xdelex", stream, mode, "ids", strconv.Itoa(len(ids))}
for _, id := range ids {
args = append(args, id)
}
cmd := NewIntCmd(ctx, args...)
cmd := NewSliceCmd(ctx, args...)
_ = c(ctx, cmd)
return cmd
}