From 5f1c69ce9806e7673a1cd1ca85857f84dfb9bc68 Mon Sep 17 00:00:00 2001 From: toom1996 <23cm.cn@gmail.com> Date: Sun, 25 Oct 2026 00:42:43 +0800 Subject: [PATCH] =?UTF-8?q?test:=20=E8=A1=A5=E9=BD=90=20fakeEmbeddingRepo?= =?UTF-8?q?=20=E7=9A=84=E5=9B=9E=E5=A1=AB=E6=8E=A5=E5=8F=A3=E6=96=B9?= =?UTF-8?q?=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/service/similar_service_test.go | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/internal/service/similar_service_test.go b/internal/service/similar_service_test.go index e8a8a08..d4195ad 100644 --- a/internal/service/similar_service_test.go +++ b/internal/service/similar_service_test.go @@ -31,6 +31,20 @@ func (f *fakeEmbeddingRepo) UpsertEmbedding(context.Context, string, uint32, []f return nil } +// 向量回填相关方法:近邻服务本身用不到,这里只需满足接口。 +// 回填链路的测试在 handler 层(backstage_embeddings)与本文件的 key 分支单测里覆盖。 +func (f *fakeEmbeddingRepo) ListPendingEmbeddings(context.Context, string, int, int) ([]repository.PendingEmbedding, error) { + return nil, nil +} + +func (f *fakeEmbeddingRepo) CountPendingEmbeddings(context.Context, string, int) (int, error) { + return 0, nil +} + +func (f *fakeEmbeddingRepo) RecordEmbeddingFailure(context.Context, string, uint32, string) error { + return nil +} + func (f *fakeEmbeddingRepo) BulkUpsertEmbedding(context.Context, string, []uint32, [][]float32) error { return nil }