Add dummy RPC (#5376)

Adding a dummy RPC makes it easier to develop new RPCs in the future.
When developing a new function, the SDK is often implemented last. 
At this time, this is helpful for debugging.

Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
pull/5402/head
Xiangyu Wang 2021-05-25 14:44:43 +08:00 committed by GitHub
parent dab536a6cf
commit 88b42304ef
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
6 changed files with 1385 additions and 232 deletions

View File

@ -234,6 +234,14 @@ class GetQuerySegmentInfoResponseDefaultTypeInternal {
public:
::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<GetQuerySegmentInfoResponse> _instance;
} _GetQuerySegmentInfoResponse_default_instance_;
class DummyRequestDefaultTypeInternal {
public:
::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<DummyRequest> _instance;
} _DummyRequest_default_instance_;
class DummyResponseDefaultTypeInternal {
public:
::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<DummyResponse> _instance;
} _DummyResponse_default_instance_;
class RegisterLinkRequestDefaultTypeInternal {
public:
::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<RegisterLinkRequest> _instance;
@ -443,6 +451,34 @@ static void InitDefaultsscc_info_DropPartitionRequest_milvus_2eproto() {
{{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 1, InitDefaultsscc_info_DropPartitionRequest_milvus_2eproto}, {
&scc_info_MsgBase_common_2eproto.base,}};
static void InitDefaultsscc_info_DummyRequest_milvus_2eproto() {
GOOGLE_PROTOBUF_VERIFY_VERSION;
{
void* ptr = &::milvus::proto::milvus::_DummyRequest_default_instance_;
new (ptr) ::milvus::proto::milvus::DummyRequest();
::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr);
}
::milvus::proto::milvus::DummyRequest::InitAsDefaultInstance();
}
::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_DummyRequest_milvus_2eproto =
{{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsscc_info_DummyRequest_milvus_2eproto}, {}};
static void InitDefaultsscc_info_DummyResponse_milvus_2eproto() {
GOOGLE_PROTOBUF_VERIFY_VERSION;
{
void* ptr = &::milvus::proto::milvus::_DummyResponse_default_instance_;
new (ptr) ::milvus::proto::milvus::DummyResponse();
::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr);
}
::milvus::proto::milvus::DummyResponse::InitAsDefaultInstance();
}
::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_DummyResponse_milvus_2eproto =
{{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsscc_info_DummyResponse_milvus_2eproto}, {}};
static void InitDefaultsscc_info_FlushRequest_milvus_2eproto() {
GOOGLE_PROTOBUF_VERIFY_VERSION;
@ -1048,7 +1084,7 @@ static void InitDefaultsscc_info_StringResponse_milvus_2eproto() {
{{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 1, InitDefaultsscc_info_StringResponse_milvus_2eproto}, {
&scc_info_Status_common_2eproto.base,}};
static ::PROTOBUF_NAMESPACE_ID::Metadata file_level_metadata_milvus_2eproto[53];
static ::PROTOBUF_NAMESPACE_ID::Metadata file_level_metadata_milvus_2eproto[55];
static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* file_level_enum_descriptors_milvus_2eproto[1];
static constexpr ::PROTOBUF_NAMESPACE_ID::ServiceDescriptor const** file_level_service_descriptors_milvus_2eproto = nullptr;
@ -1492,6 +1528,18 @@ const ::PROTOBUF_NAMESPACE_ID::uint32 TableStruct_milvus_2eproto::offsets[] PROT
PROTOBUF_FIELD_OFFSET(::milvus::proto::milvus::GetQuerySegmentInfoResponse, status_),
PROTOBUF_FIELD_OFFSET(::milvus::proto::milvus::GetQuerySegmentInfoResponse, infos_),
~0u, // no _has_bits_
PROTOBUF_FIELD_OFFSET(::milvus::proto::milvus::DummyRequest, _internal_metadata_),
~0u, // no _extensions_
~0u, // no _oneof_case_
~0u, // no _weak_field_map_
PROTOBUF_FIELD_OFFSET(::milvus::proto::milvus::DummyRequest, request_type_),
~0u, // no _has_bits_
PROTOBUF_FIELD_OFFSET(::milvus::proto::milvus::DummyResponse, _internal_metadata_),
~0u, // no _extensions_
~0u, // no _oneof_case_
~0u, // no _weak_field_map_
PROTOBUF_FIELD_OFFSET(::milvus::proto::milvus::DummyResponse, response_),
~0u, // no _has_bits_
PROTOBUF_FIELD_OFFSET(::milvus::proto::milvus::RegisterLinkRequest, _internal_metadata_),
~0u, // no _extensions_
~0u, // no _oneof_case_
@ -1556,8 +1604,10 @@ static const ::PROTOBUF_NAMESPACE_ID::internal::MigrationSchema schemas[] PROTOB
{ 411, -1, sizeof(::milvus::proto::milvus::QuerySegmentInfo)},
{ 423, -1, sizeof(::milvus::proto::milvus::GetQuerySegmentInfoRequest)},
{ 431, -1, sizeof(::milvus::proto::milvus::GetQuerySegmentInfoResponse)},
{ 438, -1, sizeof(::milvus::proto::milvus::RegisterLinkRequest)},
{ 443, -1, sizeof(::milvus::proto::milvus::RegisterLinkResponse)},
{ 438, -1, sizeof(::milvus::proto::milvus::DummyRequest)},
{ 444, -1, sizeof(::milvus::proto::milvus::DummyResponse)},
{ 450, -1, sizeof(::milvus::proto::milvus::RegisterLinkRequest)},
{ 455, -1, sizeof(::milvus::proto::milvus::RegisterLinkResponse)},
};
static ::PROTOBUF_NAMESPACE_ID::Message const * const file_default_instances[] = {
@ -1612,6 +1662,8 @@ static ::PROTOBUF_NAMESPACE_ID::Message const * const file_default_instances[] =
reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::milvus::proto::milvus::_QuerySegmentInfo_default_instance_),
reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::milvus::proto::milvus::_GetQuerySegmentInfoRequest_default_instance_),
reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::milvus::proto::milvus::_GetQuerySegmentInfoResponse_default_instance_),
reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::milvus::proto::milvus::_DummyRequest_default_instance_),
reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::milvus::proto::milvus::_DummyResponse_default_instance_),
reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::milvus::proto::milvus::_RegisterLinkRequest_default_instance_),
reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::milvus::proto::milvus::_RegisterLinkResponse_default_instance_),
};
@ -1786,92 +1838,96 @@ const char descriptor_table_protodef_milvus_2eproto[] PROTOBUF_SECTION_VARIABLE(
"erySegmentInfoResponse\022+\n\006status\030\001 \001(\0132\033"
".milvus.proto.common.Status\0224\n\005infos\030\002 \003"
"(\0132%.milvus.proto.milvus.QuerySegmentInf"
"o\"\025\n\023RegisterLinkRequest\"r\n\024RegisterLink"
"Response\022-\n\007address\030\001 \001(\0132\034.milvus.proto"
".common.Address\022+\n\006status\030\002 \001(\0132\033.milvus"
".proto.common.Status*>\n\017PlaceholderType\022"
"\010\n\004None\020\000\022\020\n\014BinaryVector\020d\022\017\n\013FloatVect"
"or\020e2\352\025\n\rMilvusService\022_\n\020CreateCollecti"
"on\022,.milvus.proto.milvus.CreateCollectio"
"o\"$\n\014DummyRequest\022\024\n\014request_type\030\001 \001(\t\""
"!\n\rDummyResponse\022\020\n\010response\030\001 \001(\t\"\025\n\023Re"
"gisterLinkRequest\"r\n\024RegisterLinkRespons"
"e\022-\n\007address\030\001 \001(\0132\034.milvus.proto.common"
".Address\022+\n\006status\030\002 \001(\0132\033.milvus.proto."
"common.Status*>\n\017PlaceholderType\022\010\n\004None"
"\020\000\022\020\n\014BinaryVector\020d\022\017\n\013FloatVector\020e2\274\026"
"\n\rMilvusService\022_\n\020CreateCollection\022,.mi"
"lvus.proto.milvus.CreateCollectionReques"
"t\032\033.milvus.proto.common.Status\"\000\022[\n\016Drop"
"Collection\022*.milvus.proto.milvus.DropCol"
"lectionRequest\032\033.milvus.proto.common.Sta"
"tus\"\000\022_\n\rHasCollection\022).milvus.proto.mi"
"lvus.HasCollectionRequest\032!.milvus.proto"
".milvus.BoolResponse\"\000\022[\n\016LoadCollection"
"\022*.milvus.proto.milvus.LoadCollectionReq"
"uest\032\033.milvus.proto.common.Status\"\000\022a\n\021R"
"eleaseCollection\022-.milvus.proto.milvus.R"
"eleaseCollectionRequest\032\033.milvus.proto.c"
"ommon.Status\"\000\022w\n\022DescribeCollection\022..m"
"ilvus.proto.milvus.DescribeCollectionReq"
"uest\032/.milvus.proto.milvus.DescribeColle"
"ctionResponse\"\000\022\206\001\n\027GetCollectionStatist"
"ics\0223.milvus.proto.milvus.GetCollectionS"
"tatisticsRequest\0324.milvus.proto.milvus.G"
"etCollectionStatisticsResponse\"\000\022n\n\017Show"
"Collections\022+.milvus.proto.milvus.ShowCo"
"llectionsRequest\032,.milvus.proto.milvus.S"
"howCollectionsResponse\"\000\022]\n\017CreatePartit"
"ion\022+.milvus.proto.milvus.CreatePartitio"
"nRequest\032\033.milvus.proto.common.Status\"\000\022"
"[\n\016DropCollection\022*.milvus.proto.milvus."
"DropCollectionRequest\032\033.milvus.proto.com"
"mon.Status\"\000\022_\n\rHasCollection\022).milvus.p"
"roto.milvus.HasCollectionRequest\032!.milvu"
"s.proto.milvus.BoolResponse\"\000\022[\n\016LoadCol"
"lection\022*.milvus.proto.milvus.LoadCollec"
"tionRequest\032\033.milvus.proto.common.Status"
"\"\000\022a\n\021ReleaseCollection\022-.milvus.proto.m"
"ilvus.ReleaseCollectionRequest\032\033.milvus."
"proto.common.Status\"\000\022w\n\022DescribeCollect"
"ion\022..milvus.proto.milvus.DescribeCollec"
"tionRequest\032/.milvus.proto.milvus.Descri"
"beCollectionResponse\"\000\022\206\001\n\027GetCollection"
"Statistics\0223.milvus.proto.milvus.GetColl"
"ectionStatisticsRequest\0324.milvus.proto.m"
"ilvus.GetCollectionStatisticsResponse\"\000\022"
"n\n\017ShowCollections\022+.milvus.proto.milvus"
".ShowCollectionsRequest\032,.milvus.proto.m"
"ilvus.ShowCollectionsResponse\"\000\022]\n\017Creat"
"ePartition\022+.milvus.proto.milvus.CreateP"
"artitionRequest\032\033.milvus.proto.common.St"
"atus\"\000\022Y\n\rDropPartition\022).milvus.proto.m"
"ilvus.DropPartitionRequest\032\033.milvus.prot"
"o.common.Status\"\000\022]\n\014HasPartition\022(.milv"
"us.proto.milvus.HasPartitionRequest\032!.mi"
"lvus.proto.milvus.BoolResponse\"\000\022[\n\016Load"
"Partitions\022*.milvus.proto.milvus.LoadPar"
"titionsRequest\032\033.milvus.proto.common.Sta"
"tus\"\000\022a\n\021ReleasePartitions\022-.milvus.prot"
"o.milvus.ReleasePartitionsRequest\032\033.milv"
"us.proto.common.Status\"\000\022\203\001\n\026GetPartitio"
"nStatistics\0222.milvus.proto.milvus.GetPar"
"titionStatisticsRequest\0323.milvus.proto.m"
"ilvus.GetPartitionStatisticsResponse\"\000\022k"
"\n\016ShowPartitions\022*.milvus.proto.milvus.S"
"howPartitionsRequest\032+.milvus.proto.milv"
"us.ShowPartitionsResponse\"\000\022U\n\013CreateInd"
"ex\022\'.milvus.proto.milvus.CreateIndexRequ"
"est\032\033.milvus.proto.common.Status\"\000\022h\n\rDe"
"scribeIndex\022).milvus.proto.milvus.Descri"
"beIndexRequest\032*.milvus.proto.milvus.Des"
"cribeIndexResponse\"\000\022h\n\rGetIndexState\022)."
"milvus.proto.milvus.GetIndexStateRequest"
"\032*.milvus.proto.milvus.GetIndexStateResp"
"onse\"\000\022\200\001\n\025GetIndexBuildProgress\0221.milvu"
"s.proto.milvus.GetIndexBuildProgressRequ"
"est\0322.milvus.proto.milvus.GetIndexBuildP"
"rogressResponse\"\000\022Q\n\tDropIndex\022%.milvus."
"proto.milvus.DropIndexRequest\032\033.milvus.p"
"roto.common.Status\"\000\022S\n\006Insert\022\".milvus."
"proto.milvus.InsertRequest\032#.milvus.prot"
"o.milvus.InsertResponse\"\000\022R\n\006Search\022\".mi"
"lvus.proto.milvus.SearchRequest\032\".milvus"
".proto.milvus.SearchResults\"\000\022X\n\010Retriev"
"e\022$.milvus.proto.milvus.RetrieveRequest\032"
"$.milvus.proto.milvus.RetrieveResults\"\000\022"
"I\n\005Flush\022!.milvus.proto.milvus.FlushRequ"
"est\032\033.milvus.proto.common.Status\"\000\022\211\001\n\030G"
"etPersistentSegmentInfo\0224.milvus.proto.m"
"ilvus.GetPersistentSegmentInfoRequest\0325."
"milvus.proto.milvus.GetPersistentSegment"
"InfoResponse\"\000\022z\n\023GetQuerySegmentInfo\022/."
"milvus.proto.milvus.GetQuerySegmentInfoR"
"equest\0320.milvus.proto.milvus.GetQuerySeg"
"mentInfoResponse\"\000\022e\n\014RegisterLink\022(.mil"
"vus.proto.milvus.RegisterLinkRequest\032).m"
"ilvus.proto.milvus.RegisterLinkResponse\""
"\0002u\n\014ProxyService\022e\n\014RegisterLink\022(.milv"
"us.proto.milvus.RegisterLinkRequest\032).mi"
"lvus.proto.milvus.RegisterLinkResponse\"\000"
"B5Z3github.com/milvus-io/milvus/internal"
"/proto/milvuspbb\006proto3"
"Y\n\rDropPartition\022).milvus.proto.milvus.D"
"ropPartitionRequest\032\033.milvus.proto.commo"
"n.Status\"\000\022]\n\014HasPartition\022(.milvus.prot"
"o.milvus.HasPartitionRequest\032!.milvus.pr"
"oto.milvus.BoolResponse\"\000\022[\n\016LoadPartiti"
"ons\022*.milvus.proto.milvus.LoadPartitions"
"Request\032\033.milvus.proto.common.Status\"\000\022a"
"\n\021ReleasePartitions\022-.milvus.proto.milvu"
"s.ReleasePartitionsRequest\032\033.milvus.prot"
"o.common.Status\"\000\022\203\001\n\026GetPartitionStatis"
"tics\0222.milvus.proto.milvus.GetPartitionS"
"tatisticsRequest\0323.milvus.proto.milvus.G"
"etPartitionStatisticsResponse\"\000\022k\n\016ShowP"
"artitions\022*.milvus.proto.milvus.ShowPart"
"itionsRequest\032+.milvus.proto.milvus.Show"
"PartitionsResponse\"\000\022U\n\013CreateIndex\022\'.mi"
"lvus.proto.milvus.CreateIndexRequest\032\033.m"
"ilvus.proto.common.Status\"\000\022h\n\rDescribeI"
"ndex\022).milvus.proto.milvus.DescribeIndex"
"Request\032*.milvus.proto.milvus.DescribeIn"
"dexResponse\"\000\022h\n\rGetIndexState\022).milvus."
"proto.milvus.GetIndexStateRequest\032*.milv"
"us.proto.milvus.GetIndexStateResponse\"\000\022"
"\200\001\n\025GetIndexBuildProgress\0221.milvus.proto"
".milvus.GetIndexBuildProgressRequest\0322.m"
"ilvus.proto.milvus.GetIndexBuildProgress"
"Response\"\000\022Q\n\tDropIndex\022%.milvus.proto.m"
"ilvus.DropIndexRequest\032\033.milvus.proto.co"
"mmon.Status\"\000\022S\n\006Insert\022\".milvus.proto.m"
"ilvus.InsertRequest\032#.milvus.proto.milvu"
"s.InsertResponse\"\000\022R\n\006Search\022\".milvus.pr"
"oto.milvus.SearchRequest\032\".milvus.proto."
"milvus.SearchResults\"\000\022X\n\010Retrieve\022$.mil"
"vus.proto.milvus.RetrieveRequest\032$.milvu"
"s.proto.milvus.RetrieveResults\"\000\022I\n\005Flus"
"h\022!.milvus.proto.milvus.FlushRequest\032\033.m"
"ilvus.proto.common.Status\"\000\022\211\001\n\030GetPersi"
"stentSegmentInfo\0224.milvus.proto.milvus.G"
"etPersistentSegmentInfoRequest\0325.milvus."
"proto.milvus.GetPersistentSegmentInfoRes"
"ponse\"\000\022z\n\023GetQuerySegmentInfo\022/.milvus."
"proto.milvus.GetQuerySegmentInfoRequest\032"
"0.milvus.proto.milvus.GetQuerySegmentInf"
"oResponse\"\000\022P\n\005Dummy\022!.milvus.proto.milv"
"us.DummyRequest\032\".milvus.proto.milvus.Du"
"mmyResponse\"\000\022e\n\014RegisterLink\022(.milvus.p"
"roto.milvus.RegisterLinkRequest\032).milvus"
".proto.milvus.RegisterLinkResponse\"\0002u\n\014"
"ProxyService\022e\n\014RegisterLink\022(.milvus.pr"
"oto.milvus.RegisterLinkRequest\032).milvus."
"proto.milvus.RegisterLinkResponse\"\000B5Z3g"
"ithub.com/milvus-io/milvus/internal/prot"
"o/milvuspbb\006proto3"
;
static const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable*const descriptor_table_milvus_2eproto_deps[2] = {
&::descriptor_table_common_2eproto,
&::descriptor_table_schema_2eproto,
};
static ::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase*const descriptor_table_milvus_2eproto_sccs[53] = {
static ::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase*const descriptor_table_milvus_2eproto_sccs[55] = {
&scc_info_BoolResponse_milvus_2eproto.base,
&scc_info_CreateCollectionRequest_milvus_2eproto.base,
&scc_info_CreateIndexRequest_milvus_2eproto.base,
@ -1885,6 +1941,8 @@ static ::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase*const descriptor_table_mil
&scc_info_DropCollectionRequest_milvus_2eproto.base,
&scc_info_DropIndexRequest_milvus_2eproto.base,
&scc_info_DropPartitionRequest_milvus_2eproto.base,
&scc_info_DummyRequest_milvus_2eproto.base,
&scc_info_DummyResponse_milvus_2eproto.base,
&scc_info_FlushRequest_milvus_2eproto.base,
&scc_info_GetCollectionStatisticsRequest_milvus_2eproto.base,
&scc_info_GetCollectionStatisticsResponse_milvus_2eproto.base,
@ -1929,10 +1987,10 @@ static ::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase*const descriptor_table_mil
static ::PROTOBUF_NAMESPACE_ID::internal::once_flag descriptor_table_milvus_2eproto_once;
static bool descriptor_table_milvus_2eproto_initialized = false;
const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_milvus_2eproto = {
&descriptor_table_milvus_2eproto_initialized, descriptor_table_protodef_milvus_2eproto, "milvus.proto", 9943,
&descriptor_table_milvus_2eproto_once, descriptor_table_milvus_2eproto_sccs, descriptor_table_milvus_2eproto_deps, 53, 2,
&descriptor_table_milvus_2eproto_initialized, descriptor_table_protodef_milvus_2eproto, "milvus.proto", 10098,
&descriptor_table_milvus_2eproto_once, descriptor_table_milvus_2eproto_sccs, descriptor_table_milvus_2eproto_deps, 55, 2,
schemas, file_default_instances, TableStruct_milvus_2eproto::offsets,
file_level_metadata_milvus_2eproto, 53, file_level_enum_descriptors_milvus_2eproto, file_level_service_descriptors_milvus_2eproto,
file_level_metadata_milvus_2eproto, 55, file_level_enum_descriptors_milvus_2eproto, file_level_service_descriptors_milvus_2eproto,
};
// Force running AddDescriptors() at dynamic initialization time.
@ -23358,6 +23416,544 @@ void GetQuerySegmentInfoResponse::InternalSwap(GetQuerySegmentInfoResponse* othe
}
// ===================================================================
void DummyRequest::InitAsDefaultInstance() {
}
class DummyRequest::_Internal {
public:
};
DummyRequest::DummyRequest()
: ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) {
SharedCtor();
// @@protoc_insertion_point(constructor:milvus.proto.milvus.DummyRequest)
}
DummyRequest::DummyRequest(const DummyRequest& from)
: ::PROTOBUF_NAMESPACE_ID::Message(),
_internal_metadata_(nullptr) {
_internal_metadata_.MergeFrom(from._internal_metadata_);
request_type_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
if (!from.request_type().empty()) {
request_type_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.request_type_);
}
// @@protoc_insertion_point(copy_constructor:milvus.proto.milvus.DummyRequest)
}
void DummyRequest::SharedCtor() {
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_DummyRequest_milvus_2eproto.base);
request_type_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
}
DummyRequest::~DummyRequest() {
// @@protoc_insertion_point(destructor:milvus.proto.milvus.DummyRequest)
SharedDtor();
}
void DummyRequest::SharedDtor() {
request_type_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
}
void DummyRequest::SetCachedSize(int size) const {
_cached_size_.Set(size);
}
const DummyRequest& DummyRequest::default_instance() {
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_DummyRequest_milvus_2eproto.base);
return *internal_default_instance();
}
void DummyRequest::Clear() {
// @@protoc_insertion_point(message_clear_start:milvus.proto.milvus.DummyRequest)
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
// Prevent compiler warnings about cached_has_bits being unused
(void) cached_has_bits;
request_type_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
_internal_metadata_.Clear();
}
#if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
const char* DummyRequest::_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 request_type = 1;
case 1:
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) {
ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParserUTF8(mutable_request_type(), ptr, ctx, "milvus.proto.milvus.DummyRequest.request_type");
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 DummyRequest::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.milvus.DummyRequest)
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 request_type = 1;
case 1: {
if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (10 & 0xFF)) {
DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadString(
input, this->mutable_request_type()));
DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
this->request_type().data(), static_cast<int>(this->request_type().length()),
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE,
"milvus.proto.milvus.DummyRequest.request_type"));
} 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.milvus.DummyRequest)
return true;
failure:
// @@protoc_insertion_point(parse_failure:milvus.proto.milvus.DummyRequest)
return false;
#undef DO_
}
#endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
void DummyRequest::SerializeWithCachedSizes(
::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const {
// @@protoc_insertion_point(serialize_start:milvus.proto.milvus.DummyRequest)
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
(void) cached_has_bits;
// string request_type = 1;
if (this->request_type().size() > 0) {
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
this->request_type().data(), static_cast<int>(this->request_type().length()),
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
"milvus.proto.milvus.DummyRequest.request_type");
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringMaybeAliased(
1, this->request_type(), 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.milvus.DummyRequest)
}
::PROTOBUF_NAMESPACE_ID::uint8* DummyRequest::InternalSerializeWithCachedSizesToArray(
::PROTOBUF_NAMESPACE_ID::uint8* target) const {
// @@protoc_insertion_point(serialize_to_array_start:milvus.proto.milvus.DummyRequest)
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
(void) cached_has_bits;
// string request_type = 1;
if (this->request_type().size() > 0) {
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
this->request_type().data(), static_cast<int>(this->request_type().length()),
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
"milvus.proto.milvus.DummyRequest.request_type");
target =
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringToArray(
1, this->request_type(), 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.milvus.DummyRequest)
return target;
}
size_t DummyRequest::ByteSizeLong() const {
// @@protoc_insertion_point(message_byte_size_start:milvus.proto.milvus.DummyRequest)
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 request_type = 1;
if (this->request_type().size() > 0) {
total_size += 1 +
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
this->request_type());
}
int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size);
SetCachedSize(cached_size);
return total_size;
}
void DummyRequest::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) {
// @@protoc_insertion_point(generalized_merge_from_start:milvus.proto.milvus.DummyRequest)
GOOGLE_DCHECK_NE(&from, this);
const DummyRequest* source =
::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated<DummyRequest>(
&from);
if (source == nullptr) {
// @@protoc_insertion_point(generalized_merge_from_cast_fail:milvus.proto.milvus.DummyRequest)
::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this);
} else {
// @@protoc_insertion_point(generalized_merge_from_cast_success:milvus.proto.milvus.DummyRequest)
MergeFrom(*source);
}
}
void DummyRequest::MergeFrom(const DummyRequest& from) {
// @@protoc_insertion_point(class_specific_merge_from_start:milvus.proto.milvus.DummyRequest)
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.request_type().size() > 0) {
request_type_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.request_type_);
}
}
void DummyRequest::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) {
// @@protoc_insertion_point(generalized_copy_from_start:milvus.proto.milvus.DummyRequest)
if (&from == this) return;
Clear();
MergeFrom(from);
}
void DummyRequest::CopyFrom(const DummyRequest& from) {
// @@protoc_insertion_point(class_specific_copy_from_start:milvus.proto.milvus.DummyRequest)
if (&from == this) return;
Clear();
MergeFrom(from);
}
bool DummyRequest::IsInitialized() const {
return true;
}
void DummyRequest::InternalSwap(DummyRequest* other) {
using std::swap;
_internal_metadata_.Swap(&other->_internal_metadata_);
request_type_.Swap(&other->request_type_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
GetArenaNoVirtual());
}
::PROTOBUF_NAMESPACE_ID::Metadata DummyRequest::GetMetadata() const {
return GetMetadataStatic();
}
// ===================================================================
void DummyResponse::InitAsDefaultInstance() {
}
class DummyResponse::_Internal {
public:
};
DummyResponse::DummyResponse()
: ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) {
SharedCtor();
// @@protoc_insertion_point(constructor:milvus.proto.milvus.DummyResponse)
}
DummyResponse::DummyResponse(const DummyResponse& from)
: ::PROTOBUF_NAMESPACE_ID::Message(),
_internal_metadata_(nullptr) {
_internal_metadata_.MergeFrom(from._internal_metadata_);
response_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
if (!from.response().empty()) {
response_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.response_);
}
// @@protoc_insertion_point(copy_constructor:milvus.proto.milvus.DummyResponse)
}
void DummyResponse::SharedCtor() {
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_DummyResponse_milvus_2eproto.base);
response_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
}
DummyResponse::~DummyResponse() {
// @@protoc_insertion_point(destructor:milvus.proto.milvus.DummyResponse)
SharedDtor();
}
void DummyResponse::SharedDtor() {
response_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
}
void DummyResponse::SetCachedSize(int size) const {
_cached_size_.Set(size);
}
const DummyResponse& DummyResponse::default_instance() {
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_DummyResponse_milvus_2eproto.base);
return *internal_default_instance();
}
void DummyResponse::Clear() {
// @@protoc_insertion_point(message_clear_start:milvus.proto.milvus.DummyResponse)
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
// Prevent compiler warnings about cached_has_bits being unused
(void) cached_has_bits;
response_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
_internal_metadata_.Clear();
}
#if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
const char* DummyResponse::_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 response = 1;
case 1:
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) {
ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParserUTF8(mutable_response(), ptr, ctx, "milvus.proto.milvus.DummyResponse.response");
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 DummyResponse::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.milvus.DummyResponse)
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 response = 1;
case 1: {
if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (10 & 0xFF)) {
DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadString(
input, this->mutable_response()));
DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
this->response().data(), static_cast<int>(this->response().length()),
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE,
"milvus.proto.milvus.DummyResponse.response"));
} 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.milvus.DummyResponse)
return true;
failure:
// @@protoc_insertion_point(parse_failure:milvus.proto.milvus.DummyResponse)
return false;
#undef DO_
}
#endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
void DummyResponse::SerializeWithCachedSizes(
::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const {
// @@protoc_insertion_point(serialize_start:milvus.proto.milvus.DummyResponse)
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
(void) cached_has_bits;
// string response = 1;
if (this->response().size() > 0) {
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
this->response().data(), static_cast<int>(this->response().length()),
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
"milvus.proto.milvus.DummyResponse.response");
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringMaybeAliased(
1, this->response(), 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.milvus.DummyResponse)
}
::PROTOBUF_NAMESPACE_ID::uint8* DummyResponse::InternalSerializeWithCachedSizesToArray(
::PROTOBUF_NAMESPACE_ID::uint8* target) const {
// @@protoc_insertion_point(serialize_to_array_start:milvus.proto.milvus.DummyResponse)
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
(void) cached_has_bits;
// string response = 1;
if (this->response().size() > 0) {
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
this->response().data(), static_cast<int>(this->response().length()),
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
"milvus.proto.milvus.DummyResponse.response");
target =
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringToArray(
1, this->response(), 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.milvus.DummyResponse)
return target;
}
size_t DummyResponse::ByteSizeLong() const {
// @@protoc_insertion_point(message_byte_size_start:milvus.proto.milvus.DummyResponse)
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 response = 1;
if (this->response().size() > 0) {
total_size += 1 +
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
this->response());
}
int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size);
SetCachedSize(cached_size);
return total_size;
}
void DummyResponse::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) {
// @@protoc_insertion_point(generalized_merge_from_start:milvus.proto.milvus.DummyResponse)
GOOGLE_DCHECK_NE(&from, this);
const DummyResponse* source =
::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated<DummyResponse>(
&from);
if (source == nullptr) {
// @@protoc_insertion_point(generalized_merge_from_cast_fail:milvus.proto.milvus.DummyResponse)
::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this);
} else {
// @@protoc_insertion_point(generalized_merge_from_cast_success:milvus.proto.milvus.DummyResponse)
MergeFrom(*source);
}
}
void DummyResponse::MergeFrom(const DummyResponse& from) {
// @@protoc_insertion_point(class_specific_merge_from_start:milvus.proto.milvus.DummyResponse)
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.response().size() > 0) {
response_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.response_);
}
}
void DummyResponse::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) {
// @@protoc_insertion_point(generalized_copy_from_start:milvus.proto.milvus.DummyResponse)
if (&from == this) return;
Clear();
MergeFrom(from);
}
void DummyResponse::CopyFrom(const DummyResponse& from) {
// @@protoc_insertion_point(class_specific_copy_from_start:milvus.proto.milvus.DummyResponse)
if (&from == this) return;
Clear();
MergeFrom(from);
}
bool DummyResponse::IsInitialized() const {
return true;
}
void DummyResponse::InternalSwap(DummyResponse* other) {
using std::swap;
_internal_metadata_.Swap(&other->_internal_metadata_);
response_.Swap(&other->response_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
GetArenaNoVirtual());
}
::PROTOBUF_NAMESPACE_ID::Metadata DummyResponse::GetMetadata() const {
return GetMetadataStatic();
}
// ===================================================================
void RegisterLinkRequest::InitAsDefaultInstance() {
@ -24054,6 +24650,12 @@ template<> PROTOBUF_NOINLINE ::milvus::proto::milvus::GetQuerySegmentInfoRequest
template<> PROTOBUF_NOINLINE ::milvus::proto::milvus::GetQuerySegmentInfoResponse* Arena::CreateMaybeMessage< ::milvus::proto::milvus::GetQuerySegmentInfoResponse >(Arena* arena) {
return Arena::CreateInternal< ::milvus::proto::milvus::GetQuerySegmentInfoResponse >(arena);
}
template<> PROTOBUF_NOINLINE ::milvus::proto::milvus::DummyRequest* Arena::CreateMaybeMessage< ::milvus::proto::milvus::DummyRequest >(Arena* arena) {
return Arena::CreateInternal< ::milvus::proto::milvus::DummyRequest >(arena);
}
template<> PROTOBUF_NOINLINE ::milvus::proto::milvus::DummyResponse* Arena::CreateMaybeMessage< ::milvus::proto::milvus::DummyResponse >(Arena* arena) {
return Arena::CreateInternal< ::milvus::proto::milvus::DummyResponse >(arena);
}
template<> PROTOBUF_NOINLINE ::milvus::proto::milvus::RegisterLinkRequest* Arena::CreateMaybeMessage< ::milvus::proto::milvus::RegisterLinkRequest >(Arena* arena) {
return Arena::CreateInternal< ::milvus::proto::milvus::RegisterLinkRequest >(arena);
}

View File

@ -50,7 +50,7 @@ struct TableStruct_milvus_2eproto {
PROTOBUF_SECTION_VARIABLE(protodesc_cold);
static const ::PROTOBUF_NAMESPACE_ID::internal::AuxillaryParseTableField aux[]
PROTOBUF_SECTION_VARIABLE(protodesc_cold);
static const ::PROTOBUF_NAMESPACE_ID::internal::ParseTable schema[53]
static const ::PROTOBUF_NAMESPACE_ID::internal::ParseTable schema[55]
PROTOBUF_SECTION_VARIABLE(protodesc_cold);
static const ::PROTOBUF_NAMESPACE_ID::internal::FieldMetadata field_metadata[];
static const ::PROTOBUF_NAMESPACE_ID::internal::SerializationTable serialization_table[];
@ -99,6 +99,12 @@ extern DropIndexRequestDefaultTypeInternal _DropIndexRequest_default_instance_;
class DropPartitionRequest;
class DropPartitionRequestDefaultTypeInternal;
extern DropPartitionRequestDefaultTypeInternal _DropPartitionRequest_default_instance_;
class DummyRequest;
class DummyRequestDefaultTypeInternal;
extern DummyRequestDefaultTypeInternal _DummyRequest_default_instance_;
class DummyResponse;
class DummyResponseDefaultTypeInternal;
extern DummyResponseDefaultTypeInternal _DummyResponse_default_instance_;
class FlushRequest;
class FlushRequestDefaultTypeInternal;
extern FlushRequestDefaultTypeInternal _FlushRequest_default_instance_;
@ -236,6 +242,8 @@ template<> ::milvus::proto::milvus::DescribeSegmentResponse* Arena::CreateMaybeM
template<> ::milvus::proto::milvus::DropCollectionRequest* Arena::CreateMaybeMessage<::milvus::proto::milvus::DropCollectionRequest>(Arena*);
template<> ::milvus::proto::milvus::DropIndexRequest* Arena::CreateMaybeMessage<::milvus::proto::milvus::DropIndexRequest>(Arena*);
template<> ::milvus::proto::milvus::DropPartitionRequest* Arena::CreateMaybeMessage<::milvus::proto::milvus::DropPartitionRequest>(Arena*);
template<> ::milvus::proto::milvus::DummyRequest* Arena::CreateMaybeMessage<::milvus::proto::milvus::DummyRequest>(Arena*);
template<> ::milvus::proto::milvus::DummyResponse* Arena::CreateMaybeMessage<::milvus::proto::milvus::DummyResponse>(Arena*);
template<> ::milvus::proto::milvus::FlushRequest* Arena::CreateMaybeMessage<::milvus::proto::milvus::FlushRequest>(Arena*);
template<> ::milvus::proto::milvus::GetCollectionStatisticsRequest* Arena::CreateMaybeMessage<::milvus::proto::milvus::GetCollectionStatisticsRequest>(Arena*);
template<> ::milvus::proto::milvus::GetCollectionStatisticsResponse* Arena::CreateMaybeMessage<::milvus::proto::milvus::GetCollectionStatisticsResponse>(Arena*);
@ -8747,6 +8755,280 @@ class GetQuerySegmentInfoResponse :
};
// -------------------------------------------------------------------
class DummyRequest :
public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:milvus.proto.milvus.DummyRequest) */ {
public:
DummyRequest();
virtual ~DummyRequest();
DummyRequest(const DummyRequest& from);
DummyRequest(DummyRequest&& from) noexcept
: DummyRequest() {
*this = ::std::move(from);
}
inline DummyRequest& operator=(const DummyRequest& from) {
CopyFrom(from);
return *this;
}
inline DummyRequest& operator=(DummyRequest&& from) noexcept {
if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) {
if (this != &from) InternalSwap(&from);
} else {
CopyFrom(from);
}
return *this;
}
static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
return GetDescriptor();
}
static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
return GetMetadataStatic().descriptor;
}
static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
return GetMetadataStatic().reflection;
}
static const DummyRequest& default_instance();
static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY
static inline const DummyRequest* internal_default_instance() {
return reinterpret_cast<const DummyRequest*>(
&_DummyRequest_default_instance_);
}
static constexpr int kIndexInFileMessages =
51;
friend void swap(DummyRequest& a, DummyRequest& b) {
a.Swap(&b);
}
inline void Swap(DummyRequest* other) {
if (other == this) return;
InternalSwap(other);
}
// implements Message ----------------------------------------------
inline DummyRequest* New() const final {
return CreateMaybeMessage<DummyRequest>(nullptr);
}
DummyRequest* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
return CreateMaybeMessage<DummyRequest>(arena);
}
void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
void CopyFrom(const DummyRequest& from);
void MergeFrom(const DummyRequest& from);
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
bool IsInitialized() const final;
size_t ByteSizeLong() const final;
#if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
#else
bool MergePartialFromCodedStream(
::PROTOBUF_NAMESPACE_ID::io::CodedInputStream* input) final;
#endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
void SerializeWithCachedSizes(
::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const final;
::PROTOBUF_NAMESPACE_ID::uint8* InternalSerializeWithCachedSizesToArray(
::PROTOBUF_NAMESPACE_ID::uint8* target) const final;
int GetCachedSize() const final { return _cached_size_.Get(); }
private:
inline void SharedCtor();
inline void SharedDtor();
void SetCachedSize(int size) const final;
void InternalSwap(DummyRequest* other);
friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
return "milvus.proto.milvus.DummyRequest";
}
private:
inline ::PROTOBUF_NAMESPACE_ID::Arena* GetArenaNoVirtual() const {
return nullptr;
}
inline void* MaybeArenaPtr() const {
return nullptr;
}
public:
::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
private:
static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&::descriptor_table_milvus_2eproto);
return ::descriptor_table_milvus_2eproto.file_level_metadata[kIndexInFileMessages];
}
public:
// nested types ----------------------------------------------------
// accessors -------------------------------------------------------
enum : int {
kRequestTypeFieldNumber = 1,
};
// string request_type = 1;
void clear_request_type();
const std::string& request_type() const;
void set_request_type(const std::string& value);
void set_request_type(std::string&& value);
void set_request_type(const char* value);
void set_request_type(const char* value, size_t size);
std::string* mutable_request_type();
std::string* release_request_type();
void set_allocated_request_type(std::string* request_type);
// @@protoc_insertion_point(class_scope:milvus.proto.milvus.DummyRequest)
private:
class _Internal;
::PROTOBUF_NAMESPACE_ID::internal::InternalMetadataWithArena _internal_metadata_;
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr request_type_;
mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
friend struct ::TableStruct_milvus_2eproto;
};
// -------------------------------------------------------------------
class DummyResponse :
public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:milvus.proto.milvus.DummyResponse) */ {
public:
DummyResponse();
virtual ~DummyResponse();
DummyResponse(const DummyResponse& from);
DummyResponse(DummyResponse&& from) noexcept
: DummyResponse() {
*this = ::std::move(from);
}
inline DummyResponse& operator=(const DummyResponse& from) {
CopyFrom(from);
return *this;
}
inline DummyResponse& operator=(DummyResponse&& from) noexcept {
if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) {
if (this != &from) InternalSwap(&from);
} else {
CopyFrom(from);
}
return *this;
}
static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
return GetDescriptor();
}
static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
return GetMetadataStatic().descriptor;
}
static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
return GetMetadataStatic().reflection;
}
static const DummyResponse& default_instance();
static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY
static inline const DummyResponse* internal_default_instance() {
return reinterpret_cast<const DummyResponse*>(
&_DummyResponse_default_instance_);
}
static constexpr int kIndexInFileMessages =
52;
friend void swap(DummyResponse& a, DummyResponse& b) {
a.Swap(&b);
}
inline void Swap(DummyResponse* other) {
if (other == this) return;
InternalSwap(other);
}
// implements Message ----------------------------------------------
inline DummyResponse* New() const final {
return CreateMaybeMessage<DummyResponse>(nullptr);
}
DummyResponse* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
return CreateMaybeMessage<DummyResponse>(arena);
}
void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
void CopyFrom(const DummyResponse& from);
void MergeFrom(const DummyResponse& from);
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
bool IsInitialized() const final;
size_t ByteSizeLong() const final;
#if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
#else
bool MergePartialFromCodedStream(
::PROTOBUF_NAMESPACE_ID::io::CodedInputStream* input) final;
#endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
void SerializeWithCachedSizes(
::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const final;
::PROTOBUF_NAMESPACE_ID::uint8* InternalSerializeWithCachedSizesToArray(
::PROTOBUF_NAMESPACE_ID::uint8* target) const final;
int GetCachedSize() const final { return _cached_size_.Get(); }
private:
inline void SharedCtor();
inline void SharedDtor();
void SetCachedSize(int size) const final;
void InternalSwap(DummyResponse* other);
friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
return "milvus.proto.milvus.DummyResponse";
}
private:
inline ::PROTOBUF_NAMESPACE_ID::Arena* GetArenaNoVirtual() const {
return nullptr;
}
inline void* MaybeArenaPtr() const {
return nullptr;
}
public:
::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
private:
static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&::descriptor_table_milvus_2eproto);
return ::descriptor_table_milvus_2eproto.file_level_metadata[kIndexInFileMessages];
}
public:
// nested types ----------------------------------------------------
// accessors -------------------------------------------------------
enum : int {
kResponseFieldNumber = 1,
};
// string response = 1;
void clear_response();
const std::string& response() const;
void set_response(const std::string& value);
void set_response(std::string&& value);
void set_response(const char* value);
void set_response(const char* value, size_t size);
std::string* mutable_response();
std::string* release_response();
void set_allocated_response(std::string* response);
// @@protoc_insertion_point(class_scope:milvus.proto.milvus.DummyResponse)
private:
class _Internal;
::PROTOBUF_NAMESPACE_ID::internal::InternalMetadataWithArena _internal_metadata_;
::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr response_;
mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
friend struct ::TableStruct_milvus_2eproto;
};
// -------------------------------------------------------------------
class RegisterLinkRequest :
public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:milvus.proto.milvus.RegisterLinkRequest) */ {
public:
@ -8789,7 +9071,7 @@ class RegisterLinkRequest :
&_RegisterLinkRequest_default_instance_);
}
static constexpr int kIndexInFileMessages =
51;
53;
friend void swap(RegisterLinkRequest& a, RegisterLinkRequest& b) {
a.Swap(&b);
@ -8911,7 +9193,7 @@ class RegisterLinkResponse :
&_RegisterLinkResponse_default_instance_);
}
static constexpr int kIndexInFileMessages =
52;
54;
friend void swap(RegisterLinkResponse& a, RegisterLinkResponse& b) {
a.Swap(&b);
@ -16836,6 +17118,116 @@ GetQuerySegmentInfoResponse::infos() const {
// -------------------------------------------------------------------
// DummyRequest
// string request_type = 1;
inline void DummyRequest::clear_request_type() {
request_type_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
}
inline const std::string& DummyRequest::request_type() const {
// @@protoc_insertion_point(field_get:milvus.proto.milvus.DummyRequest.request_type)
return request_type_.GetNoArena();
}
inline void DummyRequest::set_request_type(const std::string& value) {
request_type_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value);
// @@protoc_insertion_point(field_set:milvus.proto.milvus.DummyRequest.request_type)
}
inline void DummyRequest::set_request_type(std::string&& value) {
request_type_.SetNoArena(
&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value));
// @@protoc_insertion_point(field_set_rvalue:milvus.proto.milvus.DummyRequest.request_type)
}
inline void DummyRequest::set_request_type(const char* value) {
GOOGLE_DCHECK(value != nullptr);
request_type_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
// @@protoc_insertion_point(field_set_char:milvus.proto.milvus.DummyRequest.request_type)
}
inline void DummyRequest::set_request_type(const char* value, size_t size) {
request_type_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
::std::string(reinterpret_cast<const char*>(value), size));
// @@protoc_insertion_point(field_set_pointer:milvus.proto.milvus.DummyRequest.request_type)
}
inline std::string* DummyRequest::mutable_request_type() {
// @@protoc_insertion_point(field_mutable:milvus.proto.milvus.DummyRequest.request_type)
return request_type_.MutableNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
}
inline std::string* DummyRequest::release_request_type() {
// @@protoc_insertion_point(field_release:milvus.proto.milvus.DummyRequest.request_type)
return request_type_.ReleaseNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
}
inline void DummyRequest::set_allocated_request_type(std::string* request_type) {
if (request_type != nullptr) {
} else {
}
request_type_.SetAllocatedNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), request_type);
// @@protoc_insertion_point(field_set_allocated:milvus.proto.milvus.DummyRequest.request_type)
}
// -------------------------------------------------------------------
// DummyResponse
// string response = 1;
inline void DummyResponse::clear_response() {
response_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
}
inline const std::string& DummyResponse::response() const {
// @@protoc_insertion_point(field_get:milvus.proto.milvus.DummyResponse.response)
return response_.GetNoArena();
}
inline void DummyResponse::set_response(const std::string& value) {
response_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value);
// @@protoc_insertion_point(field_set:milvus.proto.milvus.DummyResponse.response)
}
inline void DummyResponse::set_response(std::string&& value) {
response_.SetNoArena(
&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value));
// @@protoc_insertion_point(field_set_rvalue:milvus.proto.milvus.DummyResponse.response)
}
inline void DummyResponse::set_response(const char* value) {
GOOGLE_DCHECK(value != nullptr);
response_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
// @@protoc_insertion_point(field_set_char:milvus.proto.milvus.DummyResponse.response)
}
inline void DummyResponse::set_response(const char* value, size_t size) {
response_.SetNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
::std::string(reinterpret_cast<const char*>(value), size));
// @@protoc_insertion_point(field_set_pointer:milvus.proto.milvus.DummyResponse.response)
}
inline std::string* DummyResponse::mutable_response() {
// @@protoc_insertion_point(field_mutable:milvus.proto.milvus.DummyResponse.response)
return response_.MutableNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
}
inline std::string* DummyResponse::release_response() {
// @@protoc_insertion_point(field_release:milvus.proto.milvus.DummyResponse.response)
return response_.ReleaseNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
}
inline void DummyResponse::set_allocated_response(std::string* response) {
if (response != nullptr) {
} else {
}
response_.SetAllocatedNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), response);
// @@protoc_insertion_point(field_set_allocated:milvus.proto.milvus.DummyResponse.response)
}
// -------------------------------------------------------------------
// RegisterLinkRequest
// -------------------------------------------------------------------
@ -17039,6 +17431,10 @@ inline void RegisterLinkResponse::set_allocated_status(::milvus::proto::common::
// -------------------------------------------------------------------
// -------------------------------------------------------------------
// -------------------------------------------------------------------
// @@protoc_insertion_point(namespace_scope)

View File

@ -394,6 +394,10 @@ func (s *Server) GetQuerySegmentInfo(ctx context.Context, request *milvuspb.GetQ
}
func (s *Server) Dummy(ctx context.Context, request *milvuspb.DummyRequest) (*milvuspb.DummyResponse, error) {
return s.proxynode.Dummy(ctx, request)
}
func (s *Server) RegisterLink(ctx context.Context, request *milvuspb.RegisterLinkRequest) (*milvuspb.RegisterLinkResponse, error) {
return s.proxynode.RegisterLink(ctx, request)
}

View File

@ -38,6 +38,8 @@ service MilvusService {
rpc GetPersistentSegmentInfo(GetPersistentSegmentInfoRequest) returns (GetPersistentSegmentInfoResponse) {}
rpc GetQuerySegmentInfo(GetQuerySegmentInfoRequest) returns (GetQuerySegmentInfoResponse) {}
rpc Dummy(DummyRequest) returns (DummyResponse) {}
// TODO: remove
rpc RegisterLink(RegisterLinkRequest) returns (RegisterLinkResponse) {}
}
@ -387,6 +389,13 @@ message GetQuerySegmentInfoResponse {
repeated QuerySegmentInfo infos = 2;
}
message DummyRequest {
string request_type = 1;
}
message DummyResponse {
string response = 1;
}
message RegisterLinkRequest {
}

View File

@ -3102,6 +3102,84 @@ func (m *GetQuerySegmentInfoResponse) GetInfos() []*QuerySegmentInfo {
return nil
}
type DummyRequest struct {
RequestType string `protobuf:"bytes,1,opt,name=request_type,json=requestType,proto3" json:"request_type,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *DummyRequest) Reset() { *m = DummyRequest{} }
func (m *DummyRequest) String() string { return proto.CompactTextString(m) }
func (*DummyRequest) ProtoMessage() {}
func (*DummyRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_02345ba45cc0e303, []int{51}
}
func (m *DummyRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DummyRequest.Unmarshal(m, b)
}
func (m *DummyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DummyRequest.Marshal(b, m, deterministic)
}
func (m *DummyRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_DummyRequest.Merge(m, src)
}
func (m *DummyRequest) XXX_Size() int {
return xxx_messageInfo_DummyRequest.Size(m)
}
func (m *DummyRequest) XXX_DiscardUnknown() {
xxx_messageInfo_DummyRequest.DiscardUnknown(m)
}
var xxx_messageInfo_DummyRequest proto.InternalMessageInfo
func (m *DummyRequest) GetRequestType() string {
if m != nil {
return m.RequestType
}
return ""
}
type DummyResponse struct {
Response string `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *DummyResponse) Reset() { *m = DummyResponse{} }
func (m *DummyResponse) String() string { return proto.CompactTextString(m) }
func (*DummyResponse) ProtoMessage() {}
func (*DummyResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_02345ba45cc0e303, []int{52}
}
func (m *DummyResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DummyResponse.Unmarshal(m, b)
}
func (m *DummyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DummyResponse.Marshal(b, m, deterministic)
}
func (m *DummyResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_DummyResponse.Merge(m, src)
}
func (m *DummyResponse) XXX_Size() int {
return xxx_messageInfo_DummyResponse.Size(m)
}
func (m *DummyResponse) XXX_DiscardUnknown() {
xxx_messageInfo_DummyResponse.DiscardUnknown(m)
}
var xxx_messageInfo_DummyResponse proto.InternalMessageInfo
func (m *DummyResponse) GetResponse() string {
if m != nil {
return m.Response
}
return ""
}
type RegisterLinkRequest struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
@ -3112,7 +3190,7 @@ func (m *RegisterLinkRequest) Reset() { *m = RegisterLinkRequest{} }
func (m *RegisterLinkRequest) String() string { return proto.CompactTextString(m) }
func (*RegisterLinkRequest) ProtoMessage() {}
func (*RegisterLinkRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_02345ba45cc0e303, []int{51}
return fileDescriptor_02345ba45cc0e303, []int{53}
}
func (m *RegisterLinkRequest) XXX_Unmarshal(b []byte) error {
@ -3145,7 +3223,7 @@ func (m *RegisterLinkResponse) Reset() { *m = RegisterLinkResponse{} }
func (m *RegisterLinkResponse) String() string { return proto.CompactTextString(m) }
func (*RegisterLinkResponse) ProtoMessage() {}
func (*RegisterLinkResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_02345ba45cc0e303, []int{52}
return fileDescriptor_02345ba45cc0e303, []int{54}
}
func (m *RegisterLinkResponse) XXX_Unmarshal(b []byte) error {
@ -3233,6 +3311,8 @@ func init() {
proto.RegisterType((*QuerySegmentInfo)(nil), "milvus.proto.milvus.QuerySegmentInfo")
proto.RegisterType((*GetQuerySegmentInfoRequest)(nil), "milvus.proto.milvus.GetQuerySegmentInfoRequest")
proto.RegisterType((*GetQuerySegmentInfoResponse)(nil), "milvus.proto.milvus.GetQuerySegmentInfoResponse")
proto.RegisterType((*DummyRequest)(nil), "milvus.proto.milvus.DummyRequest")
proto.RegisterType((*DummyResponse)(nil), "milvus.proto.milvus.DummyResponse")
proto.RegisterType((*RegisterLinkRequest)(nil), "milvus.proto.milvus.RegisterLinkRequest")
proto.RegisterType((*RegisterLinkResponse)(nil), "milvus.proto.milvus.RegisterLinkResponse")
}
@ -3240,147 +3320,151 @@ func init() {
func init() { proto.RegisterFile("milvus.proto", fileDescriptor_02345ba45cc0e303) }
var fileDescriptor_02345ba45cc0e303 = []byte{
// 2237 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xd4, 0x5a, 0xcf, 0x6f, 0x1b, 0xc7,
0xf5, 0xf7, 0x90, 0x22, 0x25, 0x3e, 0x92, 0x12, 0x3d, 0xfa, 0x45, 0xd3, 0xbf, 0xe8, 0x4d, 0xfc,
0x8d, 0x6c, 0x27, 0x56, 0xbe, 0x92, 0x5d, 0xb7, 0x28, 0xfa, 0x4b, 0x56, 0x2d, 0x0b, 0x4e, 0x0c,
0x65, 0x99, 0x06, 0x49, 0x03, 0x83, 0x58, 0x72, 0xc7, 0xe2, 0xc2, 0xcb, 0x5d, 0x76, 0x67, 0x28,
0x99, 0x3e, 0x15, 0x4d, 0x51, 0xa0, 0x68, 0xeb, 0x1c, 0x5a, 0x14, 0x68, 0x0f, 0x3d, 0x14, 0xc8,
0xa1, 0xa7, 0xb6, 0x48, 0x81, 0x02, 0x3d, 0xe7, 0xd0, 0x5b, 0x8b, 0xfe, 0x0f, 0xbd, 0x14, 0xed,
0x9f, 0x50, 0xb4, 0x98, 0x99, 0xdd, 0xe5, 0xee, 0x6a, 0x96, 0xa2, 0xcc, 0xb8, 0x92, 0x6e, 0xbb,
0x6f, 0xdf, 0xcc, 0x7c, 0xde, 0x9b, 0xf7, 0xde, 0xbc, 0x37, 0x6f, 0xa1, 0xd4, 0xb5, 0xec, 0xbd,
0x3e, 0xbd, 0xd9, 0xf3, 0x5c, 0xe6, 0xe2, 0xf9, 0xe8, 0xdb, 0x4d, 0xf9, 0x52, 0x2b, 0xb5, 0xdd,
0x6e, 0xd7, 0x75, 0x24, 0xb1, 0x56, 0xa2, 0xed, 0x0e, 0xe9, 0x1a, 0xf2, 0x4d, 0xfb, 0x0c, 0xc1,
0xf2, 0x5d, 0x8f, 0x18, 0x8c, 0xdc, 0x75, 0x6d, 0x9b, 0xb4, 0x99, 0xe5, 0x3a, 0x3a, 0xf9, 0x4e,
0x9f, 0x50, 0x86, 0xdf, 0x84, 0xa9, 0x96, 0x41, 0x49, 0x15, 0xd5, 0xd1, 0x4a, 0x71, 0xed, 0xc2,
0xcd, 0xd8, 0xdc, 0xfe, 0x9c, 0x6f, 0xd3, 0xdd, 0x0d, 0x83, 0x12, 0x5d, 0x70, 0xe2, 0x65, 0x98,
0x36, 0x5b, 0x4d, 0xc7, 0xe8, 0x92, 0x6a, 0xa6, 0x8e, 0x56, 0x0a, 0x7a, 0xde, 0x6c, 0x3d, 0x34,
0xba, 0x04, 0xbf, 0x06, 0x73, 0xed, 0x70, 0x7e, 0xc9, 0x90, 0x15, 0x0c, 0xb3, 0x43, 0xb2, 0x60,
0x5c, 0x82, 0xbc, 0xc4, 0x57, 0x9d, 0xaa, 0xa3, 0x95, 0x92, 0xee, 0xbf, 0xe1, 0x8b, 0x00, 0xb4,
0x63, 0x78, 0x26, 0x6d, 0x3a, 0xfd, 0x6e, 0x35, 0x57, 0x47, 0x2b, 0x39, 0xbd, 0x20, 0x29, 0x0f,
0xfb, 0x5d, 0xed, 0x47, 0x08, 0x16, 0x37, 0x3d, 0xb7, 0x77, 0x22, 0x84, 0xd0, 0x7e, 0x83, 0x60,
0xe1, 0xbe, 0x41, 0x4f, 0x86, 0x46, 0x2f, 0x02, 0x30, 0xab, 0x4b, 0x9a, 0x94, 0x19, 0xdd, 0x9e,
0xd0, 0xea, 0x94, 0x5e, 0xe0, 0x94, 0x06, 0x27, 0x68, 0x1f, 0x40, 0x69, 0xc3, 0x75, 0x6d, 0x9d,
0xd0, 0x9e, 0xeb, 0x50, 0x82, 0xd7, 0x21, 0x4f, 0x99, 0xc1, 0xfa, 0xd4, 0x07, 0x79, 0x5e, 0x09,
0xb2, 0x21, 0x58, 0x74, 0x9f, 0x15, 0x2f, 0x40, 0x6e, 0xcf, 0xb0, 0xfb, 0x12, 0xe3, 0x8c, 0x2e,
0x5f, 0xb4, 0x0f, 0x61, 0xb6, 0xc1, 0x3c, 0xcb, 0xd9, 0xfd, 0x1c, 0x27, 0x2f, 0x04, 0x93, 0xff,
0x0d, 0xc1, 0xb9, 0x4d, 0x42, 0xdb, 0x9e, 0xd5, 0x3a, 0x21, 0xa6, 0xab, 0x41, 0x69, 0x48, 0xd9,
0xde, 0x14, 0xaa, 0xce, 0xea, 0x31, 0x5a, 0x62, 0x33, 0x72, 0xc9, 0xcd, 0xf8, 0x55, 0x06, 0x6a,
0x2a, 0xa1, 0x26, 0x51, 0xdf, 0x57, 0x42, 0x8f, 0xca, 0x88, 0x41, 0x57, 0xe3, 0x83, 0xfc, 0x68,
0x30, 0x5c, 0xad, 0x21, 0x08, 0xa1, 0xe3, 0x25, 0xa5, 0xca, 0x2a, 0xa4, 0x5a, 0x83, 0xc5, 0x3d,
0xcb, 0x63, 0x7d, 0xc3, 0x6e, 0xb6, 0x3b, 0x86, 0xe3, 0x10, 0x5b, 0xe8, 0x89, 0x56, 0xa7, 0xea,
0xd9, 0x95, 0x82, 0x3e, 0xef, 0x7f, 0xbc, 0x2b, 0xbf, 0x71, 0x65, 0x51, 0x7c, 0x0b, 0x96, 0x7a,
0x9d, 0x01, 0xb5, 0xda, 0x07, 0x06, 0xe5, 0xc4, 0xa0, 0x85, 0xe0, 0x6b, 0x74, 0x94, 0xf0, 0xf3,
0xb7, 0x5c, 0xc3, 0x3c, 0x19, 0x7e, 0xfe, 0x1c, 0x41, 0x55, 0x27, 0x36, 0x31, 0xe8, 0xc9, 0x30,
0x41, 0xed, 0x67, 0x08, 0x2e, 0x6d, 0x11, 0x16, 0xd9, 0x4c, 0x66, 0x30, 0x8b, 0x32, 0xab, 0x4d,
0x8f, 0x13, 0xd6, 0xc7, 0x08, 0x2e, 0xa7, 0xc2, 0x9a, 0xc4, 0xb6, 0xef, 0x40, 0x8e, 0x3f, 0xd1,
0x6a, 0xa6, 0x9e, 0x5d, 0x29, 0xae, 0x5d, 0x51, 0x8e, 0x79, 0x40, 0x06, 0xef, 0xf1, 0x90, 0xb1,
0x63, 0x58, 0x9e, 0x2e, 0xf9, 0xb5, 0xef, 0x21, 0x58, 0x6a, 0x74, 0xdc, 0xfd, 0x21, 0xa4, 0x97,
0xa1, 0xa0, 0xb8, 0xb7, 0x67, 0x93, 0xde, 0x3e, 0x80, 0xe5, 0x03, 0x18, 0x26, 0xd1, 0xc6, 0x35,
0xa8, 0x24, 0xf6, 0x43, 0x2a, 0xa6, 0xa0, 0xcf, 0xc5, 0x37, 0x84, 0x6a, 0x9f, 0x22, 0x58, 0x92,
0xc7, 0xfe, 0x8e, 0xe1, 0x31, 0xeb, 0xb8, 0x43, 0xe7, 0x55, 0x98, 0xed, 0x05, 0x38, 0x24, 0xdf,
0x94, 0xe0, 0x2b, 0x87, 0x54, 0x61, 0x47, 0xbf, 0x47, 0xb0, 0xc0, 0x4f, 0xf9, 0xd3, 0x84, 0xf9,
0x77, 0x08, 0xe6, 0xef, 0x1b, 0xf4, 0x34, 0x41, 0xfe, 0x83, 0x1f, 0x64, 0x43, 0xcc, 0xc7, 0x19,
0x3c, 0x38, 0x63, 0x1c, 0x74, 0x70, 0xac, 0xcc, 0xc6, 0x50, 0x53, 0xed, 0x8f, 0xc3, 0x68, 0x7c,
0xca, 0x90, 0xff, 0x09, 0xc1, 0xc5, 0x2d, 0xc2, 0x42, 0xd4, 0x27, 0x22, 0x6a, 0x8f, 0x6b, 0x2d,
0xcf, 0xe5, 0x99, 0xa3, 0x04, 0x7f, 0x2c, 0xb1, 0xfd, 0xb7, 0x08, 0x16, 0x79, 0x5c, 0x3d, 0x19,
0x46, 0x30, 0x46, 0x56, 0xa8, 0xfd, 0xd2, 0x3f, 0x8d, 0xa2, 0x88, 0x27, 0x51, 0x9d, 0xc2, 0xf0,
0x32, 0x2a, 0xc3, 0xe3, 0xe0, 0x42, 0xca, 0xf6, 0x26, 0xad, 0x66, 0xeb, 0x59, 0x0e, 0x2e, 0x4a,
0xd3, 0x7e, 0x8c, 0x60, 0x29, 0xc8, 0x49, 0x1b, 0x64, 0xb7, 0x4b, 0x1c, 0xf6, 0xe2, 0xfa, 0x4c,
0x6a, 0x23, 0xa3, 0xc8, 0x26, 0x2f, 0x40, 0x81, 0xca, 0x75, 0xc2, 0x74, 0x73, 0x48, 0xd0, 0x3e,
0x41, 0xb0, 0x7c, 0x00, 0xce, 0x24, 0xca, 0xaa, 0xc2, 0xb4, 0xe5, 0x98, 0xe4, 0x69, 0x88, 0x26,
0x78, 0xe5, 0x5f, 0x5a, 0x7d, 0xcb, 0x36, 0x43, 0x18, 0xc1, 0x2b, 0xbe, 0x02, 0x25, 0xe2, 0x18,
0x2d, 0x9b, 0x34, 0x05, 0xaf, 0xd8, 0xd4, 0x19, 0xbd, 0x28, 0x69, 0xdb, 0x9c, 0xa4, 0xfd, 0x04,
0xc1, 0x3c, 0xdf, 0x53, 0x1f, 0x23, 0x7d, 0xb9, 0x3a, 0xab, 0x43, 0x31, 0xb2, 0x69, 0x3e, 0xdc,
0x28, 0x49, 0x7b, 0x02, 0x0b, 0x71, 0x38, 0x93, 0xe8, 0xec, 0x12, 0x40, 0xb8, 0x23, 0xd2, 0xb6,
0xb2, 0x7a, 0x84, 0xa2, 0xfd, 0x0b, 0x01, 0x96, 0xe9, 0x85, 0x50, 0xc6, 0x31, 0x97, 0xbf, 0x8f,
0x2d, 0x62, 0x9b, 0xd1, 0x08, 0x56, 0x10, 0x14, 0xf1, 0x79, 0x13, 0x4a, 0xe4, 0x29, 0xf3, 0x8c,
0x66, 0xcf, 0xf0, 0x8c, 0xae, 0x2c, 0x3e, 0xc6, 0x0a, 0x36, 0x45, 0x31, 0x6c, 0x47, 0x8c, 0xd2,
0xfe, 0xcc, 0x13, 0x13, 0xdf, 0x28, 0x4f, 0xba, 0xc4, 0x17, 0x01, 0x84, 0xd1, 0xca, 0xcf, 0x39,
0xf9, 0x59, 0x50, 0x44, 0x38, 0xff, 0x04, 0x41, 0x45, 0x88, 0x20, 0xe5, 0xe9, 0xf1, 0x69, 0x13,
0x63, 0x50, 0x62, 0xcc, 0x08, 0x17, 0xfa, 0x12, 0xe4, 0x7d, 0xc5, 0x66, 0xc7, 0x55, 0xac, 0x3f,
0xe0, 0x10, 0x31, 0xb4, 0x5f, 0x23, 0x58, 0x4c, 0xa8, 0x7c, 0x12, 0x8b, 0x7e, 0x17, 0xb0, 0x94,
0xd0, 0x1c, 0x8a, 0x1d, 0x1c, 0x3d, 0x89, 0x8a, 0xd9, 0x7f, 0x49, 0x2a, 0x49, 0x3f, 0x6b, 0x25,
0x28, 0x54, 0xfb, 0x2b, 0x82, 0x0b, 0x5b, 0x84, 0x09, 0xd6, 0x0d, 0x1e, 0x3b, 0x76, 0x3c, 0x77,
0xd7, 0x23, 0x94, 0x9e, 0x5e, 0xfb, 0xf8, 0xb9, 0xcc, 0x55, 0x54, 0x22, 0x4d, 0xa2, 0xff, 0x2b,
0x50, 0x12, 0x6b, 0x10, 0xb3, 0xe9, 0xb9, 0xfb, 0xd4, 0xb7, 0xa3, 0xa2, 0x4f, 0xd3, 0xdd, 0x7d,
0x61, 0x10, 0xcc, 0x65, 0x86, 0x2d, 0x19, 0xfc, 0x83, 0x41, 0x50, 0xf8, 0x67, 0xe1, 0x83, 0x01,
0x30, 0x3e, 0x39, 0x39, 0xbd, 0x3a, 0xfe, 0x08, 0xc1, 0x62, 0x42, 0x94, 0x49, 0x74, 0x7b, 0x5b,
0x66, 0x52, 0x52, 0x98, 0xd9, 0xb5, 0xcb, 0xca, 0x31, 0x91, 0xc5, 0x24, 0xb7, 0xf6, 0x19, 0x82,
0x0a, 0xaf, 0xb6, 0x4e, 0x79, 0x40, 0xfb, 0x37, 0x82, 0xf2, 0xb6, 0x43, 0x89, 0xc7, 0x4e, 0x7e,
0x32, 0x8d, 0x6f, 0xc1, 0x8c, 0xe7, 0xee, 0x37, 0x4d, 0x83, 0x19, 0xfe, 0x51, 0x74, 0x4e, 0x09,
0x6f, 0xc3, 0x76, 0x5b, 0xfa, 0xb4, 0xe7, 0xee, 0x6f, 0x1a, 0xcc, 0xc0, 0xe7, 0xa1, 0xd0, 0x31,
0x68, 0xa7, 0xf9, 0x84, 0x0c, 0x68, 0x35, 0x5f, 0xcf, 0xae, 0x94, 0xf5, 0x19, 0x4e, 0x78, 0x40,
0x06, 0x94, 0x1b, 0xd3, 0x6c, 0x20, 0xff, 0x24, 0x56, 0x74, 0x19, 0x8a, 0x9e, 0xbb, 0xbf, 0xbd,
0xd9, 0x6c, 0x91, 0x5d, 0xcb, 0xf1, 0x1d, 0x14, 0x04, 0x69, 0x83, 0x53, 0x38, 0x0a, 0xc9, 0x40,
0x1c, 0xd3, 0x77, 0xcf, 0x19, 0x41, 0xf8, 0xa6, 0x63, 0x6a, 0x7b, 0x50, 0xd9, 0xb1, 0x8d, 0x36,
0xe9, 0xb8, 0xb6, 0x49, 0x3c, 0x11, 0xed, 0x71, 0x05, 0xb2, 0xcc, 0xd8, 0xf5, 0x8f, 0x13, 0xfe,
0x88, 0xbf, 0x08, 0x53, 0x6c, 0xd0, 0x0b, 0x0c, 0xf5, 0x55, 0x65, 0xdc, 0x8d, 0x4c, 0xf3, 0xee,
0xa0, 0x47, 0x74, 0x31, 0x02, 0x2f, 0x41, 0x5e, 0xdc, 0x0b, 0xcb, 0x83, 0xa6, 0xa4, 0xfb, 0x6f,
0xda, 0xa3, 0xd8, 0xba, 0x5b, 0x9e, 0xdb, 0xef, 0xe1, 0x6d, 0x28, 0xf5, 0x86, 0x34, 0xae, 0x84,
0xf4, 0x28, 0x9f, 0x04, 0xad, 0xc7, 0x86, 0x6a, 0xff, 0xcc, 0x40, 0xb9, 0x41, 0x0c, 0xaf, 0xdd,
0x39, 0x0d, 0x85, 0x26, 0xd7, 0xb8, 0x49, 0x6d, 0xdf, 0x47, 0xf8, 0x23, 0xbe, 0x01, 0x67, 0x23,
0x02, 0x35, 0x77, 0xb9, 0x82, 0xaa, 0x79, 0xd1, 0x7a, 0xa9, 0xf4, 0x92, 0x8a, 0xbb, 0x03, 0x33,
0x26, 0xb5, 0x9b, 0x62, 0x8b, 0xa6, 0xc5, 0x16, 0xa9, 0xe5, 0xdb, 0xa4, 0xb6, 0xd8, 0x9a, 0x69,
0x53, 0x3e, 0xe0, 0x7b, 0x50, 0xa6, 0x42, 0x4b, 0x41, 0x9a, 0x35, 0x33, 0x6e, 0x36, 0x50, 0x92,
0xe3, 0xfc, 0x3c, 0xeb, 0x3f, 0x08, 0xe6, 0x74, 0xc2, 0x3c, 0x8b, 0xec, 0x91, 0x53, 0xa1, 0xf0,
0xeb, 0x90, 0xb5, 0x4c, 0x2a, 0x14, 0x5e, 0x5c, 0xab, 0x2a, 0x6f, 0xde, 0xb7, 0x37, 0xa9, 0xce,
0x99, 0xf0, 0x2b, 0x50, 0x76, 0xfb, 0xac, 0xd7, 0x67, 0x4d, 0x11, 0xdb, 0xa4, 0x27, 0x17, 0xf4,
0x92, 0x24, 0xde, 0x13, 0x34, 0xed, 0xd3, 0x98, 0x06, 0x68, 0xdf, 0x66, 0xf4, 0xc5, 0xdc, 0xd9,
0x47, 0x96, 0x19, 0x07, 0xd9, 0xd7, 0xa0, 0x28, 0x21, 0xc9, 0xc0, 0x24, 0x53, 0xb9, 0x4b, 0xca,
0x31, 0x02, 0x26, 0x0f, 0x4a, 0xba, 0x8c, 0xd9, 0x94, 0x3f, 0x6b, 0x0f, 0x60, 0xea, 0xbe, 0xc5,
0x84, 0xfd, 0xf1, 0x82, 0x01, 0x89, 0x82, 0x81, 0x3f, 0xe2, 0x73, 0x91, 0x80, 0x97, 0x11, 0x9e,
0x1b, 0x46, 0x35, 0xd1, 0x0a, 0x74, 0x3d, 0xdf, 0xa5, 0x33, 0xba, 0xff, 0xa6, 0xbd, 0x3f, 0x74,
0xb9, 0x09, 0xe4, 0xc7, 0x30, 0xd5, 0xb1, 0xfc, 0xdb, 0x85, 0x92, 0x2e, 0x9e, 0xb5, 0xef, 0x23,
0x28, 0xdd, 0xb3, 0xfb, 0xf4, 0x65, 0x38, 0xb3, 0xea, 0x72, 0x36, 0xab, 0xbe, 0x9c, 0xfd, 0x0b,
0x82, 0xc5, 0x1d, 0xe2, 0x51, 0x8b, 0x32, 0xe2, 0x30, 0xbf, 0x62, 0xdb, 0x76, 0x1e, 0xbb, 0xf1,
0xd2, 0x18, 0x25, 0x4a, 0xe3, 0xcf, 0xa7, 0x50, 0xe4, 0x3b, 0xe2, 0xf4, 0xbb, 0x32, 0xc9, 0x92,
0x97, 0x15, 0xd3, 0x4e, 0xbf, 0x2b, 0x32, 0xb0, 0x3b, 0x41, 0x22, 0x91, 0x13, 0xce, 0xaf, 0x76,
0x5f, 0x1f, 0x6f, 0x2c, 0x95, 0xf8, 0xa9, 0x6c, 0x00, 0x28, 0x85, 0x7a, 0x71, 0x5d, 0x2f, 0x81,
0xaf, 0xdc, 0x84, 0xaa, 0xff, 0x0f, 0x12, 0xfe, 0x9a, 0xd2, 0x96, 0xf8, 0x05, 0x82, 0x7a, 0x3a,
0xaa, 0x49, 0xce, 0xca, 0xaf, 0x43, 0xce, 0x72, 0x1e, 0xbb, 0x41, 0x01, 0x71, 0x5d, 0x7d, 0xb4,
0x28, 0xd7, 0x95, 0x03, 0xb5, 0xbf, 0x23, 0xa8, 0xbc, 0xd3, 0x27, 0xde, 0xe0, 0x18, 0xb6, 0xbf,
0x4b, 0xba, 0x4d, 0x6a, 0x3d, 0x23, 0xc1, 0xf6, 0x77, 0x49, 0xb7, 0x61, 0x3d, 0x23, 0x31, 0xcb,
0xc8, 0xc5, 0x2d, 0x23, 0x9e, 0x83, 0xe5, 0x47, 0x14, 0x88, 0xd3, 0xb1, 0x02, 0x51, 0x7b, 0x8e,
0xa0, 0xb6, 0x45, 0x58, 0x52, 0xd4, 0xe3, 0x33, 0x8a, 0x8f, 0x11, 0x9c, 0x57, 0x02, 0x9a, 0xc4,
0x1e, 0xbe, 0x1c, 0xb7, 0x07, 0x75, 0xaa, 0x71, 0x60, 0x49, 0xdf, 0x14, 0x16, 0x61, 0x5e, 0x27,
0xbb, 0xdc, 0x52, 0xbc, 0xb7, 0x2c, 0xe7, 0x89, 0xaf, 0x1a, 0x9e, 0xd7, 0x2d, 0xc4, 0xe9, 0x3e,
0xc2, 0x2f, 0xc0, 0xb4, 0x61, 0x9a, 0xbc, 0x24, 0x1b, 0xa9, 0xb6, 0x6f, 0x48, 0x1e, 0x3d, 0x60,
0x8e, 0x48, 0x96, 0x19, 0x5b, 0xb2, 0xeb, 0x5f, 0x85, 0xb9, 0x44, 0x42, 0x86, 0x67, 0x60, 0xea,
0xa1, 0xeb, 0x90, 0xca, 0x19, 0x5c, 0x81, 0xd2, 0x86, 0xe5, 0x18, 0xde, 0xe0, 0x3d, 0xd2, 0x66,
0xae, 0x57, 0x31, 0xf1, 0x1c, 0x14, 0xef, 0xd9, 0xae, 0xc1, 0x7c, 0x02, 0x59, 0xfb, 0xc7, 0x22,
0x94, 0xdf, 0x16, 0xcb, 0x34, 0x88, 0xb7, 0x67, 0xb5, 0x09, 0x6e, 0x42, 0x25, 0xf9, 0x43, 0x0a,
0x7e, 0x5d, 0xa9, 0xb0, 0x94, 0xff, 0x56, 0x6a, 0xa3, 0x80, 0x6b, 0x67, 0xf0, 0x87, 0x30, 0x1b,
0xff, 0x55, 0x04, 0xab, 0xfd, 0x53, 0xf9, 0x3f, 0xc9, 0x61, 0x93, 0x37, 0xa1, 0x1c, 0xfb, 0xf3,
0x03, 0x5f, 0x53, 0xce, 0xad, 0xfa, 0x3b, 0xa4, 0x76, 0x45, 0xc9, 0x1a, 0xfd, 0x3b, 0x43, 0xa2,
0x8f, 0x37, 0xc0, 0x53, 0xd0, 0x2b, 0xbb, 0xe4, 0x87, 0xa1, 0x37, 0xe0, 0xec, 0x81, 0x7e, 0x36,
0x7e, 0x43, 0x39, 0x7f, 0x5a, 0xdf, 0xfb, 0xb0, 0x25, 0xf6, 0x01, 0x1f, 0xfc, 0xc3, 0x01, 0xdf,
0x54, 0xef, 0x40, 0xda, 0xff, 0x1d, 0xb5, 0xd5, 0xb1, 0xf9, 0x43, 0xc5, 0xfd, 0x00, 0xc1, 0x72,
0x4a, 0x13, 0x1a, 0xaf, 0x2b, 0xa7, 0x1b, 0xdd, 0x49, 0xaf, 0xdd, 0x3a, 0xda, 0xa0, 0x10, 0x88,
0x03, 0x73, 0x89, 0xb6, 0x2f, 0xbe, 0xa1, 0x9c, 0x4a, 0xdd, 0xa0, 0xae, 0xbd, 0x3e, 0x1e, 0x73,
0xb8, 0xde, 0x23, 0x98, 0x4b, 0xb4, 0x7a, 0x53, 0xd6, 0x53, 0x37, 0x84, 0x0f, 0xdb, 0xd0, 0x0f,
0xa0, 0x1c, 0xeb, 0xc9, 0xa6, 0x58, 0xbc, 0xaa, 0x6f, 0x7b, 0xd8, 0xd4, 0x8f, 0xa0, 0x14, 0x6d,
0x9d, 0xe2, 0x95, 0x34, 0x5f, 0x3a, 0x30, 0xf1, 0x51, 0x5c, 0x69, 0xd8, 0x75, 0x19, 0xe1, 0x4a,
0x07, 0x9a, 0x49, 0xe3, 0xbb, 0x52, 0x64, 0xfe, 0x91, 0xae, 0x74, 0xe4, 0x25, 0x3e, 0x42, 0xb0,
0xa4, 0xee, 0xbc, 0xe1, 0xb5, 0x34, 0xdb, 0x4c, 0xef, 0x31, 0xd6, 0xd6, 0x8f, 0x34, 0x26, 0xd4,
0xe2, 0x13, 0x98, 0x8d, 0xf7, 0xae, 0x52, 0xb4, 0xa8, 0x6c, 0xc9, 0xd5, 0x6e, 0x8c, 0xc5, 0x1b,
0x2e, 0xf6, 0x2d, 0x28, 0x46, 0xfa, 0x0a, 0xf8, 0xb5, 0x11, 0x76, 0x1c, 0xbd, 0xb6, 0x3a, 0x4c,
0x93, 0x1d, 0x28, 0xc7, 0xee, 0x92, 0xd3, 0x6c, 0x58, 0x71, 0xc5, 0x5f, 0xbb, 0x3e, 0x0e, 0x6b,
0x28, 0x40, 0x07, 0xca, 0xb1, 0x9b, 0xbd, 0x94, 0x95, 0x54, 0x17, 0x99, 0x29, 0x2b, 0x29, 0x2f,
0x0a, 0xb5, 0x33, 0xf8, 0xbb, 0x91, 0x4b, 0xc4, 0xd8, 0x45, 0x2d, 0xfe, 0xff, 0x91, 0xf3, 0xa8,
0xee, 0xa9, 0x6b, 0x6b, 0x47, 0x19, 0x12, 0x42, 0x78, 0x07, 0x0a, 0xe1, 0x05, 0x22, 0xbe, 0x9a,
0x1a, 0x16, 0x8e, 0xb2, 0x53, 0x0d, 0xc8, 0xcb, 0xcb, 0x2c, 0xac, 0xa5, 0xdc, 0xca, 0x47, 0x6e,
0xfa, 0x6a, 0xaf, 0x8c, 0xe4, 0x09, 0x71, 0xea, 0x90, 0x97, 0x15, 0x65, 0xca, 0xa4, 0xb1, 0x1b,
0x9e, 0xda, 0x68, 0x1e, 0x51, 0x92, 0x6a, 0x67, 0xf0, 0xfb, 0x30, 0x13, 0xd4, 0xe9, 0xf8, 0xd5,
0x14, 0xb7, 0x8f, 0x5d, 0x64, 0xd4, 0x0e, 0xe3, 0x0a, 0x66, 0xde, 0x86, 0x9c, 0x28, 0x52, 0xb1,
0x3a, 0xc8, 0x45, 0x0b, 0xd8, 0xc3, 0xb4, 0xf9, 0x43, 0x04, 0xd5, 0xb4, 0x0a, 0x08, 0xa7, 0x9e,
0x6f, 0xa3, 0xca, 0xb8, 0xda, 0xed, 0x23, 0x8e, 0x0a, 0x37, 0xe1, 0x19, 0xcc, 0x2b, 0xf2, 0x6e,
0xbc, 0x9a, 0x36, 0x5f, 0x4a, 0xc9, 0x50, 0x7b, 0x73, 0xfc, 0x01, 0xe1, 0xda, 0x04, 0x4a, 0xd1,
0x54, 0x3a, 0xe5, 0xa0, 0x51, 0x64, 0xe1, 0xb5, 0x6b, 0x63, 0x70, 0x06, 0xcb, 0xac, 0xf5, 0xa1,
0xb4, 0xe3, 0xb9, 0x4f, 0x07, 0x41, 0xaa, 0xfb, 0xbf, 0x59, 0x76, 0xe3, 0xf6, 0xb7, 0xd7, 0x77,
0x2d, 0xd6, 0xe9, 0xb7, 0xf8, 0xfe, 0xaf, 0x4a, 0xde, 0x37, 0x2c, 0xd7, 0x7f, 0x5a, 0xb5, 0x1c,
0x46, 0x3c, 0xc7, 0xb0, 0x57, 0xc5, 0x5c, 0x3e, 0xb5, 0xd7, 0x6a, 0xe5, 0xc5, 0xfb, 0xfa, 0x7f,
0x03, 0x00, 0x00, 0xff, 0xff, 0x65, 0x94, 0xee, 0x58, 0x62, 0x2e, 0x00, 0x00,
// 2292 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xd4, 0x5a, 0xcd, 0x8f, 0x1c, 0x47,
0x15, 0x77, 0xcd, 0xec, 0xcc, 0xee, 0xbc, 0xe9, 0xd9, 0x9d, 0xd4, 0x7e, 0x78, 0xdc, 0xfe, 0x5a,
0x77, 0x62, 0xb2, 0xb6, 0x13, 0x3b, 0x59, 0xdb, 0x18, 0x84, 0xf8, 0x5a, 0x0f, 0xb6, 0x57, 0x4e,
0xac, 0x4d, 0x4f, 0x88, 0x12, 0x22, 0x6b, 0xd4, 0x33, 0x5d, 0xde, 0x69, 0xb9, 0x3f, 0x86, 0xae,
0x9e, 0x5d, 0x8f, 0x4f, 0x88, 0x20, 0x24, 0x04, 0x38, 0x07, 0x10, 0x12, 0x1c, 0x38, 0x20, 0xe5,
0xc0, 0x09, 0x50, 0x90, 0x90, 0x10, 0xc7, 0x1c, 0xb8, 0x81, 0xf8, 0x1f, 0xb8, 0xc1, 0x9f, 0x80,
0x40, 0x5d, 0x55, 0xdd, 0xd3, 0xdd, 0x5b, 0x3d, 0x3b, 0xeb, 0x89, 0xd9, 0xdd, 0x5b, 0xf7, 0xeb,
0xf7, 0xaa, 0x7e, 0xf5, 0xea, 0xbd, 0x57, 0xef, 0xd5, 0x6b, 0x50, 0x1c, 0xcb, 0xde, 0x19, 0xd0,
0xab, 0x7d, 0xdf, 0x0b, 0x3c, 0xbc, 0x98, 0x7c, 0xbb, 0xca, 0x5f, 0x54, 0xa5, 0xeb, 0x39, 0x8e,
0xe7, 0x72, 0xa2, 0xaa, 0xd0, 0x6e, 0x8f, 0x38, 0x06, 0x7f, 0xd3, 0x3e, 0x43, 0x70, 0xf2, 0xb6,
0x4f, 0x8c, 0x80, 0xdc, 0xf6, 0x6c, 0x9b, 0x74, 0x03, 0xcb, 0x73, 0x75, 0xf2, 0xdd, 0x01, 0xa1,
0x01, 0x7e, 0x03, 0x66, 0x3a, 0x06, 0x25, 0x0d, 0xb4, 0x8a, 0xd6, 0xaa, 0xeb, 0x67, 0xae, 0xa6,
0xc6, 0x16, 0x63, 0xbe, 0x4d, 0xb7, 0x37, 0x0c, 0x4a, 0x74, 0xc6, 0x89, 0x4f, 0xc2, 0xac, 0xd9,
0x69, 0xbb, 0x86, 0x43, 0x1a, 0x85, 0x55, 0xb4, 0x56, 0xd1, 0xcb, 0x66, 0xe7, 0x81, 0xe1, 0x10,
0xfc, 0x2a, 0x2c, 0x74, 0xe3, 0xf1, 0x39, 0x43, 0x91, 0x31, 0xcc, 0x8f, 0xc8, 0x8c, 0x71, 0x05,
0xca, 0x1c, 0x5f, 0x63, 0x66, 0x15, 0xad, 0x29, 0xba, 0x78, 0xc3, 0x67, 0x01, 0x68, 0xcf, 0xf0,
0x4d, 0xda, 0x76, 0x07, 0x4e, 0xa3, 0xb4, 0x8a, 0xd6, 0x4a, 0x7a, 0x85, 0x53, 0x1e, 0x0c, 0x1c,
0xed, 0xc7, 0x08, 0x96, 0x9b, 0xbe, 0xd7, 0x3f, 0x12, 0x8b, 0xd0, 0x7e, 0x8b, 0x60, 0xe9, 0x9e,
0x41, 0x8f, 0x86, 0x46, 0xcf, 0x02, 0x04, 0x96, 0x43, 0xda, 0x34, 0x30, 0x9c, 0x3e, 0xd3, 0xea,
0x8c, 0x5e, 0x09, 0x29, 0xad, 0x90, 0xa0, 0x7d, 0x00, 0xca, 0x86, 0xe7, 0xd9, 0x3a, 0xa1, 0x7d,
0xcf, 0xa5, 0x04, 0x5f, 0x87, 0x32, 0x0d, 0x8c, 0x60, 0x40, 0x05, 0xc8, 0xd3, 0x52, 0x90, 0x2d,
0xc6, 0xa2, 0x0b, 0x56, 0xbc, 0x04, 0xa5, 0x1d, 0xc3, 0x1e, 0x70, 0x8c, 0x73, 0x3a, 0x7f, 0xd1,
0x3e, 0x84, 0xf9, 0x56, 0xe0, 0x5b, 0xee, 0xf6, 0xe7, 0x38, 0x78, 0x25, 0x1a, 0xfc, 0x1f, 0x08,
0x4e, 0x35, 0x09, 0xed, 0xfa, 0x56, 0xe7, 0x88, 0x98, 0xae, 0x06, 0xca, 0x88, 0xb2, 0xd9, 0x64,
0xaa, 0x2e, 0xea, 0x29, 0x5a, 0x66, 0x33, 0x4a, 0xd9, 0xcd, 0xf8, 0x75, 0x01, 0x54, 0xd9, 0xa2,
0xa6, 0x51, 0xdf, 0x57, 0x63, 0x8f, 0x2a, 0x30, 0xa1, 0x8b, 0x69, 0x21, 0x11, 0x0d, 0x46, 0xb3,
0xb5, 0x18, 0x21, 0x76, 0xbc, 0xec, 0xaa, 0x8a, 0x92, 0x55, 0xad, 0xc3, 0xf2, 0x8e, 0xe5, 0x07,
0x03, 0xc3, 0x6e, 0x77, 0x7b, 0x86, 0xeb, 0x12, 0x9b, 0xe9, 0x89, 0x36, 0x66, 0x56, 0x8b, 0x6b,
0x15, 0x7d, 0x51, 0x7c, 0xbc, 0xcd, 0xbf, 0x85, 0xca, 0xa2, 0xf8, 0x06, 0xac, 0xf4, 0x7b, 0x43,
0x6a, 0x75, 0xf7, 0x08, 0x95, 0x98, 0xd0, 0x52, 0xf4, 0x35, 0x29, 0xc5, 0xfc, 0xfc, 0x2d, 0xcf,
0x30, 0x8f, 0x86, 0x9f, 0x3f, 0x43, 0xd0, 0xd0, 0x89, 0x4d, 0x0c, 0x7a, 0x34, 0x4c, 0x50, 0xfb,
0x39, 0x82, 0x73, 0x77, 0x49, 0x90, 0xd8, 0xcc, 0xc0, 0x08, 0x2c, 0x1a, 0x58, 0x5d, 0x7a, 0x98,
0xb0, 0x3e, 0x46, 0x70, 0x3e, 0x17, 0xd6, 0x34, 0xb6, 0x7d, 0x0b, 0x4a, 0xe1, 0x13, 0x6d, 0x14,
0x56, 0x8b, 0x6b, 0xd5, 0xf5, 0x0b, 0x52, 0x99, 0xfb, 0x64, 0xf8, 0x5e, 0x18, 0x32, 0xb6, 0x0c,
0xcb, 0xd7, 0x39, 0xbf, 0xf6, 0x7d, 0x04, 0x2b, 0xad, 0x9e, 0xb7, 0x3b, 0x82, 0xf4, 0x22, 0x14,
0x94, 0xf6, 0xf6, 0x62, 0xd6, 0xdb, 0x87, 0x70, 0x72, 0x0f, 0x86, 0x69, 0xb4, 0x71, 0x09, 0xea,
0x99, 0xfd, 0xe0, 0x8a, 0xa9, 0xe8, 0x0b, 0xe9, 0x0d, 0xa1, 0xda, 0xa7, 0x08, 0x56, 0xf8, 0xb1,
0xbf, 0x65, 0xf8, 0x81, 0x75, 0xd8, 0xa1, 0xf3, 0x22, 0xcc, 0xf7, 0x23, 0x1c, 0x9c, 0x6f, 0x86,
0xf1, 0xd5, 0x62, 0x2a, 0xb3, 0xa3, 0x3f, 0x20, 0x58, 0x0a, 0x4f, 0xf9, 0xe3, 0x84, 0xf9, 0xf7,
0x08, 0x16, 0xef, 0x19, 0xf4, 0x38, 0x41, 0xfe, 0xa3, 0x08, 0xb2, 0x31, 0xe6, 0xc3, 0x0c, 0x1e,
0x21, 0x63, 0x1a, 0x74, 0x74, 0xac, 0xcc, 0xa7, 0x50, 0x53, 0xed, 0x4f, 0xa3, 0x68, 0x7c, 0xcc,
0x90, 0xff, 0x19, 0xc1, 0xd9, 0xbb, 0x24, 0x88, 0x51, 0x1f, 0x89, 0xa8, 0x3d, 0xa9, 0xb5, 0x3c,
0xe3, 0x67, 0x8e, 0x14, 0xfc, 0xa1, 0xc4, 0xf6, 0xdf, 0x21, 0x58, 0x0e, 0xe3, 0xea, 0xd1, 0x30,
0x82, 0x09, 0xb2, 0x42, 0xed, 0x57, 0xe2, 0x34, 0x4a, 0x22, 0x9e, 0x46, 0x75, 0x12, 0xc3, 0x2b,
0xc8, 0x0c, 0x2f, 0x04, 0x17, 0x53, 0x36, 0x9b, 0xb4, 0x51, 0x5c, 0x2d, 0x86, 0xe0, 0x92, 0x34,
0xed, 0x27, 0x08, 0x56, 0xa2, 0x9c, 0xb4, 0x45, 0xb6, 0x1d, 0xe2, 0x06, 0xcf, 0xaf, 0xcf, 0xac,
0x36, 0x0a, 0x92, 0x6c, 0xf2, 0x0c, 0x54, 0x28, 0x9f, 0x27, 0x4e, 0x37, 0x47, 0x04, 0xed, 0x13,
0x04, 0x27, 0xf7, 0xc0, 0x99, 0x46, 0x59, 0x0d, 0x98, 0xb5, 0x5c, 0x93, 0x3c, 0x89, 0xd1, 0x44,
0xaf, 0xe1, 0x97, 0xce, 0xc0, 0xb2, 0xcd, 0x18, 0x46, 0xf4, 0x8a, 0x2f, 0x80, 0x42, 0x5c, 0xa3,
0x63, 0x93, 0x36, 0xe3, 0x65, 0x9b, 0x3a, 0xa7, 0x57, 0x39, 0x6d, 0x33, 0x24, 0x69, 0x3f, 0x45,
0xb0, 0x18, 0xee, 0xa9, 0xc0, 0x48, 0x5f, 0xac, 0xce, 0x56, 0xa1, 0x9a, 0xd8, 0x34, 0x01, 0x37,
0x49, 0xd2, 0x1e, 0xc3, 0x52, 0x1a, 0xce, 0x34, 0x3a, 0x3b, 0x07, 0x10, 0xef, 0x08, 0xb7, 0xad,
0xa2, 0x9e, 0xa0, 0x68, 0xff, 0x46, 0x80, 0x79, 0x7a, 0xc1, 0x94, 0x71, 0xc8, 0xe5, 0xef, 0x23,
0x8b, 0xd8, 0x66, 0x32, 0x82, 0x55, 0x18, 0x85, 0x7d, 0x6e, 0x82, 0x42, 0x9e, 0x04, 0xbe, 0xd1,
0xee, 0x1b, 0xbe, 0xe1, 0xf0, 0xe2, 0x63, 0xa2, 0x60, 0x53, 0x65, 0x62, 0x5b, 0x4c, 0x4a, 0xfb,
0x6b, 0x98, 0x98, 0x08, 0xa3, 0x3c, 0xea, 0x2b, 0x3e, 0x0b, 0xc0, 0x8c, 0x96, 0x7f, 0x2e, 0xf1,
0xcf, 0x8c, 0xc2, 0xc2, 0xf9, 0x27, 0x08, 0xea, 0x6c, 0x09, 0x7c, 0x3d, 0xfd, 0x70, 0xd8, 0x8c,
0x0c, 0xca, 0xc8, 0x8c, 0x71, 0xa1, 0x2f, 0x43, 0x59, 0x28, 0xb6, 0x38, 0xa9, 0x62, 0x85, 0xc0,
0x3e, 0xcb, 0xd0, 0x7e, 0x83, 0x60, 0x39, 0xa3, 0xf2, 0x69, 0x2c, 0xfa, 0x5d, 0xc0, 0x7c, 0x85,
0xe6, 0x68, 0xd9, 0xd1, 0xd1, 0x93, 0xa9, 0x98, 0xc5, 0x4b, 0x56, 0x49, 0xfa, 0x4b, 0x56, 0x86,
0x42, 0xb5, 0xbf, 0x23, 0x38, 0x73, 0x97, 0x04, 0x8c, 0x75, 0x23, 0x8c, 0x1d, 0x5b, 0xbe, 0xb7,
0xed, 0x13, 0x4a, 0x8f, 0xaf, 0x7d, 0xfc, 0x82, 0xe7, 0x2a, 0xb2, 0x25, 0x4d, 0xa3, 0xff, 0x0b,
0xa0, 0xb0, 0x39, 0x88, 0xd9, 0xf6, 0xbd, 0x5d, 0x2a, 0xec, 0xa8, 0x2a, 0x68, 0xba, 0xb7, 0xcb,
0x0c, 0x22, 0xf0, 0x02, 0xc3, 0xe6, 0x0c, 0xe2, 0x60, 0x60, 0x94, 0xf0, 0x33, 0xf3, 0xc1, 0x08,
0x58, 0x38, 0x38, 0x39, 0xbe, 0x3a, 0xfe, 0x08, 0xc1, 0x72, 0x66, 0x29, 0xd3, 0xe8, 0xf6, 0x26,
0xcf, 0xa4, 0xf8, 0x62, 0xe6, 0xd7, 0xcf, 0x4b, 0x65, 0x12, 0x93, 0x71, 0x6e, 0xed, 0x33, 0x04,
0xf5, 0xb0, 0xda, 0x3a, 0xe6, 0x01, 0xed, 0x3f, 0x08, 0x6a, 0x9b, 0x2e, 0x25, 0x7e, 0x70, 0xf4,
0x93, 0x69, 0x7c, 0x03, 0xe6, 0x7c, 0x6f, 0xb7, 0x6d, 0x1a, 0x81, 0x21, 0x8e, 0xa2, 0x53, 0x52,
0x78, 0x1b, 0xb6, 0xd7, 0xd1, 0x67, 0x7d, 0x6f, 0xb7, 0x69, 0x04, 0x06, 0x3e, 0x0d, 0x95, 0x9e,
0x41, 0x7b, 0xed, 0xc7, 0x64, 0x48, 0x1b, 0xe5, 0xd5, 0xe2, 0x5a, 0x4d, 0x9f, 0x0b, 0x09, 0xf7,
0xc9, 0x90, 0x86, 0xc6, 0x34, 0x1f, 0xad, 0x7f, 0x1a, 0x2b, 0x3a, 0x0f, 0x55, 0xdf, 0xdb, 0xdd,
0x6c, 0xb6, 0x3b, 0x64, 0xdb, 0x72, 0x85, 0x83, 0x02, 0x23, 0x6d, 0x84, 0x94, 0x10, 0x05, 0x67,
0x20, 0xae, 0x29, 0xdc, 0x73, 0x8e, 0x11, 0xbe, 0xe5, 0x9a, 0xda, 0x0e, 0xd4, 0xb7, 0x6c, 0xa3,
0x4b, 0x7a, 0x9e, 0x6d, 0x12, 0x9f, 0x45, 0x7b, 0x5c, 0x87, 0x62, 0x60, 0x6c, 0x8b, 0xe3, 0x24,
0x7c, 0xc4, 0x5f, 0x82, 0x99, 0x60, 0xd8, 0x8f, 0x0c, 0xf5, 0x15, 0x69, 0xdc, 0x4d, 0x0c, 0xf3,
0xee, 0xb0, 0x4f, 0x74, 0x26, 0x81, 0x57, 0xa0, 0xcc, 0xee, 0x85, 0xf9, 0x41, 0xa3, 0xe8, 0xe2,
0x4d, 0x7b, 0x98, 0x9a, 0xf7, 0xae, 0xef, 0x0d, 0xfa, 0x78, 0x13, 0x94, 0xfe, 0x88, 0x16, 0x2a,
0x21, 0x3f, 0xca, 0x67, 0x41, 0xeb, 0x29, 0x51, 0xed, 0x5f, 0x05, 0xa8, 0xb5, 0x88, 0xe1, 0x77,
0x7b, 0xc7, 0xa1, 0xd0, 0x0c, 0x35, 0x6e, 0x52, 0x5b, 0xf8, 0x48, 0xf8, 0x88, 0xaf, 0xc0, 0x4b,
0x89, 0x05, 0xb5, 0xb7, 0x43, 0x05, 0x35, 0xca, 0xac, 0xf5, 0x52, 0xef, 0x67, 0x15, 0x77, 0x0b,
0xe6, 0x4c, 0x6a, 0xb7, 0xd9, 0x16, 0xcd, 0xb2, 0x2d, 0x92, 0xaf, 0xaf, 0x49, 0x6d, 0xb6, 0x35,
0xb3, 0x26, 0x7f, 0xc0, 0x77, 0xa0, 0x46, 0x99, 0x96, 0xa2, 0x34, 0x6b, 0x6e, 0xd2, 0x6c, 0x40,
0xe1, 0x72, 0x22, 0xcf, 0xfa, 0x2f, 0x82, 0x05, 0x9d, 0x04, 0xbe, 0x45, 0x76, 0xc8, 0xb1, 0x50,
0xf8, 0x65, 0x28, 0x5a, 0x26, 0x65, 0x0a, 0xaf, 0xae, 0x37, 0xa4, 0x37, 0xef, 0x9b, 0x4d, 0xaa,
0x87, 0x4c, 0xf8, 0x65, 0xa8, 0x79, 0x83, 0xa0, 0x3f, 0x08, 0xda, 0x2c, 0xb6, 0x71, 0x4f, 0xae,
0xe8, 0x0a, 0x27, 0xde, 0x61, 0x34, 0xed, 0xd3, 0x94, 0x06, 0xe8, 0xc0, 0x0e, 0xe8, 0xf3, 0xb9,
0xb3, 0x40, 0x56, 0x98, 0x04, 0xd9, 0xd7, 0xa1, 0xca, 0x21, 0xf1, 0xc0, 0xc4, 0x53, 0xb9, 0x73,
0x52, 0x19, 0x06, 0x33, 0x0c, 0x4a, 0x3a, 0x8f, 0xd9, 0x34, 0x7c, 0xd6, 0xee, 0xc3, 0xcc, 0x3d,
0x2b, 0x60, 0xf6, 0x17, 0x16, 0x0c, 0x88, 0x15, 0x0c, 0xe1, 0x23, 0x3e, 0x95, 0x08, 0x78, 0x05,
0xe6, 0xb9, 0x71, 0x54, 0x63, 0xad, 0x40, 0xcf, 0x17, 0x2e, 0x5d, 0xd0, 0xc5, 0x9b, 0xf6, 0xfe,
0xc8, 0xe5, 0xa6, 0x58, 0x3f, 0x86, 0x99, 0x9e, 0x25, 0x6e, 0x17, 0x14, 0x9d, 0x3d, 0x6b, 0x3f,
0x40, 0xa0, 0xdc, 0xb1, 0x07, 0xf4, 0x45, 0x38, 0xb3, 0xec, 0x72, 0xb6, 0x28, 0xbf, 0x9c, 0xfd,
0x1b, 0x82, 0xe5, 0x2d, 0xe2, 0x53, 0x8b, 0x06, 0xc4, 0x0d, 0x44, 0xc5, 0xb6, 0xe9, 0x3e, 0xf2,
0xd2, 0xa5, 0x31, 0xca, 0x94, 0xc6, 0x9f, 0x4f, 0xa1, 0x18, 0xee, 0x88, 0x3b, 0x70, 0x78, 0x92,
0xc5, 0x2f, 0x2b, 0x66, 0xdd, 0x81, 0xc3, 0x32, 0xb0, 0x5b, 0x51, 0x22, 0x51, 0x62, 0xce, 0x2f,
0x77, 0x5f, 0x81, 0x37, 0x95, 0x4a, 0xfc, 0x8c, 0x37, 0x00, 0xa4, 0x8b, 0x7a, 0x7e, 0x5d, 0xaf,
0x80, 0x50, 0x6e, 0x46, 0xd5, 0x5f, 0x80, 0x8c, 0xbf, 0xe6, 0xb4, 0x25, 0x7e, 0x89, 0x60, 0x35,
0x1f, 0xd5, 0x34, 0x67, 0xe5, 0x37, 0xa0, 0x64, 0xb9, 0x8f, 0xbc, 0xa8, 0x80, 0xb8, 0x2c, 0x3f,
0x5a, 0xa4, 0xf3, 0x72, 0x41, 0xed, 0x9f, 0x08, 0xea, 0xef, 0x0c, 0x88, 0x3f, 0x3c, 0x84, 0xed,
0x77, 0x88, 0xd3, 0xa6, 0xd6, 0x53, 0x12, 0x6d, 0xbf, 0x43, 0x9c, 0x96, 0xf5, 0x94, 0xa4, 0x2c,
0xa3, 0x94, 0xb6, 0x8c, 0x74, 0x0e, 0x56, 0x1e, 0x53, 0x20, 0xce, 0xa6, 0x0a, 0x44, 0xed, 0x19,
0x02, 0xf5, 0x2e, 0x09, 0xb2, 0x4b, 0x3d, 0x3c, 0xa3, 0xf8, 0x18, 0xc1, 0x69, 0x29, 0xa0, 0x69,
0xec, 0xe1, 0x2b, 0x69, 0x7b, 0x90, 0xa7, 0x1a, 0x7b, 0xa6, 0x14, 0xa6, 0xf0, 0x26, 0x28, 0xcd,
0x81, 0xe3, 0x0c, 0x23, 0x9d, 0x5c, 0x00, 0xc5, 0xe7, 0x8f, 0xfc, 0x24, 0xe6, 0xf9, 0x53, 0x55,
0xd0, 0xc2, 0xf3, 0x56, 0xbb, 0x02, 0x35, 0x21, 0x22, 0x50, 0xab, 0x30, 0xe7, 0x8b, 0x67, 0xc1,
0x1f, 0xbf, 0x6b, 0xcb, 0xb0, 0xa8, 0x93, 0xed, 0xd0, 0x12, 0xfd, 0xb7, 0x2c, 0xf7, 0xb1, 0x98,
0x26, 0xcc, 0x1b, 0x97, 0xd2, 0x74, 0x31, 0xd6, 0x17, 0x61, 0xd6, 0x30, 0xcd, 0xb0, 0xe4, 0x1b,
0xbb, 0x2d, 0xdf, 0xe4, 0x3c, 0x7a, 0xc4, 0x9c, 0xd0, 0x5c, 0x61, 0x62, 0xcd, 0x5d, 0xfe, 0x1a,
0x2c, 0x64, 0x12, 0x3e, 0x3c, 0x07, 0x33, 0x0f, 0x3c, 0x97, 0xd4, 0x4f, 0xe0, 0x3a, 0x28, 0x1b,
0x96, 0x6b, 0xf8, 0xc3, 0xf7, 0x48, 0x37, 0xf0, 0xfc, 0xba, 0x89, 0x17, 0xa0, 0x7a, 0xc7, 0xf6,
0x8c, 0x40, 0x10, 0xc8, 0xfa, 0x5f, 0x56, 0xa0, 0xf6, 0x36, 0x9b, 0xa6, 0x45, 0xfc, 0x1d, 0xab,
0x4b, 0x70, 0x1b, 0xea, 0xd9, 0x1f, 0x5e, 0xf0, 0x6b, 0xd2, 0x0d, 0xc9, 0xf9, 0x2f, 0x46, 0x1d,
0x07, 0x5c, 0x3b, 0x81, 0x3f, 0x84, 0xf9, 0xf4, 0xaf, 0x28, 0x58, 0xee, 0xff, 0xd2, 0xff, 0x55,
0xf6, 0x1b, 0xbc, 0x0d, 0xb5, 0xd4, 0x9f, 0x25, 0xf8, 0x92, 0x74, 0x6c, 0xd9, 0xdf, 0x27, 0xea,
0x05, 0x29, 0x6b, 0xf2, 0xef, 0x0f, 0x8e, 0x3e, 0xdd, 0x60, 0xcf, 0x41, 0x2f, 0xed, 0xc2, 0xef,
0x87, 0xde, 0x80, 0x97, 0xf6, 0xf4, 0xcb, 0xf1, 0xeb, 0xd2, 0xf1, 0xf3, 0xfa, 0xea, 0xfb, 0x4d,
0xb1, 0x0b, 0x78, 0xef, 0x1f, 0x14, 0xf8, 0xaa, 0x7c, 0x07, 0xf2, 0xfe, 0x1f, 0x51, 0xaf, 0x4d,
0xcc, 0x1f, 0x2b, 0xee, 0x87, 0x08, 0x4e, 0xe6, 0x34, 0xb9, 0xf1, 0x75, 0xe9, 0x70, 0xe3, 0x3b,
0xf5, 0xea, 0x8d, 0x83, 0x09, 0xc5, 0x40, 0x5c, 0x58, 0xc8, 0xb4, 0x95, 0xf1, 0x15, 0xe9, 0x50,
0xf2, 0x06, 0xb8, 0xfa, 0xda, 0x64, 0xcc, 0xf1, 0x7c, 0x0f, 0x61, 0x21, 0xd3, 0x4a, 0xce, 0x99,
0x4f, 0xde, 0x70, 0xde, 0x6f, 0x43, 0x3f, 0x80, 0x5a, 0xaa, 0xe7, 0x9b, 0x63, 0xf1, 0xb2, 0xbe,
0xf0, 0x7e, 0x43, 0x3f, 0x04, 0x25, 0xd9, 0x9a, 0xc5, 0x6b, 0x79, 0xbe, 0xb4, 0x67, 0xe0, 0x83,
0xb8, 0xd2, 0xa8, 0xab, 0x33, 0xc6, 0x95, 0xf6, 0x34, 0xab, 0x26, 0x77, 0xa5, 0xc4, 0xf8, 0x63,
0x5d, 0xe9, 0xc0, 0x53, 0x7c, 0x84, 0x60, 0x45, 0xde, 0xd9, 0xc3, 0xeb, 0x79, 0xb6, 0x99, 0xdf,
0xc3, 0x54, 0xaf, 0x1f, 0x48, 0x26, 0xd6, 0xe2, 0x63, 0x98, 0x4f, 0xf7, 0xc6, 0x72, 0xb4, 0x28,
0x6d, 0xf9, 0xa9, 0x57, 0x26, 0xe2, 0x8d, 0x27, 0xfb, 0x36, 0x54, 0x13, 0x7d, 0x0b, 0xfc, 0xea,
0x18, 0x3b, 0x4e, 0x5e, 0x8b, 0xed, 0xa7, 0xc9, 0x1e, 0xd4, 0x52, 0x77, 0xd5, 0x79, 0x36, 0x2c,
0x69, 0x21, 0xa8, 0x97, 0x27, 0x61, 0x8d, 0x17, 0xd0, 0x83, 0x5a, 0xea, 0xe6, 0x30, 0x67, 0x26,
0xd9, 0x45, 0x69, 0xce, 0x4c, 0xd2, 0x8b, 0x48, 0xed, 0x04, 0xfe, 0x5e, 0xe2, 0x92, 0x32, 0x75,
0x11, 0x8c, 0xdf, 0x1c, 0x3b, 0x8e, 0xec, 0x1e, 0x5c, 0x5d, 0x3f, 0x88, 0x48, 0x0c, 0xe1, 0x1d,
0xa8, 0xc4, 0x17, 0x94, 0xf8, 0x62, 0x6e, 0x58, 0x38, 0xc8, 0x4e, 0xb5, 0xa0, 0xcc, 0x2f, 0xcb,
0xb0, 0x96, 0x73, 0xeb, 0x9f, 0xb8, 0x49, 0x54, 0x5f, 0x1e, 0xcb, 0x13, 0xe3, 0xd4, 0xa1, 0xcc,
0x2b, 0xd6, 0x9c, 0x41, 0x53, 0x37, 0x48, 0xea, 0x78, 0x1e, 0x56, 0xf2, 0x6a, 0x27, 0xf0, 0xfb,
0x30, 0x17, 0xdd, 0x03, 0xe0, 0x57, 0x72, 0xdc, 0x3e, 0x75, 0x51, 0xa2, 0xee, 0xc7, 0x15, 0x8d,
0xbc, 0x09, 0x25, 0x56, 0x04, 0x63, 0x79, 0x90, 0x4b, 0x16, 0xc8, 0xfb, 0x69, 0xf3, 0x47, 0x08,
0x1a, 0x79, 0x15, 0x16, 0xce, 0x3d, 0xdf, 0xc6, 0x95, 0x89, 0xea, 0xcd, 0x03, 0x4a, 0xc5, 0x9b,
0xf0, 0x14, 0x16, 0x25, 0x79, 0x3d, 0xbe, 0x96, 0x37, 0x5e, 0x4e, 0x49, 0xa2, 0xbe, 0x31, 0xb9,
0x40, 0x3c, 0xf7, 0x16, 0x94, 0x58, 0x3e, 0x9e, 0xa3, 0xd2, 0x64, 0x7a, 0x9f, 0xb3, 0xfd, 0xa9,
0x74, 0x5e, 0x3b, 0x81, 0x09, 0x28, 0xc9, 0xe4, 0x3c, 0xe7, 0xe8, 0x92, 0xe4, 0xf5, 0xea, 0xa5,
0x09, 0x38, 0xa3, 0x69, 0xd6, 0x07, 0xa0, 0x6c, 0xf9, 0xde, 0x93, 0x61, 0x94, 0x3c, 0xff, 0x7f,
0xa6, 0xdd, 0xb8, 0xf9, 0x9d, 0xeb, 0xdb, 0x56, 0xd0, 0x1b, 0x74, 0x42, 0x8b, 0xba, 0xc6, 0x79,
0x5f, 0xb7, 0x3c, 0xf1, 0x74, 0xcd, 0x72, 0x03, 0xe2, 0xbb, 0x86, 0x7d, 0x8d, 0x8d, 0x25, 0xa8,
0xfd, 0x4e, 0xa7, 0xcc, 0xde, 0xaf, 0xff, 0x2f, 0x00, 0x00, 0xff, 0xff, 0xb7, 0x14, 0xd5, 0xf4,
0x14, 0x2f, 0x00, 0x00,
}
// Reference imports to suppress errors if they are not otherwise used.
@ -3421,6 +3505,7 @@ type MilvusServiceClient interface {
Flush(ctx context.Context, in *FlushRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
GetPersistentSegmentInfo(ctx context.Context, in *GetPersistentSegmentInfoRequest, opts ...grpc.CallOption) (*GetPersistentSegmentInfoResponse, error)
GetQuerySegmentInfo(ctx context.Context, in *GetQuerySegmentInfoRequest, opts ...grpc.CallOption) (*GetQuerySegmentInfoResponse, error)
Dummy(ctx context.Context, in *DummyRequest, opts ...grpc.CallOption) (*DummyResponse, error)
// TODO: remove
RegisterLink(ctx context.Context, in *RegisterLinkRequest, opts ...grpc.CallOption) (*RegisterLinkResponse, error)
}
@ -3667,6 +3752,15 @@ func (c *milvusServiceClient) GetQuerySegmentInfo(ctx context.Context, in *GetQu
return out, nil
}
func (c *milvusServiceClient) Dummy(ctx context.Context, in *DummyRequest, opts ...grpc.CallOption) (*DummyResponse, error) {
out := new(DummyResponse)
err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/Dummy", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *milvusServiceClient) RegisterLink(ctx context.Context, in *RegisterLinkRequest, opts ...grpc.CallOption) (*RegisterLinkResponse, error) {
out := new(RegisterLinkResponse)
err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/RegisterLink", in, out, opts...)
@ -3704,6 +3798,7 @@ type MilvusServiceServer interface {
Flush(context.Context, *FlushRequest) (*commonpb.Status, error)
GetPersistentSegmentInfo(context.Context, *GetPersistentSegmentInfoRequest) (*GetPersistentSegmentInfoResponse, error)
GetQuerySegmentInfo(context.Context, *GetQuerySegmentInfoRequest) (*GetQuerySegmentInfoResponse, error)
Dummy(context.Context, *DummyRequest) (*DummyResponse, error)
// TODO: remove
RegisterLink(context.Context, *RegisterLinkRequest) (*RegisterLinkResponse, error)
}
@ -3790,6 +3885,9 @@ func (*UnimplementedMilvusServiceServer) GetPersistentSegmentInfo(ctx context.Co
func (*UnimplementedMilvusServiceServer) GetQuerySegmentInfo(ctx context.Context, req *GetQuerySegmentInfoRequest) (*GetQuerySegmentInfoResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetQuerySegmentInfo not implemented")
}
func (*UnimplementedMilvusServiceServer) Dummy(ctx context.Context, req *DummyRequest) (*DummyResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Dummy not implemented")
}
func (*UnimplementedMilvusServiceServer) RegisterLink(ctx context.Context, req *RegisterLinkRequest) (*RegisterLinkResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method RegisterLink not implemented")
}
@ -4266,6 +4364,24 @@ func _MilvusService_GetQuerySegmentInfo_Handler(srv interface{}, ctx context.Con
return interceptor(ctx, in, info, handler)
}
func _MilvusService_Dummy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DummyRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MilvusServiceServer).Dummy(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/milvus.proto.milvus.MilvusService/Dummy",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MilvusServiceServer).Dummy(ctx, req.(*DummyRequest))
}
return interceptor(ctx, in, info, handler)
}
func _MilvusService_RegisterLink_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(RegisterLinkRequest)
if err := dec(in); err != nil {
@ -4392,6 +4508,10 @@ var _MilvusService_serviceDesc = grpc.ServiceDesc{
MethodName: "GetQuerySegmentInfo",
Handler: _MilvusService_GetQuerySegmentInfo_Handler,
},
{
MethodName: "Dummy",
Handler: _MilvusService_Dummy_Handler,
},
{
MethodName: "RegisterLink",
Handler: _MilvusService_RegisterLink_Handler,

View File

@ -1435,6 +1435,28 @@ func (node *ProxyNode) getSegmentsOfCollection(ctx context.Context, dbName strin
return ret, nil
}
func (node *ProxyNode) Dummy(ctx context.Context, req *milvuspb.DummyRequest) (*milvuspb.DummyResponse, error) {
if req.RequestType == "retrieve" {
request := &milvuspb.RetrieveRequest{
DbName: "",
CollectionName: "",
PartitionNames: []string{},
Ids: &schemapb.IDs{},
OutputFields: []string{},
}
_, _ = node.Retrieve(ctx, request)
return &milvuspb.DummyResponse{
Response: `{"status": "success"}`,
}, nil
}
return &milvuspb.DummyResponse{
Response: `{"status": "fail"}`,
}, nil
}
func (node *ProxyNode) RegisterLink(ctx context.Context, req *milvuspb.RegisterLinkRequest) (*milvuspb.RegisterLinkResponse, error) {
code := node.stateCode.Load().(internalpb.StateCode)
log.Debug("RegisterLink",