// Generated by the protocol buffer compiler. DO NOT EDIT! // source: common.proto #include "common.pb.h" #include #include #include #include #include #include #include #include #include // @@protoc_insertion_point(includes) #include extern PROTOBUF_INTERNAL_EXPORT_common_2eproto ::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_MsgBase_common_2eproto; namespace milvus { namespace proto { namespace common { class StatusDefaultTypeInternal { public: ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed _instance; } _Status_default_instance_; class KeyValuePairDefaultTypeInternal { public: ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed _instance; } _KeyValuePair_default_instance_; class KeyDataPairDefaultTypeInternal { public: ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed _instance; } _KeyDataPair_default_instance_; class BlobDefaultTypeInternal { public: ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed _instance; } _Blob_default_instance_; class AddressDefaultTypeInternal { public: ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed
_instance; } _Address_default_instance_; class MsgBaseDefaultTypeInternal { public: ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed _instance; } _MsgBase_default_instance_; class MsgHeaderDefaultTypeInternal { public: ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed _instance; } _MsgHeader_default_instance_; class DMLMsgHeaderDefaultTypeInternal { public: ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed _instance; } _DMLMsgHeader_default_instance_; } // namespace common } // namespace proto } // namespace milvus static void InitDefaultsscc_info_Address_common_2eproto() { GOOGLE_PROTOBUF_VERIFY_VERSION; { void* ptr = &::milvus::proto::common::_Address_default_instance_; new (ptr) ::milvus::proto::common::Address(); ::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr); } ::milvus::proto::common::Address::InitAsDefaultInstance(); } ::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_Address_common_2eproto = {{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsscc_info_Address_common_2eproto}, {}}; static void InitDefaultsscc_info_Blob_common_2eproto() { GOOGLE_PROTOBUF_VERIFY_VERSION; { void* ptr = &::milvus::proto::common::_Blob_default_instance_; new (ptr) ::milvus::proto::common::Blob(); ::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr); } ::milvus::proto::common::Blob::InitAsDefaultInstance(); } ::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_Blob_common_2eproto = {{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsscc_info_Blob_common_2eproto}, {}}; static void InitDefaultsscc_info_DMLMsgHeader_common_2eproto() { GOOGLE_PROTOBUF_VERIFY_VERSION; { void* ptr = &::milvus::proto::common::_DMLMsgHeader_default_instance_; new (ptr) ::milvus::proto::common::DMLMsgHeader(); ::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr); } ::milvus::proto::common::DMLMsgHeader::InitAsDefaultInstance(); } ::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<1> scc_info_DMLMsgHeader_common_2eproto = {{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 1, InitDefaultsscc_info_DMLMsgHeader_common_2eproto}, { &scc_info_MsgBase_common_2eproto.base,}}; static void InitDefaultsscc_info_KeyDataPair_common_2eproto() { GOOGLE_PROTOBUF_VERIFY_VERSION; { void* ptr = &::milvus::proto::common::_KeyDataPair_default_instance_; new (ptr) ::milvus::proto::common::KeyDataPair(); ::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr); } ::milvus::proto::common::KeyDataPair::InitAsDefaultInstance(); } ::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_KeyDataPair_common_2eproto = {{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsscc_info_KeyDataPair_common_2eproto}, {}}; static void InitDefaultsscc_info_KeyValuePair_common_2eproto() { GOOGLE_PROTOBUF_VERIFY_VERSION; { void* ptr = &::milvus::proto::common::_KeyValuePair_default_instance_; new (ptr) ::milvus::proto::common::KeyValuePair(); ::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr); } ::milvus::proto::common::KeyValuePair::InitAsDefaultInstance(); } ::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_KeyValuePair_common_2eproto = {{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsscc_info_KeyValuePair_common_2eproto}, {}}; static void InitDefaultsscc_info_MsgBase_common_2eproto() { GOOGLE_PROTOBUF_VERIFY_VERSION; { void* ptr = &::milvus::proto::common::_MsgBase_default_instance_; new (ptr) ::milvus::proto::common::MsgBase(); ::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr); } ::milvus::proto::common::MsgBase::InitAsDefaultInstance(); } ::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_MsgBase_common_2eproto = {{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsscc_info_MsgBase_common_2eproto}, {}}; static void InitDefaultsscc_info_MsgHeader_common_2eproto() { GOOGLE_PROTOBUF_VERIFY_VERSION; { void* ptr = &::milvus::proto::common::_MsgHeader_default_instance_; new (ptr) ::milvus::proto::common::MsgHeader(); ::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr); } ::milvus::proto::common::MsgHeader::InitAsDefaultInstance(); } ::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<1> scc_info_MsgHeader_common_2eproto = {{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 1, InitDefaultsscc_info_MsgHeader_common_2eproto}, { &scc_info_MsgBase_common_2eproto.base,}}; static void InitDefaultsscc_info_Status_common_2eproto() { GOOGLE_PROTOBUF_VERIFY_VERSION; { void* ptr = &::milvus::proto::common::_Status_default_instance_; new (ptr) ::milvus::proto::common::Status(); ::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr); } ::milvus::proto::common::Status::InitAsDefaultInstance(); } ::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_Status_common_2eproto = {{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsscc_info_Status_common_2eproto}, {}}; static ::PROTOBUF_NAMESPACE_ID::Metadata file_level_metadata_common_2eproto[8]; static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* file_level_enum_descriptors_common_2eproto[8]; static constexpr ::PROTOBUF_NAMESPACE_ID::ServiceDescriptor const** file_level_service_descriptors_common_2eproto = nullptr; const ::PROTOBUF_NAMESPACE_ID::uint32 TableStruct_common_2eproto::offsets[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = { ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::milvus::proto::common::Status, _internal_metadata_), ~0u, // no _extensions_ ~0u, // no _oneof_case_ ~0u, // no _weak_field_map_ PROTOBUF_FIELD_OFFSET(::milvus::proto::common::Status, error_code_), PROTOBUF_FIELD_OFFSET(::milvus::proto::common::Status, reason_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::milvus::proto::common::KeyValuePair, _internal_metadata_), ~0u, // no _extensions_ ~0u, // no _oneof_case_ ~0u, // no _weak_field_map_ PROTOBUF_FIELD_OFFSET(::milvus::proto::common::KeyValuePair, key_), PROTOBUF_FIELD_OFFSET(::milvus::proto::common::KeyValuePair, value_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::milvus::proto::common::KeyDataPair, _internal_metadata_), ~0u, // no _extensions_ ~0u, // no _oneof_case_ ~0u, // no _weak_field_map_ PROTOBUF_FIELD_OFFSET(::milvus::proto::common::KeyDataPair, key_), PROTOBUF_FIELD_OFFSET(::milvus::proto::common::KeyDataPair, data_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::milvus::proto::common::Blob, _internal_metadata_), ~0u, // no _extensions_ ~0u, // no _oneof_case_ ~0u, // no _weak_field_map_ PROTOBUF_FIELD_OFFSET(::milvus::proto::common::Blob, value_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::milvus::proto::common::Address, _internal_metadata_), ~0u, // no _extensions_ ~0u, // no _oneof_case_ ~0u, // no _weak_field_map_ PROTOBUF_FIELD_OFFSET(::milvus::proto::common::Address, ip_), PROTOBUF_FIELD_OFFSET(::milvus::proto::common::Address, port_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase, _internal_metadata_), ~0u, // no _extensions_ ~0u, // no _oneof_case_ ~0u, // no _weak_field_map_ PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase, msg_type_), PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase, msgid_), PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase, timestamp_), PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgBase, sourceid_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgHeader, _internal_metadata_), ~0u, // no _extensions_ ~0u, // no _oneof_case_ ~0u, // no _weak_field_map_ PROTOBUF_FIELD_OFFSET(::milvus::proto::common::MsgHeader, base_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::milvus::proto::common::DMLMsgHeader, _internal_metadata_), ~0u, // no _extensions_ ~0u, // no _oneof_case_ ~0u, // no _weak_field_map_ PROTOBUF_FIELD_OFFSET(::milvus::proto::common::DMLMsgHeader, base_), PROTOBUF_FIELD_OFFSET(::milvus::proto::common::DMLMsgHeader, shardname_), }; static const ::PROTOBUF_NAMESPACE_ID::internal::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = { { 0, -1, sizeof(::milvus::proto::common::Status)}, { 7, -1, sizeof(::milvus::proto::common::KeyValuePair)}, { 14, -1, sizeof(::milvus::proto::common::KeyDataPair)}, { 21, -1, sizeof(::milvus::proto::common::Blob)}, { 27, -1, sizeof(::milvus::proto::common::Address)}, { 34, -1, sizeof(::milvus::proto::common::MsgBase)}, { 43, -1, sizeof(::milvus::proto::common::MsgHeader)}, { 49, -1, sizeof(::milvus::proto::common::DMLMsgHeader)}, }; static ::PROTOBUF_NAMESPACE_ID::Message const * const file_default_instances[] = { reinterpret_cast(&::milvus::proto::common::_Status_default_instance_), reinterpret_cast(&::milvus::proto::common::_KeyValuePair_default_instance_), reinterpret_cast(&::milvus::proto::common::_KeyDataPair_default_instance_), reinterpret_cast(&::milvus::proto::common::_Blob_default_instance_), reinterpret_cast(&::milvus::proto::common::_Address_default_instance_), reinterpret_cast(&::milvus::proto::common::_MsgBase_default_instance_), reinterpret_cast(&::milvus::proto::common::_MsgHeader_default_instance_), reinterpret_cast(&::milvus::proto::common::_DMLMsgHeader_default_instance_), }; const char descriptor_table_protodef_common_2eproto[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = "\n\014common.proto\022\023milvus.proto.common\"L\n\006S" "tatus\0222\n\nerror_code\030\001 \001(\0162\036.milvus.proto" ".common.ErrorCode\022\016\n\006reason\030\002 \001(\t\"*\n\014Key" "ValuePair\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t\"(\n" "\013KeyDataPair\022\013\n\003key\030\001 \001(\t\022\014\n\004data\030\002 \001(\014\"" "\025\n\004Blob\022\r\n\005value\030\001 \001(\014\"#\n\007Address\022\n\n\002ip\030" "\001 \001(\t\022\014\n\004port\030\002 \001(\003\"m\n\007MsgBase\022.\n\010msg_ty" "pe\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\010sour" "ceID\030\004 \001(\003\"7\n\tMsgHeader\022*\n\004base\030\001 \001(\0132\034." "milvus.proto.common.MsgBase\"M\n\014DMLMsgHea" "der\022*\n\004base\030\001 \001(\0132\034.milvus.proto.common." "MsgBase\022\021\n\tshardName\030\002 \001(\t*\376\005\n\tErrorCode" "\022\013\n\007Success\020\000\022\023\n\017UnexpectedError\020\001\022\021\n\rCo" "nnectFailed\020\002\022\024\n\020PermissionDenied\020\003\022\027\n\023C" "ollectionNotExists\020\004\022\023\n\017IllegalArgument\020" "\005\022\024\n\020IllegalDimension\020\007\022\024\n\020IllegalIndexT" "ype\020\010\022\031\n\025IllegalCollectionName\020\t\022\017\n\013Ille" "galTOPK\020\n\022\024\n\020IllegalRowRecord\020\013\022\023\n\017Illeg" "alVectorID\020\014\022\027\n\023IllegalSearchResult\020\r\022\020\n" "\014FileNotFound\020\016\022\016\n\nMetaFailed\020\017\022\017\n\013Cache" "Failed\020\020\022\026\n\022CannotCreateFolder\020\021\022\024\n\020Cann" "otCreateFile\020\022\022\026\n\022CannotDeleteFolder\020\023\022\024" "\n\020CannotDeleteFile\020\024\022\023\n\017BuildIndexError\020" "\025\022\020\n\014IllegalNLIST\020\026\022\025\n\021IllegalMetricType" "\020\027\022\017\n\013OutOfMemory\020\030\022\021\n\rIndexNotExist\020\031\022\023" "\n\017EmptyCollection\020\032\022\033\n\027UpdateImportTaskF" "ailure\020\033\022\032\n\026CollectionNameNotFound\020\034\022\033\n\027" "CreateCredentialFailure\020\035\022\033\n\027UpdateCrede" "ntialFailure\020\036\022\033\n\027DeleteCredentialFailur" "e\020\037\022\030\n\024GetCredentialFailure\020 \022\030\n\024ListCre" "dUsersFailure\020!\022\022\n\rDDRequestRace\020\350\007*X\n\nI" "ndexState\022\022\n\016IndexStateNone\020\000\022\014\n\010Unissue" "d\020\001\022\016\n\nInProgress\020\002\022\014\n\010Finished\020\003\022\n\n\006Fai" "led\020\004*\202\001\n\014SegmentState\022\024\n\020SegmentStateNo" "ne\020\000\022\014\n\010NotExist\020\001\022\013\n\007Growing\020\002\022\n\n\006Seale" "d\020\003\022\013\n\007Flushed\020\004\022\014\n\010Flushing\020\005\022\013\n\007Droppe" "d\020\006\022\r\n\tImporting\020\007*\307\n\n\007MsgType\022\r\n\tUndefi" "ned\020\000\022\024\n\020CreateCollection\020d\022\022\n\016DropColle" "ction\020e\022\021\n\rHasCollection\020f\022\026\n\022DescribeCo" "llection\020g\022\023\n\017ShowCollections\020h\022\024\n\020GetSy" "stemConfigs\020i\022\022\n\016LoadCollection\020j\022\025\n\021Rel" "easeCollection\020k\022\017\n\013CreateAlias\020l\022\r\n\tDro" "pAlias\020m\022\016\n\nAlterAlias\020n\022\024\n\017CreatePartit" "ion\020\310\001\022\022\n\rDropPartition\020\311\001\022\021\n\014HasPartiti" "on\020\312\001\022\026\n\021DescribePartition\020\313\001\022\023\n\016ShowPar" "titions\020\314\001\022\023\n\016LoadPartitions\020\315\001\022\026\n\021Relea" "sePartitions\020\316\001\022\021\n\014ShowSegments\020\372\001\022\024\n\017De" "scribeSegment\020\373\001\022\021\n\014LoadSegments\020\374\001\022\024\n\017R" "eleaseSegments\020\375\001\022\024\n\017HandoffSegments\020\376\001\022" "\030\n\023LoadBalanceSegments\020\377\001\022\025\n\020DescribeSeg" "ments\020\200\002\022\020\n\013CreateIndex\020\254\002\022\022\n\rDescribeIn" "dex\020\255\002\022\016\n\tDropIndex\020\256\002\022\013\n\006Insert\020\220\003\022\013\n\006D" "elete\020\221\003\022\n\n\005Flush\020\222\003\022\013\n\006Search\020\364\003\022\021\n\014Sea" "rchResult\020\365\003\022\022\n\rGetIndexState\020\366\003\022\032\n\025GetI" "ndexBuildProgress\020\367\003\022\034\n\027GetCollectionSta" "tistics\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\017W" "atchDmChannels\020\374\003\022\025\n\020RemoveDmChannels\020\375\003" "\022\027\n\022WatchQueryChannels\020\376\003\022\030\n\023RemoveQuery" "Channels\020\377\003\022\035\n\030SealedSegmentsChangeInfo\020" "\200\004\022\027\n\022WatchDeltaChannels\020\201\004\022\024\n\017GetShardL" "eaders\020\202\004\022\020\n\013SegmentInfo\020\330\004\022\017\n\nSystemInf" "o\020\331\004\022\024\n\017GetRecoveryInfo\020\332\004\022\024\n\017GetSegment" "State\020\333\004\022\r\n\010TimeTick\020\260\t\022\023\n\016QueryNodeStat" "s\020\261\t\022\016\n\tLoadIndex\020\262\t\022\016\n\tRequestID\020\263\t\022\017\n\n" "RequestTSO\020\264\t\022\024\n\017AllocateSegment\020\265\t\022\026\n\021S" "egmentStatistics\020\266\t\022\025\n\020SegmentFlushDone\020" "\267\t\022\017\n\nDataNodeTt\020\270\t\022\025\n\020CreateCredential\020" "\334\013\022\022\n\rGetCredential\020\335\013\022\025\n\020DeleteCredenti" "al\020\336\013\022\025\n\020UpdateCredential\020\337\013\022\026\n\021ListCred" "Usernames\020\340\013*\"\n\007DslType\022\007\n\003Dsl\020\000\022\016\n\nBool" "ExprV1\020\001*B\n\017CompactionState\022\021\n\rUndefiedS" "tate\020\000\022\r\n\tExecuting\020\001\022\r\n\tCompleted\020\002*X\n\020" "ConsistencyLevel\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\nCustom" "ized\020\004*\227\001\n\013ImportState\022\021\n\rImportPending\020" "\000\022\020\n\014ImportFailed\020\001\022\021\n\rImportStarted\020\002\022\024" "\n\020ImportDownloaded\020\003\022\020\n\014ImportParsed\020\004\022\023" "\n\017ImportPersisted\020\005\022\023\n\017ImportCompleted\020\006" "BW\n\016io.milvus.grpcB\013CommonProtoP\001Z3githu" "b.com/milvus-io/milvus/internal/proto/co" "mmonpb\240\001\001b\006proto3" ; static const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable*const descriptor_table_common_2eproto_deps[1] = { }; static ::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase*const descriptor_table_common_2eproto_sccs[8] = { &scc_info_Address_common_2eproto.base, &scc_info_Blob_common_2eproto.base, &scc_info_DMLMsgHeader_common_2eproto.base, &scc_info_KeyDataPair_common_2eproto.base, &scc_info_KeyValuePair_common_2eproto.base, &scc_info_MsgBase_common_2eproto.base, &scc_info_MsgHeader_common_2eproto.base, &scc_info_Status_common_2eproto.base, }; static ::PROTOBUF_NAMESPACE_ID::internal::once_flag descriptor_table_common_2eproto_once; static bool descriptor_table_common_2eproto_initialized = false; const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_common_2eproto = { &descriptor_table_common_2eproto_initialized, descriptor_table_protodef_common_2eproto, "common.proto", 3297, &descriptor_table_common_2eproto_once, descriptor_table_common_2eproto_sccs, descriptor_table_common_2eproto_deps, 8, 0, schemas, file_default_instances, TableStruct_common_2eproto::offsets, file_level_metadata_common_2eproto, 8, file_level_enum_descriptors_common_2eproto, file_level_service_descriptors_common_2eproto, }; // Force running AddDescriptors() at dynamic initialization time. static bool dynamic_init_dummy_common_2eproto = ( ::PROTOBUF_NAMESPACE_ID::internal::AddDescriptors(&descriptor_table_common_2eproto), true); namespace milvus { namespace proto { namespace common { const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* ErrorCode_descriptor() { ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&descriptor_table_common_2eproto); return file_level_enum_descriptors_common_2eproto[0]; } bool ErrorCode_IsValid(int value) { switch (value) { case 0: case 1: case 2: case 3: case 4: case 5: case 7: case 8: case 9: case 10: case 11: case 12: case 13: case 14: case 15: case 16: case 17: case 18: case 19: case 20: case 21: case 22: case 23: case 24: case 25: case 26: case 27: case 28: case 29: case 30: case 31: case 32: case 33: case 1000: return true; default: return false; } } const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* IndexState_descriptor() { ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&descriptor_table_common_2eproto); return file_level_enum_descriptors_common_2eproto[1]; } bool IndexState_IsValid(int value) { switch (value) { case 0: case 1: case 2: case 3: case 4: return true; default: return false; } } const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* SegmentState_descriptor() { ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&descriptor_table_common_2eproto); return file_level_enum_descriptors_common_2eproto[2]; } bool SegmentState_IsValid(int value) { switch (value) { case 0: case 1: case 2: case 3: case 4: case 5: case 6: case 7: return true; default: return false; } } const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* MsgType_descriptor() { ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&descriptor_table_common_2eproto); return file_level_enum_descriptors_common_2eproto[3]; } bool MsgType_IsValid(int value) { switch (value) { case 0: case 100: case 101: case 102: case 103: case 104: case 105: case 106: case 107: case 108: case 109: case 110: case 200: case 201: case 202: case 203: case 204: case 205: case 206: case 250: case 251: case 252: case 253: case 254: case 255: case 256: case 300: case 301: case 302: case 400: case 401: case 402: case 500: case 501: case 502: case 503: case 504: case 505: case 506: case 507: case 508: case 509: case 510: case 511: case 512: case 513: case 514: case 600: case 601: case 602: case 603: case 1200: case 1201: case 1202: case 1203: case 1204: case 1205: case 1206: case 1207: case 1208: case 1500: case 1501: case 1502: case 1503: case 1504: return true; default: return false; } } const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* DslType_descriptor() { ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&descriptor_table_common_2eproto); return file_level_enum_descriptors_common_2eproto[4]; } bool DslType_IsValid(int value) { switch (value) { case 0: case 1: return true; default: return false; } } const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* CompactionState_descriptor() { ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&descriptor_table_common_2eproto); return file_level_enum_descriptors_common_2eproto[5]; } bool CompactionState_IsValid(int value) { switch (value) { case 0: case 1: case 2: return true; default: return false; } } const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* ConsistencyLevel_descriptor() { ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&descriptor_table_common_2eproto); return file_level_enum_descriptors_common_2eproto[6]; } bool ConsistencyLevel_IsValid(int value) { switch (value) { case 0: case 1: case 2: case 3: case 4: return true; default: return false; } } const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* ImportState_descriptor() { ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&descriptor_table_common_2eproto); return file_level_enum_descriptors_common_2eproto[7]; } bool ImportState_IsValid(int value) { switch (value) { case 0: case 1: case 2: case 3: case 4: case 5: case 6: return true; default: return false; } } // =================================================================== void Status::InitAsDefaultInstance() { } class Status::_Internal { public: }; Status::Status() : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) { SharedCtor(); // @@protoc_insertion_point(constructor:milvus.proto.common.Status) } Status::Status(const Status& from) : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) { _internal_metadata_.MergeFrom(from._internal_metadata_); reason_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); if (!from.reason().empty()) { reason_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.reason_); } error_code_ = from.error_code_; // @@protoc_insertion_point(copy_constructor:milvus.proto.common.Status) } void Status::SharedCtor() { ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_Status_common_2eproto.base); reason_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); error_code_ = 0; } Status::~Status() { // @@protoc_insertion_point(destructor:milvus.proto.common.Status) SharedDtor(); } void Status::SharedDtor() { reason_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } void Status::SetCachedSize(int size) const { _cached_size_.Set(size); } const Status& Status::default_instance() { ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_Status_common_2eproto.base); return *internal_default_instance(); } void Status::Clear() { // @@protoc_insertion_point(message_clear_start:milvus.proto.common.Status) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; reason_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); error_code_ = 0; _internal_metadata_.Clear(); } #if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER const char* Status::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) { #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure while (!ctx->Done(&ptr)) { ::PROTOBUF_NAMESPACE_ID::uint32 tag; ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag); CHK_(ptr); switch (tag >> 3) { // .milvus.proto.common.ErrorCode error_code = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 8)) { ::PROTOBUF_NAMESPACE_ID::uint64 val = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint(&ptr); CHK_(ptr); set_error_code(static_cast<::milvus::proto::common::ErrorCode>(val)); } else goto handle_unusual; continue; // string reason = 2; case 2: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) { ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParserUTF8(mutable_reason(), ptr, ctx, "milvus.proto.common.Status.reason"); CHK_(ptr); } else goto handle_unusual; continue; default: { handle_unusual: if ((tag & 7) == 4 || tag == 0) { ctx->SetLastTag(tag); goto success; } ptr = UnknownFieldParse(tag, &_internal_metadata_, ptr, ctx); CHK_(ptr != nullptr); continue; } } // switch } // while success: return ptr; failure: ptr = nullptr; goto success; #undef CHK_ } #else // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER bool Status::MergePartialFromCodedStream( ::PROTOBUF_NAMESPACE_ID::io::CodedInputStream* input) { #define DO_(EXPRESSION) if (!PROTOBUF_PREDICT_TRUE(EXPRESSION)) goto failure ::PROTOBUF_NAMESPACE_ID::uint32 tag; // @@protoc_insertion_point(parse_start:milvus.proto.common.Status) for (;;) { ::std::pair<::PROTOBUF_NAMESPACE_ID::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); tag = p.first; if (!p.second) goto handle_unusual; switch (::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::GetTagFieldNumber(tag)) { // .milvus.proto.common.ErrorCode error_code = 1; case 1: { if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (8 & 0xFF)) { int value = 0; DO_((::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadPrimitive< int, ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_ENUM>( input, &value))); set_error_code(static_cast< ::milvus::proto::common::ErrorCode >(value)); } else { goto handle_unusual; } break; } // string reason = 2; case 2: { if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (18 & 0xFF)) { DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadString( input, this->mutable_reason())); DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->reason().data(), static_cast(this->reason().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE, "milvus.proto.common.Status.reason")); } else { goto handle_unusual; } break; } default: { handle_unusual: if (tag == 0) { goto success; } DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SkipField( input, tag, _internal_metadata_.mutable_unknown_fields())); break; } } } success: // @@protoc_insertion_point(parse_success:milvus.proto.common.Status) return true; failure: // @@protoc_insertion_point(parse_failure:milvus.proto.common.Status) return false; #undef DO_ } #endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER void Status::SerializeWithCachedSizes( ::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const { // @@protoc_insertion_point(serialize_start:milvus.proto.common.Status) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // .milvus.proto.common.ErrorCode error_code = 1; if (this->error_code() != 0) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteEnum( 1, this->error_code(), output); } // string reason = 2; if (this->reason().size() > 0) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->reason().data(), static_cast(this->reason().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, "milvus.proto.common.Status.reason"); ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringMaybeAliased( 2, this->reason(), output); } if (_internal_metadata_.have_unknown_fields()) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFields( _internal_metadata_.unknown_fields(), output); } // @@protoc_insertion_point(serialize_end:milvus.proto.common.Status) } ::PROTOBUF_NAMESPACE_ID::uint8* Status::InternalSerializeWithCachedSizesToArray( ::PROTOBUF_NAMESPACE_ID::uint8* target) const { // @@protoc_insertion_point(serialize_to_array_start:milvus.proto.common.Status) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // .milvus.proto.common.ErrorCode error_code = 1; if (this->error_code() != 0) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteEnumToArray( 1, this->error_code(), target); } // string reason = 2; if (this->reason().size() > 0) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->reason().data(), static_cast(this->reason().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, "milvus.proto.common.Status.reason"); target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringToArray( 2, this->reason(), target); } if (_internal_metadata_.have_unknown_fields()) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFieldsToArray( _internal_metadata_.unknown_fields(), target); } // @@protoc_insertion_point(serialize_to_array_end:milvus.proto.common.Status) return target; } size_t Status::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:milvus.proto.common.Status) size_t total_size = 0; if (_internal_metadata_.have_unknown_fields()) { total_size += ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::ComputeUnknownFieldsSize( _internal_metadata_.unknown_fields()); } ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; // string reason = 2; if (this->reason().size() > 0) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( this->reason()); } // .milvus.proto.common.ErrorCode error_code = 1; if (this->error_code() != 0) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::EnumSize(this->error_code()); } int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size); SetCachedSize(cached_size); return total_size; } void Status::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_merge_from_start:milvus.proto.common.Status) GOOGLE_DCHECK_NE(&from, this); const Status* source = ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated( &from); if (source == nullptr) { // @@protoc_insertion_point(generalized_merge_from_cast_fail:milvus.proto.common.Status) ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this); } else { // @@protoc_insertion_point(generalized_merge_from_cast_success:milvus.proto.common.Status) MergeFrom(*source); } } void Status::MergeFrom(const Status& from) { // @@protoc_insertion_point(class_specific_merge_from_start:milvus.proto.common.Status) GOOGLE_DCHECK_NE(&from, this); _internal_metadata_.MergeFrom(from._internal_metadata_); ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; if (from.reason().size() > 0) { reason_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.reason_); } if (from.error_code() != 0) { set_error_code(from.error_code()); } } void Status::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_copy_from_start:milvus.proto.common.Status) if (&from == this) return; Clear(); MergeFrom(from); } void Status::CopyFrom(const Status& from) { // @@protoc_insertion_point(class_specific_copy_from_start:milvus.proto.common.Status) if (&from == this) return; Clear(); MergeFrom(from); } bool Status::IsInitialized() const { return true; } void Status::InternalSwap(Status* other) { using std::swap; _internal_metadata_.Swap(&other->_internal_metadata_); reason_.Swap(&other->reason_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArenaNoVirtual()); swap(error_code_, other->error_code_); } ::PROTOBUF_NAMESPACE_ID::Metadata Status::GetMetadata() const { return GetMetadataStatic(); } // =================================================================== void KeyValuePair::InitAsDefaultInstance() { } class KeyValuePair::_Internal { public: }; KeyValuePair::KeyValuePair() : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) { SharedCtor(); // @@protoc_insertion_point(constructor:milvus.proto.common.KeyValuePair) } KeyValuePair::KeyValuePair(const KeyValuePair& from) : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) { _internal_metadata_.MergeFrom(from._internal_metadata_); key_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); if (!from.key().empty()) { key_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.key_); } value_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); if (!from.value().empty()) { value_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.value_); } // @@protoc_insertion_point(copy_constructor:milvus.proto.common.KeyValuePair) } void KeyValuePair::SharedCtor() { ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_KeyValuePair_common_2eproto.base); key_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); value_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } KeyValuePair::~KeyValuePair() { // @@protoc_insertion_point(destructor:milvus.proto.common.KeyValuePair) SharedDtor(); } void KeyValuePair::SharedDtor() { key_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); value_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } void KeyValuePair::SetCachedSize(int size) const { _cached_size_.Set(size); } const KeyValuePair& KeyValuePair::default_instance() { ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_KeyValuePair_common_2eproto.base); return *internal_default_instance(); } void KeyValuePair::Clear() { // @@protoc_insertion_point(message_clear_start:milvus.proto.common.KeyValuePair) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; key_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); value_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); _internal_metadata_.Clear(); } #if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER const char* KeyValuePair::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) { #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure while (!ctx->Done(&ptr)) { ::PROTOBUF_NAMESPACE_ID::uint32 tag; ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag); CHK_(ptr); switch (tag >> 3) { // string key = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) { ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParserUTF8(mutable_key(), ptr, ctx, "milvus.proto.common.KeyValuePair.key"); CHK_(ptr); } else goto handle_unusual; continue; // string value = 2; case 2: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) { ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParserUTF8(mutable_value(), ptr, ctx, "milvus.proto.common.KeyValuePair.value"); CHK_(ptr); } else goto handle_unusual; continue; default: { handle_unusual: if ((tag & 7) == 4 || tag == 0) { ctx->SetLastTag(tag); goto success; } ptr = UnknownFieldParse(tag, &_internal_metadata_, ptr, ctx); CHK_(ptr != nullptr); continue; } } // switch } // while success: return ptr; failure: ptr = nullptr; goto success; #undef CHK_ } #else // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER bool KeyValuePair::MergePartialFromCodedStream( ::PROTOBUF_NAMESPACE_ID::io::CodedInputStream* input) { #define DO_(EXPRESSION) if (!PROTOBUF_PREDICT_TRUE(EXPRESSION)) goto failure ::PROTOBUF_NAMESPACE_ID::uint32 tag; // @@protoc_insertion_point(parse_start:milvus.proto.common.KeyValuePair) for (;;) { ::std::pair<::PROTOBUF_NAMESPACE_ID::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); tag = p.first; if (!p.second) goto handle_unusual; switch (::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::GetTagFieldNumber(tag)) { // string key = 1; case 1: { if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (10 & 0xFF)) { DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadString( input, this->mutable_key())); DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->key().data(), static_cast(this->key().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE, "milvus.proto.common.KeyValuePair.key")); } else { goto handle_unusual; } break; } // string value = 2; case 2: { if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (18 & 0xFF)) { DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadString( input, this->mutable_value())); DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->value().data(), static_cast(this->value().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE, "milvus.proto.common.KeyValuePair.value")); } else { goto handle_unusual; } break; } default: { handle_unusual: if (tag == 0) { goto success; } DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SkipField( input, tag, _internal_metadata_.mutable_unknown_fields())); break; } } } success: // @@protoc_insertion_point(parse_success:milvus.proto.common.KeyValuePair) return true; failure: // @@protoc_insertion_point(parse_failure:milvus.proto.common.KeyValuePair) return false; #undef DO_ } #endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER void KeyValuePair::SerializeWithCachedSizes( ::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const { // @@protoc_insertion_point(serialize_start:milvus.proto.common.KeyValuePair) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // string key = 1; if (this->key().size() > 0) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->key().data(), static_cast(this->key().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, "milvus.proto.common.KeyValuePair.key"); ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringMaybeAliased( 1, this->key(), output); } // string value = 2; if (this->value().size() > 0) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->value().data(), static_cast(this->value().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, "milvus.proto.common.KeyValuePair.value"); ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringMaybeAliased( 2, this->value(), output); } if (_internal_metadata_.have_unknown_fields()) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFields( _internal_metadata_.unknown_fields(), output); } // @@protoc_insertion_point(serialize_end:milvus.proto.common.KeyValuePair) } ::PROTOBUF_NAMESPACE_ID::uint8* KeyValuePair::InternalSerializeWithCachedSizesToArray( ::PROTOBUF_NAMESPACE_ID::uint8* target) const { // @@protoc_insertion_point(serialize_to_array_start:milvus.proto.common.KeyValuePair) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // string key = 1; if (this->key().size() > 0) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->key().data(), static_cast(this->key().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, "milvus.proto.common.KeyValuePair.key"); target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringToArray( 1, this->key(), target); } // string value = 2; if (this->value().size() > 0) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->value().data(), static_cast(this->value().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, "milvus.proto.common.KeyValuePair.value"); target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringToArray( 2, this->value(), target); } if (_internal_metadata_.have_unknown_fields()) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFieldsToArray( _internal_metadata_.unknown_fields(), target); } // @@protoc_insertion_point(serialize_to_array_end:milvus.proto.common.KeyValuePair) return target; } size_t KeyValuePair::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:milvus.proto.common.KeyValuePair) size_t total_size = 0; if (_internal_metadata_.have_unknown_fields()) { total_size += ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::ComputeUnknownFieldsSize( _internal_metadata_.unknown_fields()); } ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; // string key = 1; if (this->key().size() > 0) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( this->key()); } // string value = 2; if (this->value().size() > 0) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( this->value()); } int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size); SetCachedSize(cached_size); return total_size; } void KeyValuePair::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_merge_from_start:milvus.proto.common.KeyValuePair) GOOGLE_DCHECK_NE(&from, this); const KeyValuePair* source = ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated( &from); if (source == nullptr) { // @@protoc_insertion_point(generalized_merge_from_cast_fail:milvus.proto.common.KeyValuePair) ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this); } else { // @@protoc_insertion_point(generalized_merge_from_cast_success:milvus.proto.common.KeyValuePair) MergeFrom(*source); } } void KeyValuePair::MergeFrom(const KeyValuePair& from) { // @@protoc_insertion_point(class_specific_merge_from_start:milvus.proto.common.KeyValuePair) GOOGLE_DCHECK_NE(&from, this); _internal_metadata_.MergeFrom(from._internal_metadata_); ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; if (from.key().size() > 0) { key_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.key_); } if (from.value().size() > 0) { value_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.value_); } } void KeyValuePair::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_copy_from_start:milvus.proto.common.KeyValuePair) if (&from == this) return; Clear(); MergeFrom(from); } void KeyValuePair::CopyFrom(const KeyValuePair& from) { // @@protoc_insertion_point(class_specific_copy_from_start:milvus.proto.common.KeyValuePair) if (&from == this) return; Clear(); MergeFrom(from); } bool KeyValuePair::IsInitialized() const { return true; } void KeyValuePair::InternalSwap(KeyValuePair* other) { using std::swap; _internal_metadata_.Swap(&other->_internal_metadata_); key_.Swap(&other->key_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArenaNoVirtual()); value_.Swap(&other->value_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArenaNoVirtual()); } ::PROTOBUF_NAMESPACE_ID::Metadata KeyValuePair::GetMetadata() const { return GetMetadataStatic(); } // =================================================================== void KeyDataPair::InitAsDefaultInstance() { } class KeyDataPair::_Internal { public: }; KeyDataPair::KeyDataPair() : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) { SharedCtor(); // @@protoc_insertion_point(constructor:milvus.proto.common.KeyDataPair) } KeyDataPair::KeyDataPair(const KeyDataPair& from) : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) { _internal_metadata_.MergeFrom(from._internal_metadata_); key_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); if (!from.key().empty()) { key_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.key_); } data_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); if (!from.data().empty()) { data_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.data_); } // @@protoc_insertion_point(copy_constructor:milvus.proto.common.KeyDataPair) } void KeyDataPair::SharedCtor() { ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_KeyDataPair_common_2eproto.base); key_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); data_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } KeyDataPair::~KeyDataPair() { // @@protoc_insertion_point(destructor:milvus.proto.common.KeyDataPair) SharedDtor(); } void KeyDataPair::SharedDtor() { key_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); data_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } void KeyDataPair::SetCachedSize(int size) const { _cached_size_.Set(size); } const KeyDataPair& KeyDataPair::default_instance() { ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_KeyDataPair_common_2eproto.base); return *internal_default_instance(); } void KeyDataPair::Clear() { // @@protoc_insertion_point(message_clear_start:milvus.proto.common.KeyDataPair) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; key_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); data_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); _internal_metadata_.Clear(); } #if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER const char* KeyDataPair::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) { #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure while (!ctx->Done(&ptr)) { ::PROTOBUF_NAMESPACE_ID::uint32 tag; ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag); CHK_(ptr); switch (tag >> 3) { // string key = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) { ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParserUTF8(mutable_key(), ptr, ctx, "milvus.proto.common.KeyDataPair.key"); CHK_(ptr); } else goto handle_unusual; continue; // bytes data = 2; case 2: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) { ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(mutable_data(), ptr, ctx); CHK_(ptr); } else goto handle_unusual; continue; default: { handle_unusual: if ((tag & 7) == 4 || tag == 0) { ctx->SetLastTag(tag); goto success; } ptr = UnknownFieldParse(tag, &_internal_metadata_, ptr, ctx); CHK_(ptr != nullptr); continue; } } // switch } // while success: return ptr; failure: ptr = nullptr; goto success; #undef CHK_ } #else // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER bool KeyDataPair::MergePartialFromCodedStream( ::PROTOBUF_NAMESPACE_ID::io::CodedInputStream* input) { #define DO_(EXPRESSION) if (!PROTOBUF_PREDICT_TRUE(EXPRESSION)) goto failure ::PROTOBUF_NAMESPACE_ID::uint32 tag; // @@protoc_insertion_point(parse_start:milvus.proto.common.KeyDataPair) for (;;) { ::std::pair<::PROTOBUF_NAMESPACE_ID::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); tag = p.first; if (!p.second) goto handle_unusual; switch (::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::GetTagFieldNumber(tag)) { // string key = 1; case 1: { if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (10 & 0xFF)) { DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadString( input, this->mutable_key())); DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->key().data(), static_cast(this->key().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE, "milvus.proto.common.KeyDataPair.key")); } else { goto handle_unusual; } break; } // bytes data = 2; case 2: { if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (18 & 0xFF)) { DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadBytes( input, this->mutable_data())); } else { goto handle_unusual; } break; } default: { handle_unusual: if (tag == 0) { goto success; } DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SkipField( input, tag, _internal_metadata_.mutable_unknown_fields())); break; } } } success: // @@protoc_insertion_point(parse_success:milvus.proto.common.KeyDataPair) return true; failure: // @@protoc_insertion_point(parse_failure:milvus.proto.common.KeyDataPair) return false; #undef DO_ } #endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER void KeyDataPair::SerializeWithCachedSizes( ::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const { // @@protoc_insertion_point(serialize_start:milvus.proto.common.KeyDataPair) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // string key = 1; if (this->key().size() > 0) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->key().data(), static_cast(this->key().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, "milvus.proto.common.KeyDataPair.key"); ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringMaybeAliased( 1, this->key(), output); } // bytes data = 2; if (this->data().size() > 0) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteBytesMaybeAliased( 2, this->data(), output); } if (_internal_metadata_.have_unknown_fields()) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFields( _internal_metadata_.unknown_fields(), output); } // @@protoc_insertion_point(serialize_end:milvus.proto.common.KeyDataPair) } ::PROTOBUF_NAMESPACE_ID::uint8* KeyDataPair::InternalSerializeWithCachedSizesToArray( ::PROTOBUF_NAMESPACE_ID::uint8* target) const { // @@protoc_insertion_point(serialize_to_array_start:milvus.proto.common.KeyDataPair) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // string key = 1; if (this->key().size() > 0) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->key().data(), static_cast(this->key().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, "milvus.proto.common.KeyDataPair.key"); target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringToArray( 1, this->key(), target); } // bytes data = 2; if (this->data().size() > 0) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteBytesToArray( 2, this->data(), target); } if (_internal_metadata_.have_unknown_fields()) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFieldsToArray( _internal_metadata_.unknown_fields(), target); } // @@protoc_insertion_point(serialize_to_array_end:milvus.proto.common.KeyDataPair) return target; } size_t KeyDataPair::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:milvus.proto.common.KeyDataPair) size_t total_size = 0; if (_internal_metadata_.have_unknown_fields()) { total_size += ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::ComputeUnknownFieldsSize( _internal_metadata_.unknown_fields()); } ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; // string key = 1; if (this->key().size() > 0) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( this->key()); } // bytes data = 2; if (this->data().size() > 0) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( this->data()); } int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size); SetCachedSize(cached_size); return total_size; } void KeyDataPair::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_merge_from_start:milvus.proto.common.KeyDataPair) GOOGLE_DCHECK_NE(&from, this); const KeyDataPair* source = ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated( &from); if (source == nullptr) { // @@protoc_insertion_point(generalized_merge_from_cast_fail:milvus.proto.common.KeyDataPair) ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this); } else { // @@protoc_insertion_point(generalized_merge_from_cast_success:milvus.proto.common.KeyDataPair) MergeFrom(*source); } } void KeyDataPair::MergeFrom(const KeyDataPair& from) { // @@protoc_insertion_point(class_specific_merge_from_start:milvus.proto.common.KeyDataPair) GOOGLE_DCHECK_NE(&from, this); _internal_metadata_.MergeFrom(from._internal_metadata_); ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; if (from.key().size() > 0) { key_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.key_); } if (from.data().size() > 0) { data_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.data_); } } void KeyDataPair::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_copy_from_start:milvus.proto.common.KeyDataPair) if (&from == this) return; Clear(); MergeFrom(from); } void KeyDataPair::CopyFrom(const KeyDataPair& from) { // @@protoc_insertion_point(class_specific_copy_from_start:milvus.proto.common.KeyDataPair) if (&from == this) return; Clear(); MergeFrom(from); } bool KeyDataPair::IsInitialized() const { return true; } void KeyDataPair::InternalSwap(KeyDataPair* other) { using std::swap; _internal_metadata_.Swap(&other->_internal_metadata_); key_.Swap(&other->key_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArenaNoVirtual()); data_.Swap(&other->data_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArenaNoVirtual()); } ::PROTOBUF_NAMESPACE_ID::Metadata KeyDataPair::GetMetadata() const { return GetMetadataStatic(); } // =================================================================== void Blob::InitAsDefaultInstance() { } class Blob::_Internal { public: }; Blob::Blob() : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) { SharedCtor(); // @@protoc_insertion_point(constructor:milvus.proto.common.Blob) } Blob::Blob(const Blob& from) : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) { _internal_metadata_.MergeFrom(from._internal_metadata_); value_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); if (!from.value().empty()) { value_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.value_); } // @@protoc_insertion_point(copy_constructor:milvus.proto.common.Blob) } void Blob::SharedCtor() { ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_Blob_common_2eproto.base); value_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } Blob::~Blob() { // @@protoc_insertion_point(destructor:milvus.proto.common.Blob) SharedDtor(); } void Blob::SharedDtor() { value_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } void Blob::SetCachedSize(int size) const { _cached_size_.Set(size); } const Blob& Blob::default_instance() { ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_Blob_common_2eproto.base); return *internal_default_instance(); } void Blob::Clear() { // @@protoc_insertion_point(message_clear_start:milvus.proto.common.Blob) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; value_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); _internal_metadata_.Clear(); } #if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER const char* Blob::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) { #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure while (!ctx->Done(&ptr)) { ::PROTOBUF_NAMESPACE_ID::uint32 tag; ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag); CHK_(ptr); switch (tag >> 3) { // bytes value = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) { ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(mutable_value(), ptr, ctx); CHK_(ptr); } else goto handle_unusual; continue; default: { handle_unusual: if ((tag & 7) == 4 || tag == 0) { ctx->SetLastTag(tag); goto success; } ptr = UnknownFieldParse(tag, &_internal_metadata_, ptr, ctx); CHK_(ptr != nullptr); continue; } } // switch } // while success: return ptr; failure: ptr = nullptr; goto success; #undef CHK_ } #else // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER bool Blob::MergePartialFromCodedStream( ::PROTOBUF_NAMESPACE_ID::io::CodedInputStream* input) { #define DO_(EXPRESSION) if (!PROTOBUF_PREDICT_TRUE(EXPRESSION)) goto failure ::PROTOBUF_NAMESPACE_ID::uint32 tag; // @@protoc_insertion_point(parse_start:milvus.proto.common.Blob) for (;;) { ::std::pair<::PROTOBUF_NAMESPACE_ID::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); tag = p.first; if (!p.second) goto handle_unusual; switch (::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::GetTagFieldNumber(tag)) { // bytes value = 1; case 1: { if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (10 & 0xFF)) { DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadBytes( input, this->mutable_value())); } else { goto handle_unusual; } break; } default: { handle_unusual: if (tag == 0) { goto success; } DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SkipField( input, tag, _internal_metadata_.mutable_unknown_fields())); break; } } } success: // @@protoc_insertion_point(parse_success:milvus.proto.common.Blob) return true; failure: // @@protoc_insertion_point(parse_failure:milvus.proto.common.Blob) return false; #undef DO_ } #endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER void Blob::SerializeWithCachedSizes( ::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const { // @@protoc_insertion_point(serialize_start:milvus.proto.common.Blob) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // bytes value = 1; if (this->value().size() > 0) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteBytesMaybeAliased( 1, this->value(), output); } if (_internal_metadata_.have_unknown_fields()) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFields( _internal_metadata_.unknown_fields(), output); } // @@protoc_insertion_point(serialize_end:milvus.proto.common.Blob) } ::PROTOBUF_NAMESPACE_ID::uint8* Blob::InternalSerializeWithCachedSizesToArray( ::PROTOBUF_NAMESPACE_ID::uint8* target) const { // @@protoc_insertion_point(serialize_to_array_start:milvus.proto.common.Blob) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // bytes value = 1; if (this->value().size() > 0) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteBytesToArray( 1, this->value(), target); } if (_internal_metadata_.have_unknown_fields()) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFieldsToArray( _internal_metadata_.unknown_fields(), target); } // @@protoc_insertion_point(serialize_to_array_end:milvus.proto.common.Blob) return target; } size_t Blob::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:milvus.proto.common.Blob) size_t total_size = 0; if (_internal_metadata_.have_unknown_fields()) { total_size += ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::ComputeUnknownFieldsSize( _internal_metadata_.unknown_fields()); } ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; // bytes value = 1; if (this->value().size() > 0) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( this->value()); } int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size); SetCachedSize(cached_size); return total_size; } void Blob::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_merge_from_start:milvus.proto.common.Blob) GOOGLE_DCHECK_NE(&from, this); const Blob* source = ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated( &from); if (source == nullptr) { // @@protoc_insertion_point(generalized_merge_from_cast_fail:milvus.proto.common.Blob) ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this); } else { // @@protoc_insertion_point(generalized_merge_from_cast_success:milvus.proto.common.Blob) MergeFrom(*source); } } void Blob::MergeFrom(const Blob& from) { // @@protoc_insertion_point(class_specific_merge_from_start:milvus.proto.common.Blob) GOOGLE_DCHECK_NE(&from, this); _internal_metadata_.MergeFrom(from._internal_metadata_); ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; if (from.value().size() > 0) { value_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.value_); } } void Blob::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_copy_from_start:milvus.proto.common.Blob) if (&from == this) return; Clear(); MergeFrom(from); } void Blob::CopyFrom(const Blob& from) { // @@protoc_insertion_point(class_specific_copy_from_start:milvus.proto.common.Blob) if (&from == this) return; Clear(); MergeFrom(from); } bool Blob::IsInitialized() const { return true; } void Blob::InternalSwap(Blob* other) { using std::swap; _internal_metadata_.Swap(&other->_internal_metadata_); value_.Swap(&other->value_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArenaNoVirtual()); } ::PROTOBUF_NAMESPACE_ID::Metadata Blob::GetMetadata() const { return GetMetadataStatic(); } // =================================================================== void Address::InitAsDefaultInstance() { } class Address::_Internal { public: }; Address::Address() : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) { SharedCtor(); // @@protoc_insertion_point(constructor:milvus.proto.common.Address) } Address::Address(const Address& from) : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) { _internal_metadata_.MergeFrom(from._internal_metadata_); ip_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); if (!from.ip().empty()) { ip_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.ip_); } port_ = from.port_; // @@protoc_insertion_point(copy_constructor:milvus.proto.common.Address) } void Address::SharedCtor() { ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_Address_common_2eproto.base); ip_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); port_ = PROTOBUF_LONGLONG(0); } Address::~Address() { // @@protoc_insertion_point(destructor:milvus.proto.common.Address) SharedDtor(); } void Address::SharedDtor() { ip_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } void Address::SetCachedSize(int size) const { _cached_size_.Set(size); } const Address& Address::default_instance() { ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_Address_common_2eproto.base); return *internal_default_instance(); } void Address::Clear() { // @@protoc_insertion_point(message_clear_start:milvus.proto.common.Address) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; ip_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); port_ = PROTOBUF_LONGLONG(0); _internal_metadata_.Clear(); } #if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER const char* Address::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) { #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure while (!ctx->Done(&ptr)) { ::PROTOBUF_NAMESPACE_ID::uint32 tag; ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag); CHK_(ptr); switch (tag >> 3) { // string ip = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) { ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParserUTF8(mutable_ip(), ptr, ctx, "milvus.proto.common.Address.ip"); CHK_(ptr); } else goto handle_unusual; continue; // int64 port = 2; case 2: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 16)) { port_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint(&ptr); CHK_(ptr); } else goto handle_unusual; continue; default: { handle_unusual: if ((tag & 7) == 4 || tag == 0) { ctx->SetLastTag(tag); goto success; } ptr = UnknownFieldParse(tag, &_internal_metadata_, ptr, ctx); CHK_(ptr != nullptr); continue; } } // switch } // while success: return ptr; failure: ptr = nullptr; goto success; #undef CHK_ } #else // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER bool Address::MergePartialFromCodedStream( ::PROTOBUF_NAMESPACE_ID::io::CodedInputStream* input) { #define DO_(EXPRESSION) if (!PROTOBUF_PREDICT_TRUE(EXPRESSION)) goto failure ::PROTOBUF_NAMESPACE_ID::uint32 tag; // @@protoc_insertion_point(parse_start:milvus.proto.common.Address) for (;;) { ::std::pair<::PROTOBUF_NAMESPACE_ID::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); tag = p.first; if (!p.second) goto handle_unusual; switch (::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::GetTagFieldNumber(tag)) { // string ip = 1; case 1: { if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (10 & 0xFF)) { DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadString( input, this->mutable_ip())); DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->ip().data(), static_cast(this->ip().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE, "milvus.proto.common.Address.ip")); } else { goto handle_unusual; } break; } // int64 port = 2; case 2: { if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (16 & 0xFF)) { DO_((::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadPrimitive< ::PROTOBUF_NAMESPACE_ID::int64, ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_INT64>( input, &port_))); } else { goto handle_unusual; } break; } default: { handle_unusual: if (tag == 0) { goto success; } DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SkipField( input, tag, _internal_metadata_.mutable_unknown_fields())); break; } } } success: // @@protoc_insertion_point(parse_success:milvus.proto.common.Address) return true; failure: // @@protoc_insertion_point(parse_failure:milvus.proto.common.Address) return false; #undef DO_ } #endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER void Address::SerializeWithCachedSizes( ::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const { // @@protoc_insertion_point(serialize_start:milvus.proto.common.Address) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // string ip = 1; if (this->ip().size() > 0) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->ip().data(), static_cast(this->ip().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, "milvus.proto.common.Address.ip"); ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringMaybeAliased( 1, this->ip(), output); } // int64 port = 2; if (this->port() != 0) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteInt64(2, this->port(), output); } if (_internal_metadata_.have_unknown_fields()) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFields( _internal_metadata_.unknown_fields(), output); } // @@protoc_insertion_point(serialize_end:milvus.proto.common.Address) } ::PROTOBUF_NAMESPACE_ID::uint8* Address::InternalSerializeWithCachedSizesToArray( ::PROTOBUF_NAMESPACE_ID::uint8* target) const { // @@protoc_insertion_point(serialize_to_array_start:milvus.proto.common.Address) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // string ip = 1; if (this->ip().size() > 0) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->ip().data(), static_cast(this->ip().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, "milvus.proto.common.Address.ip"); target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringToArray( 1, this->ip(), target); } // int64 port = 2; if (this->port() != 0) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteInt64ToArray(2, this->port(), target); } if (_internal_metadata_.have_unknown_fields()) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFieldsToArray( _internal_metadata_.unknown_fields(), target); } // @@protoc_insertion_point(serialize_to_array_end:milvus.proto.common.Address) return target; } size_t Address::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:milvus.proto.common.Address) size_t total_size = 0; if (_internal_metadata_.have_unknown_fields()) { total_size += ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::ComputeUnknownFieldsSize( _internal_metadata_.unknown_fields()); } ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; // string ip = 1; if (this->ip().size() > 0) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( this->ip()); } // int64 port = 2; if (this->port() != 0) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::Int64Size( this->port()); } int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size); SetCachedSize(cached_size); return total_size; } void Address::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_merge_from_start:milvus.proto.common.Address) GOOGLE_DCHECK_NE(&from, this); const Address* source = ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated
( &from); if (source == nullptr) { // @@protoc_insertion_point(generalized_merge_from_cast_fail:milvus.proto.common.Address) ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this); } else { // @@protoc_insertion_point(generalized_merge_from_cast_success:milvus.proto.common.Address) MergeFrom(*source); } } void Address::MergeFrom(const Address& from) { // @@protoc_insertion_point(class_specific_merge_from_start:milvus.proto.common.Address) GOOGLE_DCHECK_NE(&from, this); _internal_metadata_.MergeFrom(from._internal_metadata_); ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; if (from.ip().size() > 0) { ip_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.ip_); } if (from.port() != 0) { set_port(from.port()); } } void Address::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_copy_from_start:milvus.proto.common.Address) if (&from == this) return; Clear(); MergeFrom(from); } void Address::CopyFrom(const Address& from) { // @@protoc_insertion_point(class_specific_copy_from_start:milvus.proto.common.Address) if (&from == this) return; Clear(); MergeFrom(from); } bool Address::IsInitialized() const { return true; } void Address::InternalSwap(Address* other) { using std::swap; _internal_metadata_.Swap(&other->_internal_metadata_); ip_.Swap(&other->ip_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArenaNoVirtual()); swap(port_, other->port_); } ::PROTOBUF_NAMESPACE_ID::Metadata Address::GetMetadata() const { return GetMetadataStatic(); } // =================================================================== void MsgBase::InitAsDefaultInstance() { } class MsgBase::_Internal { public: }; MsgBase::MsgBase() : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) { SharedCtor(); // @@protoc_insertion_point(constructor:milvus.proto.common.MsgBase) } MsgBase::MsgBase(const MsgBase& from) : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) { _internal_metadata_.MergeFrom(from._internal_metadata_); ::memcpy(&msgid_, &from.msgid_, static_cast(reinterpret_cast(&msg_type_) - reinterpret_cast(&msgid_)) + sizeof(msg_type_)); // @@protoc_insertion_point(copy_constructor:milvus.proto.common.MsgBase) } void MsgBase::SharedCtor() { ::memset(&msgid_, 0, static_cast( reinterpret_cast(&msg_type_) - reinterpret_cast(&msgid_)) + sizeof(msg_type_)); } MsgBase::~MsgBase() { // @@protoc_insertion_point(destructor:milvus.proto.common.MsgBase) SharedDtor(); } void MsgBase::SharedDtor() { } void MsgBase::SetCachedSize(int size) const { _cached_size_.Set(size); } const MsgBase& MsgBase::default_instance() { ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_MsgBase_common_2eproto.base); return *internal_default_instance(); } void MsgBase::Clear() { // @@protoc_insertion_point(message_clear_start:milvus.proto.common.MsgBase) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; ::memset(&msgid_, 0, static_cast( reinterpret_cast(&msg_type_) - reinterpret_cast(&msgid_)) + sizeof(msg_type_)); _internal_metadata_.Clear(); } #if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER const char* MsgBase::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) { #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure while (!ctx->Done(&ptr)) { ::PROTOBUF_NAMESPACE_ID::uint32 tag; ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag); CHK_(ptr); switch (tag >> 3) { // .milvus.proto.common.MsgType msg_type = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 8)) { ::PROTOBUF_NAMESPACE_ID::uint64 val = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint(&ptr); CHK_(ptr); set_msg_type(static_cast<::milvus::proto::common::MsgType>(val)); } else goto handle_unusual; continue; // int64 msgID = 2; case 2: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 16)) { msgid_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint(&ptr); CHK_(ptr); } else goto handle_unusual; continue; // uint64 timestamp = 3; case 3: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 24)) { timestamp_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint(&ptr); CHK_(ptr); } else goto handle_unusual; continue; // int64 sourceID = 4; case 4: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 32)) { sourceid_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint(&ptr); CHK_(ptr); } else goto handle_unusual; continue; default: { handle_unusual: if ((tag & 7) == 4 || tag == 0) { ctx->SetLastTag(tag); goto success; } ptr = UnknownFieldParse(tag, &_internal_metadata_, ptr, ctx); CHK_(ptr != nullptr); continue; } } // switch } // while success: return ptr; failure: ptr = nullptr; goto success; #undef CHK_ } #else // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER bool MsgBase::MergePartialFromCodedStream( ::PROTOBUF_NAMESPACE_ID::io::CodedInputStream* input) { #define DO_(EXPRESSION) if (!PROTOBUF_PREDICT_TRUE(EXPRESSION)) goto failure ::PROTOBUF_NAMESPACE_ID::uint32 tag; // @@protoc_insertion_point(parse_start:milvus.proto.common.MsgBase) for (;;) { ::std::pair<::PROTOBUF_NAMESPACE_ID::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); tag = p.first; if (!p.second) goto handle_unusual; switch (::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::GetTagFieldNumber(tag)) { // .milvus.proto.common.MsgType msg_type = 1; case 1: { if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (8 & 0xFF)) { int value = 0; DO_((::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadPrimitive< int, ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_ENUM>( input, &value))); set_msg_type(static_cast< ::milvus::proto::common::MsgType >(value)); } else { goto handle_unusual; } break; } // int64 msgID = 2; case 2: { if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (16 & 0xFF)) { DO_((::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadPrimitive< ::PROTOBUF_NAMESPACE_ID::int64, ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_INT64>( input, &msgid_))); } else { goto handle_unusual; } break; } // uint64 timestamp = 3; case 3: { if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (24 & 0xFF)) { DO_((::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadPrimitive< ::PROTOBUF_NAMESPACE_ID::uint64, ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_UINT64>( input, ×tamp_))); } else { goto handle_unusual; } break; } // int64 sourceID = 4; case 4: { if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (32 & 0xFF)) { DO_((::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadPrimitive< ::PROTOBUF_NAMESPACE_ID::int64, ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_INT64>( input, &sourceid_))); } else { goto handle_unusual; } break; } default: { handle_unusual: if (tag == 0) { goto success; } DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SkipField( input, tag, _internal_metadata_.mutable_unknown_fields())); break; } } } success: // @@protoc_insertion_point(parse_success:milvus.proto.common.MsgBase) return true; failure: // @@protoc_insertion_point(parse_failure:milvus.proto.common.MsgBase) return false; #undef DO_ } #endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER void MsgBase::SerializeWithCachedSizes( ::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const { // @@protoc_insertion_point(serialize_start:milvus.proto.common.MsgBase) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // .milvus.proto.common.MsgType msg_type = 1; if (this->msg_type() != 0) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteEnum( 1, this->msg_type(), output); } // int64 msgID = 2; if (this->msgid() != 0) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteInt64(2, this->msgid(), output); } // uint64 timestamp = 3; if (this->timestamp() != 0) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteUInt64(3, this->timestamp(), output); } // int64 sourceID = 4; if (this->sourceid() != 0) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteInt64(4, this->sourceid(), output); } if (_internal_metadata_.have_unknown_fields()) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFields( _internal_metadata_.unknown_fields(), output); } // @@protoc_insertion_point(serialize_end:milvus.proto.common.MsgBase) } ::PROTOBUF_NAMESPACE_ID::uint8* MsgBase::InternalSerializeWithCachedSizesToArray( ::PROTOBUF_NAMESPACE_ID::uint8* target) const { // @@protoc_insertion_point(serialize_to_array_start:milvus.proto.common.MsgBase) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // .milvus.proto.common.MsgType msg_type = 1; if (this->msg_type() != 0) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteEnumToArray( 1, this->msg_type(), target); } // int64 msgID = 2; if (this->msgid() != 0) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteInt64ToArray(2, this->msgid(), target); } // uint64 timestamp = 3; if (this->timestamp() != 0) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteUInt64ToArray(3, this->timestamp(), target); } // int64 sourceID = 4; if (this->sourceid() != 0) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteInt64ToArray(4, this->sourceid(), target); } if (_internal_metadata_.have_unknown_fields()) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFieldsToArray( _internal_metadata_.unknown_fields(), target); } // @@protoc_insertion_point(serialize_to_array_end:milvus.proto.common.MsgBase) return target; } size_t MsgBase::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:milvus.proto.common.MsgBase) size_t total_size = 0; if (_internal_metadata_.have_unknown_fields()) { total_size += ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::ComputeUnknownFieldsSize( _internal_metadata_.unknown_fields()); } ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; // int64 msgID = 2; if (this->msgid() != 0) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::Int64Size( this->msgid()); } // uint64 timestamp = 3; if (this->timestamp() != 0) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::UInt64Size( this->timestamp()); } // int64 sourceID = 4; if (this->sourceid() != 0) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::Int64Size( this->sourceid()); } // .milvus.proto.common.MsgType msg_type = 1; if (this->msg_type() != 0) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::EnumSize(this->msg_type()); } int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size); SetCachedSize(cached_size); return total_size; } void MsgBase::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_merge_from_start:milvus.proto.common.MsgBase) GOOGLE_DCHECK_NE(&from, this); const MsgBase* source = ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated( &from); if (source == nullptr) { // @@protoc_insertion_point(generalized_merge_from_cast_fail:milvus.proto.common.MsgBase) ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this); } else { // @@protoc_insertion_point(generalized_merge_from_cast_success:milvus.proto.common.MsgBase) MergeFrom(*source); } } void MsgBase::MergeFrom(const MsgBase& from) { // @@protoc_insertion_point(class_specific_merge_from_start:milvus.proto.common.MsgBase) GOOGLE_DCHECK_NE(&from, this); _internal_metadata_.MergeFrom(from._internal_metadata_); ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; if (from.msgid() != 0) { set_msgid(from.msgid()); } if (from.timestamp() != 0) { set_timestamp(from.timestamp()); } if (from.sourceid() != 0) { set_sourceid(from.sourceid()); } if (from.msg_type() != 0) { set_msg_type(from.msg_type()); } } void MsgBase::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_copy_from_start:milvus.proto.common.MsgBase) if (&from == this) return; Clear(); MergeFrom(from); } void MsgBase::CopyFrom(const MsgBase& from) { // @@protoc_insertion_point(class_specific_copy_from_start:milvus.proto.common.MsgBase) if (&from == this) return; Clear(); MergeFrom(from); } bool MsgBase::IsInitialized() const { return true; } void MsgBase::InternalSwap(MsgBase* other) { using std::swap; _internal_metadata_.Swap(&other->_internal_metadata_); swap(msgid_, other->msgid_); swap(timestamp_, other->timestamp_); swap(sourceid_, other->sourceid_); swap(msg_type_, other->msg_type_); } ::PROTOBUF_NAMESPACE_ID::Metadata MsgBase::GetMetadata() const { return GetMetadataStatic(); } // =================================================================== void MsgHeader::InitAsDefaultInstance() { ::milvus::proto::common::_MsgHeader_default_instance_._instance.get_mutable()->base_ = const_cast< ::milvus::proto::common::MsgBase*>( ::milvus::proto::common::MsgBase::internal_default_instance()); } class MsgHeader::_Internal { public: static const ::milvus::proto::common::MsgBase& base(const MsgHeader* msg); }; const ::milvus::proto::common::MsgBase& MsgHeader::_Internal::base(const MsgHeader* msg) { return *msg->base_; } MsgHeader::MsgHeader() : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) { SharedCtor(); // @@protoc_insertion_point(constructor:milvus.proto.common.MsgHeader) } MsgHeader::MsgHeader(const MsgHeader& from) : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) { _internal_metadata_.MergeFrom(from._internal_metadata_); if (from.has_base()) { base_ = new ::milvus::proto::common::MsgBase(*from.base_); } else { base_ = nullptr; } // @@protoc_insertion_point(copy_constructor:milvus.proto.common.MsgHeader) } void MsgHeader::SharedCtor() { ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_MsgHeader_common_2eproto.base); base_ = nullptr; } MsgHeader::~MsgHeader() { // @@protoc_insertion_point(destructor:milvus.proto.common.MsgHeader) SharedDtor(); } void MsgHeader::SharedDtor() { if (this != internal_default_instance()) delete base_; } void MsgHeader::SetCachedSize(int size) const { _cached_size_.Set(size); } const MsgHeader& MsgHeader::default_instance() { ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_MsgHeader_common_2eproto.base); return *internal_default_instance(); } void MsgHeader::Clear() { // @@protoc_insertion_point(message_clear_start:milvus.proto.common.MsgHeader) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; if (GetArenaNoVirtual() == nullptr && base_ != nullptr) { delete base_; } base_ = nullptr; _internal_metadata_.Clear(); } #if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER const char* MsgHeader::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) { #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure while (!ctx->Done(&ptr)) { ::PROTOBUF_NAMESPACE_ID::uint32 tag; ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag); CHK_(ptr); switch (tag >> 3) { // .milvus.proto.common.MsgBase base = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) { ptr = ctx->ParseMessage(mutable_base(), ptr); CHK_(ptr); } else goto handle_unusual; continue; default: { handle_unusual: if ((tag & 7) == 4 || tag == 0) { ctx->SetLastTag(tag); goto success; } ptr = UnknownFieldParse(tag, &_internal_metadata_, ptr, ctx); CHK_(ptr != nullptr); continue; } } // switch } // while success: return ptr; failure: ptr = nullptr; goto success; #undef CHK_ } #else // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER bool MsgHeader::MergePartialFromCodedStream( ::PROTOBUF_NAMESPACE_ID::io::CodedInputStream* input) { #define DO_(EXPRESSION) if (!PROTOBUF_PREDICT_TRUE(EXPRESSION)) goto failure ::PROTOBUF_NAMESPACE_ID::uint32 tag; // @@protoc_insertion_point(parse_start:milvus.proto.common.MsgHeader) for (;;) { ::std::pair<::PROTOBUF_NAMESPACE_ID::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); tag = p.first; if (!p.second) goto handle_unusual; switch (::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::GetTagFieldNumber(tag)) { // .milvus.proto.common.MsgBase base = 1; case 1: { if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (10 & 0xFF)) { DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadMessage( input, mutable_base())); } else { goto handle_unusual; } break; } default: { handle_unusual: if (tag == 0) { goto success; } DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SkipField( input, tag, _internal_metadata_.mutable_unknown_fields())); break; } } } success: // @@protoc_insertion_point(parse_success:milvus.proto.common.MsgHeader) return true; failure: // @@protoc_insertion_point(parse_failure:milvus.proto.common.MsgHeader) return false; #undef DO_ } #endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER void MsgHeader::SerializeWithCachedSizes( ::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const { // @@protoc_insertion_point(serialize_start:milvus.proto.common.MsgHeader) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // .milvus.proto.common.MsgBase base = 1; if (this->has_base()) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteMessageMaybeToArray( 1, _Internal::base(this), output); } if (_internal_metadata_.have_unknown_fields()) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFields( _internal_metadata_.unknown_fields(), output); } // @@protoc_insertion_point(serialize_end:milvus.proto.common.MsgHeader) } ::PROTOBUF_NAMESPACE_ID::uint8* MsgHeader::InternalSerializeWithCachedSizesToArray( ::PROTOBUF_NAMESPACE_ID::uint8* target) const { // @@protoc_insertion_point(serialize_to_array_start:milvus.proto.common.MsgHeader) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // .milvus.proto.common.MsgBase base = 1; if (this->has_base()) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: InternalWriteMessageToArray( 1, _Internal::base(this), target); } if (_internal_metadata_.have_unknown_fields()) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFieldsToArray( _internal_metadata_.unknown_fields(), target); } // @@protoc_insertion_point(serialize_to_array_end:milvus.proto.common.MsgHeader) return target; } size_t MsgHeader::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:milvus.proto.common.MsgHeader) size_t total_size = 0; if (_internal_metadata_.have_unknown_fields()) { total_size += ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::ComputeUnknownFieldsSize( _internal_metadata_.unknown_fields()); } ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; // .milvus.proto.common.MsgBase base = 1; if (this->has_base()) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( *base_); } int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size); SetCachedSize(cached_size); return total_size; } void MsgHeader::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_merge_from_start:milvus.proto.common.MsgHeader) GOOGLE_DCHECK_NE(&from, this); const MsgHeader* source = ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated( &from); if (source == nullptr) { // @@protoc_insertion_point(generalized_merge_from_cast_fail:milvus.proto.common.MsgHeader) ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this); } else { // @@protoc_insertion_point(generalized_merge_from_cast_success:milvus.proto.common.MsgHeader) MergeFrom(*source); } } void MsgHeader::MergeFrom(const MsgHeader& from) { // @@protoc_insertion_point(class_specific_merge_from_start:milvus.proto.common.MsgHeader) GOOGLE_DCHECK_NE(&from, this); _internal_metadata_.MergeFrom(from._internal_metadata_); ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; if (from.has_base()) { mutable_base()->::milvus::proto::common::MsgBase::MergeFrom(from.base()); } } void MsgHeader::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_copy_from_start:milvus.proto.common.MsgHeader) if (&from == this) return; Clear(); MergeFrom(from); } void MsgHeader::CopyFrom(const MsgHeader& from) { // @@protoc_insertion_point(class_specific_copy_from_start:milvus.proto.common.MsgHeader) if (&from == this) return; Clear(); MergeFrom(from); } bool MsgHeader::IsInitialized() const { return true; } void MsgHeader::InternalSwap(MsgHeader* other) { using std::swap; _internal_metadata_.Swap(&other->_internal_metadata_); swap(base_, other->base_); } ::PROTOBUF_NAMESPACE_ID::Metadata MsgHeader::GetMetadata() const { return GetMetadataStatic(); } // =================================================================== void DMLMsgHeader::InitAsDefaultInstance() { ::milvus::proto::common::_DMLMsgHeader_default_instance_._instance.get_mutable()->base_ = const_cast< ::milvus::proto::common::MsgBase*>( ::milvus::proto::common::MsgBase::internal_default_instance()); } class DMLMsgHeader::_Internal { public: static const ::milvus::proto::common::MsgBase& base(const DMLMsgHeader* msg); }; const ::milvus::proto::common::MsgBase& DMLMsgHeader::_Internal::base(const DMLMsgHeader* msg) { return *msg->base_; } DMLMsgHeader::DMLMsgHeader() : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) { SharedCtor(); // @@protoc_insertion_point(constructor:milvus.proto.common.DMLMsgHeader) } DMLMsgHeader::DMLMsgHeader(const DMLMsgHeader& from) : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) { _internal_metadata_.MergeFrom(from._internal_metadata_); shardname_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); if (!from.shardname().empty()) { shardname_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.shardname_); } if (from.has_base()) { base_ = new ::milvus::proto::common::MsgBase(*from.base_); } else { base_ = nullptr; } // @@protoc_insertion_point(copy_constructor:milvus.proto.common.DMLMsgHeader) } void DMLMsgHeader::SharedCtor() { ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_DMLMsgHeader_common_2eproto.base); shardname_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); base_ = nullptr; } DMLMsgHeader::~DMLMsgHeader() { // @@protoc_insertion_point(destructor:milvus.proto.common.DMLMsgHeader) SharedDtor(); } void DMLMsgHeader::SharedDtor() { shardname_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); if (this != internal_default_instance()) delete base_; } void DMLMsgHeader::SetCachedSize(int size) const { _cached_size_.Set(size); } const DMLMsgHeader& DMLMsgHeader::default_instance() { ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_DMLMsgHeader_common_2eproto.base); return *internal_default_instance(); } void DMLMsgHeader::Clear() { // @@protoc_insertion_point(message_clear_start:milvus.proto.common.DMLMsgHeader) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; shardname_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); if (GetArenaNoVirtual() == nullptr && base_ != nullptr) { delete base_; } base_ = nullptr; _internal_metadata_.Clear(); } #if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER const char* DMLMsgHeader::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) { #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure while (!ctx->Done(&ptr)) { ::PROTOBUF_NAMESPACE_ID::uint32 tag; ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag); CHK_(ptr); switch (tag >> 3) { // .milvus.proto.common.MsgBase base = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) { ptr = ctx->ParseMessage(mutable_base(), ptr); CHK_(ptr); } else goto handle_unusual; continue; // string shardName = 2; case 2: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) { ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParserUTF8(mutable_shardname(), ptr, ctx, "milvus.proto.common.DMLMsgHeader.shardName"); CHK_(ptr); } else goto handle_unusual; continue; default: { handle_unusual: if ((tag & 7) == 4 || tag == 0) { ctx->SetLastTag(tag); goto success; } ptr = UnknownFieldParse(tag, &_internal_metadata_, ptr, ctx); CHK_(ptr != nullptr); continue; } } // switch } // while success: return ptr; failure: ptr = nullptr; goto success; #undef CHK_ } #else // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER bool DMLMsgHeader::MergePartialFromCodedStream( ::PROTOBUF_NAMESPACE_ID::io::CodedInputStream* input) { #define DO_(EXPRESSION) if (!PROTOBUF_PREDICT_TRUE(EXPRESSION)) goto failure ::PROTOBUF_NAMESPACE_ID::uint32 tag; // @@protoc_insertion_point(parse_start:milvus.proto.common.DMLMsgHeader) for (;;) { ::std::pair<::PROTOBUF_NAMESPACE_ID::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); tag = p.first; if (!p.second) goto handle_unusual; switch (::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::GetTagFieldNumber(tag)) { // .milvus.proto.common.MsgBase base = 1; case 1: { if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (10 & 0xFF)) { DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadMessage( input, mutable_base())); } else { goto handle_unusual; } break; } // string shardName = 2; case 2: { if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (18 & 0xFF)) { DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadString( input, this->mutable_shardname())); DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->shardname().data(), static_cast(this->shardname().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE, "milvus.proto.common.DMLMsgHeader.shardName")); } else { goto handle_unusual; } break; } default: { handle_unusual: if (tag == 0) { goto success; } DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SkipField( input, tag, _internal_metadata_.mutable_unknown_fields())); break; } } } success: // @@protoc_insertion_point(parse_success:milvus.proto.common.DMLMsgHeader) return true; failure: // @@protoc_insertion_point(parse_failure:milvus.proto.common.DMLMsgHeader) return false; #undef DO_ } #endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER void DMLMsgHeader::SerializeWithCachedSizes( ::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const { // @@protoc_insertion_point(serialize_start:milvus.proto.common.DMLMsgHeader) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // .milvus.proto.common.MsgBase base = 1; if (this->has_base()) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteMessageMaybeToArray( 1, _Internal::base(this), output); } // string shardName = 2; if (this->shardname().size() > 0) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->shardname().data(), static_cast(this->shardname().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, "milvus.proto.common.DMLMsgHeader.shardName"); ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringMaybeAliased( 2, this->shardname(), output); } if (_internal_metadata_.have_unknown_fields()) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFields( _internal_metadata_.unknown_fields(), output); } // @@protoc_insertion_point(serialize_end:milvus.proto.common.DMLMsgHeader) } ::PROTOBUF_NAMESPACE_ID::uint8* DMLMsgHeader::InternalSerializeWithCachedSizesToArray( ::PROTOBUF_NAMESPACE_ID::uint8* target) const { // @@protoc_insertion_point(serialize_to_array_start:milvus.proto.common.DMLMsgHeader) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // .milvus.proto.common.MsgBase base = 1; if (this->has_base()) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: InternalWriteMessageToArray( 1, _Internal::base(this), target); } // string shardName = 2; if (this->shardname().size() > 0) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->shardname().data(), static_cast(this->shardname().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, "milvus.proto.common.DMLMsgHeader.shardName"); target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringToArray( 2, this->shardname(), target); } if (_internal_metadata_.have_unknown_fields()) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFieldsToArray( _internal_metadata_.unknown_fields(), target); } // @@protoc_insertion_point(serialize_to_array_end:milvus.proto.common.DMLMsgHeader) return target; } size_t DMLMsgHeader::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:milvus.proto.common.DMLMsgHeader) size_t total_size = 0; if (_internal_metadata_.have_unknown_fields()) { total_size += ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::ComputeUnknownFieldsSize( _internal_metadata_.unknown_fields()); } ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; // string shardName = 2; if (this->shardname().size() > 0) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( this->shardname()); } // .milvus.proto.common.MsgBase base = 1; if (this->has_base()) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( *base_); } int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size); SetCachedSize(cached_size); return total_size; } void DMLMsgHeader::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_merge_from_start:milvus.proto.common.DMLMsgHeader) GOOGLE_DCHECK_NE(&from, this); const DMLMsgHeader* source = ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated( &from); if (source == nullptr) { // @@protoc_insertion_point(generalized_merge_from_cast_fail:milvus.proto.common.DMLMsgHeader) ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this); } else { // @@protoc_insertion_point(generalized_merge_from_cast_success:milvus.proto.common.DMLMsgHeader) MergeFrom(*source); } } void DMLMsgHeader::MergeFrom(const DMLMsgHeader& from) { // @@protoc_insertion_point(class_specific_merge_from_start:milvus.proto.common.DMLMsgHeader) GOOGLE_DCHECK_NE(&from, this); _internal_metadata_.MergeFrom(from._internal_metadata_); ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; if (from.shardname().size() > 0) { shardname_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.shardname_); } if (from.has_base()) { mutable_base()->::milvus::proto::common::MsgBase::MergeFrom(from.base()); } } void DMLMsgHeader::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_copy_from_start:milvus.proto.common.DMLMsgHeader) if (&from == this) return; Clear(); MergeFrom(from); } void DMLMsgHeader::CopyFrom(const DMLMsgHeader& from) { // @@protoc_insertion_point(class_specific_copy_from_start:milvus.proto.common.DMLMsgHeader) if (&from == this) return; Clear(); MergeFrom(from); } bool DMLMsgHeader::IsInitialized() const { return true; } void DMLMsgHeader::InternalSwap(DMLMsgHeader* other) { using std::swap; _internal_metadata_.Swap(&other->_internal_metadata_); shardname_.Swap(&other->shardname_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArenaNoVirtual()); swap(base_, other->base_); } ::PROTOBUF_NAMESPACE_ID::Metadata DMLMsgHeader::GetMetadata() const { return GetMetadataStatic(); } // @@protoc_insertion_point(namespace_scope) } // namespace common } // namespace proto } // namespace milvus PROTOBUF_NAMESPACE_OPEN template<> PROTOBUF_NOINLINE ::milvus::proto::common::Status* Arena::CreateMaybeMessage< ::milvus::proto::common::Status >(Arena* arena) { return Arena::CreateInternal< ::milvus::proto::common::Status >(arena); } template<> PROTOBUF_NOINLINE ::milvus::proto::common::KeyValuePair* Arena::CreateMaybeMessage< ::milvus::proto::common::KeyValuePair >(Arena* arena) { return Arena::CreateInternal< ::milvus::proto::common::KeyValuePair >(arena); } template<> PROTOBUF_NOINLINE ::milvus::proto::common::KeyDataPair* Arena::CreateMaybeMessage< ::milvus::proto::common::KeyDataPair >(Arena* arena) { return Arena::CreateInternal< ::milvus::proto::common::KeyDataPair >(arena); } template<> PROTOBUF_NOINLINE ::milvus::proto::common::Blob* Arena::CreateMaybeMessage< ::milvus::proto::common::Blob >(Arena* arena) { return Arena::CreateInternal< ::milvus::proto::common::Blob >(arena); } template<> PROTOBUF_NOINLINE ::milvus::proto::common::Address* Arena::CreateMaybeMessage< ::milvus::proto::common::Address >(Arena* arena) { return Arena::CreateInternal< ::milvus::proto::common::Address >(arena); } template<> PROTOBUF_NOINLINE ::milvus::proto::common::MsgBase* Arena::CreateMaybeMessage< ::milvus::proto::common::MsgBase >(Arena* arena) { return Arena::CreateInternal< ::milvus::proto::common::MsgBase >(arena); } template<> PROTOBUF_NOINLINE ::milvus::proto::common::MsgHeader* Arena::CreateMaybeMessage< ::milvus::proto::common::MsgHeader >(Arena* arena) { return Arena::CreateInternal< ::milvus::proto::common::MsgHeader >(arena); } template<> PROTOBUF_NOINLINE ::milvus::proto::common::DMLMsgHeader* Arena::CreateMaybeMessage< ::milvus::proto::common::DMLMsgHeader >(Arena* arena) { return Arena::CreateInternal< ::milvus::proto::common::DMLMsgHeader >(arena); } PROTOBUF_NAMESPACE_CLOSE // @@protoc_insertion_point(global_scope) #include