milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add ci nightly 

Signed-off-by: ThreadDao <yufen.zong@zilliz.com>
pull/4973/head^2
ThreadDao 2021-03-11 14:14:29 +08:00 committed by yefu.chen
parent ba3270112a
commit ca916a5c47
19 changed files with 200 additions and 201 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
build/ci/jenkins/Jenkinsfile vendored
View File

@ -1,8 +1,15 @@
#!/usr/bin/env groovy
@Library('mpl') _
String cron_timezone = "TZ=Asia/Shanghai"
String cron_string = BRANCH_NAME == "r0.3-test" ? "50 22 * * * " : ""
pipeline {
agent none
triggers {
cron """${cron_timezone}
${cron_string}"""
}
options {
timestamps()
}

58
internal/core/src/pb/common.pb.cc
View File

@ -246,35 +246,33 @@ const char descriptor_table_protodef_common_2eproto[] PROTOBUF_SECTION_VARIABLE(
"lder\020\023\022\024\n\020CannotDeleteFile\020\024\022\023\n\017BuildInd"
"exError\020\025\022\020\n\014IllegalNLIST\020\026\022\025\n\021IllegalMe"
"tricType\020\027\022\017\n\013OutOfMemory\020\030\022\021\n\rIndexNotE"
"xist\020\031\022\022\n\rDDRequestRace\020\350\007*\244\001\n\nIndexStat"
"e\022\024\n\020INDEX_STATE_NONE\020\000\022\030\n\024INDEX_STATE_U"
"NISSUED\020\001\022\033\n\027INDEX_STATE_IN_PROGRESS\020\002\022\030"
"\n\024INDEX_STATE_FINISHED\020\003\022\026\n\022INDEX_STATE_"
"FAILED\020\004\022\027\n\023INDEX_STATE_DELETED\020\005*o\n\014Seg"
"mentState\022\017\n\013SegmentNone\020\000\022\023\n\017SegmentNot"
"Exist\020\001\022\022\n\016SegmentGrowing\020\002\022\021\n\rSegmentSe"
"aled\020\003\022\022\n\016SegmentFlushed\020\004*\373\005\n\007MsgType\022\016"
"\n\nUnSpecific\020\000\022\024\n\020CreateCollection\020d\022\022\n\016"
"DropCollection\020e\022\021\n\rHasCollection\020f\022\026\n\022D"
"escribeCollection\020g\022\023\n\017ShowCollections\020h"
"\022\024\n\020GetSystemConfigs\020i\022\022\n\016LoadCollection"
"\020j\022\025\n\021ReleaseCollection\020k\022\024\n\017CreateParti"
"tion\020\310\001\022\022\n\rDropPartition\020\311\001\022\021\n\014HasPartit"
"ion\020\312\001\022\026\n\021DescribePartition\020\313\001\022\023\n\016ShowPa"
"rtitions\020\314\001\022\023\n\016LoadPartitions\020\315\001\022\026\n\021Rele"
"asePartitions\020\316\001\022\021\n\014ShowSegments\020\372\001\022\024\n\017D"
"escribeSegment\020\373\001\022\020\n\013CreateIndex\020\254\002\022\022\n\rD"
"escribeIndex\020\255\002\022\016\n\tDropIndex\020\256\002\022\013\n\006Inser"
"t\020\220\003\022\013\n\006Delete\020\221\003\022\n\n\005Flush\020\222\003\022\013\n\006Search\020"
"\364\003\022\021\n\014SearchResult\020\365\003\022\022\n\rGetIndexState\020\366"
"\003\022\034\n\027GetCollectionStatistics\020\367\003\022\033\n\026GetPa"
"rtitionStatistics\020\370\003\022\020\n\013SegmentInfo\020\330\004\022\r"
"\n\010TimeTick\020\260\t\022\023\n\016QueryNodeStats\020\261\t\022\016\n\tLo"
"adIndex\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\021SegmentStat"
"istics\020\266\t\022\025\n\020SegmentFlushDone\020\267\tBBZ@gith"
"ub.com/zilliztech/milvus-distributed/int"
"ernal/proto/commonpbb\006proto3"
"xist\020\031\022\022\n\rDDRequestRace\020\350\007*e\n\nIndexState"
"\022\022\n\016IndexStateNone\020\000\022\014\n\010Unissued\020\001\022\016\n\nIn"
"Progress\020\002\022\014\n\010Finished\020\003\022\n\n\006Failed\020\004\022\013\n\007"
"Deleted\020\005*X\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*\372\005\n\007MsgType\022\r\n\tUndef"
"ined\020\000\022\024\n\020CreateCollection\020d\022\022\n\016DropColl"
"ection\020e\022\021\n\rHasCollection\020f\022\026\n\022DescribeC"
"ollection\020g\022\023\n\017ShowCollections\020h\022\024\n\020GetS"
"ystemConfigs\020i\022\022\n\016LoadCollection\020j\022\025\n\021Re"
"leaseCollection\020k\022\024\n\017CreatePartition\020\310\001\022"
"\022\n\rDropPartition\020\311\001\022\021\n\014HasPartition\020\312\001\022\026"
"\n\021DescribePartition\020\313\001\022\023\n\016ShowPartitions"
"\020\314\001\022\023\n\016LoadPartitions\020\315\001\022\026\n\021ReleaseParti"
"tions\020\316\001\022\021\n\014ShowSegments\020\372\001\022\024\n\017DescribeS"
"egment\020\373\001\022\020\n\013CreateIndex\020\254\002\022\022\n\rDescribeI"
"ndex\020\255\002\022\016\n\tDropIndex\020\256\002\022\013\n\006Insert\020\220\003\022\013\n\006"
"Delete\020\221\003\022\n\n\005Flush\020\222\003\022\013\n\006Search\020\364\003\022\021\n\014Se"
"archResult\020\365\003\022\022\n\rGetIndexState\020\366\003\022\034\n\027Get"
"CollectionStatistics\020\367\003\022\033\n\026GetPartitionS"
"tatistics\020\370\003\022\020\n\013SegmentInfo\020\330\004\022\r\n\010TimeTi"
"ck\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\017A"
"llocateSegment\020\265\t\022\026\n\021SegmentStatistics\020\266"
"\t\022\025\n\020SegmentFlushDone\020\267\tBBZ@github.com/z"
"illiztech/milvus-distributed/internal/pr"
"oto/commonpbb\006proto3"
;
static const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable*const descriptor_table_common_2eproto_deps[1] = {
};
@ -290,7 +288,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", 2068,
&descriptor_table_common_2eproto_initialized, descriptor_table_protodef_common_2eproto, "common.proto", 1980,
&descriptor_table_common_2eproto_once, descriptor_table_common_2eproto_sccs, descriptor_table_common_2eproto_deps, 7, 0,
schemas, file_default_instances, TableStruct_common_2eproto::offsets,
file_level_metadata_common_2eproto, 7, file_level_enum_descriptors_common_2eproto, file_level_service_descriptors_common_2eproto,

34
internal/core/src/pb/common.pb.h
View File

@ -145,18 +145,18 @@ inline bool ErrorCode_Parse(
ErrorCode_descriptor(), name, value);
}
enum IndexState : int {
INDEX_STATE_NONE = 0,
INDEX_STATE_UNISSUED = 1,
INDEX_STATE_IN_PROGRESS = 2,
INDEX_STATE_FINISHED = 3,
INDEX_STATE_FAILED = 4,
INDEX_STATE_DELETED = 5,
IndexStateNone = 0,
Unissued = 1,
InProgress = 2,
Finished = 3,
Failed = 4,
Deleted = 5,
IndexState_INT_MIN_SENTINEL_DO_NOT_USE_ = std::numeric_limits<::PROTOBUF_NAMESPACE_ID::int32>::min(),
IndexState_INT_MAX_SENTINEL_DO_NOT_USE_ = std::numeric_limits<::PROTOBUF_NAMESPACE_ID::int32>::max()
};
bool IndexState_IsValid(int value);
constexpr IndexState IndexState_MIN = INDEX_STATE_NONE;
constexpr IndexState IndexState_MAX = INDEX_STATE_DELETED;
constexpr IndexState IndexState_MIN = IndexStateNone;
constexpr IndexState IndexState_MAX = Deleted;
constexpr int IndexState_ARRAYSIZE = IndexState_MAX + 1;
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* IndexState_descriptor();
@ -174,17 +174,17 @@ inline bool IndexState_Parse(
IndexState_descriptor(), name, value);
}
enum SegmentState : int {
SegmentNone = 0,
SegmentNotExist = 1,
SegmentGrowing = 2,
SegmentSealed = 3,
SegmentFlushed = 4,
SegmentStateNone = 0,
NotExist = 1,
Growing = 2,
Sealed = 3,
Flushed = 4,
SegmentState_INT_MIN_SENTINEL_DO_NOT_USE_ = std::numeric_limits<::PROTOBUF_NAMESPACE_ID::int32>::min(),
SegmentState_INT_MAX_SENTINEL_DO_NOT_USE_ = std::numeric_limits<::PROTOBUF_NAMESPACE_ID::int32>::max()
};
bool SegmentState_IsValid(int value);
constexpr SegmentState SegmentState_MIN = SegmentNone;
constexpr SegmentState SegmentState_MAX = SegmentFlushed;
constexpr SegmentState SegmentState_MIN = SegmentStateNone;
constexpr SegmentState SegmentState_MAX = Flushed;
constexpr int SegmentState_ARRAYSIZE = SegmentState_MAX + 1;
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* SegmentState_descriptor();
@ -202,7 +202,7 @@ inline bool SegmentState_Parse(
SegmentState_descriptor(), name, value);
}
enum MsgType : int {
UnSpecific = 0,
Undefined = 0,
CreateCollection = 100,
DropCollection = 101,
HasCollection = 102,
@ -244,7 +244,7 @@ enum MsgType : int {
MsgType_INT_MAX_SENTINEL_DO_NOT_USE_ = std::numeric_limits<::PROTOBUF_NAMESPACE_ID::int32>::max()
};
bool MsgType_IsValid(int value);
constexpr MsgType MsgType_MIN = UnSpecific;
constexpr MsgType MsgType_MIN = Undefined;
constexpr MsgType MsgType_MAX = SegmentFlushDone;
constexpr int MsgType_ARRAYSIZE = MsgType_MAX + 1;

1
internal/datanode/data_node.go
View File

@ -95,7 +95,6 @@ func (node *DataNode) Init() error {
req := &datapb.RegisterNodeRequest{
Base: &commonpb.MsgBase{
MsgType: commonpb.MsgType_UnSpecific,
SourceID: node.NodeID,
},
Address: &commonpb.Address{

2
internal/dataservice/meta.go
View File

@ -395,7 +395,7 @@ func BuildSegment(collectionID UniqueID, partitionID UniqueID, segmentID UniqueI
SealedTime: 0,
NumRows: 0,
MemSize: 0,
State: commonpb.SegmentState_SegmentGrowing,
State: commonpb.SegmentState_Growing,
StartPosition: &internalpb2.MsgPosition{
ChannelName: channelName,
MsgID: "0",

2
internal/dataservice/server.go
View File

@ -349,7 +349,7 @@ func (s *Server) startSegmentFlushChannel(ctx context.Context) {
continue
}
segmentInfo.FlushedTime = realMsg.BeginTimestamp
segmentInfo.State = commonpb.SegmentState_SegmentFlushed
segmentInfo.State = commonpb.SegmentState_Flushed
if err = s.meta.UpdateSegment(segmentInfo); err != nil {
log.Error("update segment error", zap.Error(err))
continue

2
internal/dataservice/watcher.go
View File

@ -92,7 +92,7 @@ func (watcher *dataNodeTimeTickWatcher) handleTimeTickMsg(msg *msgstream.TimeTic
log.Error("get segment from meta error", zap.Int64("segmentID", id), zap.Error(err))
continue
}
if err = watcher.meta.SetSegmentState(id, commonpb.SegmentState_SegmentSealed); err != nil {
if err = watcher.meta.SetSegmentState(id, commonpb.SegmentState_Sealed); err != nil {
log.Error("set segment state error", zap.Int64("segmentID", id), zap.Error(err))
continue
}

4
internal/distributed/querynode/mock.go
View File

@ -127,10 +127,10 @@ func (data *DataServiceMock) GetInsertBinlogPaths(req *datapb.InsertBinlogPathRe
func (data *DataServiceMock) GetSegmentStates(req *datapb.SegmentStatesRequest) (*datapb.SegmentStatesResponse, error) {
segmentGrowingInfo := &datapb.SegmentStateInfo{
State: commonpb.SegmentState_SegmentGrowing,
State: commonpb.SegmentState_Growing,
}
segmentFlushedInfo := &datapb.SegmentStateInfo{
State: commonpb.SegmentState_SegmentFlushed,
State: commonpb.SegmentState_Flushed,
}
if data.Count < 10 {

15
internal/indexservice/meta_table.go
View File

@ -81,7 +81,7 @@ func (mt *metaTable) AddIndex(indexBuildID UniqueID, req *indexpb.BuildIndexRequ
return fmt.Errorf("index already exists with ID = %d", indexBuildID)
}
meta := &indexpb.IndexMeta{
State: commonpb.IndexState_INDEX_STATE_UNISSUED,
State: commonpb.IndexState_Unissued,
IndexBuildID: indexBuildID,
Req: req,
}
@ -94,7 +94,7 @@ func (mt *metaTable) MarkIndexAsDeleted(indexID UniqueID) error {
for indexBuildID, meta := range mt.indexBuildID2Meta {
if meta.Req.IndexID == indexID {
meta.State = commonpb.IndexState_INDEX_STATE_DELETED
meta.State = commonpb.IndexState_Deleted
mt.indexBuildID2Meta[indexBuildID] = meta
}
}
@ -110,15 +110,15 @@ func (mt *metaTable) NotifyBuildIndex(nty *indexpb.BuildIndexNotification) error
if !ok {
return fmt.Errorf("index not exists with ID = %d", indexBuildID)
}
if meta.State == commonpb.IndexState_INDEX_STATE_DELETED {
if meta.State == commonpb.IndexState_Deleted {
return fmt.Errorf("index not exists with ID = %d", indexBuildID)
}
if nty.Status.ErrorCode != commonpb.ErrorCode_Success {
meta.State = commonpb.IndexState_INDEX_STATE_FAILED
meta.State = commonpb.IndexState_Failed
meta.FailReason = nty.Status.Reason
} else {
meta.State = commonpb.IndexState_INDEX_STATE_FINISHED
meta.State = commonpb.IndexState_Finished
meta.IndexFilePaths = nty.IndexFilePaths
}
@ -130,13 +130,12 @@ func (mt *metaTable) GetIndexState(indexBuildID UniqueID) (*indexpb.IndexInfo, e
defer mt.lock.Unlock()
ret := &indexpb.IndexInfo{
IndexBuildID: indexBuildID,
State: commonpb.IndexState_INDEX_STATE_NONE,
}
meta, ok := mt.indexBuildID2Meta[indexBuildID]
if !ok {
return ret, fmt.Errorf("index not exists with ID = %d", indexBuildID)
}
if meta.State == commonpb.IndexState_INDEX_STATE_DELETED {
if meta.State == commonpb.IndexState_Deleted {
return ret, fmt.Errorf("index not exists with ID = %d", indexBuildID)
}
ret.IndexID = meta.Req.IndexID
@ -156,7 +155,7 @@ func (mt *metaTable) GetIndexFilePathInfo(indexBuildID UniqueID) (*indexpb.Index
if !ok {
return nil, fmt.Errorf("index not exists with ID = %d", indexBuildID)
}
if meta.State == commonpb.IndexState_INDEX_STATE_DELETED {
if meta.State == commonpb.IndexState_Deleted {
return nil, fmt.Errorf("index not exists with ID = %d", indexBuildID)
}
ret.IndexFilePaths = meta.IndexFilePaths

24
internal/proto/common.proto
View File

@ -35,20 +35,20 @@ enum ErrorCode {
}
enum IndexState {
INDEX_STATE_NONE = 0;
INDEX_STATE_UNISSUED = 1;
INDEX_STATE_IN_PROGRESS = 2;
INDEX_STATE_FINISHED = 3;
INDEX_STATE_FAILED = 4;
INDEX_STATE_DELETED = 5;
IndexStateNone = 0;
Unissued = 1;
InProgress = 2;
Finished = 3;
Failed = 4;
Deleted = 5;
}
enum SegmentState {
SegmentNone = 0;
SegmentNotExist = 1;
SegmentGrowing = 2;
SegmentSealed = 3;
SegmentFlushed = 4;
SegmentStateNone = 0;
NotExist = 1;
Growing = 2;
Sealed = 3;
Flushed = 4;
}
message Empty{}
@ -77,7 +77,7 @@ message Address {
}
enum MsgType {
UnSpecific = 0;
Undefined = 0;
/* DEFINITION REQUESTS: COLLECTION */
CreateCollection = 100;
DropCollection = 101;

223
internal/proto/commonpb/common.pb.go
View File

@ -121,30 +121,30 @@ func (ErrorCode) EnumDescriptor() ([]byte, []int) {
type IndexState int32
const (
IndexState_INDEX_STATE_NONE IndexState = 0
IndexState_INDEX_STATE_UNISSUED IndexState = 1
IndexState_INDEX_STATE_IN_PROGRESS IndexState = 2
IndexState_INDEX_STATE_FINISHED IndexState = 3
IndexState_INDEX_STATE_FAILED IndexState = 4
IndexState_INDEX_STATE_DELETED IndexState = 5
IndexState_IndexStateNone IndexState = 0
IndexState_Unissued IndexState = 1
IndexState_InProgress IndexState = 2
IndexState_Finished IndexState = 3
IndexState_Failed IndexState = 4
IndexState_Deleted IndexState = 5
)
var IndexState_name = map[int32]string{
0: "INDEX_STATE_NONE",
1: "INDEX_STATE_UNISSUED",
2: "INDEX_STATE_IN_PROGRESS",
3: "INDEX_STATE_FINISHED",
4: "INDEX_STATE_FAILED",
5: "INDEX_STATE_DELETED",
0: "IndexStateNone",
1: "Unissued",
2: "InProgress",
3: "Finished",
4: "Failed",
5: "Deleted",
}
var IndexState_value = map[string]int32{
"INDEX_STATE_NONE": 0,
"INDEX_STATE_UNISSUED": 1,
"INDEX_STATE_IN_PROGRESS": 2,
"INDEX_STATE_FINISHED": 3,
"INDEX_STATE_FAILED": 4,
"INDEX_STATE_DELETED": 5,
"IndexStateNone": 0,
"Unissued": 1,
"InProgress": 2,
"Finished": 3,
"Failed": 4,
"Deleted": 5,
}
func (x IndexState) String() string {
@ -158,27 +158,27 @@ func (IndexState) EnumDescriptor() ([]byte, []int) {
type SegmentState int32
const (
SegmentState_SegmentNone SegmentState = 0
SegmentState_SegmentNotExist SegmentState = 1
SegmentState_SegmentGrowing SegmentState = 2
SegmentState_SegmentSealed SegmentState = 3
SegmentState_SegmentFlushed SegmentState = 4
SegmentState_SegmentStateNone SegmentState = 0
SegmentState_NotExist SegmentState = 1
SegmentState_Growing SegmentState = 2
SegmentState_Sealed SegmentState = 3
SegmentState_Flushed SegmentState = 4
)
var SegmentState_name = map[int32]string{
0: "SegmentNone",
1: "SegmentNotExist",
2: "SegmentGrowing",
3: "SegmentSealed",
4: "SegmentFlushed",
0: "SegmentStateNone",
1: "NotExist",
2: "Growing",
3: "Sealed",
4: "Flushed",
}
var SegmentState_value = map[string]int32{
"SegmentNone": 0,
"SegmentNotExist": 1,
"SegmentGrowing": 2,
"SegmentSealed": 3,
"SegmentFlushed": 4,
"SegmentStateNone": 0,
"NotExist": 1,
"Growing": 2,
"Sealed": 3,
"Flushed": 4,
}
func (x SegmentState) String() string {
@ -192,7 +192,7 @@ func (SegmentState) EnumDescriptor() ([]byte, []int) {
type MsgType int32
const (
MsgType_UnSpecific MsgType = 0
MsgType_Undefined MsgType = 0
// DEFINITION REQUESTS: COLLECTION
MsgType_CreateCollection MsgType = 100
MsgType_DropCollection MsgType = 101
@ -241,7 +241,7 @@ const (
)
var MsgType_name = map[int32]string{
0: "UnSpecific",
0: "Undefined",
100: "CreateCollection",
101: "DropCollection",
102: "HasCollection",
@ -282,7 +282,7 @@ var MsgType_name = map[int32]string{
}
var MsgType_value = map[string]int32{
"UnSpecific": 0,
"Undefined": 0,
"CreateCollection": 100,
"DropCollection": 101,
"HasCollection": 102,
@ -580,7 +580,7 @@ func (m *MsgBase) GetMsgType() MsgType {
if m != nil {
return m.MsgType
}
return MsgType_UnSpecific
return MsgType_Undefined
}
func (m *MsgBase) GetMsgID() int64 {
@ -661,80 +661,77 @@ func init() {
func init() { proto.RegisterFile("common.proto", fileDescriptor_555bd8c177793206) }
var fileDescriptor_555bd8c177793206 = []byte{
// 1193 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x74, 0x55, 0xdb, 0x6e, 0x1b, 0x45,
0x18, 0xee, 0xda, 0x4e, 0x9c, 0xfd, 0xed, 0x38, 0x93, 0xc9, 0xb1, 0x34, 0x42, 0x55, 0xae, 0xaa,
0x48, 0x4d, 0x10, 0x48, 0x70, 0x55, 0x89, 0xc4, 0xeb, 0x24, 0xab, 0x26, 0x4e, 0xd8, 0x75, 0x2a,
0xc4, 0x4d, 0xb4, 0xde, 0xfd, 0x63, 0x0f, 0xdd, 0xdd, 0x31, 0x33, 0xb3, 0x6d, 0xdc, 0xa7, 0x80,
0x3e, 0x03, 0xdc, 0x01, 0xe2, 0xcc, 0x2b, 0x70, 0xbe, 0xe6, 0x11, 0x78, 0x00, 0x4e, 0xa2, 0x37,
0x68, 0x66, 0xd7, 0xf6, 0x16, 0x95, 0xbb, 0xf9, 0xbf, 0xff, 0x30, 0xdf, 0x7f, 0x9a, 0x81, 0x66,
0xc8, 0x93, 0x84, 0xa7, 0xbb, 0x23, 0xc1, 0x15, 0xa7, 0x2b, 0x09, 0x8b, 0x1f, 0x65, 0x32, 0x97,
0x76, 0x73, 0xd5, 0x76, 0x1d, 0xe6, 0x3a, 0xc9, 0x48, 0x8d, 0xb7, 0x2f, 0x61, 0xde, 0x57, 0x81,
0xca, 0x24, 0xbd, 0x07, 0x80, 0x42, 0x70, 0x71, 0x19, 0xf2, 0x08, 0x37, 0xad, 0xdb, 0xd6, 0x9d,
0xd6, 0xab, 0x2f, 0xef, 0xbe, 0xc0, 0x79, 0xb7, 0xa3, 0xcd, 0xda, 0x3c, 0x42, 0xcf, 0xc6, 0xc9,
0x91, 0xae, 0xc3, 0xbc, 0xc0, 0x40, 0xf2, 0x74, 0xb3, 0x72, 0xdb, 0xba, 0x63, 0x7b, 0x85, 0xb4,
0xfd, 0x3a, 0x34, 0xef, 0xe3, 0xf8, 0x41, 0x10, 0x67, 0x78, 0x1e, 0x30, 0x41, 0x09, 0x54, 0x1f,
0xe2, 0xd8, 0xc4, 0xb7, 0x3d, 0x7d, 0xa4, 0xab, 0x30, 0xf7, 0x48, 0xab, 0x0b, 0xc7, 0x5c, 0xd8,
0xde, 0x82, 0xda, 0x41, 0xcc, 0xfb, 0x33, 0xad, 0xf6, 0x68, 0x4e, 0xb4, 0x77, 0xa1, 0xbe, 0x1f,
0x45, 0x02, 0xa5, 0xa4, 0x2d, 0xa8, 0xb0, 0x51, 0x11, 0xaf, 0xc2, 0x46, 0x94, 0x42, 0x6d, 0xc4,
0x85, 0x32, 0xd1, 0xaa, 0x9e, 0x39, 0x6f, 0x3f, 0xb5, 0xa0, 0x7e, 0x2a, 0x07, 0x07, 0x81, 0x44,
0xfa, 0x06, 0x2c, 0x24, 0x72, 0x70, 0xa9, 0xc6, 0xa3, 0x49, 0x96, 0x5b, 0x2f, 0xcc, 0xf2, 0x54,
0x0e, 0x7a, 0xe3, 0x11, 0x7a, 0xf5, 0x24, 0x3f, 0x68, 0x26, 0x89, 0x1c, 0xb8, 0x4e, 0x11, 0x39,
0x17, 0xe8, 0x16, 0xd8, 0x8a, 0x25, 0x28, 0x55, 0x90, 0x8c, 0x36, 0xab, 0xb7, 0xad, 0x3b, 0x35,
0x6f, 0x06, 0xd0, 0x97, 0x60, 0x41, 0xf2, 0x4c, 0x84, 0xe8, 0x3a, 0x9b, 0x35, 0xe3, 0x36, 0x95,
0xb7, 0xef, 0x81, 0x7d, 0x2a, 0x07, 0xc7, 0x18, 0x44, 0x28, 0xe8, 0x2b, 0x50, 0xeb, 0x07, 0x32,
0x67, 0xd4, 0xf8, 0x7f, 0x46, 0x3a, 0x03, 0xcf, 0x58, 0xee, 0x7c, 0x54, 0x03, 0x7b, 0xda, 0x09,
0xda, 0x80, 0xba, 0x9f, 0x85, 0x21, 0x4a, 0x49, 0x6e, 0xd0, 0x15, 0x58, 0xba, 0x48, 0xf1, 0x7a,
0x84, 0xa1, 0xc2, 0xc8, 0xd8, 0x10, 0x8b, 0x2e, 0xc3, 0x62, 0x9b, 0xa7, 0x29, 0x86, 0xea, 0x30,
0x60, 0x31, 0x46, 0xa4, 0x42, 0x57, 0x81, 0x9c, 0xa3, 0x48, 0x98, 0x94, 0x8c, 0xa7, 0x0e, 0xa6,
0x0c, 0x23, 0x52, 0xa5, 0x1b, 0xb0, 0xd2, 0xe6, 0x71, 0x8c, 0xa1, 0x62, 0x3c, 0xed, 0x72, 0xd5,
0xb9, 0x66, 0x52, 0x49, 0x52, 0xd3, 0x61, 0xdd, 0x38, 0xc6, 0x41, 0x10, 0xef, 0x8b, 0x41, 0x96,
0x60, 0xaa, 0xc8, 0x9c, 0x8e, 0x51, 0x80, 0x0e, 0x4b, 0x30, 0xd5, 0x91, 0x48, 0xbd, 0x84, 0xba,
0x69, 0x84, 0xd7, 0xba, 0x7e, 0x64, 0x81, 0xde, 0x84, 0xb5, 0x02, 0x2d, 0x5d, 0x10, 0x24, 0x48,
0x6c, 0xba, 0x04, 0x8d, 0x42, 0xd5, 0x3b, 0x3b, 0xbf, 0x4f, 0xa0, 0x14, 0xc1, 0xe3, 0x8f, 0x3d,
0x0c, 0xb9, 0x88, 0x48, 0xa3, 0x44, 0xe1, 0x01, 0x86, 0x8a, 0x0b, 0xd7, 0x21, 0x4d, 0x4d, 0xb8,
0x00, 0x7d, 0x0c, 0x44, 0x38, 0xf4, 0x50, 0x66, 0xb1, 0x22, 0x8b, 0x94, 0x40, 0xf3, 0x90, 0xc5,
0xd8, 0xe5, 0xea, 0x90, 0x67, 0x69, 0x44, 0x5a, 0xb4, 0x05, 0x70, 0x8a, 0x2a, 0x28, 0x2a, 0xb0,
0xa4, 0xaf, 0x6d, 0x07, 0xe1, 0x10, 0x0b, 0x80, 0xd0, 0x75, 0xa0, 0xed, 0x20, 0x4d, 0xb9, 0x6a,
0x0b, 0x0c, 0x14, 0x1e, 0xf2, 0x38, 0x42, 0x41, 0x96, 0x35, 0x9d, 0xe7, 0x70, 0x16, 0x23, 0xa1,
0x33, 0x6b, 0x07, 0x63, 0x9c, 0x5a, 0xaf, 0xcc, 0xac, 0x0b, 0x5c, 0x5b, 0xaf, 0x6a, 0xf2, 0x07,
0x19, 0x8b, 0x23, 0x53, 0x92, 0xbc, 0x2d, 0x6b, 0x9a, 0x63, 0x41, 0xbe, 0x7b, 0xe2, 0xfa, 0x3d,
0xb2, 0x4e, 0xd7, 0x60, 0xb9, 0x40, 0x4e, 0x51, 0x09, 0x16, 0x9a, 0xe2, 0x6d, 0x68, 0xaa, 0x67,
0x99, 0x3a, 0xbb, 0x3a, 0xc5, 0x84, 0x8b, 0x31, 0xd9, 0xd4, 0x0d, 0x35, 0x91, 0x26, 0x2d, 0x22,
0x37, 0x29, 0x85, 0x45, 0xc7, 0xf1, 0xf0, 0xbd, 0x0c, 0xa5, 0xf2, 0x82, 0x10, 0xc9, 0x6f, 0xf5,
0x9d, 0x0f, 0x2d, 0x00, 0x63, 0xa7, 0xf7, 0x1c, 0x4d, 0x5d, 0xbb, 0x4e, 0xe7, 0xed, 0x4b, 0xbf,
0xb7, 0xdf, 0xeb, 0x5c, 0x76, 0xcf, 0xba, 0x1d, 0x72, 0x83, 0x6e, 0xc2, 0x6a, 0x19, 0xbd, 0xe8,
0xba, 0xbe, 0x7f, 0xd1, 0x71, 0x88, 0x45, 0x6f, 0xc1, 0x46, 0x59, 0xe3, 0x76, 0x2f, 0xcf, 0xbd,
0xb3, 0x23, 0xaf, 0xe3, 0xfb, 0xa4, 0xf2, 0x5f, 0xb7, 0x43, 0xb7, 0xeb, 0xfa, 0xc7, 0x1d, 0x87,
0x54, 0x75, 0x65, 0x9e, 0xd3, 0xec, 0xbb, 0x27, 0x1d, 0x87, 0xd4, 0x4c, 0xaf, 0x4a, 0xb8, 0xd3,
0x39, 0xe9, 0xf4, 0x3a, 0x0e, 0x99, 0xdb, 0xe1, 0xd0, 0xf4, 0x71, 0xa0, 0x87, 0x2a, 0xe7, 0xb9,
0x04, 0x8d, 0x42, 0xee, 0xf2, 0x14, 0xf3, 0xa1, 0x9e, 0x02, 0x45, 0xc2, 0x16, 0xa5, 0xd0, 0x2a,
0xc0, 0x23, 0xc1, 0x1f, 0xb3, 0x74, 0x40, 0x2a, 0xba, 0x2e, 0x93, 0x48, 0x18, 0xc4, 0x66, 0xa4,
0x67, 0x66, 0x87, 0x71, 0x26, 0x87, 0x18, 0x91, 0xda, 0xce, 0xb3, 0x39, 0xf3, 0x26, 0x98, 0xd5,
0x6e, 0x01, 0x5c, 0xa4, 0xfe, 0x08, 0x43, 0x76, 0xc5, 0x42, 0x72, 0xc3, 0xf4, 0xcf, 0xf4, 0x79,
0x36, 0xa7, 0x24, 0xd2, 0x51, 0x1c, 0xc1, 0x47, 0x25, 0x0c, 0xf5, 0x65, 0xc7, 0x81, 0x2c, 0x41,
0x57, 0x3a, 0x75, 0x07, 0x65, 0x28, 0x58, 0xbf, 0xec, 0x3e, 0x30, 0x09, 0x0c, 0xf9, 0xe3, 0x19,
0x26, 0xc9, 0x50, 0xdf, 0x74, 0x84, 0xca, 0x1f, 0x4b, 0x85, 0x49, 0x9b, 0xa7, 0x57, 0x6c, 0x20,
0x09, 0xd3, 0x37, 0x9d, 0xf0, 0x20, 0x2a, 0xb9, 0xbf, 0xab, 0xc7, 0xc2, 0xc3, 0x18, 0x03, 0x59,
0x8e, 0xfa, 0x90, 0xae, 0xc2, 0x52, 0x4e, 0xf5, 0x3c, 0x10, 0x8a, 0x19, 0xf0, 0x3b, 0xcb, 0x0c,
0x82, 0xe0, 0xa3, 0x19, 0xf6, 0xbd, 0x7e, 0x00, 0x9a, 0xc7, 0x81, 0x9c, 0x41, 0x3f, 0x58, 0x74,
0x1d, 0x96, 0x27, 0x54, 0x67, 0xf8, 0x8f, 0x16, 0x5d, 0x81, 0x96, 0xa6, 0x3a, 0xc5, 0x24, 0xf9,
0xc9, 0x80, 0x9a, 0x54, 0x09, 0xfc, 0xd9, 0x44, 0x28, 0x58, 0x95, 0xf0, 0x5f, 0xcc, 0x65, 0x3a,
0x42, 0x51, 0x75, 0x49, 0xfe, 0xb1, 0x34, 0xd3, 0xc9, 0x65, 0x05, 0x4c, 0x9e, 0x59, 0x94, 0x40,
0x23, 0xe7, 0x6f, 0x66, 0x94, 0x7c, 0x5c, 0x31, 0xdc, 0x0b, 0xbb, 0x1c, 0xfb, 0xa4, 0x42, 0x5b,
0x60, 0xeb, 0x7c, 0x72, 0xf9, 0xd3, 0x0a, 0x6d, 0xc0, 0xbc, 0x9b, 0x4a, 0x14, 0x8a, 0xbc, 0x5f,
0xd5, 0x42, 0xbe, 0x67, 0xe4, 0x83, 0x2a, 0x05, 0x98, 0x33, 0x3d, 0x26, 0x4f, 0x8d, 0x22, 0x7f,
0x11, 0xc8, 0xef, 0x55, 0xc3, 0xa8, 0xfc, 0x3c, 0xfc, 0xa1, 0xc7, 0x62, 0xf1, 0x08, 0xd5, 0x6c,
0x39, 0xc8, 0x9f, 0x55, 0xba, 0x05, 0x1b, 0x47, 0xa8, 0x66, 0x25, 0xd6, 0x0a, 0x26, 0x15, 0x0b,
0x25, 0xf9, 0xab, 0x4a, 0x6f, 0xc1, 0xfa, 0x11, 0xaa, 0x69, 0xaa, 0x25, 0xe5, 0xdf, 0x55, 0x9d,
0x4a, 0x91, 0x98, 0x9b, 0x5e, 0x71, 0xf2, 0x6b, 0x8d, 0x2e, 0xc2, 0x42, 0x8f, 0x25, 0xd8, 0x63,
0xe1, 0x43, 0xf2, 0x99, 0xad, 0x2b, 0xf8, 0x56, 0x86, 0x62, 0xdc, 0xe5, 0x11, 0x6a, 0x57, 0x49,
0x3e, 0xb7, 0x75, 0x6a, 0xba, 0xac, 0x79, 0x6a, 0x5f, 0x18, 0xb9, 0xd8, 0x60, 0xd7, 0x21, 0x5f,
0xea, 0x97, 0x11, 0x0a, 0xb9, 0xe7, 0x9f, 0x91, 0xaf, 0x6c, 0x5d, 0xc7, 0xfd, 0x38, 0xe6, 0x61,
0xa0, 0xa6, 0x75, 0xfc, 0xda, 0xd6, 0x8d, 0x28, 0xed, 0x4f, 0x41, 0xea, 0x1b, 0x9b, 0xae, 0x01,
0x29, 0x8f, 0xbe, 0xa3, 0x97, 0xe9, 0x5b, 0xfb, 0xe0, 0xe0, 0x9d, 0x37, 0x07, 0x4c, 0x0d, 0xb3,
0xbe, 0xfe, 0x5c, 0xf6, 0x9e, 0xb0, 0x38, 0x66, 0x4f, 0x14, 0x86, 0xc3, 0xbd, 0xfc, 0xe3, 0xb9,
0x1b, 0x31, 0xa9, 0x04, 0xeb, 0x67, 0x0a, 0xa3, 0x3d, 0x96, 0x2a, 0x14, 0x69, 0x10, 0xef, 0x99,
0xdf, 0x68, 0x2f, 0xff, 0x8d, 0x46, 0xfd, 0xfe, 0xbc, 0x91, 0x5f, 0xfb, 0x37, 0x00, 0x00, 0xff,
0xff, 0x61, 0x0b, 0xb0, 0xaa, 0x70, 0x08, 0x00, 0x00,
// 1149 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x74, 0x55, 0x5b, 0x6f, 0xdc, 0x44,
0x14, 0xae, 0x77, 0x37, 0xd9, 0xf8, 0x64, 0xb3, 0x99, 0x4c, 0x2e, 0x4d, 0x21, 0x42, 0x55, 0x9e,
0xaa, 0x48, 0x4d, 0x10, 0x48, 0xf0, 0x54, 0x89, 0x66, 0xb7, 0x49, 0x57, 0x6d, 0x2e, 0x78, 0xd3,
0x0a, 0xf1, 0x52, 0x79, 0xed, 0x13, 0xef, 0x50, 0x7b, 0x66, 0x99, 0x19, 0xb7, 0xdd, 0xfe, 0x0a,
0xe8, 0x7f, 0xe0, 0x0d, 0x10, 0x77, 0xfe, 0x02, 0xf7, 0x67, 0x7e, 0x02, 0x3f, 0x80, 0x9b, 0xca,
0x0b, 0x3a, 0x63, 0x67, 0x6d, 0xa4, 0xf2, 0xe6, 0xf3, 0x9d, 0xdb, 0x77, 0x6e, 0x1e, 0xe8, 0x44,
0x2a, 0xcb, 0x94, 0xdc, 0x9d, 0x68, 0x65, 0x15, 0x5f, 0xcd, 0x44, 0xfa, 0x28, 0x37, 0x85, 0xb4,
0x5b, 0xa8, 0xb6, 0xdb, 0x30, 0x77, 0x2b, 0x9b, 0xd8, 0xe9, 0xf6, 0x03, 0x98, 0x1f, 0xda, 0xd0,
0xe6, 0x86, 0xdf, 0x00, 0x40, 0xad, 0x95, 0x7e, 0x10, 0xa9, 0x18, 0x37, 0xbd, 0xab, 0xde, 0xb5,
0xee, 0x6b, 0xaf, 0xec, 0xbe, 0xc0, 0x79, 0xf7, 0x16, 0x99, 0xf5, 0x54, 0x8c, 0x81, 0x8f, 0x17,
0x9f, 0x7c, 0x03, 0xe6, 0x35, 0x86, 0x46, 0xc9, 0xcd, 0xc6, 0x55, 0xef, 0x9a, 0x1f, 0x94, 0xd2,
0xf6, 0x1b, 0xd0, 0xb9, 0x83, 0xd3, 0xfb, 0x61, 0x9a, 0xe3, 0x69, 0x28, 0x34, 0x67, 0xd0, 0x7c,
0x88, 0x53, 0x17, 0xdf, 0x0f, 0xe8, 0x93, 0xaf, 0xc1, 0xdc, 0x23, 0x52, 0x97, 0x8e, 0x85, 0xb0,
0xbd, 0x05, 0xad, 0xfd, 0x54, 0x8d, 0x2a, 0x2d, 0x79, 0x74, 0x2e, 0xb4, 0xd7, 0xa1, 0x7d, 0x33,
0x8e, 0x35, 0x1a, 0xc3, 0xbb, 0xd0, 0x10, 0x93, 0x32, 0x5e, 0x43, 0x4c, 0x38, 0x87, 0xd6, 0x44,
0x69, 0xeb, 0xa2, 0x35, 0x03, 0xf7, 0xbd, 0xfd, 0xcc, 0x83, 0xf6, 0x91, 0x49, 0xf6, 0x43, 0x83,
0xfc, 0x4d, 0x58, 0xc8, 0x4c, 0xf2, 0xc0, 0x4e, 0x27, 0x17, 0x55, 0x6e, 0xbd, 0xb0, 0xca, 0x23,
0x93, 0x9c, 0x4d, 0x27, 0x18, 0xb4, 0xb3, 0xe2, 0x83, 0x98, 0x64, 0x26, 0x19, 0xf4, 0xcb, 0xc8,
0x85, 0xc0, 0xb7, 0xc0, 0xb7, 0x22, 0x43, 0x63, 0xc3, 0x6c, 0xb2, 0xd9, 0xbc, 0xea, 0x5d, 0x6b,
0x05, 0x15, 0xc0, 0x5f, 0x82, 0x05, 0xa3, 0x72, 0x1d, 0xe1, 0xa0, 0xbf, 0xd9, 0x72, 0x6e, 0x33,
0x79, 0xfb, 0x06, 0xf8, 0x47, 0x26, 0xb9, 0x8d, 0x61, 0x8c, 0x9a, 0xbf, 0x0a, 0xad, 0x51, 0x68,
0x0a, 0x46, 0x8b, 0xff, 0xcf, 0x88, 0x2a, 0x08, 0x9c, 0xe5, 0xce, 0x47, 0x2d, 0xf0, 0x67, 0x93,
0xe0, 0x8b, 0xd0, 0x1e, 0xe6, 0x51, 0x84, 0xc6, 0xb0, 0x4b, 0x7c, 0x15, 0x96, 0xef, 0x49, 0x7c,
0x32, 0xc1, 0xc8, 0x62, 0xec, 0x6c, 0x98, 0xc7, 0x57, 0x60, 0xa9, 0xa7, 0xa4, 0xc4, 0xc8, 0x1e,
0x84, 0x22, 0xc5, 0x98, 0x35, 0xf8, 0x1a, 0xb0, 0x53, 0xd4, 0x99, 0x30, 0x46, 0x28, 0xd9, 0x47,
0x29, 0x30, 0x66, 0x4d, 0x7e, 0x19, 0x56, 0x7b, 0x2a, 0x4d, 0x31, 0xb2, 0x42, 0xc9, 0x63, 0x65,
0x6f, 0x3d, 0x11, 0xc6, 0x1a, 0xd6, 0xa2, 0xb0, 0x83, 0x34, 0xc5, 0x24, 0x4c, 0x6f, 0xea, 0x24,
0xcf, 0x50, 0x5a, 0x36, 0x47, 0x31, 0x4a, 0xb0, 0x2f, 0x32, 0x94, 0x14, 0x89, 0xb5, 0x6b, 0xe8,
0x40, 0xc6, 0xf8, 0x84, 0xfa, 0xc7, 0x16, 0xf8, 0x15, 0x58, 0x2f, 0xd1, 0x5a, 0x82, 0x30, 0x43,
0xe6, 0xf3, 0x65, 0x58, 0x2c, 0x55, 0x67, 0x27, 0xa7, 0x77, 0x18, 0xd4, 0x22, 0x04, 0xea, 0x71,
0x80, 0x91, 0xd2, 0x31, 0x5b, 0xac, 0x51, 0xb8, 0x8f, 0x91, 0x55, 0x7a, 0xd0, 0x67, 0x1d, 0x22,
0x5c, 0x82, 0x43, 0x0c, 0x75, 0x34, 0x0e, 0xd0, 0xe4, 0xa9, 0x65, 0x4b, 0x9c, 0x41, 0xe7, 0x40,
0xa4, 0x78, 0xac, 0xec, 0x81, 0xca, 0x65, 0xcc, 0xba, 0xbc, 0x0b, 0x70, 0x84, 0x36, 0x2c, 0x3b,
0xb0, 0x4c, 0x69, 0x7b, 0x61, 0x34, 0xc6, 0x12, 0x60, 0x7c, 0x03, 0x78, 0x2f, 0x94, 0x52, 0xd9,
0x9e, 0xc6, 0xd0, 0xe2, 0x81, 0x4a, 0x63, 0xd4, 0x6c, 0x85, 0xe8, 0xfc, 0x07, 0x17, 0x29, 0x32,
0x5e, 0x59, 0xf7, 0x31, 0xc5, 0x99, 0xf5, 0x6a, 0x65, 0x5d, 0xe2, 0x64, 0xbd, 0x46, 0xe4, 0xf7,
0x73, 0x91, 0xc6, 0xae, 0x25, 0xc5, 0x58, 0xd6, 0x89, 0x63, 0x49, 0xfe, 0xf8, 0xee, 0x60, 0x78,
0xc6, 0x36, 0xf8, 0x3a, 0xac, 0x94, 0xc8, 0x11, 0x5a, 0x2d, 0x22, 0xd7, 0xbc, 0xcb, 0x44, 0xf5,
0x24, 0xb7, 0x27, 0xe7, 0x47, 0x98, 0x29, 0x3d, 0x65, 0x9b, 0x34, 0x50, 0x17, 0xe9, 0x62, 0x44,
0xec, 0x0a, 0xe7, 0xb0, 0xd4, 0xef, 0x07, 0xf8, 0x7e, 0x8e, 0xc6, 0x06, 0x61, 0x84, 0xec, 0xb7,
0xf6, 0x0e, 0x02, 0x38, 0x33, 0x3a, 0x73, 0xe4, 0x1c, 0xba, 0x95, 0x74, 0xac, 0x24, 0xb2, 0x4b,
0xbc, 0x03, 0x0b, 0xf7, 0xa4, 0x30, 0x26, 0xc7, 0x98, 0x79, 0xd4, 0xa2, 0x81, 0x3c, 0xd5, 0x2a,
0xa1, 0xeb, 0x62, 0x0d, 0xd2, 0x1e, 0x08, 0x29, 0xcc, 0xd8, 0x2d, 0x07, 0xc0, 0x7c, 0xd9, 0xab,
0x16, 0xed, 0x5c, 0x51, 0x5f, 0xcc, 0xe6, 0x76, 0xde, 0x81, 0xce, 0x10, 0x13, 0x5a, 0x8a, 0x22,
0xd1, 0x1a, 0xb0, 0xba, 0x5c, 0xa5, 0x9a, 0xd1, 0xf5, 0x28, 0xc0, 0xa1, 0x56, 0x8f, 0x85, 0x4c,
0x58, 0x83, 0x22, 0x0f, 0x31, 0x4c, 0x5d, 0x96, 0x45, 0x68, 0x1f, 0xa4, 0xb9, 0x4b, 0xd9, 0xda,
0x79, 0x3e, 0xe7, 0x8e, 0xd7, 0xdd, 0xe0, 0x12, 0xf8, 0xf7, 0x64, 0x8c, 0xe7, 0x42, 0x62, 0xcc,
0x2e, 0xb9, 0x3e, 0xbb, 0x79, 0x54, 0xfb, 0xc4, 0x62, 0xaa, 0xb1, 0xaf, 0xd5, 0xa4, 0x86, 0x21,
0x35, 0xeb, 0x76, 0x68, 0x6a, 0xd0, 0x39, 0x0d, 0xaf, 0x8f, 0x26, 0xd2, 0x62, 0x54, 0x77, 0x4f,
0x68, 0x4c, 0xc3, 0xb1, 0x7a, 0x5c, 0x61, 0x86, 0x8d, 0x29, 0xd3, 0x21, 0xda, 0xe1, 0xd4, 0x58,
0xcc, 0x7a, 0x4a, 0x9e, 0x8b, 0xc4, 0x30, 0x41, 0x99, 0xee, 0xaa, 0x30, 0xae, 0xb9, 0xbf, 0x47,
0xe3, 0x0b, 0x30, 0xc5, 0xd0, 0xd4, 0xa3, 0x3e, 0xe4, 0x6b, 0xb0, 0x5c, 0x50, 0x3d, 0x0d, 0xb5,
0x15, 0x0e, 0xfc, 0xce, 0x73, 0x03, 0xd3, 0x6a, 0x52, 0x61, 0xdf, 0xd3, 0xa1, 0x76, 0x6e, 0x87,
0xa6, 0x82, 0x7e, 0xf0, 0xf8, 0x06, 0xac, 0x5c, 0x50, 0xad, 0xf0, 0x1f, 0x3d, 0xbe, 0x0a, 0x5d,
0xa2, 0x3a, 0xc3, 0x0c, 0xfb, 0xc9, 0x81, 0x44, 0xaa, 0x06, 0xfe, 0xec, 0x22, 0x94, 0xac, 0x6a,
0xf8, 0x2f, 0x2e, 0x19, 0x45, 0x28, 0x47, 0x65, 0xd8, 0x73, 0x8f, 0x98, 0x5e, 0x24, 0x2b, 0x61,
0xf6, 0x8f, 0xc7, 0x19, 0x2c, 0x16, 0xfc, 0xdd, 0xfa, 0xb0, 0x8f, 0x1b, 0x8e, 0x7b, 0x69, 0x57,
0x60, 0x9f, 0x34, 0x78, 0x17, 0x7c, 0xaa, 0xa7, 0x90, 0x3f, 0x6d, 0xf0, 0x45, 0x98, 0x1f, 0x48,
0x83, 0xda, 0xb2, 0x0f, 0x68, 0xaa, 0xf3, 0xc5, 0xbe, 0xb0, 0x0f, 0x69, 0x91, 0xe6, 0xdc, 0x88,
0xd9, 0x33, 0xa7, 0x28, 0x2e, 0x97, 0xfd, 0xde, 0x74, 0x8c, 0xea, 0x67, 0xfc, 0x47, 0x93, 0x32,
0x1d, 0xa2, 0xad, 0xf6, 0x96, 0xfd, 0xd9, 0xe4, 0x5b, 0x70, 0xf9, 0x10, 0x6d, 0xd5, 0x62, 0x52,
0x08, 0x63, 0x45, 0x64, 0xd8, 0x5f, 0x4d, 0xfe, 0x32, 0x6c, 0x1c, 0xa2, 0x9d, 0x95, 0x5a, 0x53,
0xfe, 0xdd, 0xa4, 0x52, 0xca, 0xc2, 0x06, 0xf2, 0x5c, 0xb1, 0x5f, 0x5b, 0x7c, 0x09, 0x16, 0xce,
0x44, 0x86, 0x67, 0x22, 0x7a, 0xc8, 0x3e, 0xf3, 0xa9, 0x83, 0x6f, 0xe7, 0xa8, 0xa7, 0xc7, 0x2a,
0x46, 0x72, 0x35, 0xec, 0x73, 0x9f, 0x4a, 0xa3, 0xb6, 0x16, 0xa5, 0x7d, 0xe1, 0xe4, 0xf2, 0xd2,
0x06, 0x7d, 0xf6, 0x25, 0xfd, 0xc1, 0xa0, 0x94, 0xcf, 0x86, 0x27, 0xec, 0x2b, 0x9f, 0xfa, 0x78,
0x33, 0x4d, 0x55, 0x14, 0xda, 0x59, 0x1f, 0xbf, 0xf6, 0x69, 0x10, 0xb5, 0xbb, 0x28, 0x49, 0x7d,
0xe3, 0xf3, 0xf5, 0xd9, 0xbd, 0xb8, 0xb6, 0xf4, 0xe9, 0x5e, 0xbe, 0xf5, 0xf7, 0xf7, 0xdf, 0x7d,
0x2b, 0x11, 0x76, 0x9c, 0x8f, 0xe8, 0x11, 0xd8, 0x7b, 0x2a, 0xd2, 0x54, 0x3c, 0xb5, 0x18, 0x8d,
0xf7, 0x8a, 0x07, 0xe2, 0x7a, 0x2c, 0x8c, 0xd5, 0x62, 0x94, 0x5b, 0x8c, 0xf7, 0x84, 0xb4, 0xa8,
0x65, 0x98, 0xee, 0xb9, 0x57, 0x63, 0xaf, 0x78, 0x35, 0x26, 0xa3, 0xd1, 0xbc, 0x93, 0x5f, 0xff,
0x37, 0x00, 0x00, 0xff, 0xff, 0xf8, 0x64, 0x57, 0x6a, 0x18, 0x08, 0x00, 0x00,
}

4
internal/proto/datapb/data_service.pb.go
View File

@ -667,7 +667,7 @@ func (m *SegmentStateInfo) GetState() commonpb.SegmentState {
if m != nil {
return m.State
}
return commonpb.SegmentState_SegmentNone
return commonpb.SegmentState_SegmentStateNone
}
func (m *SegmentStateInfo) GetCreateTime() uint64 {
@ -1230,7 +1230,7 @@ func (m *SegmentInfo) GetState() commonpb.SegmentState {
if m != nil {
return m.State
}
return commonpb.SegmentState_SegmentNone
return commonpb.SegmentState_SegmentStateNone
}
func (m *SegmentInfo) GetStartPosition() *internalpb2.MsgPosition {

2
internal/proto/etcdpb/etcd_meta.pb.go
View File

@ -745,7 +745,7 @@ func (m *FieldIndexMeta) GetState() commonpb.IndexState {
if m != nil {
return m.State
}
return commonpb.IndexState_INDEX_STATE_NONE
return commonpb.IndexState_IndexStateNone
}
func (m *FieldIndexMeta) GetIndexFilePaths() []string {

4
internal/proto/indexpb/index_service.pb.go
View File

@ -200,7 +200,7 @@ func (m *IndexInfo) GetState() commonpb.IndexState {
if m != nil {
return m.State
}
return commonpb.IndexState_INDEX_STATE_NONE
return commonpb.IndexState_IndexStateNone
}
func (m *IndexInfo) GetIndexBuildID() int64 {
@ -694,7 +694,7 @@ func (m *IndexMeta) GetState() commonpb.IndexState {
if m != nil {
return m.State
}
return commonpb.IndexState_INDEX_STATE_NONE
return commonpb.IndexState_IndexStateNone
}
func (m *IndexMeta) GetFailReason() string {

4
internal/proto/milvuspb/milvus.pb.go
View File

@ -1868,7 +1868,7 @@ func (m *IndexStateResponse) GetState() commonpb.IndexState {
if m != nil {
return m.State
}
return commonpb.IndexState_INDEX_STATE_NONE
return commonpb.IndexState_IndexStateNone
}
type DropIndexRequest struct {
@ -2508,7 +2508,7 @@ func (m *PersistentSegmentInfo) GetState() commonpb.SegmentState {
if m != nil {
return m.State
}
return commonpb.SegmentState_SegmentNone
return commonpb.SegmentState_SegmentStateNone
}
type PersistentSegmentInfoRequest struct {

8
internal/proxynode/task.go
View File

@ -1760,7 +1760,7 @@ func (gist *GetIndexStateTask) Execute(ctx context.Context) error {
ErrorCode: commonpb.ErrorCode_Success,
Reason: "",
},
State: commonpb.IndexState_INDEX_STATE_IN_PROGRESS,
State: commonpb.IndexState_InProgress,
}
return err
}
@ -1778,14 +1778,14 @@ func (gist *GetIndexStateTask) Execute(ctx context.Context) error {
if states.Status.ErrorCode != commonpb.ErrorCode_Success {
gist.result = &milvuspb.IndexStateResponse{
Status: states.Status,
State: commonpb.IndexState_INDEX_STATE_FAILED,
State: commonpb.IndexState_Failed,
}
return nil
}
for _, state := range states.States {
if state.State != commonpb.IndexState_INDEX_STATE_FINISHED {
if state.State != commonpb.IndexState_Finished {
gist.result = &milvuspb.IndexStateResponse{
Status: states.Status,
State: state.State,
@ -1800,7 +1800,7 @@ func (gist *GetIndexStateTask) Execute(ctx context.Context) error {
ErrorCode: commonpb.ErrorCode_Success,
Reason: "",
},
State: commonpb.IndexState_INDEX_STATE_FINISHED,
State: commonpb.IndexState_Finished,
}
return nil

2
internal/querynode/load_service.go
View File

@ -106,7 +106,7 @@ func (s *loadService) loadSegmentInternal(collectionID UniqueID, partitionID Uni
if err != nil {
return err
}
if statesResp.States[0].State != commonpb.SegmentState_SegmentFlushed {
if statesResp.States[0].State != commonpb.SegmentState_Flushed {
return errors.New("segment not flush done")
}

3
internal/querynode/query_node.go
View File

@ -108,7 +108,6 @@ func (node *QueryNode) Init() error {
ctx := context.Background()
registerReq := &queryPb.RegisterNodeRequest{
Base: &commonpb.MsgBase{
MsgType: commonpb.MsgType_UnSpecific,
SourceID: Params.QueryNodeID,
},
Address: &commonpb.Address{
@ -445,7 +444,7 @@ func (node *QueryNode) LoadSegments(in *queryPb.LoadSegmentRequest) (*commonpb.S
//var position *internalpb2.MsgPosition = nil
for i, state := range in.SegmentStates {
//thisPosition := state.StartPosition
if state.State <= commonpb.SegmentState_SegmentGrowing {
if state.State <= commonpb.SegmentState_Growing {
//if position == nil {
// position = &internalpb2.MsgPosition{
// ChannelName: thisPosition.ChannelName,

2
internal/queryservice/mock.go
View File

@ -105,7 +105,7 @@ func NewDataMock() *DataMock {
ErrorCode: commonpb.ErrorCode_Success,
},
SegmentID: segmentID,
State: commonpb.SegmentState_SegmentFlushed,
State: commonpb.SegmentState_Flushed,
CreateTime: time,
StartPosition: position,
}