From abbe5bb5a6ca916c285a5d19740bf99d2a6f5660 Mon Sep 17 00:00:00 2001 From: muzhouliu Date: Sat, 17 Feb 2024 12:40:00 -0800 Subject: [PATCH] update blob data insert request Signed-off-by: muzhouliu --- proto/milvus.proto | 12 ++++++++++++ proto/schema.proto | 8 +++----- 2 files changed, 15 insertions(+), 5 deletions(-) diff --git a/proto/milvus.proto b/proto/milvus.proto index e19f19b..d3ccdbd 100644 --- a/proto/milvus.proto +++ b/proto/milvus.proto @@ -133,6 +133,8 @@ service MilvusService { rpc CreateBlobStorage(CreateBlobStorageRequest) returns (common.Status) {} rpc DropBlobStorage(DropBlobStorageRequest) returns (common.Status) {} + rpc InsertBlobData(InsertRequest) returns (InsertBlobDataResponse) {} + rpc DeleteBlobData(DeleteRequest) returns (MutationResult) {} rpc ReplicateMessage(ReplicateMessageRequest) returns (ReplicateMessageResponse) {} } @@ -1824,6 +1826,16 @@ message DropBlobStorageRequest { string storage_path = 2; } +message InsertBlobDataResponse { + option (common.privilege_ext_obj) = { + object_type: Global + object_privilege: PrivilegeInsert + object_name_index: -1 + }; + common.Status status = 1; + schema.FieldData saved_blob_path_string = 2; +} + message ReplicateMessageRequest { common.MsgBase base = 1; string channel_name = 2; diff --git a/proto/schema.proto b/proto/schema.proto index d4f3f8a..29936dd 100644 --- a/proto/schema.proto +++ b/proto/schema.proto @@ -67,8 +67,6 @@ message FieldSchema { bool is_dynamic = 12; // mark whether this field is the dynamic field bool is_partition_key = 13; // enable logic partitions bool is_clustering_key = 14; - - bool is_blob_saved = 15; // for blob type, mark if the blob is saved } /** @@ -105,9 +103,9 @@ message ArrayArray { message JSONArray { repeated bytes data = 1; } message BlobFile { - bytes data = 1 ; - string file_name = 2; - string stored_path = 3; + bytes data = 1 ; //data field will be set to null after saved + string file_name = 2; // s3://// locates the blob file + string sha256 = 3; } message ValueField {