mirror of https://github.com/milvus-io/milvus.git
Fix compatibility of Flush (#27543)
Signed-off-by: bigsheeper <yihao.dai@zilliz.com>pull/27706/head
yihao.dai
GitHub
parent
f0e358fc56
commit
c882e9c87b
|
|
@ -121,9 +121,21 @@ struct AddressDefaultTypeInternal {
|
|||
};
|
||||
};
|
||||
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 AddressDefaultTypeInternal _Address_default_instance_;
|
||||
PROTOBUF_CONSTEXPR MsgBase_PropertiesEntry_DoNotUse::MsgBase_PropertiesEntry_DoNotUse(
|
||||
::_pbi::ConstantInitialized) {}
|
||||
struct MsgBase_PropertiesEntry_DoNotUseDefaultTypeInternal {
|
||||
PROTOBUF_CONSTEXPR MsgBase_PropertiesEntry_DoNotUseDefaultTypeInternal()
|
||||
: _instance(::_pbi::ConstantInitialized{}) {}
|
||||
~MsgBase_PropertiesEntry_DoNotUseDefaultTypeInternal() {}
|
||||
union {
|
||||
MsgBase_PropertiesEntry_DoNotUse _instance;
|
||||
};
|
||||
};
|
||||
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 MsgBase_PropertiesEntry_DoNotUseDefaultTypeInternal _MsgBase_PropertiesEntry_DoNotUse_default_instance_;
|
||||
PROTOBUF_CONSTEXPR MsgBase::MsgBase(
|
||||
::_pbi::ConstantInitialized): _impl_{
|
||||
/*decltype(_impl_.msgid_)*/int64_t{0}
|
||||
/*decltype(_impl_.properties_)*/{::_pbi::ConstantInitialized()}
|
||||
, /*decltype(_impl_.msgid_)*/int64_t{0}
|
||||
, /*decltype(_impl_.timestamp_)*/uint64_t{0u}
|
||||
, /*decltype(_impl_.sourceid_)*/int64_t{0}
|
||||
, /*decltype(_impl_.targetid_)*/int64_t{0}
|
||||
|
|
@ -256,7 +268,7 @@ PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORIT
|
|||
} // namespace common
|
||||
} // namespace proto
|
||||
} // namespace milvus
|
||||
static ::_pb::Metadata file_level_metadata_common_2eproto[16];
|
||||
static ::_pb::Metadata file_level_metadata_common_2eproto[17];
|
||||
static const ::_pb::EnumDescriptor* file_level_enum_descriptors_common_2eproto[13];
|
||||
static constexpr ::_pb::ServiceDescriptor const** file_level_service_descriptors_common_2eproto = nullptr;
|
||||
|
||||
|
|
@ -317,6 +329,16 @@ const uint32_t TableStruct_common_2eproto::offsets[] PROTOBUF_SECTION_VARIABLE(p
|
|||
~0u, // no _inlined_string_donated_
|
||||
PROTOBUF_FIELD_OFFSET(::milvus::proto::common::Address, _impl_.ip_),
|
||||
PROTOBUF_FIELD_OFFSET(::milvus::proto::common::Address, _impl_.port_),
|
||||
PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase_PropertiesEntry_DoNotUse, _has_bits_),
|
||||
PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase_PropertiesEntry_DoNotUse, _internal_metadata_),
|
||||
~0u, // no _extensions_
|
||||
~0u, // no _oneof_case_
|
||||
~0u, // no _weak_field_map_
|
||||
~0u, // no _inlined_string_donated_
|
||||
PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase_PropertiesEntry_DoNotUse, key_),
|
||||
PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase_PropertiesEntry_DoNotUse, value_),
|
||||
0,
|
||||
1,
|
||||
~0u, // no _has_bits_
|
||||
PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase, _internal_metadata_),
|
||||
~0u, // no _extensions_
|
||||
|
|
@ -328,6 +350,7 @@ const uint32_t TableStruct_common_2eproto::offsets[] PROTOBUF_SECTION_VARIABLE(p
|
|||
PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase, _impl_.timestamp_),
|
||||
PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase, _impl_.sourceid_),
|
||||
PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase, _impl_.targetid_),
|
||||
PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase, _impl_.properties_),
|
||||
~0u, // no _has_bits_
|
||||
PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgHeader, _internal_metadata_),
|
||||
~0u, // no _extensions_
|
||||
|
|
@ -414,15 +437,16 @@ static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protode
|
|||
{ 32, -1, -1, sizeof(::milvus::proto::common::PlaceholderValue)},
|
||||
{ 41, -1, -1, sizeof(::milvus::proto::common::PlaceholderGroup)},
|
||||
{ 48, -1, -1, sizeof(::milvus::proto::common::Address)},
|
||||
{ 56, -1, -1, sizeof(::milvus::proto::common::MsgBase)},
|
||||
{ 67, -1, -1, sizeof(::milvus::proto::common::MsgHeader)},
|
||||
{ 74, -1, -1, sizeof(::milvus::proto::common::DMLMsgHeader)},
|
||||
{ 82, -1, -1, sizeof(::milvus::proto::common::PrivilegeExt)},
|
||||
{ 92, -1, -1, sizeof(::milvus::proto::common::SegmentStats)},
|
||||
{ 100, 108, -1, sizeof(::milvus::proto::common::ClientInfo_ReservedEntry_DoNotUse)},
|
||||
{ 110, -1, -1, sizeof(::milvus::proto::common::ClientInfo)},
|
||||
{ 122, 130, -1, sizeof(::milvus::proto::common::ServerInfo_ReservedEntry_DoNotUse)},
|
||||
{ 132, -1, -1, sizeof(::milvus::proto::common::ServerInfo)},
|
||||
{ 56, 64, -1, sizeof(::milvus::proto::common::MsgBase_PropertiesEntry_DoNotUse)},
|
||||
{ 66, -1, -1, sizeof(::milvus::proto::common::MsgBase)},
|
||||
{ 78, -1, -1, sizeof(::milvus::proto::common::MsgHeader)},
|
||||
{ 85, -1, -1, sizeof(::milvus::proto::common::DMLMsgHeader)},
|
||||
{ 93, -1, -1, sizeof(::milvus::proto::common::PrivilegeExt)},
|
||||
{ 103, -1, -1, sizeof(::milvus::proto::common::SegmentStats)},
|
||||
{ 111, 119, -1, sizeof(::milvus::proto::common::ClientInfo_ReservedEntry_DoNotUse)},
|
||||
{ 121, -1, -1, sizeof(::milvus::proto::common::ClientInfo)},
|
||||
{ 133, 141, -1, sizeof(::milvus::proto::common::ServerInfo_ReservedEntry_DoNotUse)},
|
||||
{ 143, -1, -1, sizeof(::milvus::proto::common::ServerInfo)},
|
||||
};
|
||||
|
||||
static const ::_pb::Message* const file_default_instances[] = {
|
||||
|
|
@ -433,6 +457,7 @@ static const ::_pb::Message* const file_default_instances[] = {
|
|||
&::milvus::proto::common::_PlaceholderValue_default_instance_._instance,
|
||||
&::milvus::proto::common::_PlaceholderGroup_default_instance_._instance,
|
||||
&::milvus::proto::common::_Address_default_instance_._instance,
|
||||
&::milvus::proto::common::_MsgBase_PropertiesEntry_DoNotUse_default_instance_._instance,
|
||||
&::milvus::proto::common::_MsgBase_default_instance_._instance,
|
||||
&::milvus::proto::common::_MsgHeader_default_instance_._instance,
|
||||
&::milvus::proto::common::_DMLMsgHeader_default_instance_._instance,
|
||||
|
|
@ -457,181 +482,184 @@ const char descriptor_table_protodef_common_2eproto[] PROTOBUF_SECTION_VARIABLE(
|
|||
"alues\030\003 \003(\014\"O\n\020PlaceholderGroup\022;\n\014place"
|
||||
"holders\030\001 \003(\0132%.milvus.proto.common.Plac"
|
||||
"eholderValue\"#\n\007Address\022\n\n\002ip\030\001 \001(\t\022\014\n\004p"
|
||||
"ort\030\002 \001(\003\"\177\n\007MsgBase\022.\n\010msg_type\030\001 \001(\0162\034"
|
||||
".milvus.proto.common.MsgType\022\r\n\005msgID\030\002 "
|
||||
"\001(\003\022\021\n\ttimestamp\030\003 \001(\004\022\020\n\010sourceID\030\004 \001(\003"
|
||||
"\022\020\n\010targetID\030\005 \001(\003\"7\n\tMsgHeader\022*\n\004base\030"
|
||||
"\001 \001(\0132\034.milvus.proto.common.MsgBase\"M\n\014D"
|
||||
"MLMsgHeader\022*\n\004base\030\001 \001(\0132\034.milvus.proto"
|
||||
".common.MsgBase\022\021\n\tshardName\030\002 \001(\t\"\273\001\n\014P"
|
||||
"rivilegeExt\0224\n\013object_type\030\001 \001(\0162\037.milvu"
|
||||
"s.proto.common.ObjectType\022>\n\020object_priv"
|
||||
"ilege\030\002 \001(\0162$.milvus.proto.common.Object"
|
||||
"Privilege\022\031\n\021object_name_index\030\003 \001(\005\022\032\n\022"
|
||||
"object_name_indexs\030\004 \001(\005\"2\n\014SegmentStats"
|
||||
"\022\021\n\tSegmentID\030\001 \001(\003\022\017\n\007NumRows\030\002 \001(\003\"\325\001\n"
|
||||
"\nClientInfo\022\020\n\010sdk_type\030\001 \001(\t\022\023\n\013sdk_ver"
|
||||
"sion\030\002 \001(\t\022\022\n\nlocal_time\030\003 \001(\t\022\014\n\004user\030\004"
|
||||
" \001(\t\022\014\n\004host\030\005 \001(\t\022\?\n\010reserved\030\006 \003(\0132-.m"
|
||||
"ilvus.proto.common.ClientInfo.ReservedEn"
|
||||
"try\032/\n\rReservedEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005val"
|
||||
"ue\030\002 \001(\t:\0028\001\"\343\001\n\nServerInfo\022\022\n\nbuild_tag"
|
||||
"s\030\001 \001(\t\022\022\n\nbuild_time\030\002 \001(\t\022\022\n\ngit_commi"
|
||||
"t\030\003 \001(\t\022\022\n\ngo_version\030\004 \001(\t\022\023\n\013deploy_mo"
|
||||
"de\030\005 \001(\t\022\?\n\010reserved\030\006 \003(\0132-.milvus.prot"
|
||||
"o.common.ServerInfo.ReservedEntry\032/\n\rRes"
|
||||
"ervedEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\002"
|
||||
"8\001*\303\n\n\tErrorCode\022\013\n\007Success\020\000\022\023\n\017Unexpec"
|
||||
"tedError\020\001\022\021\n\rConnectFailed\020\002\022\024\n\020Permiss"
|
||||
"ionDenied\020\003\022\027\n\023CollectionNotExists\020\004\022\023\n\017"
|
||||
"IllegalArgument\020\005\022\024\n\020IllegalDimension\020\007\022"
|
||||
"\024\n\020IllegalIndexType\020\010\022\031\n\025IllegalCollecti"
|
||||
"onName\020\t\022\017\n\013IllegalTOPK\020\n\022\024\n\020IllegalRowR"
|
||||
"ecord\020\013\022\023\n\017IllegalVectorID\020\014\022\027\n\023IllegalS"
|
||||
"earchResult\020\r\022\020\n\014FileNotFound\020\016\022\016\n\nMetaF"
|
||||
"ailed\020\017\022\017\n\013CacheFailed\020\020\022\026\n\022CannotCreate"
|
||||
"Folder\020\021\022\024\n\020CannotCreateFile\020\022\022\026\n\022Cannot"
|
||||
"DeleteFolder\020\023\022\024\n\020CannotDeleteFile\020\024\022\023\n\017"
|
||||
"BuildIndexError\020\025\022\020\n\014IllegalNLIST\020\026\022\025\n\021I"
|
||||
"llegalMetricType\020\027\022\017\n\013OutOfMemory\020\030\022\021\n\rI"
|
||||
"ndexNotExist\020\031\022\023\n\017EmptyCollection\020\032\022\033\n\027U"
|
||||
"pdateImportTaskFailure\020\033\022\032\n\026CollectionNa"
|
||||
"meNotFound\020\034\022\033\n\027CreateCredentialFailure\020"
|
||||
"\035\022\033\n\027UpdateCredentialFailure\020\036\022\033\n\027Delete"
|
||||
"CredentialFailure\020\037\022\030\n\024GetCredentialFail"
|
||||
"ure\020 \022\030\n\024ListCredUsersFailure\020!\022\022\n\016GetUs"
|
||||
"erFailure\020\"\022\025\n\021CreateRoleFailure\020#\022\023\n\017Dr"
|
||||
"opRoleFailure\020$\022\032\n\026OperateUserRoleFailur"
|
||||
"e\020%\022\025\n\021SelectRoleFailure\020&\022\025\n\021SelectUser"
|
||||
"Failure\020\'\022\031\n\025SelectResourceFailure\020(\022\033\n\027"
|
||||
"OperatePrivilegeFailure\020)\022\026\n\022SelectGrant"
|
||||
"Failure\020*\022!\n\035RefreshPolicyInfoCacheFailu"
|
||||
"re\020+\022\025\n\021ListPolicyFailure\020,\022\022\n\016NotShardL"
|
||||
"eader\020-\022\026\n\022NoReplicaAvailable\020.\022\023\n\017Segme"
|
||||
"ntNotFound\020/\022\r\n\tForceDeny\0200\022\r\n\tRateLimit"
|
||||
"\0201\022\022\n\016NodeIDNotMatch\0202\022\024\n\020UpsertAutoIDTr"
|
||||
"ue\0203\022\034\n\030InsufficientMemoryToLoad\0204\022\030\n\024Me"
|
||||
"moryQuotaExhausted\0205\022\026\n\022DiskQuotaExhaust"
|
||||
"ed\0206\022\025\n\021TimeTickLongDelay\0207\022\021\n\rNotReadyS"
|
||||
"erve\0208\022\033\n\027NotReadyCoordActivating\0209\022\017\n\013D"
|
||||
"ataCoordNA\020d\022\022\n\rDDRequestRace\020\350\007*c\n\nInde"
|
||||
"xState\022\022\n\016IndexStateNone\020\000\022\014\n\010Unissued\020\001"
|
||||
"\022\016\n\nInProgress\020\002\022\014\n\010Finished\020\003\022\n\n\006Failed"
|
||||
"\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"
|
||||
"\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*i\n\017Placeholde"
|
||||
"rType\022\010\n\004None\020\000\022\020\n\014BinaryVector\020d\022\017\n\013Flo"
|
||||
"atVector\020e\022\021\n\rFloat16Vector\020f\022\t\n\005Int64\020\005"
|
||||
"\022\013\n\007VarChar\020\025*\264\020\n\007MsgType\022\r\n\tUndefined\020\000"
|
||||
"\022\024\n\020CreateCollection\020d\022\022\n\016DropCollection"
|
||||
"\020e\022\021\n\rHasCollection\020f\022\026\n\022DescribeCollect"
|
||||
"ion\020g\022\023\n\017ShowCollections\020h\022\024\n\020GetSystemC"
|
||||
"onfigs\020i\022\022\n\016LoadCollection\020j\022\025\n\021ReleaseC"
|
||||
"ollection\020k\022\017\n\013CreateAlias\020l\022\r\n\tDropAlia"
|
||||
"s\020m\022\016\n\nAlterAlias\020n\022\023\n\017AlterCollection\020o"
|
||||
"\022\024\n\020RenameCollection\020p\022\021\n\rDescribeAlias\020"
|
||||
"q\022\017\n\013ListAliases\020r\022\024\n\017CreatePartition\020\310\001"
|
||||
"\022\022\n\rDropPartition\020\311\001\022\021\n\014HasPartition\020\312\001\022"
|
||||
"\026\n\021DescribePartition\020\313\001\022\023\n\016ShowPartition"
|
||||
"s\020\314\001\022\023\n\016LoadPartitions\020\315\001\022\026\n\021ReleasePart"
|
||||
"itions\020\316\001\022\021\n\014ShowSegments\020\372\001\022\024\n\017Describe"
|
||||
"Segment\020\373\001\022\021\n\014LoadSegments\020\374\001\022\024\n\017Release"
|
||||
"Segments\020\375\001\022\024\n\017HandoffSegments\020\376\001\022\030\n\023Loa"
|
||||
"dBalanceSegments\020\377\001\022\025\n\020DescribeSegments\020"
|
||||
"\200\002\022\034\n\027FederListIndexedSegment\020\201\002\022\"\n\035Fede"
|
||||
"rDescribeSegmentIndexData\020\202\002\022\020\n\013CreateIn"
|
||||
"dex\020\254\002\022\022\n\rDescribeIndex\020\255\002\022\016\n\tDropIndex\020"
|
||||
"\256\002\022\027\n\022GetIndexStatistics\020\257\002\022\013\n\006Insert\020\220\003"
|
||||
"\022\013\n\006Delete\020\221\003\022\n\n\005Flush\020\222\003\022\027\n\022ResendSegme"
|
||||
"ntStats\020\223\003\022\013\n\006Upsert\020\224\003\022\013\n\006Search\020\364\003\022\021\n\014"
|
||||
"SearchResult\020\365\003\022\022\n\rGetIndexState\020\366\003\022\032\n\025G"
|
||||
"etIndexBuildProgress\020\367\003\022\034\n\027GetCollection"
|
||||
"Statistics\020\370\003\022\033\n\026GetPartitionStatistics\020"
|
||||
"\371\003\022\r\n\010Retrieve\020\372\003\022\023\n\016RetrieveResult\020\373\003\022\024"
|
||||
"\n\017WatchDmChannels\020\374\003\022\025\n\020RemoveDmChannels"
|
||||
"\020\375\003\022\027\n\022WatchQueryChannels\020\376\003\022\030\n\023RemoveQu"
|
||||
"eryChannels\020\377\003\022\035\n\030SealedSegmentsChangeIn"
|
||||
"fo\020\200\004\022\027\n\022WatchDeltaChannels\020\201\004\022\024\n\017GetSha"
|
||||
"rdLeaders\020\202\004\022\020\n\013GetReplicas\020\203\004\022\023\n\016UnsubD"
|
||||
"mChannel\020\204\004\022\024\n\017GetDistribution\020\205\004\022\025\n\020Syn"
|
||||
"cDistribution\020\206\004\022\020\n\013SegmentInfo\020\330\004\022\017\n\nSy"
|
||||
"stemInfo\020\331\004\022\024\n\017GetRecoveryInfo\020\332\004\022\024\n\017Get"
|
||||
"SegmentState\020\333\004\022\r\n\010TimeTick\020\260\t\022\023\n\016QueryN"
|
||||
"odeStats\020\261\t\022\016\n\tLoadIndex\020\262\t\022\016\n\tRequestID"
|
||||
"\020\263\t\022\017\n\nRequestTSO\020\264\t\022\024\n\017AllocateSegment\020"
|
||||
"\265\t\022\026\n\021SegmentStatistics\020\266\t\022\025\n\020SegmentFlu"
|
||||
"shDone\020\267\t\022\017\n\nDataNodeTt\020\270\t\022\014\n\007Connect\020\271\t"
|
||||
"\022\024\n\017ListClientInfos\020\272\t\022\023\n\016AllocTimestamp"
|
||||
"\020\273\t\022\025\n\020CreateCredential\020\334\013\022\022\n\rGetCredent"
|
||||
"ial\020\335\013\022\025\n\020DeleteCredential\020\336\013\022\025\n\020UpdateC"
|
||||
"redential\020\337\013\022\026\n\021ListCredUsernames\020\340\013\022\017\n\n"
|
||||
"CreateRole\020\300\014\022\r\n\010DropRole\020\301\014\022\024\n\017OperateU"
|
||||
"serRole\020\302\014\022\017\n\nSelectRole\020\303\014\022\017\n\nSelectUse"
|
||||
"r\020\304\014\022\023\n\016SelectResource\020\305\014\022\025\n\020OperatePriv"
|
||||
"ilege\020\306\014\022\020\n\013SelectGrant\020\307\014\022\033\n\026RefreshPol"
|
||||
"icyInfoCache\020\310\014\022\017\n\nListPolicy\020\311\014\022\030\n\023Crea"
|
||||
"teResourceGroup\020\244\r\022\026\n\021DropResourceGroup\020"
|
||||
"\245\r\022\027\n\022ListResourceGroups\020\246\r\022\032\n\025DescribeR"
|
||||
"esourceGroup\020\247\r\022\021\n\014TransferNode\020\250\r\022\024\n\017Tr"
|
||||
"ansferReplica\020\251\r\022\023\n\016CreateDatabase\020\211\016\022\021\n"
|
||||
"\014DropDatabase\020\212\016\022\022\n\rListDatabases\020\213\016*\"\n\007"
|
||||
"DslType\022\007\n\003Dsl\020\000\022\016\n\nBoolExprV1\020\001*B\n\017Comp"
|
||||
"actionState\022\021\n\rUndefiedState\020\000\022\r\n\tExecut"
|
||||
"ing\020\001\022\r\n\tCompleted\020\002*X\n\020ConsistencyLevel"
|
||||
"\022\n\n\006Strong\020\000\022\013\n\007Session\020\001\022\013\n\007Bounded\020\002\022\016"
|
||||
"\n\nEventually\020\003\022\016\n\nCustomized\020\004*\236\001\n\013Impor"
|
||||
"tState\022\021\n\rImportPending\020\000\022\020\n\014ImportFaile"
|
||||
"d\020\001\022\021\n\rImportStarted\020\002\022\023\n\017ImportPersiste"
|
||||
"d\020\005\022\021\n\rImportFlushed\020\010\022\023\n\017ImportComplete"
|
||||
"d\020\006\022\032\n\026ImportFailedAndCleaned\020\007*2\n\nObjec"
|
||||
"tType\022\016\n\nCollection\020\000\022\n\n\006Global\020\001\022\010\n\004Use"
|
||||
"r\020\002*\241\010\n\017ObjectPrivilege\022\020\n\014PrivilegeAll\020"
|
||||
"\000\022\035\n\031PrivilegeCreateCollection\020\001\022\033\n\027Priv"
|
||||
"ilegeDropCollection\020\002\022\037\n\033PrivilegeDescri"
|
||||
"beCollection\020\003\022\034\n\030PrivilegeShowCollectio"
|
||||
"ns\020\004\022\021\n\rPrivilegeLoad\020\005\022\024\n\020PrivilegeRele"
|
||||
"ase\020\006\022\027\n\023PrivilegeCompaction\020\007\022\023\n\017Privil"
|
||||
"egeInsert\020\010\022\023\n\017PrivilegeDelete\020\t\022\032\n\026Priv"
|
||||
"ilegeGetStatistics\020\n\022\030\n\024PrivilegeCreateI"
|
||||
"ndex\020\013\022\030\n\024PrivilegeIndexDetail\020\014\022\026\n\022Priv"
|
||||
"ilegeDropIndex\020\r\022\023\n\017PrivilegeSearch\020\016\022\022\n"
|
||||
"\016PrivilegeFlush\020\017\022\022\n\016PrivilegeQuery\020\020\022\030\n"
|
||||
"\024PrivilegeLoadBalance\020\021\022\023\n\017PrivilegeImpo"
|
||||
"rt\020\022\022\034\n\030PrivilegeCreateOwnership\020\023\022\027\n\023Pr"
|
||||
"ivilegeUpdateUser\020\024\022\032\n\026PrivilegeDropOwne"
|
||||
"rship\020\025\022\034\n\030PrivilegeSelectOwnership\020\026\022\034\n"
|
||||
"\030PrivilegeManageOwnership\020\027\022\027\n\023Privilege"
|
||||
"SelectUser\020\030\022\023\n\017PrivilegeUpsert\020\031\022 \n\034Pri"
|
||||
"vilegeCreateResourceGroup\020\032\022\036\n\032Privilege"
|
||||
"DropResourceGroup\020\033\022\"\n\036PrivilegeDescribe"
|
||||
"ResourceGroup\020\034\022\037\n\033PrivilegeListResource"
|
||||
"Groups\020\035\022\031\n\025PrivilegeTransferNode\020\036\022\034\n\030P"
|
||||
"rivilegeTransferReplica\020\037\022\037\n\033PrivilegeGe"
|
||||
"tLoadingProgress\020 \022\031\n\025PrivilegeGetLoadSt"
|
||||
"ate\020!\022\035\n\031PrivilegeRenameCollection\020\"\022\033\n\027"
|
||||
"PrivilegeCreateDatabase\020#\022\031\n\025PrivilegeDr"
|
||||
"opDatabase\020$\022\032\n\026PrivilegeListDatabases\020%"
|
||||
"\022\025\n\021PrivilegeFlushAll\020&*S\n\tStateCode\022\020\n\014"
|
||||
"Initializing\020\000\022\013\n\007Healthy\020\001\022\014\n\010Abnormal\020"
|
||||
"\002\022\013\n\007StandBy\020\003\022\014\n\010Stopping\020\004*c\n\tLoadStat"
|
||||
"e\022\025\n\021LoadStateNotExist\020\000\022\024\n\020LoadStateNot"
|
||||
"Load\020\001\022\024\n\020LoadStateLoading\020\002\022\023\n\017LoadStat"
|
||||
"eLoaded\020\003:^\n\021privilege_ext_obj\022\037.google."
|
||||
"protobuf.MessageOptions\030\351\007 \001(\0132!.milvus."
|
||||
"proto.common.PrivilegeExtBm\n\016io.milvus.g"
|
||||
"rpcB\013CommonProtoP\001Z4github.com/milvus-io"
|
||||
"/milvus-proto/go-api/v2/commonpb\240\001\001\252\002\022Mi"
|
||||
"lvus.Client.Grpcb\006proto3"
|
||||
"ort\030\002 \001(\003\"\364\001\n\007MsgBase\022.\n\010msg_type\030\001 \001(\0162"
|
||||
"\034.milvus.proto.common.MsgType\022\r\n\005msgID\030\002"
|
||||
" \001(\003\022\021\n\ttimestamp\030\003 \001(\004\022\020\n\010sourceID\030\004 \001("
|
||||
"\003\022\020\n\010targetID\030\005 \001(\003\022@\n\nproperties\030\006 \003(\0132"
|
||||
",.milvus.proto.common.MsgBase.Properties"
|
||||
"Entry\0321\n\017PropertiesEntry\022\013\n\003key\030\001 \001(\t\022\r\n"
|
||||
"\005value\030\002 \001(\t:\0028\001\"7\n\tMsgHeader\022*\n\004base\030\001 "
|
||||
"\001(\0132\034.milvus.proto.common.MsgBase\"M\n\014DML"
|
||||
"MsgHeader\022*\n\004base\030\001 \001(\0132\034.milvus.proto.c"
|
||||
"ommon.MsgBase\022\021\n\tshardName\030\002 \001(\t\"\273\001\n\014Pri"
|
||||
"vilegeExt\0224\n\013object_type\030\001 \001(\0162\037.milvus."
|
||||
"proto.common.ObjectType\022>\n\020object_privil"
|
||||
"ege\030\002 \001(\0162$.milvus.proto.common.ObjectPr"
|
||||
"ivilege\022\031\n\021object_name_index\030\003 \001(\005\022\032\n\022ob"
|
||||
"ject_name_indexs\030\004 \001(\005\"2\n\014SegmentStats\022\021"
|
||||
"\n\tSegmentID\030\001 \001(\003\022\017\n\007NumRows\030\002 \001(\003\"\325\001\n\nC"
|
||||
"lientInfo\022\020\n\010sdk_type\030\001 \001(\t\022\023\n\013sdk_versi"
|
||||
"on\030\002 \001(\t\022\022\n\nlocal_time\030\003 \001(\t\022\014\n\004user\030\004 \001"
|
||||
"(\t\022\014\n\004host\030\005 \001(\t\022\?\n\010reserved\030\006 \003(\0132-.mil"
|
||||
"vus.proto.common.ClientInfo.ReservedEntr"
|
||||
"y\032/\n\rReservedEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value"
|
||||
"\030\002 \001(\t:\0028\001\"\343\001\n\nServerInfo\022\022\n\nbuild_tags\030"
|
||||
"\001 \001(\t\022\022\n\nbuild_time\030\002 \001(\t\022\022\n\ngit_commit\030"
|
||||
"\003 \001(\t\022\022\n\ngo_version\030\004 \001(\t\022\023\n\013deploy_mode"
|
||||
"\030\005 \001(\t\022\?\n\010reserved\030\006 \003(\0132-.milvus.proto."
|
||||
"common.ServerInfo.ReservedEntry\032/\n\rReser"
|
||||
"vedEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001"
|
||||
"*\303\n\n\tErrorCode\022\013\n\007Success\020\000\022\023\n\017Unexpecte"
|
||||
"dError\020\001\022\021\n\rConnectFailed\020\002\022\024\n\020Permissio"
|
||||
"nDenied\020\003\022\027\n\023CollectionNotExists\020\004\022\023\n\017Il"
|
||||
"legalArgument\020\005\022\024\n\020IllegalDimension\020\007\022\024\n"
|
||||
"\020IllegalIndexType\020\010\022\031\n\025IllegalCollection"
|
||||
"Name\020\t\022\017\n\013IllegalTOPK\020\n\022\024\n\020IllegalRowRec"
|
||||
"ord\020\013\022\023\n\017IllegalVectorID\020\014\022\027\n\023IllegalSea"
|
||||
"rchResult\020\r\022\020\n\014FileNotFound\020\016\022\016\n\nMetaFai"
|
||||
"led\020\017\022\017\n\013CacheFailed\020\020\022\026\n\022CannotCreateFo"
|
||||
"lder\020\021\022\024\n\020CannotCreateFile\020\022\022\026\n\022CannotDe"
|
||||
"leteFolder\020\023\022\024\n\020CannotDeleteFile\020\024\022\023\n\017Bu"
|
||||
"ildIndexError\020\025\022\020\n\014IllegalNLIST\020\026\022\025\n\021Ill"
|
||||
"egalMetricType\020\027\022\017\n\013OutOfMemory\020\030\022\021\n\rInd"
|
||||
"exNotExist\020\031\022\023\n\017EmptyCollection\020\032\022\033\n\027Upd"
|
||||
"ateImportTaskFailure\020\033\022\032\n\026CollectionName"
|
||||
"NotFound\020\034\022\033\n\027CreateCredentialFailure\020\035\022"
|
||||
"\033\n\027UpdateCredentialFailure\020\036\022\033\n\027DeleteCr"
|
||||
"edentialFailure\020\037\022\030\n\024GetCredentialFailur"
|
||||
"e\020 \022\030\n\024ListCredUsersFailure\020!\022\022\n\016GetUser"
|
||||
"Failure\020\"\022\025\n\021CreateRoleFailure\020#\022\023\n\017Drop"
|
||||
"RoleFailure\020$\022\032\n\026OperateUserRoleFailure\020"
|
||||
"%\022\025\n\021SelectRoleFailure\020&\022\025\n\021SelectUserFa"
|
||||
"ilure\020\'\022\031\n\025SelectResourceFailure\020(\022\033\n\027Op"
|
||||
"eratePrivilegeFailure\020)\022\026\n\022SelectGrantFa"
|
||||
"ilure\020*\022!\n\035RefreshPolicyInfoCacheFailure"
|
||||
"\020+\022\025\n\021ListPolicyFailure\020,\022\022\n\016NotShardLea"
|
||||
"der\020-\022\026\n\022NoReplicaAvailable\020.\022\023\n\017Segment"
|
||||
"NotFound\020/\022\r\n\tForceDeny\0200\022\r\n\tRateLimit\0201"
|
||||
"\022\022\n\016NodeIDNotMatch\0202\022\024\n\020UpsertAutoIDTrue"
|
||||
"\0203\022\034\n\030InsufficientMemoryToLoad\0204\022\030\n\024Memo"
|
||||
"ryQuotaExhausted\0205\022\026\n\022DiskQuotaExhausted"
|
||||
"\0206\022\025\n\021TimeTickLongDelay\0207\022\021\n\rNotReadySer"
|
||||
"ve\0208\022\033\n\027NotReadyCoordActivating\0209\022\017\n\013Dat"
|
||||
"aCoordNA\020d\022\022\n\rDDRequestRace\020\350\007*c\n\nIndexS"
|
||||
"tate\022\022\n\016IndexStateNone\020\000\022\014\n\010Unissued\020\001\022\016"
|
||||
"\n\nInProgress\020\002\022\014\n\010Finished\020\003\022\n\n\006Failed\020\004"
|
||||
"\022\t\n\005Retry\020\005*\202\001\n\014SegmentState\022\024\n\020SegmentS"
|
||||
"tateNone\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\007"
|
||||
"Dropped\020\006\022\r\n\tImporting\020\007*i\n\017PlaceholderT"
|
||||
"ype\022\010\n\004None\020\000\022\020\n\014BinaryVector\020d\022\017\n\013Float"
|
||||
"Vector\020e\022\021\n\rFloat16Vector\020f\022\t\n\005Int64\020\005\022\013"
|
||||
"\n\007VarChar\020\025*\264\020\n\007MsgType\022\r\n\tUndefined\020\000\022\024"
|
||||
"\n\020CreateCollection\020d\022\022\n\016DropCollection\020e"
|
||||
"\022\021\n\rHasCollection\020f\022\026\n\022DescribeCollectio"
|
||||
"n\020g\022\023\n\017ShowCollections\020h\022\024\n\020GetSystemCon"
|
||||
"figs\020i\022\022\n\016LoadCollection\020j\022\025\n\021ReleaseCol"
|
||||
"lection\020k\022\017\n\013CreateAlias\020l\022\r\n\tDropAlias\020"
|
||||
"m\022\016\n\nAlterAlias\020n\022\023\n\017AlterCollection\020o\022\024"
|
||||
"\n\020RenameCollection\020p\022\021\n\rDescribeAlias\020q\022"
|
||||
"\017\n\013ListAliases\020r\022\024\n\017CreatePartition\020\310\001\022\022"
|
||||
"\n\rDropPartition\020\311\001\022\021\n\014HasPartition\020\312\001\022\026\n"
|
||||
"\021DescribePartition\020\313\001\022\023\n\016ShowPartitions\020"
|
||||
"\314\001\022\023\n\016LoadPartitions\020\315\001\022\026\n\021ReleasePartit"
|
||||
"ions\020\316\001\022\021\n\014ShowSegments\020\372\001\022\024\n\017DescribeSe"
|
||||
"gment\020\373\001\022\021\n\014LoadSegments\020\374\001\022\024\n\017ReleaseSe"
|
||||
"gments\020\375\001\022\024\n\017HandoffSegments\020\376\001\022\030\n\023LoadB"
|
||||
"alanceSegments\020\377\001\022\025\n\020DescribeSegments\020\200\002"
|
||||
"\022\034\n\027FederListIndexedSegment\020\201\002\022\"\n\035FederD"
|
||||
"escribeSegmentIndexData\020\202\002\022\020\n\013CreateInde"
|
||||
"x\020\254\002\022\022\n\rDescribeIndex\020\255\002\022\016\n\tDropIndex\020\256\002"
|
||||
"\022\027\n\022GetIndexStatistics\020\257\002\022\013\n\006Insert\020\220\003\022\013"
|
||||
"\n\006Delete\020\221\003\022\n\n\005Flush\020\222\003\022\027\n\022ResendSegment"
|
||||
"Stats\020\223\003\022\013\n\006Upsert\020\224\003\022\013\n\006Search\020\364\003\022\021\n\014Se"
|
||||
"archResult\020\365\003\022\022\n\rGetIndexState\020\366\003\022\032\n\025Get"
|
||||
"IndexBuildProgress\020\367\003\022\034\n\027GetCollectionSt"
|
||||
"atistics\020\370\003\022\033\n\026GetPartitionStatistics\020\371\003"
|
||||
"\022\r\n\010Retrieve\020\372\003\022\023\n\016RetrieveResult\020\373\003\022\024\n\017"
|
||||
"WatchDmChannels\020\374\003\022\025\n\020RemoveDmChannels\020\375"
|
||||
"\003\022\027\n\022WatchQueryChannels\020\376\003\022\030\n\023RemoveQuer"
|
||||
"yChannels\020\377\003\022\035\n\030SealedSegmentsChangeInfo"
|
||||
"\020\200\004\022\027\n\022WatchDeltaChannels\020\201\004\022\024\n\017GetShard"
|
||||
"Leaders\020\202\004\022\020\n\013GetReplicas\020\203\004\022\023\n\016UnsubDmC"
|
||||
"hannel\020\204\004\022\024\n\017GetDistribution\020\205\004\022\025\n\020SyncD"
|
||||
"istribution\020\206\004\022\020\n\013SegmentInfo\020\330\004\022\017\n\nSyst"
|
||||
"emInfo\020\331\004\022\024\n\017GetRecoveryInfo\020\332\004\022\024\n\017GetSe"
|
||||
"gmentState\020\333\004\022\r\n\010TimeTick\020\260\t\022\023\n\016QueryNod"
|
||||
"eStats\020\261\t\022\016\n\tLoadIndex\020\262\t\022\016\n\tRequestID\020\263"
|
||||
"\t\022\017\n\nRequestTSO\020\264\t\022\024\n\017AllocateSegment\020\265\t"
|
||||
"\022\026\n\021SegmentStatistics\020\266\t\022\025\n\020SegmentFlush"
|
||||
"Done\020\267\t\022\017\n\nDataNodeTt\020\270\t\022\014\n\007Connect\020\271\t\022\024"
|
||||
"\n\017ListClientInfos\020\272\t\022\023\n\016AllocTimestamp\020\273"
|
||||
"\t\022\025\n\020CreateCredential\020\334\013\022\022\n\rGetCredentia"
|
||||
"l\020\335\013\022\025\n\020DeleteCredential\020\336\013\022\025\n\020UpdateCre"
|
||||
"dential\020\337\013\022\026\n\021ListCredUsernames\020\340\013\022\017\n\nCr"
|
||||
"eateRole\020\300\014\022\r\n\010DropRole\020\301\014\022\024\n\017OperateUse"
|
||||
"rRole\020\302\014\022\017\n\nSelectRole\020\303\014\022\017\n\nSelectUser\020"
|
||||
"\304\014\022\023\n\016SelectResource\020\305\014\022\025\n\020OperatePrivil"
|
||||
"ege\020\306\014\022\020\n\013SelectGrant\020\307\014\022\033\n\026RefreshPolic"
|
||||
"yInfoCache\020\310\014\022\017\n\nListPolicy\020\311\014\022\030\n\023Create"
|
||||
"ResourceGroup\020\244\r\022\026\n\021DropResourceGroup\020\245\r"
|
||||
"\022\027\n\022ListResourceGroups\020\246\r\022\032\n\025DescribeRes"
|
||||
"ourceGroup\020\247\r\022\021\n\014TransferNode\020\250\r\022\024\n\017Tran"
|
||||
"sferReplica\020\251\r\022\023\n\016CreateDatabase\020\211\016\022\021\n\014D"
|
||||
"ropDatabase\020\212\016\022\022\n\rListDatabases\020\213\016*\"\n\007Ds"
|
||||
"lType\022\007\n\003Dsl\020\000\022\016\n\nBoolExprV1\020\001*B\n\017Compac"
|
||||
"tionState\022\021\n\rUndefiedState\020\000\022\r\n\tExecutin"
|
||||
"g\020\001\022\r\n\tCompleted\020\002*X\n\020ConsistencyLevel\022\n"
|
||||
"\n\006Strong\020\000\022\013\n\007Session\020\001\022\013\n\007Bounded\020\002\022\016\n\n"
|
||||
"Eventually\020\003\022\016\n\nCustomized\020\004*\236\001\n\013ImportS"
|
||||
"tate\022\021\n\rImportPending\020\000\022\020\n\014ImportFailed\020"
|
||||
"\001\022\021\n\rImportStarted\020\002\022\023\n\017ImportPersisted\020"
|
||||
"\005\022\021\n\rImportFlushed\020\010\022\023\n\017ImportCompleted\020"
|
||||
"\006\022\032\n\026ImportFailedAndCleaned\020\007*2\n\nObjectT"
|
||||
"ype\022\016\n\nCollection\020\000\022\n\n\006Global\020\001\022\010\n\004User\020"
|
||||
"\002*\241\010\n\017ObjectPrivilege\022\020\n\014PrivilegeAll\020\000\022"
|
||||
"\035\n\031PrivilegeCreateCollection\020\001\022\033\n\027Privil"
|
||||
"egeDropCollection\020\002\022\037\n\033PrivilegeDescribe"
|
||||
"Collection\020\003\022\034\n\030PrivilegeShowCollections"
|
||||
"\020\004\022\021\n\rPrivilegeLoad\020\005\022\024\n\020PrivilegeReleas"
|
||||
"e\020\006\022\027\n\023PrivilegeCompaction\020\007\022\023\n\017Privileg"
|
||||
"eInsert\020\010\022\023\n\017PrivilegeDelete\020\t\022\032\n\026Privil"
|
||||
"egeGetStatistics\020\n\022\030\n\024PrivilegeCreateInd"
|
||||
"ex\020\013\022\030\n\024PrivilegeIndexDetail\020\014\022\026\n\022Privil"
|
||||
"egeDropIndex\020\r\022\023\n\017PrivilegeSearch\020\016\022\022\n\016P"
|
||||
"rivilegeFlush\020\017\022\022\n\016PrivilegeQuery\020\020\022\030\n\024P"
|
||||
"rivilegeLoadBalance\020\021\022\023\n\017PrivilegeImport"
|
||||
"\020\022\022\034\n\030PrivilegeCreateOwnership\020\023\022\027\n\023Priv"
|
||||
"ilegeUpdateUser\020\024\022\032\n\026PrivilegeDropOwners"
|
||||
"hip\020\025\022\034\n\030PrivilegeSelectOwnership\020\026\022\034\n\030P"
|
||||
"rivilegeManageOwnership\020\027\022\027\n\023PrivilegeSe"
|
||||
"lectUser\020\030\022\023\n\017PrivilegeUpsert\020\031\022 \n\034Privi"
|
||||
"legeCreateResourceGroup\020\032\022\036\n\032PrivilegeDr"
|
||||
"opResourceGroup\020\033\022\"\n\036PrivilegeDescribeRe"
|
||||
"sourceGroup\020\034\022\037\n\033PrivilegeListResourceGr"
|
||||
"oups\020\035\022\031\n\025PrivilegeTransferNode\020\036\022\034\n\030Pri"
|
||||
"vilegeTransferReplica\020\037\022\037\n\033PrivilegeGetL"
|
||||
"oadingProgress\020 \022\031\n\025PrivilegeGetLoadStat"
|
||||
"e\020!\022\035\n\031PrivilegeRenameCollection\020\"\022\033\n\027Pr"
|
||||
"ivilegeCreateDatabase\020#\022\031\n\025PrivilegeDrop"
|
||||
"Database\020$\022\032\n\026PrivilegeListDatabases\020%\022\025"
|
||||
"\n\021PrivilegeFlushAll\020&*S\n\tStateCode\022\020\n\014In"
|
||||
"itializing\020\000\022\013\n\007Healthy\020\001\022\014\n\010Abnormal\020\002\022"
|
||||
"\013\n\007StandBy\020\003\022\014\n\010Stopping\020\004*c\n\tLoadState\022"
|
||||
"\025\n\021LoadStateNotExist\020\000\022\024\n\020LoadStateNotLo"
|
||||
"ad\020\001\022\024\n\020LoadStateLoading\020\002\022\023\n\017LoadStateL"
|
||||
"oaded\020\003:^\n\021privilege_ext_obj\022\037.google.pr"
|
||||
"otobuf.MessageOptions\030\351\007 \001(\0132!.milvus.pr"
|
||||
"oto.common.PrivilegeExtBm\n\016io.milvus.grp"
|
||||
"cB\013CommonProtoP\001Z4github.com/milvus-io/m"
|
||||
"ilvus-proto/go-api/v2/commonpb\240\001\001\252\002\022Milv"
|
||||
"us.Client.Grpcb\006proto3"
|
||||
;
|
||||
static const ::_pbi::DescriptorTable* const descriptor_table_common_2eproto_deps[1] = {
|
||||
&::descriptor_table_google_2fprotobuf_2fdescriptor_2eproto,
|
||||
};
|
||||
static ::_pbi::once_flag descriptor_table_common_2eproto_once;
|
||||
const ::_pbi::DescriptorTable descriptor_table_common_2eproto = {
|
||||
false, false, 7104, descriptor_table_protodef_common_2eproto,
|
||||
false, false, 7222, descriptor_table_protodef_common_2eproto,
|
||||
"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, 17,
|
||||
schemas, file_default_instances, TableStruct_common_2eproto::offsets,
|
||||
file_level_metadata_common_2eproto, file_level_enum_descriptors_common_2eproto,
|
||||
file_level_service_descriptors_common_2eproto,
|
||||
|
|
@ -2698,6 +2726,20 @@ void Address::InternalSwap(Address* other) {
|
|||
|
||||
// ===================================================================
|
||||
|
||||
MsgBase_PropertiesEntry_DoNotUse::MsgBase_PropertiesEntry_DoNotUse() {}
|
||||
MsgBase_PropertiesEntry_DoNotUse::MsgBase_PropertiesEntry_DoNotUse(::PROTOBUF_NAMESPACE_ID::Arena* arena)
|
||||
: SuperType(arena) {}
|
||||
void MsgBase_PropertiesEntry_DoNotUse::MergeFrom(const MsgBase_PropertiesEntry_DoNotUse& other) {
|
||||
MergeFromInternal(other);
|
||||
}
|
||||
::PROTOBUF_NAMESPACE_ID::Metadata MsgBase_PropertiesEntry_DoNotUse::GetMetadata() const {
|
||||
return ::_pbi::AssignDescriptors(
|
||||
&descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
|
||||
file_level_metadata_common_2eproto[7]);
|
||||
}
|
||||
|
||||
// ===================================================================
|
||||
|
||||
class MsgBase::_Internal {
|
||||
public:
|
||||
};
|
||||
|
|
@ -2706,13 +2748,17 @@ MsgBase::MsgBase(::PROTOBUF_NAMESPACE_ID::Arena* arena,
|
|||
bool is_message_owned)
|
||||
: ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) {
|
||||
SharedCtor(arena, is_message_owned);
|
||||
if (arena != nullptr && !is_message_owned) {
|
||||
arena->OwnCustomDestructor(this, &MsgBase::ArenaDtor);
|
||||
}
|
||||
// @@protoc_insertion_point(arena_constructor:milvus.proto.common.MsgBase)
|
||||
}
|
||||
MsgBase::MsgBase(const MsgBase& from)
|
||||
: ::PROTOBUF_NAMESPACE_ID::Message() {
|
||||
MsgBase* const _this = this; (void)_this;
|
||||
new (&_impl_) Impl_{
|
||||
decltype(_impl_.msgid_){}
|
||||
/*decltype(_impl_.properties_)*/{}
|
||||
, decltype(_impl_.msgid_){}
|
||||
, decltype(_impl_.timestamp_){}
|
||||
, decltype(_impl_.sourceid_){}
|
||||
, decltype(_impl_.targetid_){}
|
||||
|
|
@ -2720,6 +2766,7 @@ MsgBase::MsgBase(const MsgBase& from)
|
|||
, /*decltype(_impl_._cached_size_)*/{}};
|
||||
|
||||
_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
|
||||
_this->_impl_.properties_.MergeFrom(from._impl_.properties_);
|
||||
::memcpy(&_impl_.msgid_, &from._impl_.msgid_,
|
||||
static_cast<size_t>(reinterpret_cast<char*>(&_impl_.msg_type_) -
|
||||
reinterpret_cast<char*>(&_impl_.msgid_)) + sizeof(_impl_.msg_type_));
|
||||
|
|
@ -2731,7 +2778,8 @@ inline void MsgBase::SharedCtor(
|
|||
(void)arena;
|
||||
(void)is_message_owned;
|
||||
new (&_impl_) Impl_{
|
||||
decltype(_impl_.msgid_){int64_t{0}}
|
||||
/*decltype(_impl_.properties_)*/{::_pbi::ArenaInitialized(), arena}
|
||||
, decltype(_impl_.msgid_){int64_t{0}}
|
||||
, decltype(_impl_.timestamp_){uint64_t{0u}}
|
||||
, decltype(_impl_.sourceid_){int64_t{0}}
|
||||
, decltype(_impl_.targetid_){int64_t{0}}
|
||||
|
|
@ -2744,6 +2792,7 @@ MsgBase::~MsgBase() {
|
|||
// @@protoc_insertion_point(destructor:milvus.proto.common.MsgBase)
|
||||
if (auto *arena = _internal_metadata_.DeleteReturnArena<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>()) {
|
||||
(void)arena;
|
||||
ArenaDtor(this);
|
||||
return;
|
||||
}
|
||||
SharedDtor();
|
||||
|
|
@ -2751,8 +2800,14 @@ MsgBase::~MsgBase() {
|
|||
|
||||
inline void MsgBase::SharedDtor() {
|
||||
GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
|
||||
_impl_.properties_.Destruct();
|
||||
_impl_.properties_.~MapField();
|
||||
}
|
||||
|
||||
void MsgBase::ArenaDtor(void* object) {
|
||||
MsgBase* _this = reinterpret_cast< MsgBase* >(object);
|
||||
_this->_impl_.properties_.Destruct();
|
||||
}
|
||||
void MsgBase::SetCachedSize(int size) const {
|
||||
_impl_._cached_size_.Set(size);
|
||||
}
|
||||
|
|
@ -2763,6 +2818,7 @@ void MsgBase::Clear() {
|
|||
// Prevent compiler warnings about cached_has_bits being unused
|
||||
(void) cached_has_bits;
|
||||
|
||||
_impl_.properties_.Clear();
|
||||
::memset(&_impl_.msgid_, 0, static_cast<size_t>(
|
||||
reinterpret_cast<char*>(&_impl_.msg_type_) -
|
||||
reinterpret_cast<char*>(&_impl_.msgid_)) + sizeof(_impl_.msg_type_));
|
||||
|
|
@ -2816,6 +2872,19 @@ const char* MsgBase::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx)
|
|||
} else
|
||||
goto handle_unusual;
|
||||
continue;
|
||||
// map<string, string> properties = 6;
|
||||
case 6:
|
||||
if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 50)) {
|
||||
ptr -= 1;
|
||||
do {
|
||||
ptr += 1;
|
||||
ptr = ctx->ParseMessage(&_impl_.properties_, ptr);
|
||||
CHK_(ptr);
|
||||
if (!ctx->DataAvailable(ptr)) break;
|
||||
} while (::PROTOBUF_NAMESPACE_ID::internal::ExpectTag<50>(ptr));
|
||||
} else
|
||||
goto handle_unusual;
|
||||
continue;
|
||||
default:
|
||||
goto handle_unusual;
|
||||
} // switch
|
||||
|
|
@ -2876,6 +2945,36 @@ uint8_t* MsgBase::_InternalSerialize(
|
|||
target = ::_pbi::WireFormatLite::WriteInt64ToArray(5, this->_internal_targetid(), target);
|
||||
}
|
||||
|
||||
// map<string, string> properties = 6;
|
||||
if (!this->_internal_properties().empty()) {
|
||||
using MapType = ::_pb::Map<std::string, std::string>;
|
||||
using WireHelper = MsgBase_PropertiesEntry_DoNotUse::Funcs;
|
||||
const auto& map_field = this->_internal_properties();
|
||||
auto check_utf8 = [](const MapType::value_type& entry) {
|
||||
(void)entry;
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
|
||||
entry.first.data(), static_cast<int>(entry.first.length()),
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
|
||||
"milvus.proto.common.MsgBase.PropertiesEntry.key");
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
|
||||
entry.second.data(), static_cast<int>(entry.second.length()),
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
|
||||
"milvus.proto.common.MsgBase.PropertiesEntry.value");
|
||||
};
|
||||
|
||||
if (stream->IsSerializationDeterministic() && map_field.size() > 1) {
|
||||
for (const auto& entry : ::_pbi::MapSorterPtr<MapType>(map_field)) {
|
||||
target = WireHelper::InternalSerialize(6, entry.first, entry.second, target, stream);
|
||||
check_utf8(entry);
|
||||
}
|
||||
} else {
|
||||
for (const auto& entry : map_field) {
|
||||
target = WireHelper::InternalSerialize(6, entry.first, entry.second, target, stream);
|
||||
check_utf8(entry);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
||||
target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
|
||||
_internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream);
|
||||
|
|
@ -2892,6 +2991,15 @@ size_t MsgBase::ByteSizeLong() const {
|
|||
// Prevent compiler warnings about cached_has_bits being unused
|
||||
(void) cached_has_bits;
|
||||
|
||||
// map<string, string> properties = 6;
|
||||
total_size += 1 *
|
||||
::PROTOBUF_NAMESPACE_ID::internal::FromIntSize(this->_internal_properties_size());
|
||||
for (::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >::const_iterator
|
||||
it = this->_internal_properties().begin();
|
||||
it != this->_internal_properties().end(); ++it) {
|
||||
total_size += MsgBase_PropertiesEntry_DoNotUse::Funcs::ByteSizeLong(it->first, it->second);
|
||||
}
|
||||
|
||||
// int64 msgID = 2;
|
||||
if (this->_internal_msgid() != 0) {
|
||||
total_size += ::_pbi::WireFormatLite::Int64SizePlusOne(this->_internal_msgid());
|
||||
|
|
@ -2936,6 +3044,7 @@ void MsgBase::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOB
|
|||
uint32_t cached_has_bits = 0;
|
||||
(void) cached_has_bits;
|
||||
|
||||
_this->_impl_.properties_.MergeFrom(from._impl_.properties_);
|
||||
if (from._internal_msgid() != 0) {
|
||||
_this->_internal_set_msgid(from._internal_msgid());
|
||||
}
|
||||
|
|
@ -2968,6 +3077,7 @@ bool MsgBase::IsInitialized() const {
|
|||
void MsgBase::InternalSwap(MsgBase* other) {
|
||||
using std::swap;
|
||||
_internal_metadata_.InternalSwap(&other->_internal_metadata_);
|
||||
_impl_.properties_.InternalSwap(&other->_impl_.properties_);
|
||||
::PROTOBUF_NAMESPACE_ID::internal::memswap<
|
||||
PROTOBUF_FIELD_OFFSET(MsgBase, _impl_.msg_type_)
|
||||
+ sizeof(MsgBase::_impl_.msg_type_)
|
||||
|
|
@ -2979,7 +3089,7 @@ void MsgBase::InternalSwap(MsgBase* other) {
|
|||
::PROTOBUF_NAMESPACE_ID::Metadata MsgBase::GetMetadata() const {
|
||||
return ::_pbi::AssignDescriptors(
|
||||
&descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
|
||||
file_level_metadata_common_2eproto[7]);
|
||||
file_level_metadata_common_2eproto[8]);
|
||||
}
|
||||
|
||||
// ===================================================================
|
||||
|
|
@ -3172,7 +3282,7 @@ void MsgHeader::InternalSwap(MsgHeader* other) {
|
|||
::PROTOBUF_NAMESPACE_ID::Metadata MsgHeader::GetMetadata() const {
|
||||
return ::_pbi::AssignDescriptors(
|
||||
&descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
|
||||
file_level_metadata_common_2eproto[8]);
|
||||
file_level_metadata_common_2eproto[9]);
|
||||
}
|
||||
|
||||
// ===================================================================
|
||||
|
|
@ -3417,7 +3527,7 @@ void DMLMsgHeader::InternalSwap(DMLMsgHeader* other) {
|
|||
::PROTOBUF_NAMESPACE_ID::Metadata DMLMsgHeader::GetMetadata() const {
|
||||
return ::_pbi::AssignDescriptors(
|
||||
&descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
|
||||
file_level_metadata_common_2eproto[9]);
|
||||
file_level_metadata_common_2eproto[10]);
|
||||
}
|
||||
|
||||
// ===================================================================
|
||||
|
|
@ -3682,7 +3792,7 @@ void PrivilegeExt::InternalSwap(PrivilegeExt* other) {
|
|||
::PROTOBUF_NAMESPACE_ID::Metadata PrivilegeExt::GetMetadata() const {
|
||||
return ::_pbi::AssignDescriptors(
|
||||
&descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
|
||||
file_level_metadata_common_2eproto[10]);
|
||||
file_level_metadata_common_2eproto[11]);
|
||||
}
|
||||
|
||||
// ===================================================================
|
||||
|
|
@ -3893,7 +4003,7 @@ void SegmentStats::InternalSwap(SegmentStats* other) {
|
|||
::PROTOBUF_NAMESPACE_ID::Metadata SegmentStats::GetMetadata() const {
|
||||
return ::_pbi::AssignDescriptors(
|
||||
&descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
|
||||
file_level_metadata_common_2eproto[11]);
|
||||
file_level_metadata_common_2eproto[12]);
|
||||
}
|
||||
|
||||
// ===================================================================
|
||||
|
|
@ -3907,7 +4017,7 @@ void ClientInfo_ReservedEntry_DoNotUse::MergeFrom(const ClientInfo_ReservedEntry
|
|||
::PROTOBUF_NAMESPACE_ID::Metadata ClientInfo_ReservedEntry_DoNotUse::GetMetadata() const {
|
||||
return ::_pbi::AssignDescriptors(
|
||||
&descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
|
||||
file_level_metadata_common_2eproto[12]);
|
||||
file_level_metadata_common_2eproto[13]);
|
||||
}
|
||||
|
||||
// ===================================================================
|
||||
|
|
@ -4378,7 +4488,7 @@ void ClientInfo::InternalSwap(ClientInfo* other) {
|
|||
::PROTOBUF_NAMESPACE_ID::Metadata ClientInfo::GetMetadata() const {
|
||||
return ::_pbi::AssignDescriptors(
|
||||
&descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
|
||||
file_level_metadata_common_2eproto[13]);
|
||||
file_level_metadata_common_2eproto[14]);
|
||||
}
|
||||
|
||||
// ===================================================================
|
||||
|
|
@ -4392,7 +4502,7 @@ void ServerInfo_ReservedEntry_DoNotUse::MergeFrom(const ServerInfo_ReservedEntry
|
|||
::PROTOBUF_NAMESPACE_ID::Metadata ServerInfo_ReservedEntry_DoNotUse::GetMetadata() const {
|
||||
return ::_pbi::AssignDescriptors(
|
||||
&descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
|
||||
file_level_metadata_common_2eproto[14]);
|
||||
file_level_metadata_common_2eproto[15]);
|
||||
}
|
||||
|
||||
// ===================================================================
|
||||
|
|
@ -4863,7 +4973,7 @@ void ServerInfo::InternalSwap(ServerInfo* other) {
|
|||
::PROTOBUF_NAMESPACE_ID::Metadata ServerInfo::GetMetadata() const {
|
||||
return ::_pbi::AssignDescriptors(
|
||||
&descriptor_table_common_2eproto_getter, &descriptor_table_common_2eproto_once,
|
||||
file_level_metadata_common_2eproto[15]);
|
||||
file_level_metadata_common_2eproto[16]);
|
||||
}
|
||||
PROTOBUF_ATTRIBUTE_INIT_PRIORITY2 ::PROTOBUF_NAMESPACE_ID::internal::ExtensionIdentifier< ::PROTOBUF_NAMESPACE_ID::MessageOptions,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::MessageTypeTraits< ::milvus::proto::common::PrivilegeExt >, 11, false>
|
||||
|
|
@ -4902,6 +5012,10 @@ template<> PROTOBUF_NOINLINE ::milvus::proto::common::Address*
|
|||
Arena::CreateMaybeMessage< ::milvus::proto::common::Address >(Arena* arena) {
|
||||
return Arena::CreateMessageInternal< ::milvus::proto::common::Address >(arena);
|
||||
}
|
||||
template<> PROTOBUF_NOINLINE ::milvus::proto::common::MsgBase_PropertiesEntry_DoNotUse*
|
||||
Arena::CreateMaybeMessage< ::milvus::proto::common::MsgBase_PropertiesEntry_DoNotUse >(Arena* arena) {
|
||||
return Arena::CreateMessageInternal< ::milvus::proto::common::MsgBase_PropertiesEntry_DoNotUse >(arena);
|
||||
}
|
||||
template<> PROTOBUF_NOINLINE ::milvus::proto::common::MsgBase*
|
||||
Arena::CreateMaybeMessage< ::milvus::proto::common::MsgBase >(Arena* arena) {
|
||||
return Arena::CreateMessageInternal< ::milvus::proto::common::MsgBase >(arena);
|
||||
|
|
|
|||
|
|
@ -76,6 +76,9 @@ extern KeyValuePairDefaultTypeInternal _KeyValuePair_default_instance_;
|
|||
class MsgBase;
|
||||
struct MsgBaseDefaultTypeInternal;
|
||||
extern MsgBaseDefaultTypeInternal _MsgBase_default_instance_;
|
||||
class MsgBase_PropertiesEntry_DoNotUse;
|
||||
struct MsgBase_PropertiesEntry_DoNotUseDefaultTypeInternal;
|
||||
extern MsgBase_PropertiesEntry_DoNotUseDefaultTypeInternal _MsgBase_PropertiesEntry_DoNotUse_default_instance_;
|
||||
class MsgHeader;
|
||||
struct MsgHeaderDefaultTypeInternal;
|
||||
extern MsgHeaderDefaultTypeInternal _MsgHeader_default_instance_;
|
||||
|
|
@ -112,6 +115,7 @@ template<> ::milvus::proto::common::DMLMsgHeader* Arena::CreateMaybeMessage<::mi
|
|||
template<> ::milvus::proto::common::KeyDataPair* Arena::CreateMaybeMessage<::milvus::proto::common::KeyDataPair>(Arena*);
|
||||
template<> ::milvus::proto::common::KeyValuePair* Arena::CreateMaybeMessage<::milvus::proto::common::KeyValuePair>(Arena*);
|
||||
template<> ::milvus::proto::common::MsgBase* Arena::CreateMaybeMessage<::milvus::proto::common::MsgBase>(Arena*);
|
||||
template<> ::milvus::proto::common::MsgBase_PropertiesEntry_DoNotUse* Arena::CreateMaybeMessage<::milvus::proto::common::MsgBase_PropertiesEntry_DoNotUse>(Arena*);
|
||||
template<> ::milvus::proto::common::MsgHeader* Arena::CreateMaybeMessage<::milvus::proto::common::MsgHeader>(Arena*);
|
||||
template<> ::milvus::proto::common::PlaceholderGroup* Arena::CreateMaybeMessage<::milvus::proto::common::PlaceholderGroup>(Arena*);
|
||||
template<> ::milvus::proto::common::PlaceholderValue* Arena::CreateMaybeMessage<::milvus::proto::common::PlaceholderValue>(Arena*);
|
||||
|
|
@ -1850,6 +1854,34 @@ class Address final :
|
|||
};
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
class MsgBase_PropertiesEntry_DoNotUse : public ::PROTOBUF_NAMESPACE_ID::internal::MapEntry<MsgBase_PropertiesEntry_DoNotUse,
|
||||
std::string, std::string,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING> {
|
||||
public:
|
||||
typedef ::PROTOBUF_NAMESPACE_ID::internal::MapEntry<MsgBase_PropertiesEntry_DoNotUse,
|
||||
std::string, std::string,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING> SuperType;
|
||||
MsgBase_PropertiesEntry_DoNotUse();
|
||||
explicit PROTOBUF_CONSTEXPR MsgBase_PropertiesEntry_DoNotUse(
|
||||
::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
|
||||
explicit MsgBase_PropertiesEntry_DoNotUse(::PROTOBUF_NAMESPACE_ID::Arena* arena);
|
||||
void MergeFrom(const MsgBase_PropertiesEntry_DoNotUse& other);
|
||||
static const MsgBase_PropertiesEntry_DoNotUse* internal_default_instance() { return reinterpret_cast<const MsgBase_PropertiesEntry_DoNotUse*>(&_MsgBase_PropertiesEntry_DoNotUse_default_instance_); }
|
||||
static bool ValidateKey(std::string* s) {
|
||||
return ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(s->data(), static_cast<int>(s->size()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE, "milvus.proto.common.MsgBase.PropertiesEntry.key");
|
||||
}
|
||||
static bool ValidateValue(std::string* s) {
|
||||
return ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(s->data(), static_cast<int>(s->size()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE, "milvus.proto.common.MsgBase.PropertiesEntry.value");
|
||||
}
|
||||
using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
|
||||
::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
|
||||
friend struct ::TableStruct_common_2eproto;
|
||||
};
|
||||
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
class MsgBase final :
|
||||
public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:milvus.proto.common.MsgBase) */ {
|
||||
public:
|
||||
|
|
@ -1898,7 +1930,7 @@ class MsgBase final :
|
|||
&_MsgBase_default_instance_);
|
||||
}
|
||||
static constexpr int kIndexInFileMessages =
|
||||
7;
|
||||
8;
|
||||
|
||||
friend void swap(MsgBase& a, MsgBase& b) {
|
||||
a.Swap(&b);
|
||||
|
|
@ -1959,6 +1991,8 @@ class MsgBase final :
|
|||
protected:
|
||||
explicit MsgBase(::PROTOBUF_NAMESPACE_ID::Arena* arena,
|
||||
bool is_message_owned = false);
|
||||
private:
|
||||
static void ArenaDtor(void* object);
|
||||
public:
|
||||
|
||||
static const ClassData _class_data_;
|
||||
|
|
@ -1968,15 +2002,34 @@ class MsgBase final :
|
|||
|
||||
// nested types ----------------------------------------------------
|
||||
|
||||
|
||||
// accessors -------------------------------------------------------
|
||||
|
||||
enum : int {
|
||||
kPropertiesFieldNumber = 6,
|
||||
kMsgIDFieldNumber = 2,
|
||||
kTimestampFieldNumber = 3,
|
||||
kSourceIDFieldNumber = 4,
|
||||
kTargetIDFieldNumber = 5,
|
||||
kMsgTypeFieldNumber = 1,
|
||||
};
|
||||
// map<string, string> properties = 6;
|
||||
int properties_size() const;
|
||||
private:
|
||||
int _internal_properties_size() const;
|
||||
public:
|
||||
void clear_properties();
|
||||
private:
|
||||
const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >&
|
||||
_internal_properties() const;
|
||||
::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >*
|
||||
_internal_mutable_properties();
|
||||
public:
|
||||
const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >&
|
||||
properties() const;
|
||||
::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >*
|
||||
mutable_properties();
|
||||
|
||||
// int64 msgID = 2;
|
||||
void clear_msgid();
|
||||
int64_t msgid() const;
|
||||
|
|
@ -2030,6 +2083,11 @@ class MsgBase final :
|
|||
typedef void InternalArenaConstructable_;
|
||||
typedef void DestructorSkippable_;
|
||||
struct Impl_ {
|
||||
::PROTOBUF_NAMESPACE_ID::internal::MapField<
|
||||
MsgBase_PropertiesEntry_DoNotUse,
|
||||
std::string, std::string,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING,
|
||||
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING> properties_;
|
||||
int64_t msgid_;
|
||||
uint64_t timestamp_;
|
||||
int64_t sourceid_;
|
||||
|
|
@ -2090,7 +2148,7 @@ class MsgHeader final :
|
|||
&_MsgHeader_default_instance_);
|
||||
}
|
||||
static constexpr int kIndexInFileMessages =
|
||||
8;
|
||||
9;
|
||||
|
||||
friend void swap(MsgHeader& a, MsgHeader& b) {
|
||||
a.Swap(&b);
|
||||
|
|
@ -2247,7 +2305,7 @@ class DMLMsgHeader final :
|
|||
&_DMLMsgHeader_default_instance_);
|
||||
}
|
||||
static constexpr int kIndexInFileMessages =
|
||||
9;
|
||||
10;
|
||||
|
||||
friend void swap(DMLMsgHeader& a, DMLMsgHeader& b) {
|
||||
a.Swap(&b);
|
||||
|
|
@ -2420,7 +2478,7 @@ class PrivilegeExt final :
|
|||
&_PrivilegeExt_default_instance_);
|
||||
}
|
||||
static constexpr int kIndexInFileMessages =
|
||||
10;
|
||||
11;
|
||||
|
||||
friend void swap(PrivilegeExt& a, PrivilegeExt& b) {
|
||||
a.Swap(&b);
|
||||
|
|
@ -2601,7 +2659,7 @@ class SegmentStats final :
|
|||
&_SegmentStats_default_instance_);
|
||||
}
|
||||
static constexpr int kIndexInFileMessages =
|
||||
11;
|
||||
12;
|
||||
|
||||
friend void swap(SegmentStats& a, SegmentStats& b) {
|
||||
a.Swap(&b);
|
||||
|
|
@ -2788,7 +2846,7 @@ class ClientInfo final :
|
|||
&_ClientInfo_default_instance_);
|
||||
}
|
||||
static constexpr int kIndexInFileMessages =
|
||||
13;
|
||||
14;
|
||||
|
||||
friend void swap(ClientInfo& a, ClientInfo& b) {
|
||||
a.Swap(&b);
|
||||
|
|
@ -3059,7 +3117,7 @@ class ServerInfo final :
|
|||
&_ServerInfo_default_instance_);
|
||||
}
|
||||
static constexpr int kIndexInFileMessages =
|
||||
15;
|
||||
16;
|
||||
|
||||
friend void swap(ServerInfo& a, ServerInfo& b) {
|
||||
a.Swap(&b);
|
||||
|
|
@ -3888,6 +3946,8 @@ inline void Address::set_port(int64_t value) {
|
|||
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
// MsgBase
|
||||
|
||||
// .milvus.proto.common.MsgType msg_type = 1;
|
||||
|
|
@ -3990,6 +4050,35 @@ inline void MsgBase::set_targetid(int64_t value) {
|
|||
// @@protoc_insertion_point(field_set:milvus.proto.common.MsgBase.targetID)
|
||||
}
|
||||
|
||||
// map<string, string> properties = 6;
|
||||
inline int MsgBase::_internal_properties_size() const {
|
||||
return _impl_.properties_.size();
|
||||
}
|
||||
inline int MsgBase::properties_size() const {
|
||||
return _internal_properties_size();
|
||||
}
|
||||
inline void MsgBase::clear_properties() {
|
||||
_impl_.properties_.Clear();
|
||||
}
|
||||
inline const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >&
|
||||
MsgBase::_internal_properties() const {
|
||||
return _impl_.properties_.GetMap();
|
||||
}
|
||||
inline const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >&
|
||||
MsgBase::properties() const {
|
||||
// @@protoc_insertion_point(field_map:milvus.proto.common.MsgBase.properties)
|
||||
return _internal_properties();
|
||||
}
|
||||
inline ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >*
|
||||
MsgBase::_internal_mutable_properties() {
|
||||
return _impl_.properties_.MutableMap();
|
||||
}
|
||||
inline ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >*
|
||||
MsgBase::mutable_properties() {
|
||||
// @@protoc_insertion_point(field_mutable_map:milvus.proto.common.MsgBase.properties)
|
||||
return _internal_mutable_properties();
|
||||
}
|
||||
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
// MsgHeader
|
||||
|
|
@ -4959,6 +5048,8 @@ ServerInfo::mutable_reserved() {
|
|||
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
// -------------------------------------------------------------------
|
||||
|
||||
|
||||
// @@protoc_insertion_point(namespace_scope)
|
||||
|
||||
|
|
|
|||
|
|
@ -37,6 +37,8 @@ import (
|
|||
clientv3 "go.etcd.io/etcd/client/v3"
|
||||
"go.uber.org/zap"
|
||||
"google.golang.org/grpc"
|
||||
"google.golang.org/grpc/codes"
|
||||
grpcStatus "google.golang.org/grpc/status"
|
||||
|
||||
"github.com/milvus-io/milvus-proto/go-api/v2/commonpb"
|
||||
"github.com/milvus-io/milvus-proto/go-api/v2/milvuspb"
|
||||
|
|
@ -328,6 +330,40 @@ func TestFlush(t *testing.T) {
|
|||
assert.NoError(t, err)
|
||||
assert.ErrorIs(t, merr.Error(resp.GetStatus()), merr.ErrServiceNotReady)
|
||||
})
|
||||
|
||||
t.Run("test rolling upgrade", func(t *testing.T) {
|
||||
svr := newTestServer(t, nil)
|
||||
closeTestServer(t, svr)
|
||||
svr.stateCode.Store(commonpb.StateCode_Healthy)
|
||||
sm := NewSessionManager()
|
||||
|
||||
datanodeClient := mocks.NewMockDataNodeClient(t)
|
||||
datanodeClient.EXPECT().FlushChannels(mock.Anything, mock.Anything).Return(nil,
|
||||
grpcStatus.Error(codes.Unimplemented, "mock grpc unimplemented error"))
|
||||
|
||||
sm.sessions = struct {
|
||||
sync.RWMutex
|
||||
data map[int64]*Session
|
||||
}{data: map[int64]*Session{1: {
|
||||
client: datanodeClient,
|
||||
clientCreator: func(ctx context.Context, addr string, nodeID int64) (types.DataNodeClient, error) {
|
||||
return datanodeClient, nil
|
||||
},
|
||||
}}}
|
||||
|
||||
svr.sessionManager = sm
|
||||
svr.cluster.sessionManager = sm
|
||||
|
||||
err := svr.channelManager.AddNode(1)
|
||||
assert.NoError(t, err)
|
||||
err = svr.channelManager.Watch(&channel{Name: "ch1", CollectionID: 0})
|
||||
assert.NoError(t, err)
|
||||
|
||||
resp, err := svr.Flush(context.TODO(), req)
|
||||
assert.NoError(t, err)
|
||||
assert.EqualValues(t, commonpb.ErrorCode_Success, resp.GetStatus().GetErrorCode())
|
||||
assert.Equal(t, Timestamp(0), resp.GetFlushTs())
|
||||
})
|
||||
}
|
||||
|
||||
// func TestGetComponentStates(t *testing.T) {
|
||||
|
|
|
|||
|
|
@ -28,6 +28,7 @@ import (
|
|||
"go.opentelemetry.io/otel"
|
||||
"go.uber.org/zap"
|
||||
"golang.org/x/sync/errgroup"
|
||||
"google.golang.org/grpc/codes"
|
||||
|
||||
"github.com/milvus-io/milvus-proto/go-api/v2/commonpb"
|
||||
"github.com/milvus-io/milvus-proto/go-api/v2/milvuspb"
|
||||
|
|
@ -39,6 +40,7 @@ import (
|
|||
"github.com/milvus-io/milvus/pkg/log"
|
||||
"github.com/milvus-io/milvus/pkg/metrics"
|
||||
"github.com/milvus-io/milvus/pkg/util/commonpbutil"
|
||||
"github.com/milvus-io/milvus/pkg/util/funcutil"
|
||||
"github.com/milvus-io/milvus/pkg/util/merr"
|
||||
"github.com/milvus-io/milvus/pkg/util/metricsinfo"
|
||||
"github.com/milvus-io/milvus/pkg/util/paramtable"
|
||||
|
|
@ -66,11 +68,11 @@ func (s *Server) GetStatisticsChannel(ctx context.Context, req *internalpb.GetSt
|
|||
// this api only guarantees all the segments requested is sealed
|
||||
// these segments will be flushed only after the Flush policy is fulfilled
|
||||
func (s *Server) Flush(ctx context.Context, req *datapb.FlushRequest) (*datapb.FlushResponse, error) {
|
||||
log := log.Ctx(ctx)
|
||||
log.Info("receive flush request",
|
||||
log := log.Ctx(ctx).With(
|
||||
zap.Int64("dbID", req.GetDbID()),
|
||||
zap.Int64("collectionID", req.GetCollectionID()),
|
||||
zap.Bool("isImporting", req.GetIsImport()))
|
||||
log.Info("receive flush request")
|
||||
ctx, sp := otel.Tracer(typeutil.DataCoordRole).Start(ctx, "DataCoord-Flush")
|
||||
defer sp.End()
|
||||
|
||||
|
|
@ -113,6 +115,7 @@ func (s *Server) Flush(ctx context.Context, req *datapb.FlushRequest) (*datapb.F
|
|||
}
|
||||
}
|
||||
|
||||
var isUnimplemented bool
|
||||
err = retry.Do(ctx, func() error {
|
||||
for _, channelInfo := range s.channelManager.GetChannels() {
|
||||
nodeID := channelInfo.NodeID
|
||||
|
|
@ -123,6 +126,10 @@ func (s *Server) Flush(ctx context.Context, req *datapb.FlushRequest) (*datapb.F
|
|||
return channel.Name
|
||||
})
|
||||
err = s.cluster.FlushChannels(ctx, nodeID, ts, channelNames)
|
||||
if err != nil && funcutil.IsGrpcErr(err, codes.Unimplemented) {
|
||||
isUnimplemented = true
|
||||
return nil
|
||||
}
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
|
@ -135,6 +142,13 @@ func (s *Server) Flush(ctx context.Context, req *datapb.FlushRequest) (*datapb.F
|
|||
}, nil
|
||||
}
|
||||
|
||||
if isUnimplemented {
|
||||
// For compatible with rolling upgrade from version 2.2.x,
|
||||
// fall back to the flush logic of version 2.2.x;
|
||||
log.Warn("DataNode FlushChannels unimplemented", zap.Error(err))
|
||||
ts = 0
|
||||
}
|
||||
|
||||
log.Info("flush response with segments",
|
||||
zap.Int64("collectionID", req.GetCollectionID()),
|
||||
zap.Int64s("sealSegments", sealedSegmentIDs),
|
||||
|
|
|
|||
Loading…
Reference in New Issue