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

Rename indexID to indexBuildID and add IndexID and IndexName 

Signed-off-by: zhenshan.cao <zhenshan.cao@zilliz.com>
pull/4973/head^2
zhenshan.cao 2021-02-02 19:56:04 +08:00 committed by yefu.chen
parent 66d5189601
commit bfa14d40a8
10 changed files with 183 additions and 143 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/indexnode/indexnode.go
View File

@ -170,7 +170,7 @@ func (i *NodeImpl) BuildIndex(request *indexpb.BuildIndexCmd) (*commonpb.Status,
ret.Reason = err.Error()
return ret, nil
}
log.Println("index scheduler successfully with indexID = ", request.IndexID)
log.Println("index scheduler successfully with indexBuildID = ", request.IndexBuildID)
err = t.WaitToFinish()
log.Println("build index finish ...err = ", err)
if err != nil {

6
internal/indexnode/task.go
View File

@ -78,7 +78,7 @@ func (it *IndexBuildTask) SetID(ID UniqueID) {
}
func (it *IndexBuildTask) OnEnqueue() error {
it.SetID(it.cmd.IndexID)
it.SetID(it.cmd.IndexBuildID)
log.Printf("[IndexBuilderTask] Enqueue TaskID: %v", it.ID())
return nil
}
@ -106,7 +106,7 @@ func (it *IndexBuildTask) PostExecute() error {
Status: &commonpb.Status{
ErrorCode: commonpb.ErrorCode_SUCCESS,
},
IndexID: it.cmd.IndexID,
IndexBuildID: it.cmd.IndexBuildID,
NodeID: it.nodeID,
IndexFilePaths: it.savePaths,
}
@ -254,7 +254,7 @@ func (it *IndexBuildTask) Execute() error {
getSavePathByKey := func(key string) string {
// TODO: fix me, use more reasonable method
return strconv.Itoa(int(it.cmd.IndexID)) + "/" + strconv.Itoa(int(partitionID)) + "/" + strconv.Itoa(int(segmentID)) + "/" + key
return strconv.Itoa(int(it.cmd.IndexBuildID)) + "/" + strconv.Itoa(int(partitionID)) + "/" + strconv.Itoa(int(segmentID)) + "/" + key
}
saveBlob := func(path string, value []byte) error {
return it.kv.Save(path, string(value))

6
internal/indexservice/indexservice.go
View File

@ -221,13 +221,13 @@ func (i *ServiceImpl) BuildIndex(req *indexpb.BuildIndexRequest) (*indexpb.Build
ret.Status.Reason = err.Error()
return ret, nil
}
ret.IndexID = t.indexID
ret.IndexBuildID = t.indexBuildID
return ret, nil
}
func (i *ServiceImpl) GetIndexStates(req *indexpb.IndexStatesRequest) (*indexpb.IndexStatesResponse, error) {
var indexStates []*indexpb.IndexInfo
for _, indexID := range req.IndexIDs {
for _, indexID := range req.IndexBuildIDs {
indexState, err := i.metaTable.GetIndexState(indexID)
if err != nil {
indexState.Reason = err.Error()
@ -246,7 +246,7 @@ func (i *ServiceImpl) GetIndexStates(req *indexpb.IndexStatesRequest) (*indexpb.
func (i *ServiceImpl) GetIndexFilePaths(req *indexpb.IndexFilePathsRequest) (*indexpb.IndexFilePathsResponse, error) {
var indexPaths []*indexpb.IndexFilePathInfo
for _, indexID := range req.IndexIDs {
for _, indexID := range req.IndexBuildIDs {
indexPathInfo, _ := i.metaTable.GetIndexFilePathInfo(indexID)
indexPaths = append(indexPaths, indexPathInfo)
}

57
internal/indexservice/meta_table.go
View File

@ -24,8 +24,8 @@ import (
)
type metaTable struct {
client kv.TxnBase // client of a reliable kv service, i.e. etcd client
indexID2Meta map[UniqueID]indexpb.IndexMeta // index id to index meta
client kv.TxnBase // client of a reliable kv service, i.e. etcd client
indexBuildID2Meta map[UniqueID]indexpb.IndexMeta // index id to index meta
lock sync.RWMutex
}
@ -44,7 +44,7 @@ func NewMetaTable(kv kv.TxnBase) (*metaTable, error) {
}
func (mt *metaTable) reloadFromKV() error {
mt.indexID2Meta = make(map[UniqueID]indexpb.IndexMeta)
mt.indexBuildID2Meta = make(map[UniqueID]indexpb.IndexMeta)
_, values, err := mt.client.LoadWithPrefix("indexes")
if err != nil {
@ -57,7 +57,7 @@ func (mt *metaTable) reloadFromKV() error {
if err != nil {
return err
}
mt.indexID2Meta[indexMeta.IndexID] = indexMeta
mt.indexBuildID2Meta[indexMeta.IndexBuildID] = indexMeta
}
return nil
}
@ -66,22 +66,22 @@ func (mt *metaTable) reloadFromKV() error {
func (mt *metaTable) saveIndexMeta(meta *indexpb.IndexMeta) error {
value := proto.MarshalTextString(meta)
mt.indexID2Meta[meta.IndexID] = *meta
mt.indexBuildID2Meta[meta.IndexBuildID] = *meta
return mt.client.Save("/indexes/"+strconv.FormatInt(meta.IndexID, 10), value)
return mt.client.Save("/indexes/"+strconv.FormatInt(meta.IndexBuildID, 10), value)
}
func (mt *metaTable) AddIndex(indexID UniqueID, req *indexpb.BuildIndexRequest) error {
func (mt *metaTable) AddIndex(indexBuildID UniqueID, req *indexpb.BuildIndexRequest) error {
mt.lock.Lock()
defer mt.lock.Unlock()
_, ok := mt.indexID2Meta[indexID]
_, ok := mt.indexBuildID2Meta[indexBuildID]
if ok {
return errors.Errorf("index already exists with ID = " + strconv.FormatInt(indexID, 10))
return errors.Errorf("index already exists with ID = " + strconv.FormatInt(indexBuildID, 10))
}
meta := &indexpb.IndexMeta{
State: commonpb.IndexState_UNISSUED,
IndexID: indexID,
Req: req,
State: commonpb.IndexState_UNISSUED,
IndexBuildID: indexBuildID,
Req: req,
}
return mt.saveIndexMeta(meta)
}
@ -89,10 +89,10 @@ func (mt *metaTable) AddIndex(indexID UniqueID, req *indexpb.BuildIndexRequest)
func (mt *metaTable) NotifyBuildIndex(nty *indexpb.BuildIndexNotification) error {
mt.lock.Lock()
defer mt.lock.Unlock()
indexID := nty.IndexID
meta, ok := mt.indexID2Meta[indexID]
indexBuildID := nty.IndexBuildID
meta, ok := mt.indexBuildID2Meta[indexBuildID]
if !ok {
return errors.Errorf("index not exists with ID = " + strconv.FormatInt(indexID, 10))
return errors.Errorf("index not exists with ID = " + strconv.FormatInt(indexBuildID, 10))
}
if nty.Status.ErrorCode != commonpb.ErrorCode_SUCCESS {
@ -106,44 +106,45 @@ func (mt *metaTable) NotifyBuildIndex(nty *indexpb.BuildIndexNotification) error
return mt.saveIndexMeta(&meta)
}
func (mt *metaTable) GetIndexState(indexID UniqueID) (*indexpb.IndexInfo, error) {
func (mt *metaTable) GetIndexState(indexBuildID UniqueID) (*indexpb.IndexInfo, error) {
mt.lock.Lock()
defer mt.lock.Unlock()
ret := &indexpb.IndexInfo{
IndexID: indexID,
State: commonpb.IndexState_NONE,
IndexBuildID: indexBuildID,
State: commonpb.IndexState_NONE,
}
meta, ok := mt.indexID2Meta[indexID]
meta, ok := mt.indexBuildID2Meta[indexBuildID]
if !ok {
return ret, errors.Errorf("index not exists with ID = " + strconv.FormatInt(indexID, 10))
return ret, errors.Errorf("index not exists with ID = " + strconv.FormatInt(indexBuildID, 10))
}
ret.IndexID = meta.IndexID
ret.IndexID = meta.Req.IndexID
ret.IndexName = meta.Req.IndexName
ret.Reason = meta.FailReason
ret.State = meta.State
return ret, nil
}
func (mt *metaTable) GetIndexFilePathInfo(indexID UniqueID) (*indexpb.IndexFilePathInfo, error) {
func (mt *metaTable) GetIndexFilePathInfo(indexBuildID UniqueID) (*indexpb.IndexFilePathInfo, error) {
mt.lock.Lock()
defer mt.lock.Unlock()
ret := &indexpb.IndexFilePathInfo{
IndexID: indexID,
IndexBuildID: indexBuildID,
}
meta, ok := mt.indexID2Meta[indexID]
meta, ok := mt.indexBuildID2Meta[indexBuildID]
if !ok {
return nil, errors.Errorf("index not exists with ID = " + strconv.FormatInt(indexID, 10))
return nil, errors.Errorf("index not exists with ID = " + strconv.FormatInt(indexBuildID, 10))
}
ret.IndexFilePaths = meta.IndexFilePaths
return ret, nil
}
func (mt *metaTable) DeleteIndex(indexID UniqueID) error {
func (mt *metaTable) DeleteIndex(indexBuildID UniqueID) error {
mt.lock.Lock()
defer mt.lock.Unlock()
indexMeta, ok := mt.indexID2Meta[indexID]
indexMeta, ok := mt.indexBuildID2Meta[indexBuildID]
if !ok {
return errors.Errorf("can't find index. id = " + strconv.FormatInt(indexID, 10))
return errors.Errorf("can't find index. id = " + strconv.FormatInt(indexBuildID, 10))
}
fmt.Print(indexMeta)

10
internal/indexservice/task.go
View File

@ -54,7 +54,7 @@ func (bt *BaseTask) Notify(err error) {
type IndexAddTask struct {
BaseTask
req *indexpb.BuildIndexRequest
indexID UniqueID
indexBuildID UniqueID
idAllocator *GlobalIDAllocator
buildQueue TaskQueue
kv kv.Base
@ -69,7 +69,7 @@ func (it *IndexAddTask) SetID(ID UniqueID) {
func (it *IndexAddTask) OnEnqueue() error {
var err error
it.indexID, err = it.idAllocator.AllocOne()
it.indexBuildID, err = it.idAllocator.AllocOne()
if err != nil {
return err
}
@ -84,7 +84,7 @@ func (it *IndexAddTask) PreExecute() error {
}
it.builderClient = builderClient
it.buildClientNodeID = nodeID
err := it.table.AddIndex(it.indexID, it.req)
err := it.table.AddIndex(it.indexBuildID, it.req)
if err != nil {
return err
}
@ -93,8 +93,8 @@ func (it *IndexAddTask) PreExecute() error {
func (it *IndexAddTask) Execute() error {
cmd := &indexpb.BuildIndexCmd{
IndexID: it.indexID,
Req: it.req,
IndexBuildID: it.indexBuildID,
Req: it.req,
}
log.Println("before index ...")
resp, err := it.builderClient.BuildIndex(cmd)

2
internal/masterservice/master_service.go
View File

@ -683,7 +683,7 @@ func (c *Core) SetIndexService(s IndexServiceInterface) error {
if rsp.Status.ErrorCode != commonpb.ErrorCode_SUCCESS {
return 0, errors.Errorf("BuildIndex from index service failed, error = %s", rsp.Status.Reason)
}
return rsp.IndexID, nil
return rsp.IndexBuildID, nil
}
return nil
}

2
internal/masterservice/master_service_test.go
View File

@ -93,7 +93,7 @@ func (idx *indexMock) BuildIndex(req *indexpb.BuildIndexRequest) (*indexpb.Build
ErrorCode: commonpb.ErrorCode_SUCCESS,
Reason: "",
},
IndexID: idx.idxArray[len(idx.idxArray)-1],
IndexBuildID: idx.idxArray[len(idx.idxArray)-1],
}, nil
}

30
internal/proto/index_service.proto
View File

@ -20,13 +20,15 @@ message RegisterNodeResponse {
}
message IndexStatesRequest {
repeated int64 indexIDs = 1;
repeated int64 indexBuildIDs = 1;
}
message IndexInfo {
common.IndexState state = 1;
int64 indexID = 2;
string Reason = 3;
int64 indexBuildID = 2;
int64 indexID = 3;
string index_name = 4;
string Reason = 5;
}
message IndexStatesResponse {
@ -35,35 +37,37 @@ message IndexStatesResponse {
}
message BuildIndexRequest {
repeated string data_paths = 1;
repeated common.KeyValuePair type_params = 2;
repeated common.KeyValuePair index_params = 3;
string index_name = 1;
int64 indexID = 2;
repeated string data_paths = 3;
repeated common.KeyValuePair type_params = 4;
repeated common.KeyValuePair index_params = 5;
}
message BuildIndexResponse {
common.Status status = 1;
int64 indexID = 2;
int64 indexBuildID = 2;
}
message BuildIndexCmd {
int64 indexID = 1;
int64 indexBuildID = 1;
BuildIndexRequest req = 2;
}
message BuildIndexNotification {
common.Status status = 1;
int64 indexID = 2;
int64 indexBuildID = 2;
repeated string index_file_paths = 3;
int64 nodeID = 4;
}
message IndexFilePathsRequest {
repeated int64 indexIDs = 1;
repeated int64 indexBuildIDs = 1;
}
message IndexFilePathInfo {
common.Status status = 1;
int64 indexID = 2;
int64 indexBuildID = 2;
repeated string index_file_paths = 3;
}
@ -73,8 +77,8 @@ message IndexFilePathsResponse {
}
message IndexMeta {
common.IndexState state = 1;
int64 indexID = 2;
int64 indexBuildID = 1;
common.IndexState state = 2;
string fail_reason = 3;
BuildIndexRequest req = 4;
repeated string index_file_paths = 5;

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

@ -122,7 +122,7 @@ func (m *RegisterNodeResponse) GetInitParams() *internalpb2.InitParams {
}
type IndexStatesRequest struct {
IndexIDs []int64 `protobuf:"varint,1,rep,packed,name=indexIDs,proto3" json:"indexIDs,omitempty"`
IndexBuildIDs []int64 `protobuf:"varint,1,rep,packed,name=indexBuildIDs,proto3" json:"indexBuildIDs,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
@ -153,17 +153,19 @@ func (m *IndexStatesRequest) XXX_DiscardUnknown() {
var xxx_messageInfo_IndexStatesRequest proto.InternalMessageInfo
func (m *IndexStatesRequest) GetIndexIDs() []int64 {
func (m *IndexStatesRequest) GetIndexBuildIDs() []int64 {
if m != nil {
return m.IndexIDs
return m.IndexBuildIDs
}
return nil
}
type IndexInfo struct {
State commonpb.IndexState `protobuf:"varint,1,opt,name=state,proto3,enum=milvus.proto.common.IndexState" json:"state,omitempty"`
IndexID int64 `protobuf:"varint,2,opt,name=indexID,proto3" json:"indexID,omitempty"`
Reason string `protobuf:"bytes,3,opt,name=Reason,proto3" json:"Reason,omitempty"`
IndexBuildID int64 `protobuf:"varint,2,opt,name=indexBuildID,proto3" json:"indexBuildID,omitempty"`
IndexID int64 `protobuf:"varint,3,opt,name=indexID,proto3" json:"indexID,omitempty"`
IndexName string `protobuf:"bytes,4,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
Reason string `protobuf:"bytes,5,opt,name=Reason,proto3" json:"Reason,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
@ -201,6 +203,13 @@ func (m *IndexInfo) GetState() commonpb.IndexState {
return commonpb.IndexState_NONE
}
func (m *IndexInfo) GetIndexBuildID() int64 {
if m != nil {
return m.IndexBuildID
}
return 0
}
func (m *IndexInfo) GetIndexID() int64 {
if m != nil {
return m.IndexID
@ -208,6 +217,13 @@ func (m *IndexInfo) GetIndexID() int64 {
return 0
}
func (m *IndexInfo) GetIndexName() string {
if m != nil {
return m.IndexName
}
return ""
}
func (m *IndexInfo) GetReason() string {
if m != nil {
return m.Reason
@ -263,9 +279,11 @@ func (m *IndexStatesResponse) GetStates() []*IndexInfo {
}
type BuildIndexRequest struct {
DataPaths []string `protobuf:"bytes,1,rep,name=data_paths,json=dataPaths,proto3" json:"data_paths,omitempty"`
TypeParams []*commonpb.KeyValuePair `protobuf:"bytes,2,rep,name=type_params,json=typeParams,proto3" json:"type_params,omitempty"`
IndexParams []*commonpb.KeyValuePair `protobuf:"bytes,3,rep,name=index_params,json=indexParams,proto3" json:"index_params,omitempty"`
IndexName string `protobuf:"bytes,1,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
IndexID int64 `protobuf:"varint,2,opt,name=indexID,proto3" json:"indexID,omitempty"`
DataPaths []string `protobuf:"bytes,3,rep,name=data_paths,json=dataPaths,proto3" json:"data_paths,omitempty"`
TypeParams []*commonpb.KeyValuePair `protobuf:"bytes,4,rep,name=type_params,json=typeParams,proto3" json:"type_params,omitempty"`
IndexParams []*commonpb.KeyValuePair `protobuf:"bytes,5,rep,name=index_params,json=indexParams,proto3" json:"index_params,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
@ -296,6 +314,20 @@ func (m *BuildIndexRequest) XXX_DiscardUnknown() {
var xxx_messageInfo_BuildIndexRequest proto.InternalMessageInfo
func (m *BuildIndexRequest) GetIndexName() string {
if m != nil {
return m.IndexName
}
return ""
}
func (m *BuildIndexRequest) GetIndexID() int64 {
if m != nil {
return m.IndexID
}
return 0
}
func (m *BuildIndexRequest) GetDataPaths() []string {
if m != nil {
return m.DataPaths
@ -319,7 +351,7 @@ func (m *BuildIndexRequest) GetIndexParams() []*commonpb.KeyValuePair {
type BuildIndexResponse struct {
Status *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
IndexID int64 `protobuf:"varint,2,opt,name=indexID,proto3" json:"indexID,omitempty"`
IndexBuildID int64 `protobuf:"varint,2,opt,name=indexBuildID,proto3" json:"indexBuildID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
@ -357,15 +389,15 @@ func (m *BuildIndexResponse) GetStatus() *commonpb.Status {
return nil
}
func (m *BuildIndexResponse) GetIndexID() int64 {
func (m *BuildIndexResponse) GetIndexBuildID() int64 {
if m != nil {
return m.IndexID
return m.IndexBuildID
}
return 0
}
type BuildIndexCmd struct {
IndexID int64 `protobuf:"varint,1,opt,name=indexID,proto3" json:"indexID,omitempty"`
IndexBuildID int64 `protobuf:"varint,1,opt,name=indexBuildID,proto3" json:"indexBuildID,omitempty"`
Req *BuildIndexRequest `protobuf:"bytes,2,opt,name=req,proto3" json:"req,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
@ -397,9 +429,9 @@ func (m *BuildIndexCmd) XXX_DiscardUnknown() {
var xxx_messageInfo_BuildIndexCmd proto.InternalMessageInfo
func (m *BuildIndexCmd) GetIndexID() int64 {
func (m *BuildIndexCmd) GetIndexBuildID() int64 {
if m != nil {
return m.IndexID
return m.IndexBuildID
}
return 0
}
@ -413,7 +445,7 @@ func (m *BuildIndexCmd) GetReq() *BuildIndexRequest {
type BuildIndexNotification struct {
Status *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
IndexID int64 `protobuf:"varint,2,opt,name=indexID,proto3" json:"indexID,omitempty"`
IndexBuildID int64 `protobuf:"varint,2,opt,name=indexBuildID,proto3" json:"indexBuildID,omitempty"`
IndexFilePaths []string `protobuf:"bytes,3,rep,name=index_file_paths,json=indexFilePaths,proto3" json:"index_file_paths,omitempty"`
NodeID int64 `protobuf:"varint,4,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
@ -453,9 +485,9 @@ func (m *BuildIndexNotification) GetStatus() *commonpb.Status {
return nil
}
func (m *BuildIndexNotification) GetIndexID() int64 {
func (m *BuildIndexNotification) GetIndexBuildID() int64 {
if m != nil {
return m.IndexID
return m.IndexBuildID
}
return 0
}
@ -475,7 +507,7 @@ func (m *BuildIndexNotification) GetNodeID() int64 {
}
type IndexFilePathsRequest struct {
IndexIDs []int64 `protobuf:"varint,1,rep,packed,name=indexIDs,proto3" json:"indexIDs,omitempty"`
IndexBuildIDs []int64 `protobuf:"varint,1,rep,packed,name=indexBuildIDs,proto3" json:"indexBuildIDs,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
@ -506,16 +538,16 @@ func (m *IndexFilePathsRequest) XXX_DiscardUnknown() {
var xxx_messageInfo_IndexFilePathsRequest proto.InternalMessageInfo
func (m *IndexFilePathsRequest) GetIndexIDs() []int64 {
func (m *IndexFilePathsRequest) GetIndexBuildIDs() []int64 {
if m != nil {
return m.IndexIDs
return m.IndexBuildIDs
}
return nil
}
type IndexFilePathInfo struct {
Status *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
IndexID int64 `protobuf:"varint,2,opt,name=indexID,proto3" json:"indexID,omitempty"`
IndexBuildID int64 `protobuf:"varint,2,opt,name=indexBuildID,proto3" json:"indexBuildID,omitempty"`
IndexFilePaths []string `protobuf:"bytes,3,rep,name=index_file_paths,json=indexFilePaths,proto3" json:"index_file_paths,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
@ -554,9 +586,9 @@ func (m *IndexFilePathInfo) GetStatus() *commonpb.Status {
return nil
}
func (m *IndexFilePathInfo) GetIndexID() int64 {
func (m *IndexFilePathInfo) GetIndexBuildID() int64 {
if m != nil {
return m.IndexID
return m.IndexBuildID
}
return 0
}
@ -616,8 +648,8 @@ func (m *IndexFilePathsResponse) GetFilePaths() []*IndexFilePathInfo {
}
type IndexMeta struct {
State commonpb.IndexState `protobuf:"varint,1,opt,name=state,proto3,enum=milvus.proto.common.IndexState" json:"state,omitempty"`
IndexID int64 `protobuf:"varint,2,opt,name=indexID,proto3" json:"indexID,omitempty"`
IndexBuildID int64 `protobuf:"varint,1,opt,name=indexBuildID,proto3" json:"indexBuildID,omitempty"`
State commonpb.IndexState `protobuf:"varint,2,opt,name=state,proto3,enum=milvus.proto.common.IndexState" json:"state,omitempty"`
FailReason string `protobuf:"bytes,3,opt,name=fail_reason,json=failReason,proto3" json:"fail_reason,omitempty"`
Req *BuildIndexRequest `protobuf:"bytes,4,opt,name=req,proto3" json:"req,omitempty"`
IndexFilePaths []string `protobuf:"bytes,5,rep,name=index_file_paths,json=indexFilePaths,proto3" json:"index_file_paths,omitempty"`
@ -651,6 +683,13 @@ func (m *IndexMeta) XXX_DiscardUnknown() {
var xxx_messageInfo_IndexMeta proto.InternalMessageInfo
func (m *IndexMeta) GetIndexBuildID() int64 {
if m != nil {
return m.IndexBuildID
}
return 0
}
func (m *IndexMeta) GetState() commonpb.IndexState {
if m != nil {
return m.State
@ -658,13 +697,6 @@ func (m *IndexMeta) GetState() commonpb.IndexState {
return commonpb.IndexState_NONE
}
func (m *IndexMeta) GetIndexID() int64 {
if m != nil {
return m.IndexID
}
return 0
}
func (m *IndexMeta) GetFailReason() string {
if m != nil {
return m.FailReason
@ -705,60 +737,63 @@ func init() {
func init() { proto.RegisterFile("index_service.proto", fileDescriptor_a5d2036b4df73e0a) }
var fileDescriptor_a5d2036b4df73e0a = []byte{
// 842 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xec, 0x56, 0xd1, 0x6e, 0x1b, 0x45,
0x14, 0xcd, 0x76, 0x53, 0x17, 0x5f, 0x9b, 0xa8, 0x99, 0x94, 0xc8, 0x5a, 0xa8, 0xda, 0x2e, 0x6a,
0x6b, 0x2a, 0x61, 0x57, 0x8e, 0x0a, 0x8f, 0xa8, 0x49, 0x20, 0xb2, 0x50, 0xa3, 0x68, 0x5a, 0x81,
0xa8, 0x84, 0xa2, 0xf1, 0xee, 0x75, 0x32, 0x62, 0x77, 0x76, 0xbb, 0x33, 0xae, 0x48, 0x5f, 0x10,
0xef, 0x48, 0x3c, 0xc0, 0x4f, 0xf0, 0x0f, 0x7c, 0x0c, 0xef, 0xfc, 0x04, 0xda, 0x99, 0x59, 0x7b,
0x37, 0xde, 0xd8, 0x8e, 0x12, 0x89, 0x97, 0xbe, 0xf9, 0xce, 0x9e, 0x7b, 0xee, 0x9d, 0x73, 0xe6,
0xce, 0x18, 0xb6, 0xb8, 0x08, 0xf1, 0xe7, 0x63, 0x89, 0xd9, 0x5b, 0x1e, 0x60, 0x2f, 0xcd, 0x12,
0x95, 0x10, 0x12, 0xf3, 0xe8, 0xed, 0x44, 0x9a, 0xa8, 0xa7, 0x11, 0x5e, 0x3b, 0x48, 0xe2, 0x38,
0x11, 0x66, 0xcd, 0xdb, 0xe0, 0x42, 0x61, 0x26, 0x58, 0x64, 0xe3, 0x76, 0x39, 0xc3, 0xff, 0x05,
0xb6, 0x28, 0x9e, 0x70, 0xa9, 0x30, 0x3b, 0x4c, 0x42, 0xa4, 0xf8, 0x66, 0x82, 0x52, 0x91, 0xa7,
0xb0, 0x3e, 0x62, 0x12, 0x3b, 0xce, 0x7d, 0xa7, 0xdb, 0x1a, 0x7c, 0xd2, 0xab, 0x54, 0xb1, 0xf4,
0x2f, 0xe4, 0xc9, 0x2e, 0x93, 0x48, 0x35, 0x92, 0x7c, 0x01, 0xb7, 0x58, 0x18, 0x66, 0x28, 0x65,
0xe7, 0xc6, 0x82, 0xa4, 0xe7, 0x06, 0x43, 0x0b, 0xb0, 0xff, 0xbb, 0x03, 0x77, 0xaa, 0x1d, 0xc8,
0x34, 0x11, 0x12, 0xc9, 0x0e, 0x34, 0xa4, 0x62, 0x6a, 0x22, 0x6d, 0x13, 0x1f, 0xd7, 0xf2, 0xbd,
0xd4, 0x10, 0x6a, 0xa1, 0x64, 0x17, 0x5a, 0x5c, 0x70, 0x75, 0x9c, 0xb2, 0x8c, 0xc5, 0x45, 0x27,
0x0f, 0x7a, 0xe7, 0x44, 0xb2, 0x7a, 0x0c, 0x05, 0x57, 0x47, 0x1a, 0x48, 0x81, 0x4f, 0x7f, 0xfb,
0x4f, 0x81, 0x0c, 0x73, 0x1d, 0x73, 0x6a, 0x94, 0x85, 0x22, 0x1e, 0x7c, 0xa0, 0xd5, 0x1d, 0xee,
0xe7, 0x0d, 0xb9, 0x5d, 0x97, 0x4e, 0x63, 0x5f, 0x41, 0x53, 0x67, 0x0c, 0xc5, 0x38, 0x21, 0xcf,
0xe0, 0x66, 0xde, 0x8c, 0xd1, 0x6e, 0x63, 0x70, 0xaf, 0xb6, 0xed, 0x59, 0x01, 0x6a, 0xd0, 0xa4,
0x03, 0xb7, 0x2c, 0x9f, 0xee, 0xda, 0xa5, 0x45, 0x48, 0xb6, 0xa1, 0x41, 0x91, 0xc9, 0x44, 0x74,
0xdc, 0xfb, 0x4e, 0xb7, 0x49, 0x6d, 0xe4, 0xff, 0xea, 0xc0, 0x56, 0xa5, 0xd1, 0xab, 0x08, 0xf7,
0xcc, 0x24, 0x61, 0xae, 0x99, 0xdb, 0x6d, 0x0d, 0xee, 0xf6, 0xe6, 0x0f, 0x56, 0x6f, 0xba, 0x49,
0x6a, 0xc1, 0xfe, 0xdf, 0x0e, 0x6c, 0xee, 0x4e, 0x78, 0x14, 0xea, 0x4f, 0x85, 0x56, 0x77, 0x01,
0x42, 0xa6, 0xd8, 0x71, 0xca, 0xd4, 0xa9, 0x51, 0xab, 0x49, 0x9b, 0xf9, 0xca, 0x51, 0xbe, 0x90,
0x9b, 0xa4, 0xce, 0x52, 0x9c, 0x99, 0xe4, 0xce, 0x9b, 0x64, 0xbb, 0xfc, 0x16, 0xcf, 0xbe, 0x63,
0xd1, 0x04, 0x8f, 0x18, 0xcf, 0x28, 0xe4, 0x59, 0xc6, 0x24, 0xb2, 0x0f, 0x6d, 0x33, 0x0e, 0x96,
0xc4, 0x5d, 0x95, 0xa4, 0xa5, 0xd3, 0xac, 0xd5, 0x01, 0x90, 0x72, 0xf7, 0x57, 0x11, 0xf0, 0x42,
0xff, 0xfc, 0x11, 0x7c, 0x38, 0x2b, 0xb2, 0x17, 0x87, 0x65, 0xa8, 0x53, 0xb5, 0xfa, 0x4b, 0x70,
0x33, 0x7c, 0x63, 0x8f, 0xed, 0xc3, 0x3a, 0x0b, 0xe6, 0xc4, 0xa6, 0x79, 0x86, 0xff, 0x97, 0x03,
0xdb, 0xb3, 0x4f, 0x87, 0x89, 0xe2, 0x63, 0x1e, 0x30, 0xc5, 0x13, 0x71, 0xcd, 0xbb, 0x21, 0x5d,
0xb8, 0x6d, 0x84, 0x1f, 0xf3, 0x08, 0xad, 0xc3, 0xae, 0x76, 0x78, 0x43, 0xaf, 0x7f, 0xc3, 0x23,
0x34, 0x36, 0x6f, 0x43, 0x43, 0x24, 0x21, 0x0e, 0xf7, 0x3b, 0xeb, 0x9a, 0xc2, 0x46, 0xfe, 0x0e,
0x7c, 0x34, 0xac, 0x20, 0x57, 0x19, 0xb1, 0xdf, 0x1c, 0xd8, 0xac, 0x64, 0xe9, 0x59, 0xfb, 0xbf,
0xf6, 0xe6, 0xff, 0xe1, 0xc0, 0xf6, 0xf9, 0x4d, 0x5c, 0xe5, 0xf4, 0xec, 0x03, 0x94, 0x6a, 0x9a,
0x89, 0x78, 0x78, 0xe1, 0x08, 0x96, 0x35, 0xa0, 0xcd, 0xf1, 0xb4, 0xab, 0x7f, 0x1c, 0x7b, 0x11,
0xbd, 0x40, 0xc5, 0xae, 0xff, 0x22, 0xba, 0x07, 0xad, 0x31, 0xe3, 0xd1, 0x71, 0x56, 0xbe, 0x8d,
0x20, 0x5f, 0x32, 0x37, 0x52, 0x71, 0x7c, 0xd7, 0x2f, 0x7b, 0x7c, 0x6b, 0x85, 0xbf, 0x59, 0x27,
0xfc, 0xe0, 0xcf, 0x06, 0xb4, 0x4d, 0xcf, 0xe6, 0x19, 0x24, 0x01, 0xb4, 0xcb, 0xcf, 0x07, 0x79,
0x5c, 0x57, 0xb6, 0xe6, 0x89, 0xf3, 0xba, 0xcb, 0x81, 0xc6, 0x51, 0x7f, 0x8d, 0xfc, 0x08, 0x30,
0xeb, 0x9c, 0xac, 0xb6, 0x33, 0xef, 0xd1, 0x32, 0xd8, 0x94, 0x3e, 0x80, 0x8d, 0x03, 0x54, 0xa5,
0xbb, 0x9c, 0x3c, 0xba, 0xd0, 0xfb, 0xca, 0xab, 0xe4, 0x3d, 0x5e, 0x8a, 0x9b, 0x16, 0x89, 0x60,
0xb3, 0x28, 0x32, 0x9b, 0xd1, 0xcf, 0x96, 0x9e, 0xb1, 0x69, 0xa9, 0x27, 0xab, 0x40, 0x4b, 0x8a,
0xdd, 0xd6, 0xb7, 0xd0, 0x59, 0x49, 0xb7, 0x27, 0x8b, 0x05, 0x29, 0xdf, 0x5a, 0xde, 0xa2, 0xa9,
0xf1, 0xd7, 0xc8, 0x6b, 0x20, 0x07, 0xa8, 0xf6, 0x92, 0x38, 0x4d, 0x04, 0x0a, 0x65, 0x55, 0xf3,
0x6a, 0x93, 0xbe, 0x8e, 0x53, 0x75, 0x36, 0xef, 0x86, 0xfd, 0x13, 0x70, 0x8e, 0xc3, 0x5f, 0x23,
0xdf, 0x6b, 0xee, 0x57, 0x3c, 0xc6, 0x57, 0x3c, 0xf8, 0x69, 0xef, 0x94, 0x09, 0x81, 0xd1, 0x42,
0xee, 0x4f, 0xab, 0xdf, 0x6c, 0xf0, 0x52, 0x65, 0x5c, 0x9c, 0x94, 0x34, 0xf9, 0x01, 0xee, 0x1c,
0xa0, 0xae, 0xc3, 0xa5, 0xe2, 0x81, 0xbc, 0x3e, 0xea, 0xc1, 0xbf, 0x37, 0xec, 0xe4, 0xeb, 0x19,
0x38, 0xac, 0x1c, 0xd7, 0x07, 0x8b, 0x65, 0xdf, 0x8b, 0xc3, 0xf7, 0x6a, 0x5f, 0x8a, 0x7a, 0xf7,
0xf9, 0xeb, 0xaf, 0x4e, 0xb8, 0x3a, 0x9d, 0x8c, 0xf2, 0xec, 0xfe, 0x3b, 0x1e, 0x45, 0xfc, 0x9d,
0xc2, 0xe0, 0xb4, 0x6f, 0x12, 0x3e, 0x0f, 0xb9, 0x54, 0x19, 0x1f, 0x4d, 0x14, 0x86, 0xfd, 0x62,
0xeb, 0x7d, 0x4d, 0xd9, 0xd7, 0xea, 0xa7, 0xa3, 0x51, 0x43, 0x87, 0x3b, 0xff, 0x05, 0x00, 0x00,
0xff, 0xff, 0xde, 0x02, 0xad, 0xb0, 0xd5, 0x0b, 0x00, 0x00,
// 891 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xec, 0x56, 0x5f, 0x6f, 0x1b, 0x45,
0x10, 0xcf, 0xe5, 0x12, 0x57, 0x19, 0xbb, 0x51, 0xb3, 0x29, 0x91, 0x65, 0xa8, 0x9a, 0x1c, 0xb4,
0x35, 0x95, 0xb0, 0x91, 0xab, 0x82, 0x84, 0x84, 0x50, 0x13, 0x43, 0x64, 0xa1, 0x46, 0xd1, 0xb6,
0x02, 0x51, 0x09, 0x45, 0xeb, 0xbb, 0xb1, 0xbd, 0xe2, 0x6e, 0xef, 0x7a, 0xbb, 0xae, 0x70, 0x5f,
0x10, 0x9f, 0x80, 0x07, 0x10, 0x5f, 0x84, 0x07, 0xbe, 0x13, 0x3c, 0xf3, 0x8e, 0x6e, 0xf7, 0xce,
0xbe, 0xb3, 0xaf, 0xfe, 0xa3, 0x80, 0x78, 0xe1, 0xcd, 0x33, 0x37, 0x7f, 0x7f, 0xf3, 0x9b, 0x59,
0xc3, 0x21, 0x17, 0x1e, 0x7e, 0x7f, 0x25, 0x31, 0x7e, 0xc5, 0x5d, 0x6c, 0x45, 0x71, 0xa8, 0x42,
0x42, 0x02, 0xee, 0xbf, 0x1a, 0x4b, 0x23, 0xb5, 0xb4, 0x45, 0xa3, 0xe6, 0x86, 0x41, 0x10, 0x0a,
0xa3, 0x6b, 0xec, 0x73, 0xa1, 0x30, 0x16, 0xcc, 0x4f, 0xe5, 0x5a, 0xde, 0xc3, 0xf9, 0x01, 0x0e,
0x29, 0x0e, 0xb9, 0x54, 0x18, 0x5f, 0x84, 0x1e, 0x52, 0x7c, 0x39, 0x46, 0xa9, 0xc8, 0x87, 0xb0,
0xd3, 0x67, 0x12, 0xeb, 0xd6, 0xb1, 0xd5, 0xac, 0x76, 0xde, 0x69, 0x15, 0xb2, 0xa4, 0xe1, 0x9f,
0xca, 0xe1, 0x29, 0x93, 0x48, 0xb5, 0x25, 0xf9, 0x08, 0x6e, 0x30, 0xcf, 0x8b, 0x51, 0xca, 0xfa,
0xf6, 0x12, 0xa7, 0x27, 0xc6, 0x86, 0x66, 0xc6, 0xce, 0x4f, 0x16, 0xdc, 0x2e, 0x56, 0x20, 0xa3,
0x50, 0x48, 0x24, 0x8f, 0xa0, 0x22, 0x15, 0x53, 0x63, 0x99, 0x16, 0xf1, 0x76, 0x69, 0xbc, 0x67,
0xda, 0x84, 0xa6, 0xa6, 0xe4, 0x14, 0xaa, 0x5c, 0x70, 0x75, 0x15, 0xb1, 0x98, 0x05, 0x59, 0x25,
0x27, 0xad, 0x39, 0x90, 0x52, 0x3c, 0x7a, 0x82, 0xab, 0x4b, 0x6d, 0x48, 0x81, 0x4f, 0x7f, 0x3b,
0x9f, 0x00, 0xe9, 0x25, 0x38, 0x26, 0xa1, 0x51, 0x66, 0x88, 0xbc, 0x07, 0x37, 0x35, 0xba, 0xa7,
0x63, 0xee, 0x7b, 0xbd, 0x6e, 0x52, 0x95, 0xdd, 0xb4, 0x69, 0x51, 0xe9, 0xfc, 0x6e, 0xc1, 0x9e,
0x76, 0xee, 0x89, 0x41, 0x48, 0x1e, 0xc3, 0x6e, 0x52, 0x97, 0x81, 0x71, 0xbf, 0x73, 0xb7, 0xb4,
0x83, 0x59, 0x2e, 0x6a, 0xac, 0x89, 0x03, 0xb5, 0x7c, 0x54, 0xdd, 0x85, 0x4d, 0x0b, 0x3a, 0x52,
0x87, 0x1b, 0x5a, 0xee, 0x75, 0xeb, 0xb6, 0xfe, 0x9c, 0x89, 0xe4, 0x0e, 0x80, 0x21, 0x8a, 0x60,
0x01, 0xd6, 0x77, 0x8e, 0xad, 0xe6, 0x1e, 0xdd, 0xd3, 0x9a, 0x0b, 0x16, 0x20, 0x39, 0x82, 0x0a,
0x45, 0x26, 0x43, 0x51, 0xdf, 0xd5, 0x9f, 0x52, 0xc9, 0xf9, 0xd1, 0x82, 0xc3, 0x42, 0xdb, 0xd7,
0x19, 0xc3, 0x63, 0xe3, 0x84, 0xc9, 0x04, 0xec, 0x66, 0xb5, 0x73, 0xa7, 0xb5, 0x48, 0xd3, 0xd6,
0x14, 0x27, 0x9a, 0x1a, 0x3b, 0x7f, 0x59, 0x70, 0x60, 0x1a, 0x4c, 0x3e, 0x65, 0xc8, 0x17, 0x1b,
0xb2, 0xe6, 0x1b, 0xca, 0x21, 0xb1, 0xbd, 0x80, 0x84, 0xc7, 0x14, 0xbb, 0x8a, 0x98, 0x1a, 0xc9,
0xba, 0x7d, 0x6c, 0x27, 0x8e, 0x89, 0xe6, 0x32, 0x51, 0x24, 0x5c, 0x51, 0x93, 0x08, 0x33, 0xae,
0xec, 0xe8, 0x4a, 0x4f, 0x4a, 0xdb, 0xfb, 0x12, 0x27, 0x5f, 0x31, 0x7f, 0x8c, 0x97, 0x8c, 0xc7,
0x14, 0x12, 0x2f, 0xc3, 0x15, 0xd2, 0x4d, 0x47, 0x95, 0x05, 0xd9, 0x5d, 0x37, 0x48, 0x55, 0xbb,
0xa5, 0x8c, 0x0b, 0x80, 0xe4, 0xdb, 0xbe, 0x0e, 0xf2, 0x6b, 0x70, 0xc7, 0xf1, 0xe1, 0xe6, 0x2c,
0xdd, 0x59, 0xe0, 0x2d, 0x38, 0x59, 0x25, 0x84, 0xfb, 0x18, 0xec, 0x18, 0x5f, 0xa6, 0x1b, 0x75,
0xaf, 0x6c, 0x9e, 0x0b, 0x93, 0xa3, 0x89, 0x87, 0xf3, 0x9b, 0x05, 0x47, 0xb3, 0x4f, 0x17, 0xa1,
0xe2, 0x03, 0xee, 0x32, 0xc5, 0x43, 0xf1, 0xaf, 0x75, 0x48, 0x9a, 0x70, 0xcb, 0x8c, 0x65, 0xc0,
0x7d, 0x2c, 0xcc, 0x7f, 0x5f, 0xeb, 0xbf, 0xe0, 0x3e, 0x1a, 0x12, 0x1c, 0x41, 0x45, 0x84, 0x1e,
0xf6, 0xba, 0x7a, 0x53, 0x6c, 0x9a, 0x4a, 0xce, 0xa7, 0xf0, 0x56, 0xaf, 0x60, 0xb9, 0xd9, 0x1d,
0xf8, 0xd5, 0x82, 0x83, 0x82, 0xbf, 0xbe, 0x07, 0xff, 0x7d, 0xbf, 0xce, 0xcf, 0x16, 0x1c, 0xcd,
0x37, 0x76, 0x1d, 0xbe, 0x75, 0x01, 0x72, 0x39, 0xcd, 0xb6, 0xdf, 0x7b, 0xe3, 0xb6, 0xe7, 0xd1,
0xa0, 0x7b, 0x83, 0x69, 0x55, 0x7f, 0x64, 0x67, 0xf3, 0x29, 0x2a, 0xb6, 0x16, 0x1d, 0xa7, 0xa7,
0x75, 0x7b, 0xa3, 0xd3, 0x7a, 0x17, 0xaa, 0x03, 0xc6, 0xfd, 0xab, 0xd8, 0x9c, 0x40, 0x5b, 0x1f,
0x13, 0x48, 0x54, 0xe6, 0x0c, 0x66, 0x34, 0xdf, 0xd9, 0x94, 0xe6, 0xa5, 0x23, 0xd8, 0x2d, 0x1b,
0x41, 0xe7, 0x97, 0x0a, 0xd4, 0x4c, 0x65, 0xe6, 0x25, 0x27, 0x2e, 0xd4, 0xf2, 0x2f, 0x20, 0x79,
0x50, 0x96, 0xb6, 0xe4, 0x95, 0x6e, 0x34, 0x57, 0x1b, 0x9a, 0xd9, 0x3a, 0x5b, 0xe4, 0x5b, 0x80,
0x59, 0xe5, 0x64, 0xbd, 0xce, 0x1a, 0xf7, 0x57, 0x99, 0x4d, 0xc3, 0xbb, 0xb0, 0x7f, 0x8e, 0x2a,
0xf7, 0x80, 0x90, 0xfb, 0x6f, 0x64, 0x41, 0xe1, 0x61, 0x6d, 0x3c, 0x58, 0x69, 0x37, 0x4d, 0xe2,
0xc3, 0x41, 0x96, 0x64, 0xb6, 0xc1, 0xef, 0xaf, 0x64, 0xdb, 0x34, 0xd5, 0xc3, 0x75, 0x4c, 0x73,
0x88, 0xdd, 0xd2, 0xd7, 0x6a, 0x92, 0xc3, 0xed, 0xe1, 0x72, 0x40, 0xf2, 0xd7, 0xad, 0xb1, 0x6c,
0x7f, 0x9c, 0x2d, 0xf2, 0x02, 0xc8, 0x39, 0xaa, 0xb3, 0x30, 0x88, 0x42, 0x81, 0x42, 0xa5, 0xa8,
0x35, 0x4a, 0x9d, 0x3e, 0x0f, 0x22, 0x35, 0x59, 0x9c, 0x46, 0xfa, 0x3f, 0x66, 0x2e, 0x86, 0xb3,
0x45, 0xbe, 0xd6, 0xb1, 0x9f, 0xf3, 0x00, 0x9f, 0x73, 0xf7, 0xbb, 0xb3, 0x11, 0x13, 0x02, 0xfd,
0xa5, 0xb1, 0xdf, 0x2d, 0x7e, 0x4b, 0x85, 0x67, 0x2a, 0xe6, 0x62, 0x98, 0xc3, 0xe4, 0x1b, 0xb8,
0x7d, 0x8e, 0x3a, 0x0f, 0x97, 0x8a, 0xbb, 0xf2, 0x9f, 0x0b, 0xdd, 0xf9, 0x73, 0x3b, 0xbd, 0x01,
0x7a, 0x07, 0x2e, 0x0a, 0x74, 0x3d, 0x59, 0x0e, 0xfb, 0x59, 0xe0, 0xfd, 0x8f, 0xf6, 0x46, 0xa1,
0x4f, 0x9f, 0xbc, 0xf8, 0x6c, 0xc8, 0xd5, 0x68, 0xdc, 0x4f, 0xbc, 0xdb, 0xaf, 0xb9, 0xef, 0xf3,
0xd7, 0x0a, 0xdd, 0x51, 0xdb, 0x38, 0x7c, 0xe0, 0x71, 0xa9, 0x62, 0xde, 0x1f, 0x2b, 0xf4, 0xda,
0x59, 0xeb, 0x6d, 0x1d, 0xb2, 0xad, 0xd1, 0x8f, 0xfa, 0xfd, 0x8a, 0x16, 0x1f, 0xfd, 0x1d, 0x00,
0x00, 0xff, 0xff, 0xe9, 0x3f, 0x99, 0x70, 0x98, 0x0c, 0x00, 0x00,
}
// Reference imports to suppress errors if they are not otherwise used.

4
internal/querynode/load_service.go
View File

@ -395,14 +395,14 @@ func (s *loadService) seekSegment(positions []*internalpb2.MsgPosition) error {
return nil
}
func (s *loadService) getIndexPaths(buildID UniqueID) ([]string, error) {
func (s *loadService) getIndexPaths(indexBuildID UniqueID) ([]string, error) {
if s.indexClient == nil {
return nil, errors.New("null index service client")
}
indexFilePathRequest := &indexpb.IndexFilePathsRequest{
// TODO: rename indexIDs to buildIDs
IndexIDs: []UniqueID{buildID},
IndexBuildIDs: []UniqueID{indexBuildID},
}
pathResponse, err := s.indexClient.GetIndexFilePaths(indexFilePathRequest)
if err != nil || pathResponse.Status.ErrorCode != commonpb.ErrorCode_SUCCESS {