Sync pb files (#26643)

Signed-off-by: Enwei Jiao <enwei.jiao@zilliz.com>
pull/26616/head
Enwei Jiao 2023-08-29 12:36:26 +08:00 committed by GitHub
parent 87c2b3a025
commit a73eb1c831
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
9 changed files with 308 additions and 164 deletions

View File

@ -520,116 +520,116 @@ const char descriptor_table_protodef_common_2eproto[] PROTOBUF_SECTION_VARIABLE(
"\020\004\022\t\n\005Retry\020\005*\202\001\n\014SegmentState\022\024\n\020Segmen" "\020\004\022\t\n\005Retry\020\005*\202\001\n\014SegmentState\022\024\n\020Segmen"
"tStateNone\020\000\022\014\n\010NotExist\020\001\022\013\n\007Growing\020\002\022" "tStateNone\020\000\022\014\n\010NotExist\020\001\022\013\n\007Growing\020\002\022"
"\n\n\006Sealed\020\003\022\013\n\007Flushed\020\004\022\014\n\010Flushing\020\005\022\013" "\n\n\006Sealed\020\003\022\013\n\007Flushed\020\004\022\014\n\010Flushing\020\005\022\013"
"\n\007Dropped\020\006\022\r\n\tImporting\020\007*V\n\017Placeholde" "\n\007Dropped\020\006\022\r\n\tImporting\020\007*i\n\017Placeholde"
"rType\022\010\n\004None\020\000\022\020\n\014BinaryVector\020d\022\017\n\013Flo" "rType\022\010\n\004None\020\000\022\020\n\014BinaryVector\020d\022\017\n\013Flo"
"atVector\020e\022\t\n\005Int64\020\005\022\013\n\007VarChar\020\025*\264\020\n\007M" "atVector\020e\022\021\n\rFloat16Vector\020f\022\t\n\005Int64\020\005"
"sgType\022\r\n\tUndefined\020\000\022\024\n\020CreateCollectio" "\022\013\n\007VarChar\020\025*\264\020\n\007MsgType\022\r\n\tUndefined\020\000"
"n\020d\022\022\n\016DropCollection\020e\022\021\n\rHasCollection" "\022\024\n\020CreateCollection\020d\022\022\n\016DropCollection"
"\020f\022\026\n\022DescribeCollection\020g\022\023\n\017ShowCollec" "\020e\022\021\n\rHasCollection\020f\022\026\n\022DescribeCollect"
"tions\020h\022\024\n\020GetSystemConfigs\020i\022\022\n\016LoadCol" "ion\020g\022\023\n\017ShowCollections\020h\022\024\n\020GetSystemC"
"lection\020j\022\025\n\021ReleaseCollection\020k\022\017\n\013Crea" "onfigs\020i\022\022\n\016LoadCollection\020j\022\025\n\021ReleaseC"
"teAlias\020l\022\r\n\tDropAlias\020m\022\016\n\nAlterAlias\020n" "ollection\020k\022\017\n\013CreateAlias\020l\022\r\n\tDropAlia"
"\022\023\n\017AlterCollection\020o\022\024\n\020RenameCollectio" "s\020m\022\016\n\nAlterAlias\020n\022\023\n\017AlterCollection\020o"
"n\020p\022\021\n\rDescribeAlias\020q\022\017\n\013ListAliases\020r\022" "\022\024\n\020RenameCollection\020p\022\021\n\rDescribeAlias\020"
"\024\n\017CreatePartition\020\310\001\022\022\n\rDropPartition\020\311" "q\022\017\n\013ListAliases\020r\022\024\n\017CreatePartition\020\310\001"
"\001\022\021\n\014HasPartition\020\312\001\022\026\n\021DescribePartitio" "\022\022\n\rDropPartition\020\311\001\022\021\n\014HasPartition\020\312\001\022"
"n\020\313\001\022\023\n\016ShowPartitions\020\314\001\022\023\n\016LoadPartiti" "\026\n\021DescribePartition\020\313\001\022\023\n\016ShowPartition"
"ons\020\315\001\022\026\n\021ReleasePartitions\020\316\001\022\021\n\014ShowSe" "s\020\314\001\022\023\n\016LoadPartitions\020\315\001\022\026\n\021ReleasePart"
"gments\020\372\001\022\024\n\017DescribeSegment\020\373\001\022\021\n\014LoadS" "itions\020\316\001\022\021\n\014ShowSegments\020\372\001\022\024\n\017Describe"
"egments\020\374\001\022\024\n\017ReleaseSegments\020\375\001\022\024\n\017Hand" "Segment\020\373\001\022\021\n\014LoadSegments\020\374\001\022\024\n\017Release"
"offSegments\020\376\001\022\030\n\023LoadBalanceSegments\020\377\001" "Segments\020\375\001\022\024\n\017HandoffSegments\020\376\001\022\030\n\023Loa"
"\022\025\n\020DescribeSegments\020\200\002\022\034\n\027FederListInde" "dBalanceSegments\020\377\001\022\025\n\020DescribeSegments\020"
"xedSegment\020\201\002\022\"\n\035FederDescribeSegmentInd" "\200\002\022\034\n\027FederListIndexedSegment\020\201\002\022\"\n\035Fede"
"exData\020\202\002\022\020\n\013CreateIndex\020\254\002\022\022\n\rDescribeI" "rDescribeSegmentIndexData\020\202\002\022\020\n\013CreateIn"
"ndex\020\255\002\022\016\n\tDropIndex\020\256\002\022\027\n\022GetIndexStati" "dex\020\254\002\022\022\n\rDescribeIndex\020\255\002\022\016\n\tDropIndex\020"
"stics\020\257\002\022\013\n\006Insert\020\220\003\022\013\n\006Delete\020\221\003\022\n\n\005Fl" "\256\002\022\027\n\022GetIndexStatistics\020\257\002\022\013\n\006Insert\020\220\003"
"ush\020\222\003\022\027\n\022ResendSegmentStats\020\223\003\022\013\n\006Upser" "\022\013\n\006Delete\020\221\003\022\n\n\005Flush\020\222\003\022\027\n\022ResendSegme"
"t\020\224\003\022\013\n\006Search\020\364\003\022\021\n\014SearchResult\020\365\003\022\022\n\r" "ntStats\020\223\003\022\013\n\006Upsert\020\224\003\022\013\n\006Search\020\364\003\022\021\n\014"
"GetIndexState\020\366\003\022\032\n\025GetIndexBuildProgres" "SearchResult\020\365\003\022\022\n\rGetIndexState\020\366\003\022\032\n\025G"
"s\020\367\003\022\034\n\027GetCollectionStatistics\020\370\003\022\033\n\026Ge" "etIndexBuildProgress\020\367\003\022\034\n\027GetCollection"
"tPartitionStatistics\020\371\003\022\r\n\010Retrieve\020\372\003\022\023" "Statistics\020\370\003\022\033\n\026GetPartitionStatistics\020"
"\n\016RetrieveResult\020\373\003\022\024\n\017WatchDmChannels\020\374" "\371\003\022\r\n\010Retrieve\020\372\003\022\023\n\016RetrieveResult\020\373\003\022\024"
"\003\022\025\n\020RemoveDmChannels\020\375\003\022\027\n\022WatchQueryCh" "\n\017WatchDmChannels\020\374\003\022\025\n\020RemoveDmChannels"
"annels\020\376\003\022\030\n\023RemoveQueryChannels\020\377\003\022\035\n\030S" "\020\375\003\022\027\n\022WatchQueryChannels\020\376\003\022\030\n\023RemoveQu"
"ealedSegmentsChangeInfo\020\200\004\022\027\n\022WatchDelta" "eryChannels\020\377\003\022\035\n\030SealedSegmentsChangeIn"
"Channels\020\201\004\022\024\n\017GetShardLeaders\020\202\004\022\020\n\013Get" "fo\020\200\004\022\027\n\022WatchDeltaChannels\020\201\004\022\024\n\017GetSha"
"Replicas\020\203\004\022\023\n\016UnsubDmChannel\020\204\004\022\024\n\017GetD" "rdLeaders\020\202\004\022\020\n\013GetReplicas\020\203\004\022\023\n\016UnsubD"
"istribution\020\205\004\022\025\n\020SyncDistribution\020\206\004\022\020\n" "mChannel\020\204\004\022\024\n\017GetDistribution\020\205\004\022\025\n\020Syn"
"\013SegmentInfo\020\330\004\022\017\n\nSystemInfo\020\331\004\022\024\n\017GetR" "cDistribution\020\206\004\022\020\n\013SegmentInfo\020\330\004\022\017\n\nSy"
"ecoveryInfo\020\332\004\022\024\n\017GetSegmentState\020\333\004\022\r\n\010" "stemInfo\020\331\004\022\024\n\017GetRecoveryInfo\020\332\004\022\024\n\017Get"
"TimeTick\020\260\t\022\023\n\016QueryNodeStats\020\261\t\022\016\n\tLoad" "SegmentState\020\333\004\022\r\n\010TimeTick\020\260\t\022\023\n\016QueryN"
"Index\020\262\t\022\016\n\tRequestID\020\263\t\022\017\n\nRequestTSO\020\264" "odeStats\020\261\t\022\016\n\tLoadIndex\020\262\t\022\016\n\tRequestID"
"\t\022\024\n\017AllocateSegment\020\265\t\022\026\n\021SegmentStatis" "\020\263\t\022\017\n\nRequestTSO\020\264\t\022\024\n\017AllocateSegment\020"
"tics\020\266\t\022\025\n\020SegmentFlushDone\020\267\t\022\017\n\nDataNo" "\265\t\022\026\n\021SegmentStatistics\020\266\t\022\025\n\020SegmentFlu"
"deTt\020\270\t\022\014\n\007Connect\020\271\t\022\024\n\017ListClientInfos" "shDone\020\267\t\022\017\n\nDataNodeTt\020\270\t\022\014\n\007Connect\020\271\t"
"\020\272\t\022\023\n\016AllocTimestamp\020\273\t\022\025\n\020CreateCreden" "\022\024\n\017ListClientInfos\020\272\t\022\023\n\016AllocTimestamp"
"tial\020\334\013\022\022\n\rGetCredential\020\335\013\022\025\n\020DeleteCre" "\020\273\t\022\025\n\020CreateCredential\020\334\013\022\022\n\rGetCredent"
"dential\020\336\013\022\025\n\020UpdateCredential\020\337\013\022\026\n\021Lis" "ial\020\335\013\022\025\n\020DeleteCredential\020\336\013\022\025\n\020UpdateC"
"tCredUsernames\020\340\013\022\017\n\nCreateRole\020\300\014\022\r\n\010Dr" "redential\020\337\013\022\026\n\021ListCredUsernames\020\340\013\022\017\n\n"
"opRole\020\301\014\022\024\n\017OperateUserRole\020\302\014\022\017\n\nSelec" "CreateRole\020\300\014\022\r\n\010DropRole\020\301\014\022\024\n\017OperateU"
"tRole\020\303\014\022\017\n\nSelectUser\020\304\014\022\023\n\016SelectResou" "serRole\020\302\014\022\017\n\nSelectRole\020\303\014\022\017\n\nSelectUse"
"rce\020\305\014\022\025\n\020OperatePrivilege\020\306\014\022\020\n\013SelectG" "r\020\304\014\022\023\n\016SelectResource\020\305\014\022\025\n\020OperatePriv"
"rant\020\307\014\022\033\n\026RefreshPolicyInfoCache\020\310\014\022\017\n\n" "ilege\020\306\014\022\020\n\013SelectGrant\020\307\014\022\033\n\026RefreshPol"
"ListPolicy\020\311\014\022\030\n\023CreateResourceGroup\020\244\r\022" "icyInfoCache\020\310\014\022\017\n\nListPolicy\020\311\014\022\030\n\023Crea"
"\026\n\021DropResourceGroup\020\245\r\022\027\n\022ListResourceG" "teResourceGroup\020\244\r\022\026\n\021DropResourceGroup\020"
"roups\020\246\r\022\032\n\025DescribeResourceGroup\020\247\r\022\021\n\014" "\245\r\022\027\n\022ListResourceGroups\020\246\r\022\032\n\025DescribeR"
"TransferNode\020\250\r\022\024\n\017TransferReplica\020\251\r\022\023\n" "esourceGroup\020\247\r\022\021\n\014TransferNode\020\250\r\022\024\n\017Tr"
"\016CreateDatabase\020\211\016\022\021\n\014DropDatabase\020\212\016\022\022\n" "ansferReplica\020\251\r\022\023\n\016CreateDatabase\020\211\016\022\021\n"
"\rListDatabases\020\213\016*\"\n\007DslType\022\007\n\003Dsl\020\000\022\016\n" "\014DropDatabase\020\212\016\022\022\n\rListDatabases\020\213\016*\"\n\007"
"\nBoolExprV1\020\001*B\n\017CompactionState\022\021\n\rUnde" "DslType\022\007\n\003Dsl\020\000\022\016\n\nBoolExprV1\020\001*B\n\017Comp"
"fiedState\020\000\022\r\n\tExecuting\020\001\022\r\n\tCompleted\020" "actionState\022\021\n\rUndefiedState\020\000\022\r\n\tExecut"
"\002*X\n\020ConsistencyLevel\022\n\n\006Strong\020\000\022\013\n\007Ses" "ing\020\001\022\r\n\tCompleted\020\002*X\n\020ConsistencyLevel"
"sion\020\001\022\013\n\007Bounded\020\002\022\016\n\nEventually\020\003\022\016\n\nC" "\022\n\n\006Strong\020\000\022\013\n\007Session\020\001\022\013\n\007Bounded\020\002\022\016"
"ustomized\020\004*\236\001\n\013ImportState\022\021\n\rImportPen" "\n\nEventually\020\003\022\016\n\nCustomized\020\004*\236\001\n\013Impor"
"ding\020\000\022\020\n\014ImportFailed\020\001\022\021\n\rImportStarte" "tState\022\021\n\rImportPending\020\000\022\020\n\014ImportFaile"
"d\020\002\022\023\n\017ImportPersisted\020\005\022\021\n\rImportFlushe" "d\020\001\022\021\n\rImportStarted\020\002\022\023\n\017ImportPersiste"
"d\020\010\022\023\n\017ImportCompleted\020\006\022\032\n\026ImportFailed" "d\020\005\022\021\n\rImportFlushed\020\010\022\023\n\017ImportComplete"
"AndCleaned\020\007*2\n\nObjectType\022\016\n\nCollection" "d\020\006\022\032\n\026ImportFailedAndCleaned\020\007*2\n\nObjec"
"\020\000\022\n\n\006Global\020\001\022\010\n\004User\020\002*\241\010\n\017ObjectPrivi" "tType\022\016\n\nCollection\020\000\022\n\n\006Global\020\001\022\010\n\004Use"
"lege\022\020\n\014PrivilegeAll\020\000\022\035\n\031PrivilegeCreat" "r\020\002*\241\010\n\017ObjectPrivilege\022\020\n\014PrivilegeAll\020"
"eCollection\020\001\022\033\n\027PrivilegeDropCollection" "\000\022\035\n\031PrivilegeCreateCollection\020\001\022\033\n\027Priv"
"\020\002\022\037\n\033PrivilegeDescribeCollection\020\003\022\034\n\030P" "ilegeDropCollection\020\002\022\037\n\033PrivilegeDescri"
"rivilegeShowCollections\020\004\022\021\n\rPrivilegeLo" "beCollection\020\003\022\034\n\030PrivilegeShowCollectio"
"ad\020\005\022\024\n\020PrivilegeRelease\020\006\022\027\n\023PrivilegeC" "ns\020\004\022\021\n\rPrivilegeLoad\020\005\022\024\n\020PrivilegeRele"
"ompaction\020\007\022\023\n\017PrivilegeInsert\020\010\022\023\n\017Priv" "ase\020\006\022\027\n\023PrivilegeCompaction\020\007\022\023\n\017Privil"
"ilegeDelete\020\t\022\032\n\026PrivilegeGetStatistics\020" "egeInsert\020\010\022\023\n\017PrivilegeDelete\020\t\022\032\n\026Priv"
"\n\022\030\n\024PrivilegeCreateIndex\020\013\022\030\n\024Privilege" "ilegeGetStatistics\020\n\022\030\n\024PrivilegeCreateI"
"IndexDetail\020\014\022\026\n\022PrivilegeDropIndex\020\r\022\023\n" "ndex\020\013\022\030\n\024PrivilegeIndexDetail\020\014\022\026\n\022Priv"
"\017PrivilegeSearch\020\016\022\022\n\016PrivilegeFlush\020\017\022\022" "ilegeDropIndex\020\r\022\023\n\017PrivilegeSearch\020\016\022\022\n"
"\n\016PrivilegeQuery\020\020\022\030\n\024PrivilegeLoadBalan" "\016PrivilegeFlush\020\017\022\022\n\016PrivilegeQuery\020\020\022\030\n"
"ce\020\021\022\023\n\017PrivilegeImport\020\022\022\034\n\030PrivilegeCr" "\024PrivilegeLoadBalance\020\021\022\023\n\017PrivilegeImpo"
"eateOwnership\020\023\022\027\n\023PrivilegeUpdateUser\020\024" "rt\020\022\022\034\n\030PrivilegeCreateOwnership\020\023\022\027\n\023Pr"
"\022\032\n\026PrivilegeDropOwnership\020\025\022\034\n\030Privileg" "ivilegeUpdateUser\020\024\022\032\n\026PrivilegeDropOwne"
"eSelectOwnership\020\026\022\034\n\030PrivilegeManageOwn" "rship\020\025\022\034\n\030PrivilegeSelectOwnership\020\026\022\034\n"
"ership\020\027\022\027\n\023PrivilegeSelectUser\020\030\022\023\n\017Pri" "\030PrivilegeManageOwnership\020\027\022\027\n\023Privilege"
"vilegeUpsert\020\031\022 \n\034PrivilegeCreateResourc" "SelectUser\020\030\022\023\n\017PrivilegeUpsert\020\031\022 \n\034Pri"
"eGroup\020\032\022\036\n\032PrivilegeDropResourceGroup\020\033" "vilegeCreateResourceGroup\020\032\022\036\n\032Privilege"
"\022\"\n\036PrivilegeDescribeResourceGroup\020\034\022\037\n\033" "DropResourceGroup\020\033\022\"\n\036PrivilegeDescribe"
"PrivilegeListResourceGroups\020\035\022\031\n\025Privile" "ResourceGroup\020\034\022\037\n\033PrivilegeListResource"
"geTransferNode\020\036\022\034\n\030PrivilegeTransferRep" "Groups\020\035\022\031\n\025PrivilegeTransferNode\020\036\022\034\n\030P"
"lica\020\037\022\037\n\033PrivilegeGetLoadingProgress\020 \022" "rivilegeTransferReplica\020\037\022\037\n\033PrivilegeGe"
"\031\n\025PrivilegeGetLoadState\020!\022\035\n\031PrivilegeR" "tLoadingProgress\020 \022\031\n\025PrivilegeGetLoadSt"
"enameCollection\020\"\022\033\n\027PrivilegeCreateData" "ate\020!\022\035\n\031PrivilegeRenameCollection\020\"\022\033\n\027"
"base\020#\022\031\n\025PrivilegeDropDatabase\020$\022\032\n\026Pri" "PrivilegeCreateDatabase\020#\022\031\n\025PrivilegeDr"
"vilegeListDatabases\020%\022\025\n\021PrivilegeFlushA" "opDatabase\020$\022\032\n\026PrivilegeListDatabases\020%"
"ll\020&*S\n\tStateCode\022\020\n\014Initializing\020\000\022\013\n\007H" "\022\025\n\021PrivilegeFlushAll\020&*S\n\tStateCode\022\020\n\014"
"ealthy\020\001\022\014\n\010Abnormal\020\002\022\013\n\007StandBy\020\003\022\014\n\010S" "Initializing\020\000\022\013\n\007Healthy\020\001\022\014\n\010Abnormal\020"
"topping\020\004*c\n\tLoadState\022\025\n\021LoadStateNotEx" "\002\022\013\n\007StandBy\020\003\022\014\n\010Stopping\020\004*c\n\tLoadStat"
"ist\020\000\022\024\n\020LoadStateNotLoad\020\001\022\024\n\020LoadState" "e\022\025\n\021LoadStateNotExist\020\000\022\024\n\020LoadStateNot"
"Loading\020\002\022\023\n\017LoadStateLoaded\020\003:^\n\021privil" "Load\020\001\022\024\n\020LoadStateLoading\020\002\022\023\n\017LoadStat"
"ege_ext_obj\022\037.google.protobuf.MessageOpt" "eLoaded\020\003:^\n\021privilege_ext_obj\022\037.google."
"ions\030\351\007 \001(\0132!.milvus.proto.common.Privil" "protobuf.MessageOptions\030\351\007 \001(\0132!.milvus."
"egeExtBi\n\016io.milvus.grpcB\013CommonProtoP\001Z" "proto.common.PrivilegeExtBm\n\016io.milvus.g"
"4github.com/milvus-io/milvus-proto/go-ap" "rpcB\013CommonProtoP\001Z4github.com/milvus-io"
"i/v2/commonpb\240\001\001\252\002\016IO.Milvus.Grpcb\006proto" "/milvus-proto/go-api/v2/commonpb\240\001\001\252\002\022Mi"
"3" "lvus.Client.Grpcb\006proto3"
; ;
static const ::_pbi::DescriptorTable* const descriptor_table_common_2eproto_deps[1] = { static const ::_pbi::DescriptorTable* const descriptor_table_common_2eproto_deps[1] = {
&::descriptor_table_google_2fprotobuf_2fdescriptor_2eproto, &::descriptor_table_google_2fprotobuf_2fdescriptor_2eproto,
}; };
static ::_pbi::once_flag descriptor_table_common_2eproto_once; static ::_pbi::once_flag descriptor_table_common_2eproto_once;
const ::_pbi::DescriptorTable descriptor_table_common_2eproto = { const ::_pbi::DescriptorTable descriptor_table_common_2eproto = {
false, false, 7081, descriptor_table_protodef_common_2eproto, false, false, 7104, descriptor_table_protodef_common_2eproto,
"common.proto", "common.proto",
&descriptor_table_common_2eproto_once, descriptor_table_common_2eproto_deps, 1, 16, &descriptor_table_common_2eproto_once, descriptor_table_common_2eproto_deps, 1, 16,
schemas, file_default_instances, TableStruct_common_2eproto::offsets, schemas, file_default_instances, TableStruct_common_2eproto::offsets,
@ -765,6 +765,7 @@ bool PlaceholderType_IsValid(int value) {
case 21: case 21:
case 100: case 100:
case 101: case 101:
case 102:
return true; return true;
default: default:
return false; return false;

View File

@ -271,6 +271,7 @@ enum PlaceholderType : int {
None = 0, None = 0,
BinaryVector = 100, BinaryVector = 100,
FloatVector = 101, FloatVector = 101,
Float16Vector = 102,
Int64 = 5, Int64 = 5,
VarChar = 21, VarChar = 21,
PlaceholderType_INT_MIN_SENTINEL_DO_NOT_USE_ = std::numeric_limits<int32_t>::min(), PlaceholderType_INT_MIN_SENTINEL_DO_NOT_USE_ = std::numeric_limits<int32_t>::min(),
@ -278,7 +279,7 @@ enum PlaceholderType : int {
}; };
bool PlaceholderType_IsValid(int value); bool PlaceholderType_IsValid(int value);
constexpr PlaceholderType PlaceholderType_MIN = None; constexpr PlaceholderType PlaceholderType_MIN = None;
constexpr PlaceholderType PlaceholderType_MAX = FloatVector; constexpr PlaceholderType PlaceholderType_MAX = Float16Vector;
constexpr int PlaceholderType_ARRAYSIZE = PlaceholderType_MAX + 1; constexpr int PlaceholderType_ARRAYSIZE = PlaceholderType_MAX + 1;
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* PlaceholderType_descriptor(); const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* PlaceholderType_descriptor();

View File

@ -421,6 +421,7 @@ const uint32_t TableStruct_schema_2eproto::offsets[] PROTOBUF_SECTION_VARIABLE(p
PROTOBUF_FIELD_OFFSET(::milvus::proto::schema::VectorField, _impl_.dim_), PROTOBUF_FIELD_OFFSET(::milvus::proto::schema::VectorField, _impl_.dim_),
::_pbi::kInvalidFieldOffsetTag, ::_pbi::kInvalidFieldOffsetTag,
::_pbi::kInvalidFieldOffsetTag, ::_pbi::kInvalidFieldOffsetTag,
::_pbi::kInvalidFieldOffsetTag,
PROTOBUF_FIELD_OFFSET(::milvus::proto::schema::VectorField, _impl_.data_), PROTOBUF_FIELD_OFFSET(::milvus::proto::schema::VectorField, _impl_.data_),
~0u, // no _has_bits_ ~0u, // no _has_bits_
PROTOBUF_FIELD_OFFSET(::milvus::proto::schema::FieldData, _internal_metadata_), PROTOBUF_FIELD_OFFSET(::milvus::proto::schema::FieldData, _internal_metadata_),
@ -473,9 +474,9 @@ static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protode
{ 94, -1, -1, sizeof(::milvus::proto::schema::ValueField)}, { 94, -1, -1, sizeof(::milvus::proto::schema::ValueField)},
{ 108, -1, -1, sizeof(::milvus::proto::schema::ScalarField)}, { 108, -1, -1, sizeof(::milvus::proto::schema::ScalarField)},
{ 124, -1, -1, sizeof(::milvus::proto::schema::VectorField)}, { 124, -1, -1, sizeof(::milvus::proto::schema::VectorField)},
{ 134, -1, -1, sizeof(::milvus::proto::schema::FieldData)}, { 135, -1, -1, sizeof(::milvus::proto::schema::FieldData)},
{ 147, -1, -1, sizeof(::milvus::proto::schema::IDs)}, { 148, -1, -1, sizeof(::milvus::proto::schema::IDs)},
{ 156, -1, -1, sizeof(::milvus::proto::schema::SearchResultData)}, { 157, -1, -1, sizeof(::milvus::proto::schema::SearchResultData)},
}; };
static const ::_pb::Message* const file_default_instances[] = { static const ::_pb::Message* const file_default_instances[] = {
@ -541,40 +542,42 @@ const char descriptor_table_protodef_schema_2eproto[] PROTOBUF_SECTION_VARIABLE(
"oto.schema.BytesArrayH\000\0225\n\narray_data\030\010 " "oto.schema.BytesArrayH\000\0225\n\narray_data\030\010 "
"\001(\0132\037.milvus.proto.schema.ArrayArrayH\000\0223" "\001(\0132\037.milvus.proto.schema.ArrayArrayH\000\0223"
"\n\tjson_data\030\t \001(\0132\036.milvus.proto.schema." "\n\tjson_data\030\t \001(\0132\036.milvus.proto.schema."
"JSONArrayH\000B\006\n\004data\"t\n\013VectorField\022\013\n\003di" "JSONArrayH\000B\006\n\004data\"\216\001\n\013VectorField\022\013\n\003d"
"m\030\001 \001(\003\0227\n\014float_vector\030\002 \001(\0132\037.milvus.p" "im\030\001 \001(\003\0227\n\014float_vector\030\002 \001(\0132\037.milvus."
"roto.schema.FloatArrayH\000\022\027\n\rbinary_vecto" "proto.schema.FloatArrayH\000\022\027\n\rbinary_vect"
"r\030\003 \001(\014H\000B\006\n\004data\"\345\001\n\tFieldData\022+\n\004type\030" "or\030\003 \001(\014H\000\022\030\n\016float16_vector\030\004 \001(\014H\000B\006\n\004"
"\001 \001(\0162\035.milvus.proto.schema.DataType\022\022\n\n" "data\"\345\001\n\tFieldData\022+\n\004type\030\001 \001(\0162\035.milvu"
"field_name\030\002 \001(\t\0223\n\007scalars\030\003 \001(\0132 .milv" "s.proto.schema.DataType\022\022\n\nfield_name\030\002 "
"us.proto.schema.ScalarFieldH\000\0223\n\007vectors" "\001(\t\0223\n\007scalars\030\003 \001(\0132 .milvus.proto.sche"
"\030\004 \001(\0132 .milvus.proto.schema.VectorField" "ma.ScalarFieldH\000\0223\n\007vectors\030\004 \001(\0132 .milv"
"H\000\022\020\n\010field_id\030\005 \001(\003\022\022\n\nis_dynamic\030\006 \001(\010" "us.proto.schema.VectorFieldH\000\022\020\n\010field_i"
"B\007\n\005field\"w\n\003IDs\0220\n\006int_id\030\001 \001(\0132\036.milvu" "d\030\005 \001(\003\022\022\n\nis_dynamic\030\006 \001(\010B\007\n\005field\"w\n\003"
"s.proto.schema.LongArrayH\000\0222\n\006str_id\030\002 \001" "IDs\0220\n\006int_id\030\001 \001(\0132\036.milvus.proto.schem"
"(\0132 .milvus.proto.schema.StringArrayH\000B\n" "a.LongArrayH\000\0222\n\006str_id\030\002 \001(\0132 .milvus.p"
"\n\010id_field\"\310\001\n\020SearchResultData\022\023\n\013num_q" "roto.schema.StringArrayH\000B\n\n\010id_field\"\310\001"
"ueries\030\001 \001(\003\022\r\n\005top_k\030\002 \001(\003\0223\n\013fields_da" "\n\020SearchResultData\022\023\n\013num_queries\030\001 \001(\003\022"
"ta\030\003 \003(\0132\036.milvus.proto.schema.FieldData" "\r\n\005top_k\030\002 \001(\003\0223\n\013fields_data\030\003 \003(\0132\036.mi"
"\022\016\n\006scores\030\004 \003(\002\022%\n\003ids\030\005 \001(\0132\030.milvus.p" "lvus.proto.schema.FieldData\022\016\n\006scores\030\004 "
"roto.schema.IDs\022\r\n\005topks\030\006 \003(\003\022\025\n\routput" "\003(\002\022%\n\003ids\030\005 \001(\0132\030.milvus.proto.schema.I"
"_fields\030\007 \003(\t*\261\001\n\010DataType\022\010\n\004None\020\000\022\010\n\004" "Ds\022\r\n\005topks\030\006 \003(\003\022\025\n\routput_fields\030\007 \003(\t"
"Bool\020\001\022\010\n\004Int8\020\002\022\t\n\005Int16\020\003\022\t\n\005Int32\020\004\022\t" "*\304\001\n\010DataType\022\010\n\004None\020\000\022\010\n\004Bool\020\001\022\010\n\004Int"
"\n\005Int64\020\005\022\t\n\005Float\020\n\022\n\n\006Double\020\013\022\n\n\006Stri" "8\020\002\022\t\n\005Int16\020\003\022\t\n\005Int32\020\004\022\t\n\005Int64\020\005\022\t\n\005"
"ng\020\024\022\013\n\007VarChar\020\025\022\t\n\005Array\020\026\022\010\n\004JSON\020\027\022\020" "Float\020\n\022\n\n\006Double\020\013\022\n\n\006String\020\024\022\013\n\007VarCh"
"\n\014BinaryVector\020d\022\017\n\013FloatVector\020e*V\n\nFie" "ar\020\025\022\t\n\005Array\020\026\022\010\n\004JSON\020\027\022\020\n\014BinaryVecto"
"ldState\022\020\n\014FieldCreated\020\000\022\021\n\rFieldCreati" "r\020d\022\017\n\013FloatVector\020e\022\021\n\rFloat16Vector\020f*"
"ng\020\001\022\021\n\rFieldDropping\020\002\022\020\n\014FieldDropped\020" "V\n\nFieldState\022\020\n\014FieldCreated\020\000\022\021\n\rField"
"\003Bi\n\016io.milvus.grpcB\013SchemaProtoP\001Z4gith" "Creating\020\001\022\021\n\rFieldDropping\020\002\022\020\n\014FieldDr"
"ub.com/milvus-io/milvus-proto/go-api/v2/" "opped\020\003Bm\n\016io.milvus.grpcB\013SchemaProtoP\001"
"schemapb\240\001\001\252\002\016IO.Milvus.Grpcb\006proto3" "Z4github.com/milvus-io/milvus-proto/go-a"
"pi/v2/schemapb\240\001\001\252\002\022Milvus.Client.Grpcb\006"
"proto3"
; ;
static const ::_pbi::DescriptorTable* const descriptor_table_schema_2eproto_deps[1] = { static const ::_pbi::DescriptorTable* const descriptor_table_schema_2eproto_deps[1] = {
&::descriptor_table_common_2eproto, &::descriptor_table_common_2eproto,
}; };
static ::_pbi::once_flag descriptor_table_schema_2eproto_once; static ::_pbi::once_flag descriptor_table_schema_2eproto_once;
const ::_pbi::DescriptorTable descriptor_table_schema_2eproto = { const ::_pbi::DescriptorTable descriptor_table_schema_2eproto = {
false, false, 2756, descriptor_table_protodef_schema_2eproto, false, false, 2806, descriptor_table_protodef_schema_2eproto,
"schema.proto", "schema.proto",
&descriptor_table_schema_2eproto_once, descriptor_table_schema_2eproto_deps, 1, 17, &descriptor_table_schema_2eproto_once, descriptor_table_schema_2eproto_deps, 1, 17,
schemas, file_default_instances, TableStruct_schema_2eproto::offsets, schemas, file_default_instances, TableStruct_schema_2eproto::offsets,
@ -610,6 +613,7 @@ bool DataType_IsValid(int value) {
case 23: case 23:
case 100: case 100:
case 101: case 101:
case 102:
return true; return true;
default: default:
return false; return false;
@ -4456,6 +4460,10 @@ VectorField::VectorField(const VectorField& from)
_this->_internal_set_binary_vector(from._internal_binary_vector()); _this->_internal_set_binary_vector(from._internal_binary_vector());
break; break;
} }
case kFloat16Vector: {
_this->_internal_set_float16_vector(from._internal_float16_vector());
break;
}
case DATA_NOT_SET: { case DATA_NOT_SET: {
break; break;
} }
@ -4509,6 +4517,10 @@ void VectorField::clear_data() {
_impl_.data_.binary_vector_.Destroy(); _impl_.data_.binary_vector_.Destroy();
break; break;
} }
case kFloat16Vector: {
_impl_.data_.float16_vector_.Destroy();
break;
}
case DATA_NOT_SET: { case DATA_NOT_SET: {
break; break;
} }
@ -4559,6 +4571,15 @@ const char* VectorField::_InternalParse(const char* ptr, ::_pbi::ParseContext* c
} else } else
goto handle_unusual; goto handle_unusual;
continue; continue;
// bytes float16_vector = 4;
case 4:
if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 34)) {
auto str = _internal_mutable_float16_vector();
ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
CHK_(ptr);
} else
goto handle_unusual;
continue;
default: default:
goto handle_unusual; goto handle_unusual;
} // switch } // switch
@ -4607,6 +4628,12 @@ uint8_t* VectorField::_InternalSerialize(
3, this->_internal_binary_vector(), target); 3, this->_internal_binary_vector(), target);
} }
// bytes float16_vector = 4;
if (_internal_has_float16_vector()) {
target = stream->WriteBytesMaybeAliased(
4, this->_internal_float16_vector(), target);
}
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray( target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
_internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream); _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream);
@ -4643,6 +4670,13 @@ size_t VectorField::ByteSizeLong() const {
this->_internal_binary_vector()); this->_internal_binary_vector());
break; break;
} }
// bytes float16_vector = 4;
case kFloat16Vector: {
total_size += 1 +
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize(
this->_internal_float16_vector());
break;
}
case DATA_NOT_SET: { case DATA_NOT_SET: {
break; break;
} }
@ -4678,6 +4712,10 @@ void VectorField::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PR
_this->_internal_set_binary_vector(from._internal_binary_vector()); _this->_internal_set_binary_vector(from._internal_binary_vector());
break; break;
} }
case kFloat16Vector: {
_this->_internal_set_float16_vector(from._internal_float16_vector());
break;
}
case DATA_NOT_SET: { case DATA_NOT_SET: {
break; break;
} }

View File

@ -141,12 +141,13 @@ enum DataType : int {
JSON = 23, JSON = 23,
BinaryVector = 100, BinaryVector = 100,
FloatVector = 101, FloatVector = 101,
Float16Vector = 102,
DataType_INT_MIN_SENTINEL_DO_NOT_USE_ = std::numeric_limits<int32_t>::min(), DataType_INT_MIN_SENTINEL_DO_NOT_USE_ = std::numeric_limits<int32_t>::min(),
DataType_INT_MAX_SENTINEL_DO_NOT_USE_ = std::numeric_limits<int32_t>::max() DataType_INT_MAX_SENTINEL_DO_NOT_USE_ = std::numeric_limits<int32_t>::max()
}; };
bool DataType_IsValid(int value); bool DataType_IsValid(int value);
constexpr DataType DataType_MIN = None; constexpr DataType DataType_MIN = None;
constexpr DataType DataType_MAX = FloatVector; constexpr DataType DataType_MAX = Float16Vector;
constexpr int DataType_ARRAYSIZE = DataType_MAX + 1; constexpr int DataType_ARRAYSIZE = DataType_MAX + 1;
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* DataType_descriptor(); const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* DataType_descriptor();
@ -2861,6 +2862,7 @@ class VectorField final :
enum DataCase { enum DataCase {
kFloatVector = 2, kFloatVector = 2,
kBinaryVector = 3, kBinaryVector = 3,
kFloat16Vector = 4,
DATA_NOT_SET = 0, DATA_NOT_SET = 0,
}; };
@ -2945,6 +2947,7 @@ class VectorField final :
kDimFieldNumber = 1, kDimFieldNumber = 1,
kFloatVectorFieldNumber = 2, kFloatVectorFieldNumber = 2,
kBinaryVectorFieldNumber = 3, kBinaryVectorFieldNumber = 3,
kFloat16VectorFieldNumber = 4,
}; };
// int64 dim = 1; // int64 dim = 1;
void clear_dim(); void clear_dim();
@ -2991,6 +2994,24 @@ class VectorField final :
std::string* _internal_mutable_binary_vector(); std::string* _internal_mutable_binary_vector();
public: public:
// bytes float16_vector = 4;
bool has_float16_vector() const;
private:
bool _internal_has_float16_vector() const;
public:
void clear_float16_vector();
const std::string& float16_vector() const;
template <typename ArgT0 = const std::string&, typename... ArgT>
void set_float16_vector(ArgT0&& arg0, ArgT... args);
std::string* mutable_float16_vector();
PROTOBUF_NODISCARD std::string* release_float16_vector();
void set_allocated_float16_vector(std::string* float16_vector);
private:
const std::string& _internal_float16_vector() const;
inline PROTOBUF_ALWAYS_INLINE void _internal_set_float16_vector(const std::string& value);
std::string* _internal_mutable_float16_vector();
public:
void clear_data(); void clear_data();
DataCase data_case() const; DataCase data_case() const;
// @@protoc_insertion_point(class_scope:milvus.proto.schema.VectorField) // @@protoc_insertion_point(class_scope:milvus.proto.schema.VectorField)
@ -2998,6 +3019,7 @@ class VectorField final :
class _Internal; class _Internal;
void set_has_float_vector(); void set_has_float_vector();
void set_has_binary_vector(); void set_has_binary_vector();
void set_has_float16_vector();
inline bool has_data() const; inline bool has_data() const;
inline void clear_has_data(); inline void clear_has_data();
@ -3012,6 +3034,7 @@ class VectorField final :
::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized _constinit_; ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized _constinit_;
::milvus::proto::schema::FloatArray* float_vector_; ::milvus::proto::schema::FloatArray* float_vector_;
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr binary_vector_; ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr binary_vector_;
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr float16_vector_;
} data_; } data_;
mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
uint32_t _oneof_case_[1]; uint32_t _oneof_case_[1];
@ -6121,6 +6144,83 @@ inline void VectorField::set_allocated_binary_vector(std::string* binary_vector)
// @@protoc_insertion_point(field_set_allocated:milvus.proto.schema.VectorField.binary_vector) // @@protoc_insertion_point(field_set_allocated:milvus.proto.schema.VectorField.binary_vector)
} }
// bytes float16_vector = 4;
inline bool VectorField::_internal_has_float16_vector() const {
return data_case() == kFloat16Vector;
}
inline bool VectorField::has_float16_vector() const {
return _internal_has_float16_vector();
}
inline void VectorField::set_has_float16_vector() {
_impl_._oneof_case_[0] = kFloat16Vector;
}
inline void VectorField::clear_float16_vector() {
if (_internal_has_float16_vector()) {
_impl_.data_.float16_vector_.Destroy();
clear_has_data();
}
}
inline const std::string& VectorField::float16_vector() const {
// @@protoc_insertion_point(field_get:milvus.proto.schema.VectorField.float16_vector)
return _internal_float16_vector();
}
template <typename ArgT0, typename... ArgT>
inline void VectorField::set_float16_vector(ArgT0&& arg0, ArgT... args) {
if (!_internal_has_float16_vector()) {
clear_data();
set_has_float16_vector();
_impl_.data_.float16_vector_.InitDefault();
}
_impl_.data_.float16_vector_.SetBytes( static_cast<ArgT0 &&>(arg0), args..., GetArenaForAllocation());
// @@protoc_insertion_point(field_set:milvus.proto.schema.VectorField.float16_vector)
}
inline std::string* VectorField::mutable_float16_vector() {
std::string* _s = _internal_mutable_float16_vector();
// @@protoc_insertion_point(field_mutable:milvus.proto.schema.VectorField.float16_vector)
return _s;
}
inline const std::string& VectorField::_internal_float16_vector() const {
if (_internal_has_float16_vector()) {
return _impl_.data_.float16_vector_.Get();
}
return ::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited();
}
inline void VectorField::_internal_set_float16_vector(const std::string& value) {
if (!_internal_has_float16_vector()) {
clear_data();
set_has_float16_vector();
_impl_.data_.float16_vector_.InitDefault();
}
_impl_.data_.float16_vector_.Set(value, GetArenaForAllocation());
}
inline std::string* VectorField::_internal_mutable_float16_vector() {
if (!_internal_has_float16_vector()) {
clear_data();
set_has_float16_vector();
_impl_.data_.float16_vector_.InitDefault();
}
return _impl_.data_.float16_vector_.Mutable( GetArenaForAllocation());
}
inline std::string* VectorField::release_float16_vector() {
// @@protoc_insertion_point(field_release:milvus.proto.schema.VectorField.float16_vector)
if (_internal_has_float16_vector()) {
clear_has_data();
return _impl_.data_.float16_vector_.Release();
} else {
return nullptr;
}
}
inline void VectorField::set_allocated_float16_vector(std::string* float16_vector) {
if (has_data()) {
clear_data();
}
if (float16_vector != nullptr) {
set_has_float16_vector();
_impl_.data_.float16_vector_.InitAllocated(float16_vector, GetArenaForAllocation());
}
// @@protoc_insertion_point(field_set_allocated:milvus.proto.schema.VectorField.float16_vector)
}
inline bool VectorField::has_data() const { inline bool VectorField::has_data() const {
return data_case() != DATA_NOT_SET; return data_case() != DATA_NOT_SET;
} }

View File

@ -206,6 +206,7 @@ func (BinaryExpr_BinaryOp) EnumDescriptor() ([]byte, []int) {
type GenericValue struct { type GenericValue struct {
// Types that are valid to be assigned to Val: // Types that are valid to be assigned to Val:
//
// *GenericValue_BoolVal // *GenericValue_BoolVal
// *GenericValue_Int64Val // *GenericValue_Int64Val
// *GenericValue_FloatVal // *GenericValue_FloatVal
@ -1250,6 +1251,7 @@ var xxx_messageInfo_AlwaysTrueExpr proto.InternalMessageInfo
type Expr struct { type Expr struct {
// Types that are valid to be assigned to Expr: // Types that are valid to be assigned to Expr:
//
// *Expr_TermExpr // *Expr_TermExpr
// *Expr_UnaryExpr // *Expr_UnaryExpr
// *Expr_BinaryExpr // *Expr_BinaryExpr
@ -1621,6 +1623,7 @@ func (m *QueryPlanNode) GetLimit() int64 {
type PlanNode struct { type PlanNode struct {
// Types that are valid to be assigned to Node: // Types that are valid to be assigned to Node:
//
// *PlanNode_VectorAnns // *PlanNode_VectorAnns
// *PlanNode_Predicates // *PlanNode_Predicates
// *PlanNode_Query // *PlanNode_Query

View File

@ -29,8 +29,9 @@ const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
type InvalidateCollMetaCacheRequest struct { type InvalidateCollMetaCacheRequest struct {
// MsgType: // MsgType:
// DropCollection -> {meta cache, dml channels} //
// Other -> {meta cache} // DropCollection -> {meta cache, dml channels}
// Other -> {meta cache}
Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"` Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"` DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
CollectionName string `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"` CollectionName string `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`

View File

@ -251,7 +251,7 @@ func (SyncType) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_aab7cc9a69ed26e8, []int{6} return fileDescriptor_aab7cc9a69ed26e8, []int{6}
} }
//--------------------QueryCoord grpc request and response proto------------------ // --------------------QueryCoord grpc request and response proto------------------
type ShowCollectionsRequest struct { type ShowCollectionsRequest struct {
Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"` Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
// Not useful for now // Not useful for now
@ -1336,7 +1336,7 @@ func (m *SyncNewCreatedPartitionRequest) GetPartitionID() int64 {
return 0 return 0
} }
//-----------------query node grpc request and response proto---------------- // -----------------query node grpc request and response proto----------------
type LoadMetaInfo struct { type LoadMetaInfo struct {
LoadType LoadType `protobuf:"varint,1,opt,name=load_type,json=loadType,proto3,enum=milvus.proto.query.LoadType" json:"load_type,omitempty"` LoadType LoadType `protobuf:"varint,1,opt,name=load_type,json=loadType,proto3,enum=milvus.proto.query.LoadType" json:"load_type,omitempty"`
CollectionID int64 `protobuf:"varint,2,opt,name=collectionID,proto3" json:"collectionID,omitempty"` CollectionID int64 `protobuf:"varint,2,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
@ -2488,7 +2488,7 @@ func (m *GetLoadInfoResponse) GetPartitions() []int64 {
return nil return nil
} }
//----------------request auto triggered by QueryCoord----------------- // ----------------request auto triggered by QueryCoord-----------------
type HandoffSegmentsRequest struct { type HandoffSegmentsRequest struct {
Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"` Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
SegmentInfos []*SegmentInfo `protobuf:"bytes,2,rep,name=segmentInfos,proto3" json:"segmentInfos,omitempty"` SegmentInfos []*SegmentInfo `protobuf:"bytes,2,rep,name=segmentInfos,proto3" json:"segmentInfos,omitempty"`
@ -3185,7 +3185,7 @@ func (m *UnsubscribeChannelInfo) GetCollectionChannels() []*UnsubscribeChannels
return nil return nil
} }
//---- synchronize messages proto between QueryCoord and QueryNode ----- // ---- synchronize messages proto between QueryCoord and QueryNode -----
type SegmentChangeInfo struct { type SegmentChangeInfo struct {
OnlineNodeID int64 `protobuf:"varint,1,opt,name=online_nodeID,json=onlineNodeID,proto3" json:"online_nodeID,omitempty"` OnlineNodeID int64 `protobuf:"varint,1,opt,name=online_nodeID,json=onlineNodeID,proto3" json:"online_nodeID,omitempty"`
OnlineSegments []*SegmentInfo `protobuf:"bytes,2,rep,name=online_segments,json=onlineSegments,proto3" json:"online_segments,omitempty"` OnlineSegments []*SegmentInfo `protobuf:"bytes,2,rep,name=online_segments,json=onlineSegments,proto3" json:"online_segments,omitempty"`

View File

@ -793,28 +793,28 @@ type RootCoordClient interface {
GetComponentStates(ctx context.Context, in *milvuspb.GetComponentStatesRequest, opts ...grpc.CallOption) (*milvuspb.ComponentStates, error) GetComponentStates(ctx context.Context, in *milvuspb.GetComponentStatesRequest, opts ...grpc.CallOption) (*milvuspb.ComponentStates, error)
GetTimeTickChannel(ctx context.Context, in *internalpb.GetTimeTickChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error) GetTimeTickChannel(ctx context.Context, in *internalpb.GetTimeTickChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error)
GetStatisticsChannel(ctx context.Context, in *internalpb.GetStatisticsChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error) GetStatisticsChannel(ctx context.Context, in *internalpb.GetStatisticsChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error)
//* // *
// @brief This method is used to create collection // @brief This method is used to create collection
// //
// @param CreateCollectionRequest, use to provide collection information to be created. // @param CreateCollectionRequest, use to provide collection information to be created.
// //
// @return Status // @return Status
CreateCollection(ctx context.Context, in *milvuspb.CreateCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error) CreateCollection(ctx context.Context, in *milvuspb.CreateCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
//* // *
// @brief This method is used to delete collection. // @brief This method is used to delete collection.
// //
// @param DropCollectionRequest, collection name is going to be deleted. // @param DropCollectionRequest, collection name is going to be deleted.
// //
// @return Status // @return Status
DropCollection(ctx context.Context, in *milvuspb.DropCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error) DropCollection(ctx context.Context, in *milvuspb.DropCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
//* // *
// @brief This method is used to test collection existence. // @brief This method is used to test collection existence.
// //
// @param HasCollectionRequest, collection name is going to be tested. // @param HasCollectionRequest, collection name is going to be tested.
// //
// @return BoolResponse // @return BoolResponse
HasCollection(ctx context.Context, in *milvuspb.HasCollectionRequest, opts ...grpc.CallOption) (*milvuspb.BoolResponse, error) HasCollection(ctx context.Context, in *milvuspb.HasCollectionRequest, opts ...grpc.CallOption) (*milvuspb.BoolResponse, error)
//* // *
// @brief This method is used to get collection schema. // @brief This method is used to get collection schema.
// //
// @param DescribeCollectionRequest, target collection name. // @param DescribeCollectionRequest, target collection name.
@ -825,28 +825,28 @@ type RootCoordClient interface {
CreateAlias(ctx context.Context, in *milvuspb.CreateAliasRequest, opts ...grpc.CallOption) (*commonpb.Status, error) CreateAlias(ctx context.Context, in *milvuspb.CreateAliasRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
DropAlias(ctx context.Context, in *milvuspb.DropAliasRequest, opts ...grpc.CallOption) (*commonpb.Status, error) DropAlias(ctx context.Context, in *milvuspb.DropAliasRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
AlterAlias(ctx context.Context, in *milvuspb.AlterAliasRequest, opts ...grpc.CallOption) (*commonpb.Status, error) AlterAlias(ctx context.Context, in *milvuspb.AlterAliasRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
//* // *
// @brief This method is used to list all collections. // @brief This method is used to list all collections.
// //
// @return StringListResponse, collection name list // @return StringListResponse, collection name list
ShowCollections(ctx context.Context, in *milvuspb.ShowCollectionsRequest, opts ...grpc.CallOption) (*milvuspb.ShowCollectionsResponse, error) ShowCollections(ctx context.Context, in *milvuspb.ShowCollectionsRequest, opts ...grpc.CallOption) (*milvuspb.ShowCollectionsResponse, error)
AlterCollection(ctx context.Context, in *milvuspb.AlterCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error) AlterCollection(ctx context.Context, in *milvuspb.AlterCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
//* // *
// @brief This method is used to create partition // @brief This method is used to create partition
// //
// @return Status // @return Status
CreatePartition(ctx context.Context, in *milvuspb.CreatePartitionRequest, opts ...grpc.CallOption) (*commonpb.Status, error) CreatePartition(ctx context.Context, in *milvuspb.CreatePartitionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
//* // *
// @brief This method is used to drop partition // @brief This method is used to drop partition
// //
// @return Status // @return Status
DropPartition(ctx context.Context, in *milvuspb.DropPartitionRequest, opts ...grpc.CallOption) (*commonpb.Status, error) DropPartition(ctx context.Context, in *milvuspb.DropPartitionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
//* // *
// @brief This method is used to test partition existence. // @brief This method is used to test partition existence.
// //
// @return BoolResponse // @return BoolResponse
HasPartition(ctx context.Context, in *milvuspb.HasPartitionRequest, opts ...grpc.CallOption) (*milvuspb.BoolResponse, error) HasPartition(ctx context.Context, in *milvuspb.HasPartitionRequest, opts ...grpc.CallOption) (*milvuspb.BoolResponse, error)
//* // *
// @brief This method is used to show partition information // @brief This method is used to show partition information
// //
// @param ShowPartitionRequest, target collection name. // @param ShowPartitionRequest, target collection name.
@ -854,7 +854,7 @@ type RootCoordClient interface {
// @return StringListResponse // @return StringListResponse
ShowPartitions(ctx context.Context, in *milvuspb.ShowPartitionsRequest, opts ...grpc.CallOption) (*milvuspb.ShowPartitionsResponse, error) ShowPartitions(ctx context.Context, in *milvuspb.ShowPartitionsRequest, opts ...grpc.CallOption) (*milvuspb.ShowPartitionsResponse, error)
ShowPartitionsInternal(ctx context.Context, in *milvuspb.ShowPartitionsRequest, opts ...grpc.CallOption) (*milvuspb.ShowPartitionsResponse, error) ShowPartitionsInternal(ctx context.Context, in *milvuspb.ShowPartitionsRequest, opts ...grpc.CallOption) (*milvuspb.ShowPartitionsResponse, error)
// rpc DescribeSegment(milvus.DescribeSegmentRequest) returns (milvus.DescribeSegmentResponse) {} // rpc DescribeSegment(milvus.DescribeSegmentRequest) returns (milvus.DescribeSegmentResponse) {}
ShowSegments(ctx context.Context, in *milvuspb.ShowSegmentsRequest, opts ...grpc.CallOption) (*milvuspb.ShowSegmentsResponse, error) ShowSegments(ctx context.Context, in *milvuspb.ShowSegmentsRequest, opts ...grpc.CallOption) (*milvuspb.ShowSegmentsResponse, error)
AllocTimestamp(ctx context.Context, in *AllocTimestampRequest, opts ...grpc.CallOption) (*AllocTimestampResponse, error) AllocTimestamp(ctx context.Context, in *AllocTimestampRequest, opts ...grpc.CallOption) (*AllocTimestampResponse, error)
AllocID(ctx context.Context, in *AllocIDRequest, opts ...grpc.CallOption) (*AllocIDResponse, error) AllocID(ctx context.Context, in *AllocIDRequest, opts ...grpc.CallOption) (*AllocIDResponse, error)
@ -1327,28 +1327,28 @@ type RootCoordServer interface {
GetComponentStates(context.Context, *milvuspb.GetComponentStatesRequest) (*milvuspb.ComponentStates, error) GetComponentStates(context.Context, *milvuspb.GetComponentStatesRequest) (*milvuspb.ComponentStates, error)
GetTimeTickChannel(context.Context, *internalpb.GetTimeTickChannelRequest) (*milvuspb.StringResponse, error) GetTimeTickChannel(context.Context, *internalpb.GetTimeTickChannelRequest) (*milvuspb.StringResponse, error)
GetStatisticsChannel(context.Context, *internalpb.GetStatisticsChannelRequest) (*milvuspb.StringResponse, error) GetStatisticsChannel(context.Context, *internalpb.GetStatisticsChannelRequest) (*milvuspb.StringResponse, error)
//* // *
// @brief This method is used to create collection // @brief This method is used to create collection
// //
// @param CreateCollectionRequest, use to provide collection information to be created. // @param CreateCollectionRequest, use to provide collection information to be created.
// //
// @return Status // @return Status
CreateCollection(context.Context, *milvuspb.CreateCollectionRequest) (*commonpb.Status, error) CreateCollection(context.Context, *milvuspb.CreateCollectionRequest) (*commonpb.Status, error)
//* // *
// @brief This method is used to delete collection. // @brief This method is used to delete collection.
// //
// @param DropCollectionRequest, collection name is going to be deleted. // @param DropCollectionRequest, collection name is going to be deleted.
// //
// @return Status // @return Status
DropCollection(context.Context, *milvuspb.DropCollectionRequest) (*commonpb.Status, error) DropCollection(context.Context, *milvuspb.DropCollectionRequest) (*commonpb.Status, error)
//* // *
// @brief This method is used to test collection existence. // @brief This method is used to test collection existence.
// //
// @param HasCollectionRequest, collection name is going to be tested. // @param HasCollectionRequest, collection name is going to be tested.
// //
// @return BoolResponse // @return BoolResponse
HasCollection(context.Context, *milvuspb.HasCollectionRequest) (*milvuspb.BoolResponse, error) HasCollection(context.Context, *milvuspb.HasCollectionRequest) (*milvuspb.BoolResponse, error)
//* // *
// @brief This method is used to get collection schema. // @brief This method is used to get collection schema.
// //
// @param DescribeCollectionRequest, target collection name. // @param DescribeCollectionRequest, target collection name.
@ -1359,28 +1359,28 @@ type RootCoordServer interface {
CreateAlias(context.Context, *milvuspb.CreateAliasRequest) (*commonpb.Status, error) CreateAlias(context.Context, *milvuspb.CreateAliasRequest) (*commonpb.Status, error)
DropAlias(context.Context, *milvuspb.DropAliasRequest) (*commonpb.Status, error) DropAlias(context.Context, *milvuspb.DropAliasRequest) (*commonpb.Status, error)
AlterAlias(context.Context, *milvuspb.AlterAliasRequest) (*commonpb.Status, error) AlterAlias(context.Context, *milvuspb.AlterAliasRequest) (*commonpb.Status, error)
//* // *
// @brief This method is used to list all collections. // @brief This method is used to list all collections.
// //
// @return StringListResponse, collection name list // @return StringListResponse, collection name list
ShowCollections(context.Context, *milvuspb.ShowCollectionsRequest) (*milvuspb.ShowCollectionsResponse, error) ShowCollections(context.Context, *milvuspb.ShowCollectionsRequest) (*milvuspb.ShowCollectionsResponse, error)
AlterCollection(context.Context, *milvuspb.AlterCollectionRequest) (*commonpb.Status, error) AlterCollection(context.Context, *milvuspb.AlterCollectionRequest) (*commonpb.Status, error)
//* // *
// @brief This method is used to create partition // @brief This method is used to create partition
// //
// @return Status // @return Status
CreatePartition(context.Context, *milvuspb.CreatePartitionRequest) (*commonpb.Status, error) CreatePartition(context.Context, *milvuspb.CreatePartitionRequest) (*commonpb.Status, error)
//* // *
// @brief This method is used to drop partition // @brief This method is used to drop partition
// //
// @return Status // @return Status
DropPartition(context.Context, *milvuspb.DropPartitionRequest) (*commonpb.Status, error) DropPartition(context.Context, *milvuspb.DropPartitionRequest) (*commonpb.Status, error)
//* // *
// @brief This method is used to test partition existence. // @brief This method is used to test partition existence.
// //
// @return BoolResponse // @return BoolResponse
HasPartition(context.Context, *milvuspb.HasPartitionRequest) (*milvuspb.BoolResponse, error) HasPartition(context.Context, *milvuspb.HasPartitionRequest) (*milvuspb.BoolResponse, error)
//* // *
// @brief This method is used to show partition information // @brief This method is used to show partition information
// //
// @param ShowPartitionRequest, target collection name. // @param ShowPartitionRequest, target collection name.
@ -1388,7 +1388,7 @@ type RootCoordServer interface {
// @return StringListResponse // @return StringListResponse
ShowPartitions(context.Context, *milvuspb.ShowPartitionsRequest) (*milvuspb.ShowPartitionsResponse, error) ShowPartitions(context.Context, *milvuspb.ShowPartitionsRequest) (*milvuspb.ShowPartitionsResponse, error)
ShowPartitionsInternal(context.Context, *milvuspb.ShowPartitionsRequest) (*milvuspb.ShowPartitionsResponse, error) ShowPartitionsInternal(context.Context, *milvuspb.ShowPartitionsRequest) (*milvuspb.ShowPartitionsResponse, error)
// rpc DescribeSegment(milvus.DescribeSegmentRequest) returns (milvus.DescribeSegmentResponse) {} // rpc DescribeSegment(milvus.DescribeSegmentRequest) returns (milvus.DescribeSegmentResponse) {}
ShowSegments(context.Context, *milvuspb.ShowSegmentsRequest) (*milvuspb.ShowSegmentsResponse, error) ShowSegments(context.Context, *milvuspb.ShowSegmentsRequest) (*milvuspb.ShowSegmentsResponse, error)
AllocTimestamp(context.Context, *AllocTimestampRequest) (*AllocTimestampResponse, error) AllocTimestamp(context.Context, *AllocTimestampRequest) (*AllocTimestampResponse, error)
AllocID(context.Context, *AllocIDRequest) (*AllocIDResponse, error) AllocID(context.Context, *AllocIDRequest) (*AllocIDResponse, error)

View File

@ -89,8 +89,8 @@ ${LCOV_CMD} -r "${FILE_INFO_COMBINE}" -o "${FILE_INFO_OUTPUT}" \
"*/thirdparty/*" "*/thirdparty/*"
# generate html report # generate html report
${LCOV_GEN_CMD} ${FILE_INFO_OUTPUT} --output-directory ${DIR_LCOV_OUTPUT}/ #${LCOV_GEN_CMD} ${FILE_INFO_OUTPUT} --output-directory ${DIR_LCOV_OUTPUT}/
echo "Generate cpp code coverage report to ${DIR_LCOV_OUTPUT}" #echo "Generate cpp code coverage report to ${DIR_LCOV_OUTPUT}"
endTime=`date +%s` endTime=`date +%s`