Add flush API for deleting all vectors (#2273)

* add flush api Signed-off-by: aknishid <[email protected]> * added flush api * fix typo * fix pb.go & fix conflict Signed-off-by: aknishid <[email protected]> * add flush api * add handler Flush Signed-off-by: aknishid <[email protected]> * add vald.Client flush * fix filter gateway Signed-off-by: aknishid <[email protected]> * fix handler cnts Signed-off-by: aknishid <[email protected]> * delete unused var Signed-off-by: aknishid <[email protected]> * add author Signed-off-by: Yamada Takuya <[email protected]> * fix error Signed-off-by: aknishid <[email protected]> * fix flush.go & ngt.go Signed-off-by: aknishid <[email protected]> * add flush to example Signed-off-by: aknishid <[email protected]> * fix gateway lb Signed-off-by: aknishid <[email protected]> * update flush proto Signed-off-by: aknishid <[email protected]> * fix docs api README.md Signed-off-by: aknishid <[email protected]> * Fix flush ctx Signed-off-by: aknishid <[email protected]> * update docs & comment Signed-off-by: aknishid <[email protected]> * after make format Signed-off-by: aknishid <[email protected]> * add e2e Signed-off-by: aknishid <[email protected]> * update example & tutorial Signed-off-by: aknishid <[email protected]> * Update internal/errors/ngt.go Co-authored-by: Kiichiro YUKAWA <[email protected]> * fix review Signed-off-by: aknishid <[email protected]> * modify status.md Signed-off-by: aknishid <[email protected]> * add error handling Signed-off-by: aknishid <[email protected]> * update proto Signed-off-by: aknishid <[email protected]> * fix doc Signed-off-by: aknishid <[email protected]> * ♻️ Fix proto Signed-off-by: vankichi <[email protected]> * use atomic bool Signed-off-by: aknishid <[email protected]> * fix proto Signed-off-by: aknishid <[email protected]> * update proto Signed-off-by: aknishid <[email protected]> * fix gateway error Signed-off-by: aknishid <[email protected]> * ✅ 🚧 Avoid e2e failing due to unimplemented handler and Add unimplmented handler method for the future Signed-off-by: vankichi <[email protected]> * Update apis/proto/v1/payload/payload.proto Co-authored-by: Kiichiro YUKAWA <[email protected]> Signed-off-by: aknishid <[email protected]> --------- Signed-off-by: aknishid <[email protected]> Signed-off-by: Yamada Takuya <[email protected]> Signed-off-by: vankichi <[email protected]> Signed-off-by: aknishid <[email protected]> Co-authored-by: takuyaymd <[email protected]> Co-authored-by: takuyyam <[email protected]> Co-authored-by: Kiichiro YUKAWA <[email protected]> Co-authored-by: Yusuke Kato <[email protected]>
vdaas · Mar 4, 2024 · 9562a3b · 9562a3b
1 parent 79317ce
commit 9562a3b
Show file tree

Hide file tree

Showing 44 changed files with 2,529 additions and 681 deletions.
diff --git a/apis/docs/v1/docs.md b/apis/docs/v1/docs.md
@@ -14,6 +14,8 @@
   - [Filter](#payload-v1-Filter)
   - [Filter.Config](#payload-v1-Filter-Config)
   - [Filter.Target](#payload-v1-Filter-Target)
+  - [Flush](#payload-v1-Flush)
+  - [Flush.Request](#payload-v1-Flush-Request)
   - [Info](#payload-v1-Info)
   - [Info.Annotations](#payload-v1-Info-Annotations)
   - [Info.Annotations.AnnotationsEntry](#payload-v1-Info-Annotations-AnnotationsEntry)
@@ -127,6 +129,8 @@
   - [RetryInfo](#rpc-v1-RetryInfo)
 - [v1/vald/filter.proto](#v1_vald_filter-proto)
   - [Filter](#vald-v1-Filter)
+- [v1/vald/flush.proto](#v1_vald_flush-proto)
+  - [Flush](#vald-v1-Flush)
 - [v1/vald/insert.proto](#v1_vald_insert-proto)
   - [Insert](#vald-v1-Insert)
 - [v1/vald/object.proto](#v1_vald_object-proto)
@@ -214,6 +218,14 @@ Represent the target filter server.
 | host  | [string](#string) |       | The target hostname. |
 | port  | [uint32](#uint32) |       | The target port.     |
 
+<a name="payload-v1-Flush"></a>
+
+### Flush
+
+<a name="payload-v1-Flush-Request"></a>
+
+### Flush.Request
+
 <a name="payload-v1-Info"></a>
 
 ### Info
@@ -1449,6 +1461,22 @@ Filter service provides ways to connect to Vald through filter.
 | StreamUpsertObject | [.payload.v1.Upsert.ObjectRequest](#payload-v1-Upsert-ObjectRequest) stream    | [.payload.v1.Object.StreamLocation](#payload-v1-Object-StreamLocation) stream | A method to upsert object by bidirectional streaming.                    |
 | MultiUpsertObject  | [.payload.v1.Upsert.MultiObjectRequest](#payload-v1-Upsert-MultiObjectRequest) | [.payload.v1.Object.Locations](#payload-v1-Object-Locations)                  | A method to upsert multiple objects.                                     |
 
+<a name="v1_vald_flush-proto"></a>
+
+<p align="right"><a href="#top">Top</a></p>
+
+## v1/vald/flush.proto
+
+<a name="vald-v1-Flush"></a>
+
+### Flush
+
+Flush service provides ways to flush all indexed vectors.
+
+| Method Name | Request Type                                           | Response Type                                                | Description                           |
+| ----------- | ------------------------------------------------------ | ------------------------------------------------------------ | ------------------------------------- |
+| Flush       | [.payload.v1.Flush.Request](#payload-v1-Flush-Request) | [.payload.v1.Info.Index.Count](#payload-v1-Info-Index-Count) | A method to flush all indexed vector. |
+
 <a name="v1_vald_insert-proto"></a>
 
 <p align="right"><a href="#top">Top</a></p>