(ctx context.Context, stream string, group string, mode string, ids ...string)
| 167 | } |
| 168 | |
| 169 | func (c cmdable) XAckDel(ctx context.Context, stream string, group string, mode string, ids ...string) *SliceCmd { |
| 170 | args := []interface{}{"xackdel", stream, group, mode, "ids", len(ids)} |
| 171 | for _, id := range ids { |
| 172 | args = append(args, id) |
| 173 | } |
| 174 | cmd := NewSliceCmd(ctx, args...) |
| 175 | _ = c(ctx, cmd) |
| 176 | return cmd |
| 177 | } |
| 178 | |
| 179 | func (c cmdable) XDel(ctx context.Context, stream string, ids ...string) *IntCmd { |
| 180 | args := []interface{}{"xdel", stream} |
nothing calls this directly
no test coverage detected