feat: support vectorset (redis#3375)

* feat: support vectorset

* fix: char encoding error

* use `any` instread of `interface{}`

* update vectorset API

Signed-off-by: fukua95 <[email protected]>

* refact: MapStringFloat64Cmd -> VectorInfoSliceCmd

Signed-off-by: fukua95 <[email protected]>

* update:

* the type of vector attribute: string -> VectorAttributeMarshaller
* Add a new API VRemAttr
* mark the APIs are experimental

Signed-off-by: fukua95 <[email protected]>

* trigger CI again

Signed-off-by: fukua95 <[email protected]>

* rename a API: VRemAttr -> VClearAttributes

Signed-off-by: fukua95 <[email protected]>

* add test

Signed-off-by: fukua95 <[email protected]>

* feat(vectorset): improve VSetAttr API and add comprehensive test suite

- Simplify VSetAttr to accept interface{} with automatic JSON marshalling
- Remove VectorAttributeMarshaller interface for simpler API
- Add comprehensive unit tests for all vectorset commands

---------

Signed-off-by: fukua95 <[email protected]>
Co-authored-by: Nedyalko Dyakov <[email protected]>

Author: 2 people

command.go

@@ -6826,3 +6826,59 @@ func (cmd *MonitorCmd) Clone() Cmder {
 	// Return a new MonitorCmd with the same channel
 	return newMonitorCmd(cmd.ctx, cmd.ch)
 }
+
+type VectorScoreSliceCmd struct {
+	baseCmd
+
+	val []VectorScore
+}
+
+var _ Cmder = (*VectorScoreSliceCmd)(nil)
+
+func NewVectorInfoSliceCmd(ctx context.Context, args ...any) *VectorScoreSliceCmd {
+	return &VectorScoreSliceCmd{
+		baseCmd: baseCmd{
+			ctx:  ctx,
+			args: args,
+		},
+	}
+}
+
+func (cmd *VectorScoreSliceCmd) SetVal(val []VectorScore) {
+	cmd.val = val
+}
+
+func (cmd *VectorScoreSliceCmd) Val() []VectorScore {
+	return cmd.val
+}
+
+func (cmd *VectorScoreSliceCmd) Result() ([]VectorScore, error) {
+	return cmd.val, cmd.err
+}
+
+func (cmd *VectorScoreSliceCmd) String() string {
+	return cmdString(cmd, cmd.val)
+}
+
+func (cmd *VectorScoreSliceCmd) readReply(rd *proto.Reader) error {
+	n, err := rd.ReadMapLen()
+	if err != nil {
+		return err
+	}
+
+	cmd.val = make([]VectorScore, n)
+	for i := 0; i < n; i++ {
+		name, err := rd.ReadString()
+		if err != nil {
+			return err
+		}
+		cmd.val[i].Name = name
+
+		score, err := rd.ReadFloat()
+		if err != nil {
+			return err
+		}
+		cmd.val[i].Score = score
+	}
+	return nil
+}

commands.go

@@ -234,6 +234,7 @@ type Cmdable interface {
 	StreamCmdable
 	TimeseriesCmdable
 	JSONCmdable
+	VectorSetCmdable
 }
 
 type StatefulCmdable interface {

unit_test.go

@@ -0,0 +1,26 @@
+package redis
+
+import (
+	"context"
+)
+
+// mockCmdable is a mock implementation of cmdable that records the last command.
+// This is used for unit testing command construction without requiring a Redis server.
+type mockCmdable struct {
+	lastCmd   Cmder
+	returnErr error
+}
+
+func (m *mockCmdable) call(ctx context.Context, cmd Cmder) error {
+	m.lastCmd = cmd
+	if m.returnErr != nil {
+		cmd.SetErr(m.returnErr)
+	}
+	return m.returnErr
+}
+
+func (m *mockCmdable) asCmdable() cmdable {
+	return func(ctx context.Context, cmd Cmder) error {
+		return m.call(ctx, cmd)
+	}
+}