Skip to content

M
milvus

milvus / milvus
9 个月 前同步成功

通知 260
Star 22476
Fork 2472
M
milvus

前往新版Gitcode，体验更适合开发者的 AI 搜索 >>

未验证 提交 cc5bee46 编写于 作者: X xige-16 提交者： GitHub
浏览文件
操作

Stop handoff if segment has been compacted (#15181) 

Signed-off-by: Nxige-16 <xi.ge@zilliz.com>
上级 2819f6cc
隐藏空白更改
内联 并排
Showing with 241 addition and 116 deletion
internal/core/src/pb/common.pb.cc
浏览文件 @ cc5bee46
......@@ -285,7 +285,7 @@ const char descriptor_table_protodef_common_2eproto[] PROTOBUF_SECTION_VARIABLE(
"\006Failed\020\004*s\n\014SegmentState\022\024\n\020SegmentStat"
"eNone\020\000\022\014\n\010NotExist\020\001\022\013\n\007Growing\020\002\022\n\n\006Se"
"aled\020\003\022\013\n\007Flushed\020\004\022\014\n\010Flushing\020\005\022\013\n\007Dro"
"pped\020\006*\223\t\n\007MsgType\022\r\n\tUndefined\020\000\022\024\n\020Cre"
"pped\020\006*\251\t\n\007MsgType\022\r\n\tUndefined\020\000\022\024\n\020Cre"
"ateCollection\020d\022\022\n\016DropCollection\020e\022\021\n\rH"
"asCollection\020f\022\026\n\022DescribeCollection\020g\022\023"
"\n\017ShowCollections\020h\022\024\n\020GetSystemConfigs\020"
......@@ -310,17 +310,18 @@ const char descriptor_table_protodef_common_2eproto[] PROTOBUF_SECTION_VARIABLE(
"QueryChannels\020\377\003\022\035\n\030SealedSegmentsChange"
"Info\020\200\004\022\027\n\022WatchDeltaChannels\020\201\004\022\020\n\013Segm"
"entInfo\020\330\004\022\017\n\nSystemInfo\020\331\004\022\024\n\017GetRecove"
"ryInfo\020\332\004\022\r\n\010TimeTick\020\260\t\022\023\n\016QueryNodeSta"
"ts\020\261\t\022\016\n\tLoadIndex\020\262\t\022\016\n\tRequestID\020\263\t\022\017\n"
"\nRequestTSO\020\264\t\022\024\n\017AllocateSegment\020\265\t\022\026\n\021"
"SegmentStatistics\020\266\t\022\025\n\020SegmentFlushDone"
"\020\267\t\022\017\n\nDataNodeTt\020\270\t*\"\n\007DslType\022\007\n\003Dsl\020\000"
"\022\016\n\nBoolExprV1\020\001*B\n\017CompactionState\022\021\n\rU"
"ndefiedState\020\000\022\r\n\tExecuting\020\001\022\r\n\tComplet"
"ed\020\002*X\n\020ConsistencyLevel\022\n\n\006Strong\020\000\022\013\n\007"
"Session\020\001\022\013\n\007Bounded\020\002\022\016\n\nEventually\020\003\022\016"
"\n\nCustomized\020\004B5Z3github.com/milvus-io/m"
"ilvus/internal/proto/commonpbb\006proto3"
"ryInfo\020\332\004\022\024\n\017GetSegmentState\020\333\004\022\r\n\010TimeT"
"ick\020\260\t\022\023\n\016QueryNodeStats\020\261\t\022\016\n\tLoadIndex"
"\020\262\t\022\016\n\tRequestID\020\263\t\022\017\n\nRequestTSO\020\264\t\022\024\n\017"
"AllocateSegment\020\265\t\022\026\n\021SegmentStatistics\020"
"\266\t\022\025\n\020SegmentFlushDone\020\267\t\022\017\n\nDataNodeTt\020"
"\270\t*\"\n\007DslType\022\007\n\003Dsl\020\000\022\016\n\nBoolExprV1\020\001*B"
"\n\017CompactionState\022\021\n\rUndefiedState\020\000\022\r\n\t"
"Executing\020\001\022\r\n\tCompleted\020\002*X\n\020Consistenc"
"yLevel\022\n\n\006Strong\020\000\022\013\n\007Session\020\001\022\013\n\007Bound"
"ed\020\002\022\016\n\nEventually\020\003\022\016\n\nCustomized\020\004B5Z3"
"github.com/milvus-io/milvus/internal/pro"
"to/commonpbb\006proto3"
;
static const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable*const descriptor_table_common_2eproto_deps[1] = {
};
......@@ -337,7 +338,7 @@ static ::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase*const descriptor_table_com
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", 2717,
&descriptor_table_common_2eproto_initialized, descriptor_table_protodef_common_2eproto, "common.proto", 2739,
&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,
......@@ -477,6 +478,7 @@ bool MsgType_IsValid(int value) {
case 600:
case 601:
case 602:
case 603:
case 1200:
case 1201:
case 1202:
......
internal/core/src/pb/common.pb.h
浏览文件 @ cc5bee46
......@@ -256,6 +256,7 @@ enum MsgType : int {
SegmentInfo = 600,
SystemInfo = 601,
GetRecoveryInfo = 602,
GetSegmentState = 603,
TimeTick = 1200,
QueryNodeStats = 1201,
LoadIndex = 1202,
......
internal/datacoord/server_test.go
浏览文件 @ cc5bee46
......@@ -294,7 +294,6 @@ func TestGetSegmentStates(t *testing.T) {
assert.EqualValues(t, commonpb.ErrorCode_Success, resp.Status.ErrorCode)
assert.EqualValues(t, 1, len(resp.States))
if test.expected {
assert.EqualValues(t, commonpb.ErrorCode_Success, resp.States[0].Status.ErrorCode)
assert.EqualValues(t, test.expectedState, resp.States[0].State)
}
})
......
internal/datacoord/services.go
浏览文件 @ cc5bee46
......@@ -174,15 +174,12 @@ func (s *Server) GetSegmentStates(ctx context.Context, req *datapb.GetSegmentSta
for _, segmentID := range req.SegmentIDs {
state := &datapb.SegmentStateInfo{
Status: &commonpb.Status{},
SegmentID: segmentID,
}
segmentInfo := s.meta.GetSegment(segmentID)
if segmentInfo == nil {
state.Status.ErrorCode = commonpb.ErrorCode_UnexpectedError
state.Status.Reason = fmt.Sprintf("failed to get segment %d", segmentID)
state.State = commonpb.SegmentState_NotExist
} else {
state.Status.ErrorCode = commonpb.ErrorCode_Success
state.State = segmentInfo.GetState()
state.StartPosition = segmentInfo.GetStartPosition()
}
......
internal/proto/common.proto
浏览文件 @ cc5bee46
......@@ -141,6 +141,7 @@ enum MsgType {
SegmentInfo = 600;
SystemInfo = 601;
GetRecoveryInfo = 602;
GetSegmentState = 603;
/* SYSTEM CONTROL */
TimeTick = 1200;
......
internal/proto/commonpb/common.pb.go
浏览文件 @ cc5bee46
......@@ -253,6 +253,7 @@ const (
MsgType_SegmentInfo MsgType = 600
MsgType_SystemInfo MsgType = 601
MsgType_GetRecoveryInfo MsgType = 602
MsgType_GetSegmentState MsgType = 603
// SYSTEM CONTROL
MsgType_TimeTick MsgType = 1200
MsgType_QueryNodeStats MsgType = 1201
......@@ -314,6 +315,7 @@ var MsgType_name = map[int32]string{
600: "SegmentInfo",
601: "SystemInfo",
602: "GetRecoveryInfo",
603: "GetSegmentState",
1200: "TimeTick",
1201: "QueryNodeStats",
1202: "LoadIndex",
......@@ -374,6 +376,7 @@ var MsgType_value = map[string]int32{
"SegmentInfo": 600,
"SystemInfo": 601,
"GetRecoveryInfo": 602,
"GetSegmentState": 603,
"TimeTick": 1200,
"QueryNodeStats": 1201,
"LoadIndex": 1202,
......@@ -879,99 +882,100 @@ func init() {
func init() { proto.RegisterFile("common.proto", fileDescriptor_555bd8c177793206) }
var fileDescriptor_555bd8c177793206 = []byte{
// 1503 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x56, 0xdd, 0x72, 0x1b, 0x4b,
0x11, 0xf6, 0x6a, 0x15, 0xcb, 0x6a, 0xcb, 0xf6, 0x64, 0xfc, 0x13, 0x9f, 0x10, 0xa8, 0x94, 0xaf,
0x52, 0xae, 0x3a, 0x09, 0x90, 0x02, 0xae, 0xce, 0x85, 0xa5, 0xb5, 0x1d, 0x55, 0x62, 0xc7, 0x48,
0x4e, 0x38, 0xc5, 0x05, 0xa9, 0xf1, 0x6e, 0x5b, 0x1a, 0x32, 0x3b, 0x23, 0x66, 0x66, 0x1d, 0x8b,
0x2b, 0x78, 0x03, 0x38, 0xbc, 0x06, 0x50, 0xfc, 0x43, 0xf1, 0x04, 0xfc, 0x5f, 0x03, 0x4f, 0xc0,
0x03, 0xf0, 0x7b, 0x7e, 0xa9, 0x9e, 0x5d, 0x49, 0x7b, 0xaa, 0x4e, 0xae, 0xce, 0xdd, 0xf6, 0xd7,
0xdd, 0x5f, 0xf7, 0x74, 0xf7, 0xf4, 0x0e, 0x74, 0x52, 0x93, 0xe7, 0x46, 0xdf, 0x9f, 0x58, 0xe3,
0x0d, 0xdf, 0xcc, 0xa5, 0xba, 0x2a, 0x5c, 0x29, 0xdd, 0x2f, 0x55, 0x7b, 0x2f, 0x60, 0x79, 0xe8,
0x85, 0x2f, 0x1c, 0x7f, 0x0b, 0x00, 0xad, 0x35, 0xf6, 0x45, 0x6a, 0x32, 0xdc, 0x8d, 0xee, 0x46,
0xf7, 0xd6, 0xbf, 0xf8, 0xb9, 0xfb, 0x9f, 0xe0, 0x73, 0xff, 0x90, 0xcc, 0x7a, 0x26, 0xc3, 0x41,
0x1b, 0x67, 0x9f, 0x7c, 0x07, 0x96, 0x2d, 0x0a, 0x67, 0xf4, 0x6e, 0xe3, 0x6e, 0x74, 0xaf, 0x3d,
0xa8, 0xa4, 0xbd, 0x2f, 0x43, 0xe7, 0x31, 0x4e, 0x9f, 0x0b, 0x55, 0xe0, 0x99, 0x90, 0x96, 0x33,
0x88, 0x5f, 0xe2, 0x34, 0xf0, 0xb7, 0x07, 0xf4, 0xc9, 0xb7, 0xe0, 0xc6, 0x15, 0xa9, 0x2b, 0xc7,
0x52, 0xd8, 0x7b, 0x08, 0xab, 0x8f, 0x71, 0x9a, 0x08, 0x2f, 0x5e, 0xe3, 0xc6, 0xa1, 0x99, 0x09,
0x2f, 0x82, 0x57, 0x67, 0x10, 0xbe, 0xf7, 0xee, 0x40, 0xb3, 0xab, 0xcc, 0xc5, 0x82, 0x32, 0x0a,
0xca, 0x8a, 0xf2, 0x4d, 0x68, 0x1d, 0x64, 0x99, 0x45, 0xe7, 0xf8, 0x3a, 0x34, 0xe4, 0xa4, 0x62,
0x6b, 0xc8, 0x09, 0x91, 0x4d, 0x8c, 0xf5, 0x81, 0x2c, 0x1e, 0x84, 0xef, 0xbd, 0x77, 0x22, 0x68,
0x9d, 0xb8, 0x51, 0x57, 0x38, 0xe4, 0x5f, 0x81, 0x95, 0xdc, 0x8d, 0x5e, 0xf8, 0xe9, 0x64, 0x56,
0x9a, 0x3b, 0x9f, 0x58, 0x9a, 0x13, 0x37, 0x3a, 0x9f, 0x4e, 0x70, 0xd0, 0xca, 0xcb, 0x0f, 0xca,
0x24, 0x77, 0xa3, 0x7e, 0x52, 0x31, 0x97, 0x02, 0xbf, 0x03, 0x6d, 0x2f, 0x73, 0x74, 0x5e, 0xe4,
0x93, 0xdd, 0xf8, 0x6e, 0x74, 0xaf, 0x39, 0x58, 0x00, 0xfc, 0x36, 0xac, 0x38, 0x53, 0xd8, 0x14,
0xfb, 0xc9, 0x6e, 0x33, 0xb8, 0xcd, 0xe5, 0xbd, 0xb7, 0xa0, 0x7d, 0xe2, 0x46, 0x8f, 0x50, 0x64,
0x68, 0xf9, 0xe7, 0xa1, 0x79, 0x21, 0x5c, 0x99, 0xd1, 0xea, 0xeb, 0x33, 0xa2, 0x13, 0x0c, 0x82,
0xe5, 0xde, 0x37, 0xa0, 0x93, 0x9c, 0x3c, 0xf9, 0x14, 0x0c, 0x94, 0xba, 0x1b, 0x0b, 0x9b, 0x9d,
0x8a, 0x7c, 0xd6, 0xb1, 0x05, 0xb0, 0xff, 0xdb, 0x26, 0xb4, 0xe7, 0xe3, 0xc1, 0x57, 0xa1, 0x35,
0x2c, 0xd2, 0x14, 0x9d, 0x63, 0x4b, 0x7c, 0x13, 0x36, 0x9e, 0x69, 0xbc, 0x9e, 0x60, 0xea, 0x31,
0x0b, 0x36, 0x2c, 0xe2, 0x37, 0x61, 0xad, 0x67, 0xb4, 0xc6, 0xd4, 0x1f, 0x09, 0xa9, 0x30, 0x63,
0x0d, 0xbe, 0x05, 0xec, 0x0c, 0x6d, 0x2e, 0x9d, 0x93, 0x46, 0x27, 0xa8, 0x25, 0x66, 0x2c, 0xe6,
0xb7, 0x60, 0xb3, 0x67, 0x94, 0xc2, 0xd4, 0x4b, 0xa3, 0x4f, 0x8d, 0x3f, 0xbc, 0x96, 0xce, 0x3b,
0xd6, 0x24, 0xda, 0xbe, 0x52, 0x38, 0x12, 0xea, 0xc0, 0x8e, 0x8a, 0x1c, 0xb5, 0x67, 0x37, 0x88,
0xa3, 0x02, 0x13, 0x99, 0xa3, 0x26, 0x26, 0xd6, 0xaa, 0xa1, 0x7d, 0x9d, 0xe1, 0x35, 0xf5, 0x87,
0xad, 0xf0, 0x37, 0x60, 0xbb, 0x42, 0x6b, 0x01, 0x44, 0x8e, 0xac, 0xcd, 0x37, 0x60, 0xb5, 0x52,
0x9d, 0x3f, 0x3d, 0x7b, 0xcc, 0xa0, 0xc6, 0x30, 0x30, 0xaf, 0x06, 0x98, 0x1a, 0x9b, 0xb1, 0xd5,
0x5a, 0x0a, 0xcf, 0x31, 0xf5, 0xc6, 0xf6, 0x13, 0xd6, 0xa1, 0x84, 0x2b, 0x70, 0x88, 0xc2, 0xa6,
0xe3, 0x01, 0xba, 0x42, 0x79, 0xb6, 0xc6, 0x19, 0x74, 0x8e, 0xa4, 0xc2, 0x53, 0xe3, 0x8f, 0x4c,
0xa1, 0x33, 0xb6, 0xce, 0xd7, 0x01, 0x4e, 0xd0, 0x8b, 0xaa, 0x02, 0x1b, 0x14, 0xb6, 0x27, 0xd2,
0x31, 0x56, 0x00, 0xe3, 0x3b, 0xc0, 0x7b, 0x42, 0x6b, 0xe3, 0x7b, 0x16, 0x85, 0xc7, 0x23, 0xa3,
0x32, 0xb4, 0xec, 0x26, 0xa5, 0xf3, 0x31, 0x5c, 0x2a, 0x64, 0x7c, 0x61, 0x9d, 0xa0, 0xc2, 0xb9,
0xf5, 0xe6, 0xc2, 0xba, 0xc2, 0xc9, 0x7a, 0x8b, 0x92, 0xef, 0x16, 0x52, 0x65, 0xa1, 0x24, 0x65,
0x5b, 0xb6, 0x29, 0xc7, 0x2a, 0xf9, 0xd3, 0x27, 0xfd, 0xe1, 0x39, 0xdb, 0xe1, 0xdb, 0x70, 0xb3,
0x42, 0x4e, 0xd0, 0x5b, 0x99, 0x86, 0xe2, 0xdd, 0xa2, 0x54, 0x9f, 0x16, 0xfe, 0xe9, 0xe5, 0x09,
0xe6, 0xc6, 0x4e, 0xd9, 0x2e, 0x35, 0x34, 0x30, 0xcd, 0x5a, 0xc4, 0xde, 0xa0, 0x08, 0x87, 0xf9,
0xc4, 0x4f, 0x17, 0xe5, 0x65, 0xb7, 0x39, 0x87, 0xb5, 0x24, 0x19, 0xe0, 0xb7, 0x0a, 0x74, 0x7e,
0x20, 0x52, 0x64, 0xff, 0x68, 0xed, 0xbf, 0x0d, 0x10, 0x7c, 0x69, 0x21, 0x21, 0xe7, 0xb0, 0xbe,
0x90, 0x4e, 0x8d, 0x46, 0xb6, 0xc4, 0x3b, 0xb0, 0xf2, 0x4c, 0x4b, 0xe7, 0x0a, 0xcc, 0x58, 0x44,
0x75, 0xeb, 0xeb, 0x33, 0x6b, 0x46, 0x74, 0xa5, 0x59, 0x83, 0xb4, 0x47, 0x52, 0x4b, 0x37, 0x0e,
0x13, 0x03, 0xb0, 0x5c, 0x15, 0xb0, 0xb9, 0xef, 0xa0, 0x33, 0xc4, 0x11, 0x0d, 0x47, 0xc9, 0xbd,
0x05, 0xac, 0x2e, 0x2f, 0xd8, 0xe7, 0x69, 0x47, 0x34, 0xbc, 0xc7, 0xd6, 0xbc, 0x92, 0x7a, 0xc4,
0x1a, 0x44, 0x36, 0x44, 0xa1, 0x02, 0xf1, 0x2a, 0xb4, 0x8e, 0x54, 0x11, 0xa2, 0x34, 0x43, 0x4c,
0x12, 0xc8, 0xec, 0x06, 0xa9, 0x12, 0x6b, 0x26, 0x13, 0xcc, 0xd8, 0xf2, 0xfe, 0x0f, 0xda, 0x61,
0x7f, 0x84, 0x35, 0xb0, 0x06, 0xed, 0x67, 0x3a, 0xc3, 0x4b, 0xa9, 0x31, 0x63, 0x4b, 0xa1, 0x15,
0xa1, 0x65, 0xb5, 0x9a, 0x64, 0x74, 0x62, 0xf2, 0xae, 0x61, 0x48, 0xf5, 0x7c, 0x24, 0x5c, 0x0d,
0xba, 0xa4, 0xfe, 0x26, 0xe8, 0x52, 0x2b, 0x2f, 0xea, 0xee, 0x23, 0xaa, 0xf3, 0x70, 0x6c, 0x5e,
0x2d, 0x30, 0xc7, 0xc6, 0x14, 0xe9, 0x18, 0xfd, 0x70, 0xea, 0x3c, 0xe6, 0x3d, 0xa3, 0x2f, 0xe5,
0xc8, 0x31, 0x49, 0x91, 0x9e, 0x18, 0x91, 0xd5, 0xdc, 0xbf, 0x49, 0x1d, 0x1e, 0xa0, 0x42, 0xe1,
0xea, 0xac, 0x2f, 0xc3, 0x30, 0x86, 0x54, 0x0f, 0x94, 0x14, 0x8e, 0x29, 0x3a, 0x0a, 0x65, 0x59,
0x8a, 0x39, 0x35, 0xe1, 0x40, 0x79, 0xb4, 0xa5, 0xac, 0xf9, 0x16, 0x6c, 0x94, 0xf6, 0x67, 0xc2,
0x7a, 0x19, 0x48, 0x7e, 0x17, 0x85, 0x76, 0x5b, 0x33, 0x59, 0x60, 0xbf, 0xa7, 0xbb, 0xdf, 0x79,
0x24, 0xdc, 0x02, 0xfa, 0x43, 0xc4, 0x77, 0xe0, 0xe6, 0xec, 0x68, 0x0b, 0xfc, 0x8f, 0x11, 0xdf,
0x84, 0x75, 0x3a, 0xda, 0x1c, 0x73, 0xec, 0x4f, 0x01, 0xa4, 0x43, 0xd4, 0xc0, 0x3f, 0x07, 0x86,
0xea, 0x14, 0x35, 0xfc, 0x2f, 0x21, 0x18, 0x31, 0x54, 0x5d, 0x77, 0xec, 0xdd, 0x88, 0x32, 0x9d,
0x05, 0xab, 0x60, 0xf6, 0x5e, 0x30, 0x24, 0xd6, 0xb9, 0xe1, 0xfb, 0xc1, 0xb0, 0xe2, 0x9c, 0xa3,
0x1f, 0x04, 0xf4, 0x91, 0xd0, 0x99, 0xb9, 0xbc, 0x9c, 0xa3, 0x1f, 0x46, 0x7c, 0x17, 0x36, 0xc9,
0xbd, 0x2b, 0x94, 0xd0, 0xe9, 0xc2, 0xfe, 0xa3, 0x88, 0xb3, 0x59, 0x21, 0xc3, 0x54, 0xb3, 0x1f,
0x36, 0x42, 0x51, 0xaa, 0x04, 0x4a, 0xec, 0x47, 0x0d, 0xbe, 0x5e, 0x56, 0xb7, 0x94, 0x7f, 0xdc,
0xe0, 0xab, 0xb0, 0xdc, 0xd7, 0x0e, 0xad, 0x67, 0xdf, 0xa3, 0xc9, 0x5b, 0x2e, 0xef, 0x2e, 0xfb,
0x3e, 0xcd, 0xf7, 0x8d, 0x30, 0x79, 0xec, 0x9d, 0xa0, 0x28, 0xb7, 0x0c, 0xfb, 0x67, 0x1c, 0x8e,
0x5a, 0x5f, 0x39, 0xff, 0x8a, 0x29, 0xd2, 0x31, 0xfa, 0xc5, 0x75, 0x62, 0xff, 0x8e, 0xf9, 0x6d,
0xd8, 0x9e, 0x61, 0x61, 0x01, 0xcc, 0x2f, 0xd2, 0x7f, 0x62, 0x7e, 0x07, 0x6e, 0x1d, 0xa3, 0x5f,
0xcc, 0x01, 0x39, 0x49, 0xe7, 0x65, 0xea, 0xd8, 0x7f, 0x63, 0xfe, 0x19, 0xd8, 0x39, 0x46, 0x3f,
0xaf, 0x6f, 0x4d, 0xf9, 0xbf, 0x98, 0xaf, 0xc1, 0xca, 0x80, 0x36, 0x04, 0x5e, 0x21, 0x7b, 0x37,
0xa6, 0x26, 0xcd, 0xc4, 0x2a, 0x9d, 0xf7, 0x62, 0x2a, 0xdd, 0xd7, 0x84, 0x4f, 0xc7, 0x49, 0xde,
0x1b, 0x0b, 0xad, 0x51, 0x39, 0xf6, 0x7e, 0xcc, 0xb7, 0x81, 0x0d, 0x30, 0x37, 0x57, 0x58, 0x83,
0x3f, 0xa0, 0xcd, 0xcf, 0x83, 0xf1, 0x57, 0x0b, 0xb4, 0xd3, 0xb9, 0xe2, 0xc3, 0x98, 0x4a, 0x5d,
0xda, 0x7f, 0x5c, 0xf3, 0x51, 0xcc, 0x3f, 0x0b, 0xbb, 0xe5, 0x6d, 0x9d, 0xd5, 0x9f, 0x94, 0x23,
0xec, 0xeb, 0x4b, 0xc3, 0xbe, 0xd3, 0x9c, 0x33, 0x26, 0xa8, 0xbc, 0x98, 0xfb, 0x7d, 0xb7, 0x49,
0x2d, 0xaa, 0x3c, 0x82, 0xe9, 0x5f, 0x9b, 0x7c, 0x03, 0xa0, 0xbc, 0x3b, 0x01, 0xf8, 0x5b, 0x93,
0x52, 0x3f, 0x46, 0x4f, 0xab, 0xff, 0x0a, 0xed, 0x34, 0xa0, 0x7f, 0x6f, 0xd2, 0xa1, 0xcf, 0x65,
0x8e, 0xe7, 0x32, 0x7d, 0xc9, 0x7e, 0xd2, 0xa6, 0x43, 0x87, 0x9c, 0x4e, 0x4d, 0x86, 0x54, 0x1d,
0xc7, 0x7e, 0xda, 0xa6, 0xce, 0xd2, 0x64, 0x94, 0x9d, 0xfd, 0x59, 0x90, 0xab, 0xfd, 0xd7, 0x4f,
0xd8, 0xcf, 0xe9, 0x67, 0x03, 0x95, 0x7c, 0x3e, 0x7c, 0xca, 0x7e, 0xd1, 0xa6, 0x50, 0x07, 0x4a,
0x99, 0x54, 0xf8, 0xf9, 0x7c, 0xfe, 0xb2, 0x4d, 0x03, 0x5e, 0x5b, 0x5d, 0x55, 0xdd, 0x7f, 0xd5,
0xa6, 0xea, 0x55, 0x78, 0x98, 0x8a, 0x84, 0x56, 0xda, 0xaf, 0x03, 0x2b, 0xbd, 0xa1, 0x28, 0x93,
0x73, 0xcf, 0x7e, 0xd3, 0xde, 0xdf, 0x83, 0x56, 0xe2, 0x54, 0x58, 0x4a, 0x2d, 0x88, 0x13, 0xa7,
0xd8, 0x12, 0xdd, 0xe1, 0xae, 0x31, 0xea, 0xf0, 0x7a, 0x62, 0x9f, 0x7f, 0x81, 0x45, 0xfb, 0x5d,
0xd8, 0xe8, 0x99, 0x7c, 0x22, 0xe6, 0xbd, 0x0f, 0x7b, 0xa8, 0x5c, 0x60, 0x98, 0x95, 0x13, 0xb4,
0x44, 0x8b, 0xe0, 0xf0, 0x1a, 0xd3, 0xc2, 0xd3, 0xee, 0x8b, 0x48, 0x24, 0x27, 0x1a, 0xcf, 0x8c,
0x35, 0xf6, 0xdf, 0x06, 0xd6, 0x33, 0xda, 0x49, 0xe7, 0x51, 0xa7, 0xd3, 0x27, 0x78, 0x85, 0x2a,
0x6c, 0x51, 0x6f, 0x8d, 0x1e, 0xb1, 0xa5, 0xf0, 0x36, 0xc0, 0xf0, 0x8f, 0x2f, 0x77, 0x6d, 0x97,
0x7e, 0x86, 0xe1, 0x01, 0xb0, 0x0e, 0x70, 0x78, 0x85, 0xda, 0x17, 0x42, 0xa9, 0x29, 0x8b, 0x49,
0xee, 0x15, 0xce, 0x9b, 0x5c, 0x7e, 0x9b, 0x56, 0x6e, 0xf7, 0x4b, 0x5f, 0x7f, 0x38, 0x92, 0x7e,
0x5c, 0x5c, 0xd0, 0x03, 0xe5, 0x41, 0xf9, 0x62, 0x79, 0x53, 0x9a, 0xea, 0xeb, 0x81, 0xd4, 0x1e,
0xad, 0x16, 0xea, 0x41, 0x78, 0xc4, 0x3c, 0x28, 0x1f, 0x31, 0x93, 0x8b, 0x8b, 0xe5, 0x20, 0x3f,
0xfc, 0x7f, 0x00, 0x00, 0x00, 0xff, 0xff, 0x23, 0x0e, 0xd4, 0xcf, 0x15, 0x0b, 0x00, 0x00,
// 1509 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x56, 0x5b, 0x73, 0x1b, 0x4b,
0x11, 0xf6, 0x6a, 0x15, 0xcb, 0x6a, 0xcb, 0xf6, 0x64, 0x7c, 0x89, 0x4f, 0x08, 0x54, 0xca, 0x4f,
0x29, 0x57, 0x9d, 0x04, 0x48, 0x01, 0x4f, 0xe7, 0xc1, 0xd2, 0xda, 0x8e, 0x2a, 0xb1, 0x63, 0x24,
0x27, 0x9c, 0xe2, 0x81, 0xd4, 0x78, 0xb7, 0x2d, 0x0d, 0x99, 0x9d, 0x11, 0x33, 0xb3, 0x8e, 0xc5,
0x13, 0xfc, 0x03, 0x38, 0xff, 0x82, 0x2a, 0xa0, 0xb8, 0x43, 0xf1, 0x0b, 0xb8, 0x3f, 0x73, 0xf9,
0x03, 0xfc, 0x00, 0xae, 0xe7, 0x4a, 0xf5, 0xec, 0x4a, 0xda, 0x53, 0x75, 0xf2, 0xc4, 0xdb, 0xf6,
0xd7, 0xdd, 0x5f, 0xf7, 0x74, 0xf7, 0xf4, 0x0e, 0x74, 0x52, 0x93, 0xe7, 0x46, 0xdf, 0x9f, 0x58,
0xe3, 0x0d, 0xdf, 0xcc, 0xa5, 0xba, 0x2a, 0x5c, 0x29, 0xdd, 0x2f, 0x55, 0x7b, 0x2f, 0x60, 0x79,
0xe8, 0x85, 0x2f, 0x1c, 0x7f, 0x0b, 0x00, 0xad, 0x35, 0xf6, 0x45, 0x6a, 0x32, 0xdc, 0x8d, 0xee,
0x46, 0xf7, 0xd6, 0x3f, 0xff, 0x99, 0xfb, 0x9f, 0xe0, 0x73, 0xff, 0x90, 0xcc, 0x7a, 0x26, 0xc3,
0x41, 0x1b, 0x67, 0x9f, 0x7c, 0x07, 0x96, 0x2d, 0x0a, 0x67, 0xf4, 0x6e, 0xe3, 0x6e, 0x74, 0xaf,
0x3d, 0xa8, 0xa4, 0xbd, 0x2f, 0x42, 0xe7, 0x31, 0x4e, 0x9f, 0x0b, 0x55, 0xe0, 0x99, 0x90, 0x96,
0x33, 0x88, 0x5f, 0xe2, 0x34, 0xf0, 0xb7, 0x07, 0xf4, 0xc9, 0xb7, 0xe0, 0xc6, 0x15, 0xa9, 0x2b,
0xc7, 0x52, 0xd8, 0x7b, 0x08, 0xab, 0x8f, 0x71, 0x9a, 0x08, 0x2f, 0x5e, 0xe3, 0xc6, 0xa1, 0x99,
0x09, 0x2f, 0x82, 0x57, 0x67, 0x10, 0xbe, 0xf7, 0xee, 0x40, 0xb3, 0xab, 0xcc, 0xc5, 0x82, 0x32,
0x0a, 0xca, 0x8a, 0xf2, 0x4d, 0x68, 0x1d, 0x64, 0x99, 0x45, 0xe7, 0xf8, 0x3a, 0x34, 0xe4, 0xa4,
0x62, 0x6b, 0xc8, 0x09, 0x91, 0x4d, 0x8c, 0xf5, 0x81, 0x2c, 0x1e, 0x84, 0xef, 0xbd, 0x77, 0x22,
0x68, 0x9d, 0xb8, 0x51, 0x57, 0x38, 0xe4, 0x5f, 0x82, 0x95, 0xdc, 0x8d, 0x5e, 0xf8, 0xe9, 0x64,
0x56, 0x9a, 0x3b, 0x9f, 0x58, 0x9a, 0x13, 0x37, 0x3a, 0x9f, 0x4e, 0x70, 0xd0, 0xca, 0xcb, 0x0f,
0xca, 0x24, 0x77, 0xa3, 0x7e, 0x52, 0x31, 0x97, 0x02, 0xbf, 0x03, 0x6d, 0x2f, 0x73, 0x74, 0x5e,
0xe4, 0x93, 0xdd, 0xf8, 0x6e, 0x74, 0xaf, 0x39, 0x58, 0x00, 0xfc, 0x36, 0xac, 0x38, 0x53, 0xd8,
0x14, 0xfb, 0xc9, 0x6e, 0x33, 0xb8, 0xcd, 0xe5, 0xbd, 0xb7, 0xa0, 0x7d, 0xe2, 0x46, 0x8f, 0x50,
0x64, 0x68, 0xf9, 0x67, 0xa1, 0x79, 0x21, 0x5c, 0x99, 0xd1, 0xea, 0xeb, 0x33, 0xa2, 0x13, 0x0c,
0x82, 0xe5, 0xde, 0xd7, 0xa0, 0x93, 0x9c, 0x3c, 0xf9, 0x3f, 0x18, 0x28, 0x75, 0x37, 0x16, 0x36,
0x3b, 0x15, 0xf9, 0xac, 0x63, 0x0b, 0x60, 0xff, 0xd7, 0x4d, 0x68, 0xcf, 0xc7, 0x83, 0xaf, 0x42,
0x6b, 0x58, 0xa4, 0x29, 0x3a, 0xc7, 0x96, 0xf8, 0x26, 0x6c, 0x3c, 0xd3, 0x78, 0x3d, 0xc1, 0xd4,
0x63, 0x16, 0x6c, 0x58, 0xc4, 0x6f, 0xc2, 0x5a, 0xcf, 0x68, 0x8d, 0xa9, 0x3f, 0x12, 0x52, 0x61,
0xc6, 0x1a, 0x7c, 0x0b, 0xd8, 0x19, 0xda, 0x5c, 0x3a, 0x27, 0x8d, 0x4e, 0x50, 0x4b, 0xcc, 0x58,
0xcc, 0x6f, 0xc1, 0x66, 0xcf, 0x28, 0x85, 0xa9, 0x97, 0x46, 0x9f, 0x1a, 0x7f, 0x78, 0x2d, 0x9d,
0x77, 0xac, 0x49, 0xb4, 0x7d, 0xa5, 0x70, 0x24, 0xd4, 0x81, 0x1d, 0x15, 0x39, 0x6a, 0xcf, 0x6e,
0x10, 0x47, 0x05, 0x26, 0x32, 0x47, 0x4d, 0x4c, 0xac, 0x55, 0x43, 0xfb, 0x3a, 0xc3, 0x6b, 0xea,
0x0f, 0x5b, 0xe1, 0x6f, 0xc0, 0x76, 0x85, 0xd6, 0x02, 0x88, 0x1c, 0x59, 0x9b, 0x6f, 0xc0, 0x6a,
0xa5, 0x3a, 0x7f, 0x7a, 0xf6, 0x98, 0x41, 0x8d, 0x61, 0x60, 0x5e, 0x0d, 0x30, 0x35, 0x36, 0x63,
0xab, 0xb5, 0x14, 0x9e, 0x63, 0xea, 0x8d, 0xed, 0x27, 0xac, 0x43, 0x09, 0x57, 0xe0, 0x10, 0x85,
0x4d, 0xc7, 0x03, 0x74, 0x85, 0xf2, 0x6c, 0x8d, 0x33, 0xe8, 0x1c, 0x49, 0x85, 0xa7, 0xc6, 0x1f,
0x99, 0x42, 0x67, 0x6c, 0x9d, 0xaf, 0x03, 0x9c, 0xa0, 0x17, 0x55, 0x05, 0x36, 0x28, 0x6c, 0x4f,
0xa4, 0x63, 0xac, 0x00, 0xc6, 0x77, 0x80, 0xf7, 0x84, 0xd6, 0xc6, 0xf7, 0x2c, 0x0a, 0x8f, 0x47,
0x46, 0x65, 0x68, 0xd9, 0x4d, 0x4a, 0xe7, 0x63, 0xb8, 0x54, 0xc8, 0xf8, 0xc2, 0x3a, 0x41, 0x85,
0x73, 0xeb, 0xcd, 0x85, 0x75, 0x85, 0x93, 0xf5, 0x16, 0x25, 0xdf, 0x2d, 0xa4, 0xca, 0x42, 0x49,
0xca, 0xb6, 0x6c, 0x53, 0x8e, 0x55, 0xf2, 0xa7, 0x4f, 0xfa, 0xc3, 0x73, 0xb6, 0xc3, 0xb7, 0xe1,
0x66, 0x85, 0x9c, 0xa0, 0xb7, 0x32, 0x0d, 0xc5, 0xbb, 0x45, 0xa9, 0x3e, 0x2d, 0xfc, 0xd3, 0xcb,
0x13, 0xcc, 0x8d, 0x9d, 0xb2, 0x5d, 0x6a, 0x68, 0x60, 0x9a, 0xb5, 0x88, 0xbd, 0x41, 0x11, 0x0e,
0xf3, 0x89, 0x9f, 0x2e, 0xca, 0xcb, 0x6e, 0x73, 0x0e, 0x6b, 0x49, 0x32, 0xc0, 0x6f, 0x14, 0xe8,
0xfc, 0x40, 0xa4, 0xc8, 0xfe, 0xde, 0xda, 0x7f, 0x1b, 0x20, 0xf8, 0xd2, 0x42, 0x42, 0xce, 0x61,
0x7d, 0x21, 0x9d, 0x1a, 0x8d, 0x6c, 0x89, 0x77, 0x60, 0xe5, 0x99, 0x96, 0xce, 0x15, 0x98, 0xb1,
0x88, 0xea, 0xd6, 0xd7, 0x67, 0xd6, 0x8c, 0xe8, 0x4a, 0xb3, 0x06, 0x69, 0x8f, 0xa4, 0x96, 0x6e,
0x1c, 0x26, 0x06, 0x60, 0xb9, 0x2a, 0x60, 0x73, 0xdf, 0x41, 0x67, 0x88, 0x23, 0x1a, 0x8e, 0x92,
0x7b, 0x0b, 0x58, 0x5d, 0x5e, 0xb0, 0xcf, 0xd3, 0x8e, 0x68, 0x78, 0x8f, 0xad, 0x79, 0x25, 0xf5,
0x88, 0x35, 0x88, 0x6c, 0x88, 0x42, 0x05, 0xe2, 0x55, 0x68, 0x1d, 0xa9, 0x22, 0x44, 0x69, 0x86,
0x98, 0x24, 0x90, 0xd9, 0x0d, 0x52, 0x25, 0xd6, 0x4c, 0x26, 0x98, 0xb1, 0xe5, 0xfd, 0xef, 0xb5,
0xc3, 0xfe, 0x08, 0x6b, 0x60, 0x0d, 0xda, 0xcf, 0x74, 0x86, 0x97, 0x52, 0x63, 0xc6, 0x96, 0x42,
0x2b, 0x42, 0xcb, 0x6a, 0x35, 0xc9, 0xe8, 0xc4, 0xe4, 0x5d, 0xc3, 0x90, 0xea, 0xf9, 0x48, 0xb8,
0x1a, 0x74, 0x49, 0xfd, 0x4d, 0xd0, 0xa5, 0x56, 0x5e, 0xd4, 0xdd, 0x47, 0x54, 0xe7, 0xe1, 0xd8,
0xbc, 0x5a, 0x60, 0x8e, 0x8d, 0x29, 0xd2, 0x31, 0xfa, 0xe1, 0xd4, 0x79, 0xcc, 0x7b, 0x46, 0x5f,
0xca, 0x91, 0x63, 0x92, 0x22, 0x3d, 0x31, 0x22, 0xab, 0xb9, 0x7f, 0x9d, 0x3a, 0x3c, 0x40, 0x85,
0xc2, 0xd5, 0x59, 0x5f, 0x86, 0x61, 0x0c, 0xa9, 0x1e, 0x28, 0x29, 0x1c, 0x53, 0x74, 0x14, 0xca,
0xb2, 0x14, 0x73, 0x6a, 0xc2, 0x81, 0xf2, 0x68, 0x4b, 0x59, 0xf3, 0x2d, 0xd8, 0x28, 0xed, 0xcf,
0x84, 0xf5, 0x32, 0x90, 0xfc, 0x26, 0x0a, 0xed, 0xb6, 0x66, 0xb2, 0xc0, 0x7e, 0x4b, 0x77, 0xbf,
0xf3, 0x48, 0xb8, 0x05, 0xf4, 0xbb, 0x88, 0xef, 0xc0, 0xcd, 0xd9, 0xd1, 0x16, 0xf8, 0xef, 0x23,
0xbe, 0x09, 0xeb, 0x74, 0xb4, 0x39, 0xe6, 0xd8, 0x1f, 0x02, 0x48, 0x87, 0xa8, 0x81, 0x7f, 0x0c,
0x0c, 0xd5, 0x29, 0x6a, 0xf8, 0x9f, 0x42, 0x30, 0x62, 0xa8, 0xba, 0xee, 0xd8, 0xbb, 0x11, 0x65,
0x3a, 0x0b, 0x56, 0xc1, 0xec, 0xbd, 0x60, 0x48, 0xac, 0x73, 0xc3, 0xf7, 0x83, 0x61, 0xc5, 0x39,
0x47, 0x3f, 0x08, 0xe8, 0x23, 0xa1, 0x33, 0x73, 0x79, 0x39, 0x47, 0x3f, 0x8c, 0xf8, 0x2e, 0x6c,
0x92, 0x7b, 0x57, 0x28, 0xa1, 0xd3, 0x85, 0xfd, 0x47, 0x11, 0x67, 0xb3, 0x42, 0x86, 0xa9, 0x66,
0xdf, 0x6f, 0x84, 0xa2, 0x54, 0x09, 0x94, 0xd8, 0x0f, 0x1a, 0x7c, 0xbd, 0xac, 0x6e, 0x29, 0xff,
0xb0, 0xc1, 0x57, 0x61, 0xb9, 0xaf, 0x1d, 0x5a, 0xcf, 0xbe, 0x43, 0x93, 0xb7, 0x5c, 0xde, 0x5d,
0xf6, 0x5d, 0x9a, 0xef, 0x1b, 0x61, 0xf2, 0xd8, 0x3b, 0x41, 0x51, 0x6e, 0x19, 0xf6, 0x8f, 0x38,
0x1c, 0xb5, 0xbe, 0x72, 0xfe, 0x19, 0x53, 0xa4, 0x63, 0xf4, 0x8b, 0xeb, 0xc4, 0xfe, 0x15, 0xf3,
0xdb, 0xb0, 0x3d, 0xc3, 0xc2, 0x02, 0x98, 0x5f, 0xa4, 0x7f, 0xc7, 0xfc, 0x0e, 0xdc, 0x3a, 0x46,
0xbf, 0x98, 0x03, 0x72, 0x92, 0xce, 0xcb, 0xd4, 0xb1, 0xff, 0xc4, 0xfc, 0x53, 0xb0, 0x73, 0x8c,
0x7e, 0x5e, 0xdf, 0x9a, 0xf2, 0xbf, 0x31, 0x5f, 0x83, 0x95, 0x01, 0x6d, 0x08, 0xbc, 0x42, 0xf6,
0x6e, 0x4c, 0x4d, 0x9a, 0x89, 0x55, 0x3a, 0xef, 0xc5, 0x54, 0xba, 0xaf, 0x08, 0x9f, 0x8e, 0x93,
0xbc, 0x37, 0x16, 0x5a, 0xa3, 0x72, 0xec, 0xfd, 0x98, 0x6f, 0x03, 0x1b, 0x60, 0x6e, 0xae, 0xb0,
0x06, 0x7f, 0x40, 0x9b, 0x9f, 0x07, 0xe3, 0x2f, 0x17, 0x68, 0xa7, 0x73, 0xc5, 0x87, 0x31, 0x95,
0xba, 0xb4, 0xff, 0xb8, 0xe6, 0xa3, 0x98, 0x7f, 0x1a, 0x76, 0xcb, 0xdb, 0x3a, 0xab, 0x3f, 0x29,
0x47, 0xd8, 0xd7, 0x97, 0x86, 0x7d, 0xab, 0x39, 0x67, 0x4c, 0x50, 0x79, 0x31, 0xf7, 0xfb, 0x76,
0x93, 0x5a, 0x54, 0x79, 0x04, 0xd3, 0x3f, 0x37, 0xf9, 0x06, 0x40, 0x79, 0x77, 0x02, 0xf0, 0x97,
0x26, 0xa5, 0x7e, 0x8c, 0x9e, 0x56, 0xff, 0x15, 0xda, 0x69, 0x40, 0xff, 0x3a, 0x43, 0xeb, 0x2b,
0x85, 0xfd, 0xad, 0x49, 0xa5, 0x38, 0x97, 0x39, 0x9e, 0xcb, 0xf4, 0x25, 0xfb, 0x51, 0x9b, 0x4a,
0x11, 0x32, 0x3d, 0x35, 0x19, 0x92, 0x8d, 0x63, 0x3f, 0x6e, 0x53, 0xbf, 0x69, 0x5e, 0xca, 0x7e,
0xff, 0x24, 0xc8, 0xd5, 0x56, 0xec, 0x27, 0xec, 0xa7, 0xf4, 0x0b, 0x82, 0x4a, 0x3e, 0x1f, 0x3e,
0x65, 0x3f, 0x6b, 0x53, 0xa8, 0x03, 0xa5, 0x4c, 0x2a, 0xfc, 0x7c, 0x6a, 0x7f, 0xde, 0xa6, 0xb1,
0xaf, 0x45, 0xaf, 0xba, 0xf1, 0x8b, 0x36, 0xd5, 0xb4, 0xc2, 0xc3, 0xac, 0x24, 0xb4, 0xe8, 0x7e,
0x19, 0x58, 0xe9, 0x65, 0x45, 0x99, 0x9c, 0x7b, 0xf6, 0xab, 0xf6, 0xfe, 0x1e, 0xb4, 0x12, 0xa7,
0xc2, 0xaa, 0x6a, 0x41, 0x9c, 0x38, 0xc5, 0x96, 0xe8, 0x66, 0x77, 0x8d, 0x51, 0x87, 0xd7, 0x13,
0xfb, 0xfc, 0x73, 0x2c, 0xda, 0xef, 0xc2, 0x46, 0xcf, 0xe4, 0x13, 0x31, 0x9f, 0x88, 0xb0, 0x9d,
0xca, 0xb5, 0x86, 0x59, 0x79, 0xea, 0x25, 0x5a, 0x0f, 0x87, 0xd7, 0x98, 0x16, 0x9e, 0x36, 0x62,
0x44, 0x22, 0x39, 0xd1, 0xd0, 0x66, 0xac, 0xb1, 0xff, 0x36, 0xb0, 0x9e, 0xd1, 0x4e, 0x3a, 0x8f,
0x3a, 0x9d, 0x3e, 0xc1, 0x2b, 0x54, 0x61, 0xb7, 0x7a, 0x6b, 0xf4, 0x88, 0x2d, 0x85, 0x17, 0x03,
0x86, 0x3f, 0x7f, 0xb9, 0x81, 0xbb, 0xf4, 0x8b, 0x0c, 0xcf, 0x82, 0x75, 0x80, 0xc3, 0x2b, 0xd4,
0xbe, 0x10, 0x4a, 0x4d, 0x59, 0x4c, 0x72, 0xaf, 0x70, 0xde, 0xe4, 0xf2, 0x9b, 0xb4, 0x88, 0xbb,
0x5f, 0xf8, 0xea, 0xc3, 0x91, 0xf4, 0xe3, 0xe2, 0x82, 0x9e, 0x2d, 0x0f, 0xca, 0x77, 0xcc, 0x9b,
0xd2, 0x54, 0x5f, 0x0f, 0xa4, 0xf6, 0x68, 0xb5, 0x50, 0x0f, 0xc2, 0xd3, 0xe6, 0x41, 0xf9, 0xb4,
0x99, 0x5c, 0x5c, 0x2c, 0x07, 0xf9, 0xe1, 0xff, 0x02, 0x00, 0x00, 0xff, 0xff, 0x51, 0x37, 0xf3,
0x7a, 0x2b, 0x0b, 0x00, 0x00,
}
internal/querycoord/index_checker.go
浏览文件 @ cc5bee46
......@@ -28,6 +28,7 @@ import (
"github.com/milvus-io/milvus/internal/kv"
"github.com/milvus-io/milvus/internal/log"
"github.com/milvus-io/milvus/internal/proto/commonpb"
"github.com/milvus-io/milvus/internal/proto/datapb"
"github.com/milvus-io/milvus/internal/proto/indexpb"
"github.com/milvus-io/milvus/internal/proto/milvuspb"
"github.com/milvus-io/milvus/internal/proto/querypb"
......@@ -192,13 +193,25 @@ func (ic *IndexChecker) checkIndexLoop() {
validHandoffReq, collectionInfo := ic.verifyHandoffReqValid(segmentInfo)
if validHandoffReq && Params.QueryCoordCfg.AutoHandoff {
indexInfo, err := getIndexInfo(ic.ctx, segmentInfo, collectionInfo.Schema, ic.rootCoord, ic.indexCoord)
if err == nil {
// if index exist or not enableIndex, ready to load
segmentInfo.IndexInfos = indexInfo
ic.enqueueIndexedSegment(segmentInfo)
break
}
// if segment has not been compacted and dropped, continue to wait for the build index to complete
segmentState, err := getSegmentStates(ic.ctx, segmentInfo.SegmentID, ic.dataCoord)
if err != nil {
log.Warn("checkIndexLoop: get segment state failed", zap.Int64("segmentID", segmentInfo.SegmentID), zap.Error(err))
continue
}
if segmentState.State != commonpb.SegmentState_NotExist {
continue
}
segmentInfo.IndexInfos = indexInfo
ic.enqueueIndexedSegment(segmentInfo)
break
log.Debug("checkIndexLoop: segment has been compacted and dropped before handoff", zap.Int64("segmentID", segmentInfo.SegmentID))
}
buildQuerySegmentPath := fmt.Sprintf("%s/%d/%d/%d", handoffSegmentPrefix, segmentInfo.CollectionID, segmentInfo.PartitionID, segmentInfo.SegmentID)
......@@ -335,3 +348,31 @@ func getIndexInfo(ctx context.Context, info *querypb.SegmentInfo, schema *schema
}
return []*querypb.VecFieldIndexInfo{indexInfo}, nil
}
func getSegmentStates(ctx context.Context, segmentID UniqueID, dataCoord types.DataCoord) (*datapb.SegmentStateInfo, error) {
ctx2, cancel2 := context.WithTimeout(ctx, timeoutForRPC)
defer cancel2()
req := &datapb.GetSegmentStatesRequest{
Base: &commonpb.MsgBase{
MsgType: commonpb.MsgType_GetSegmentState,
},
SegmentIDs: []UniqueID{segmentID},
}
resp, err := dataCoord.GetSegmentStates(ctx2, req)
if err != nil {
return nil, err
}
if resp.Status.ErrorCode != commonpb.ErrorCode_Success {
err = errors.New(resp.Status.Reason)
return nil, err
}
if len(resp.States) != 1 {
err = errors.New("the length of segmentStates result should be 1")
return nil, err
}
return resp.States[0], nil
}
internal/querycoord/index_checker_test.go
浏览文件 @ cc5bee46
......@@ -154,6 +154,55 @@ func TestCheckIndexLoop(t *testing.T) {
cancel()
}
func TestHandoffNotExistSegment(t *testing.T) {
refreshParams()
ctx, cancel := context.WithCancel(context.Background())
etcdCli, err := etcd.GetEtcdClient(&Params.BaseParams)
defer etcdCli.Close()
assert.Nil(t, err)
kv := etcdkv.NewEtcdKV(etcdCli, Params.BaseParams.MetaRootPath)
meta, err := newMeta(ctx, kv, nil, nil)
assert.Nil(t, err)
rootCoord := newRootCoordMock()
assert.Nil(t, err)
indexCoord := newIndexCoordMock()
indexCoord.returnError = true
dataCoord, err := newDataCoordMock(ctx)
assert.Nil(t, err)
dataCoord.segmentNotExist = true
meta.addCollection(defaultCollectionID, querypb.LoadType_loadCollection, genCollectionSchema(defaultCollectionID, false))
segmentInfo := &querypb.SegmentInfo{
SegmentID: defaultSegmentID,
CollectionID: defaultCollectionID,
PartitionID: defaultPartitionID,
SegmentState: commonpb.SegmentState_Sealed,
}
key := fmt.Sprintf("%s/%d/%d/%d", handoffSegmentPrefix, defaultCollectionID, defaultPartitionID, defaultSegmentID)
value, err := proto.Marshal(segmentInfo)
assert.Nil(t, err)
indexChecker, err := newIndexChecker(ctx, kv, meta, nil, nil, rootCoord, indexCoord, dataCoord)
assert.Nil(t, err)
err = kv.Save(key, string(value))
assert.Nil(t, err)
indexChecker.enqueueHandoffReq(segmentInfo)
indexChecker.wg.Add(1)
go indexChecker.checkIndexLoop()
for {
_, err := kv.Load(key)
if err != nil {
break
}
}
assert.Equal(t, 0, len(indexChecker.indexedSegmentsChan))
cancel()
indexChecker.wg.Wait()
}
func TestProcessHandoffAfterIndexDone(t *testing.T) {
refreshParams()
ctx, cancel := context.WithCancel(context.Background())
......
internal/querycoord/mock_3rd_component_test.go
浏览文件 @ cc5bee46
......@@ -302,6 +302,7 @@ type dataCoordMock struct {
Segment2Binlog map[UniqueID]*datapb.SegmentBinlogs
baseSegmentID UniqueID
channelNumPerCol int
segmentNotExist bool
}
func newDataCoordMock(ctx context.Context) (*dataCoordMock, error) {
......@@ -402,9 +403,33 @@ func (data *dataCoordMock) GetRecoveryInfo(ctx context.Context, req *datapb.GetR
}, nil
}
func (data *dataCoordMock) GetSegmentStates(ctx context.Context, req *datapb.GetSegmentStatesRequest) (*datapb.GetSegmentStatesResponse, error) {
var state commonpb.SegmentState
if data.segmentNotExist {
state = commonpb.SegmentState_NotExist
} else {
state = commonpb.SegmentState_Flushed
}
var segmentStates []*datapb.SegmentStateInfo
for _, segmentID := range req.SegmentIDs {
segmentStates = append(segmentStates, &datapb.SegmentStateInfo{
SegmentID: segmentID,
State: state,
})
}
return &datapb.GetSegmentStatesResponse{
Status: &commonpb.Status{
ErrorCode: commonpb.ErrorCode_Success,
},
States: segmentStates,
}, nil
}
type indexCoordMock struct {
types.IndexCoord
returnIndexFile bool
returnError bool
}
func newIndexCoordMock() *indexCoordMock {
......@@ -419,6 +444,12 @@ func (c *indexCoordMock) GetIndexFilePaths(ctx context.Context, req *indexpb.Get
ErrorCode: commonpb.ErrorCode_Success,
},
}
if c.returnError {
res.Status.ErrorCode = commonpb.ErrorCode_UnexpectedError
return res, nil
}
if c.returnIndexFile {
indexPaths, _ := generateIndex(defaultSegmentID)
indexPathInfo := &indexpb.IndexFilePathInfo{
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或