Skip to content

Commit 0cf9947

Browse files
committed
pull main
1 parent 07a5e0f commit 0cf9947

File tree

2 files changed

+57
-1
lines changed

2 files changed

+57
-1
lines changed

command.go

Lines changed: 56 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6941,3 +6941,59 @@ func (cmd *MonitorCmd) Clone() Cmder {
69416941
return newMonitorCmd(cmd.ctx, cmd.ch)
69426942

69436943
}
6944+
6945+
type VectorScoreSliceCmd struct {
6946+
baseCmd
6947+
6948+
val []VectorScore
6949+
}
6950+
6951+
var _ Cmder = (*VectorScoreSliceCmd)(nil)
6952+
6953+
func NewVectorInfoSliceCmd(ctx context.Context, args ...any) *VectorScoreSliceCmd {
6954+
return &VectorScoreSliceCmd{
6955+
baseCmd: baseCmd{
6956+
ctx: ctx,
6957+
args: args,
6958+
},
6959+
}
6960+
}
6961+
6962+
func (cmd *VectorScoreSliceCmd) SetVal(val []VectorScore) {
6963+
cmd.val = val
6964+
}
6965+
6966+
func (cmd *VectorScoreSliceCmd) Val() []VectorScore {
6967+
return cmd.val
6968+
}
6969+
6970+
func (cmd *VectorScoreSliceCmd) Result() ([]VectorScore, error) {
6971+
return cmd.val, cmd.err
6972+
}
6973+
6974+
func (cmd *VectorScoreSliceCmd) String() string {
6975+
return cmdString(cmd, cmd.val)
6976+
}
6977+
6978+
func (cmd *VectorScoreSliceCmd) readReply(rd *proto.Reader) error {
6979+
n, err := rd.ReadMapLen()
6980+
if err != nil {
6981+
return err
6982+
}
6983+
6984+
cmd.val = make([]VectorScore, n)
6985+
for i := 0; i < n; i++ {
6986+
name, err := rd.ReadString()
6987+
if err != nil {
6988+
return err
6989+
}
6990+
cmd.val[i].Name = name
6991+
6992+
score, err := rd.ReadFloat()
6993+
if err != nil {
6994+
return err
6995+
}
6996+
cmd.val[i].Score = score
6997+
}
6998+
return nil
6999+
}

unit_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ type mockCmdable struct {
1111
returnErr error
1212
}
1313

14-
func (m *mockCmdable) call(_ context.Context, cmd Cmder) error {
14+
func (m *mockCmdable) call(ctx context.Context, cmd Cmder) error {
1515
m.lastCmd = cmd
1616
if m.returnErr != nil {
1717
cmd.SetErr(m.returnErr)

0 commit comments

Comments
 (0)