Skip to content
Snippets Groups Projects
Commit a8b78f11 authored by Cai Zhang 【张财】's avatar Cai Zhang 【张财】 Committed by yefu.chen
Browse files

Update proto about index


Signed-off-by: default avatarcai.zhang <cai.zhang@zilliz.com>
parent 342f4cb7
No related branches found
No related tags found
No related merge requests found
This diff is collapsed.
This diff is collapsed.
......@@ -122,7 +122,7 @@ service MilvusService {
*
* @return IndexParam
*/
rpc DescribeIndex(IndexParam) returns (DescribeIndexResponse) {}
rpc DescribeIndex(DescribeIndexRequest) returns (DescribeIndexResponse) {}
/**
* @brief This method is used to query index building progress
......@@ -131,5 +131,5 @@ service MilvusService {
*
* @return IndexParam
*/
rpc DescribeIndexProgress(IndexParam) returns (BoolResponse) {}
rpc DescribeIndexProgress(DescribeIndexProgressRequest) returns (BoolResponse) {}
}
\ No newline at end of file
......@@ -184,11 +184,19 @@ message QueryResult {
repeated common.KeyValuePair extra_params = 3;
}
message DescribeIndexRequest {
string collection_name = 1;
string field_name = 2;
}
message DescribeIndexProgressRequest {
string collection_name = 1;
string field_name = 2;
}
message DescribeIndexResponse {
common.Status status = 1;
string collection_name = 2;
string field_name = 3;
string index_name = 4;
repeated common.KeyValuePair extra_params = 5;
repeated common.KeyValuePair extra_params = 4;
}
......@@ -29,36 +29,37 @@ const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
func init() { proto.RegisterFile("service.proto", fileDescriptor_a0b84a42fa06f626) }
var fileDescriptor_a0b84a42fa06f626 = []byte{
// 464 bytes of a gzipped FileDescriptorProto
// 479 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x93, 0xcf, 0x6e, 0xd3, 0x40,
0x10, 0xc6, 0x73, 0xca, 0x61, 0x88, 0x5b, 0xba, 0x82, 0x8b, 0x2b, 0x21, 0x30, 0x20, 0x21, 0x10,
0xb1, 0x04, 0x4f, 0x40, 0x52, 0xa4, 0x06, 0x41, 0x15, 0x62, 0x15, 0x51, 0x38, 0x94, 0xb5, 0x33,
0xd8, 0x2b, 0xd9, 0xbb, 0xd6, 0xce, 0xb8, 0xff, 0xde, 0x99, 0x77, 0x40, 0xb1, 0xdd, 0xd6, 0x96,
0x1c, 0x62, 0x4b, 0xdc, 0xb2, 0x33, 0xdf, 0xfc, 0x76, 0xbf, 0x7c, 0x63, 0x70, 0x08, 0xed, 0x85,
0x8a, 0x70, 0x9a, 0x5b, 0xc3, 0x46, 0x3c, 0xca, 0x54, 0x7a, 0x51, 0x50, 0x75, 0x9a, 0xd6, 0x3d,
0x77, 0x12, 0x99, 0x2c, 0x33, 0xba, 0xaa, 0xba, 0x07, 0x75, 0xf9, 0x3c, 0xa3, 0xb8, 0x2e, 0x4d,
0x28, 0x4a, 0x30, 0x93, 0xd5, 0xe9, 0xdd, 0x1f, 0x00, 0xe7, 0x4b, 0xc9, 0x09, 0x2a, 0xa5, 0xf8,
0x0e, 0x0f, 0xe7, 0x16, 0x25, 0xe3, 0xdc, 0xa4, 0x29, 0x46, 0xac, 0x8c, 0x16, 0x2f, 0xa7, 0xed,
0xbb, 0x2a, 0xc2, 0xbd, 0x20, 0x28, 0x0b, 0xee, 0x61, 0x5b, 0x56, 0xbf, 0x24, 0x60, 0xc9, 0x05,
0x79, 0x23, 0x71, 0x0a, 0x7b, 0x47, 0xd6, 0xe4, 0x0d, 0xee, 0x8b, 0x69, 0x97, 0x87, 0x06, 0xf8,
0x44, 0x66, 0xb8, 0x0b, 0xfb, 0x13, 0x9c, 0x63, 0x49, 0x83, 0xa9, 0x5e, 0xb7, 0x6a, 0x66, 0x4c,
0xba, 0x42, 0xca, 0x8d, 0x26, 0xf4, 0x46, 0x42, 0x81, 0x38, 0x42, 0x8a, 0xac, 0x0a, 0x71, 0xf0,
0x0d, 0x6f, 0x76, 0xa9, 0x2a, 0x72, 0xbe, 0xf9, 0xe9, 0x8d, 0xc4, 0x19, 0xec, 0x07, 0x89, 0xb9,
0xbc, 0x6f, 0x93, 0x70, 0x3b, 0x9d, 0x7f, 0xcc, 0x72, 0xbe, 0x76, 0x5f, 0x75, 0xd3, 0x03, 0xb6,
0x4a, 0xc7, 0x9f, 0x15, 0x71, 0xc3, 0xc5, 0x29, 0xec, 0x57, 0x99, 0x2e, 0xa5, 0x65, 0x55, 0x5a,
0x78, 0xde, 0x3d, 0x7e, 0x27, 0xe8, 0xf3, 0xcf, 0x07, 0xe0, 0x6c, 0x02, 0xfd, 0xbf, 0xd0, 0x33,
0x98, 0x1c, 0x4b, 0x1a, 0xc8, 0xec, 0x17, 0xe6, 0x6f, 0x38, 0xb8, 0x0d, 0x73, 0x20, 0xff, 0xf5,
0x0e, 0x51, 0x3b, 0xc9, 0x10, 0xf6, 0x36, 0x49, 0xde, 0x75, 0xa9, 0xe7, 0xc2, 0x0c, 0x89, 0xf4,
0x1b, 0x8c, 0x17, 0x9a, 0xd0, 0xb2, 0x78, 0xd2, 0x3d, 0xb5, 0x32, 0x97, 0x33, 0xc9, 0x51, 0xb2,
0xed, 0xed, 0x0b, 0xcd, 0x18, 0xa3, 0x5d, 0x49, 0x1d, 0x63, 0x83, 0xfb, 0x09, 0xc6, 0x01, 0x4a,
0x1b, 0x25, 0xe2, 0xb0, 0x7b, 0xee, 0x6b, 0x81, 0xf6, 0xda, 0x7d, 0xf6, 0x8f, 0xe6, 0x0a, 0xa9,
0x48, 0xd9, 0x1b, 0x89, 0x13, 0x78, 0x50, 0xad, 0xdd, 0x42, 0xaf, 0xf1, 0x4a, 0x3c, 0xdd, 0xf6,
0x90, 0x35, 0x5e, 0x2d, 0xa5, 0x95, 0xd9, 0xae, 0xd5, 0xf8, 0x05, 0xce, 0x6d, 0x7e, 0x7d, 0x89,
0x5b, 0xbe, 0xc1, 0x16, 0xa6, 0xe1, 0xfe, 0x1c, 0x1e, 0xb7, 0x5a, 0x4b, 0x6b, 0x62, 0x8b, 0x44,
0x3d, 0x6e, 0xea, 0xb5, 0x82, 0xb3, 0xf9, 0x8f, 0x0f, 0xb1, 0xe2, 0xa4, 0x08, 0x37, 0xe6, 0xfc,
0x1b, 0x95, 0xa6, 0xea, 0x86, 0x31, 0x4a, 0xfc, 0x6a, 0xf8, 0xed, 0x5a, 0x11, 0x5b, 0x15, 0x16,
0x8c, 0x6b, 0x5f, 0x69, 0x46, 0xab, 0x65, 0xea, 0x97, 0x44, 0xbf, 0x26, 0xe6, 0x61, 0x38, 0x2e,
0x0b, 0xef, 0xff, 0x06, 0x00, 0x00, 0xff, 0xff, 0x9b, 0xf8, 0xbc, 0x74, 0x11, 0x06, 0x00, 0x00,
0x10, 0xc6, 0x73, 0xca, 0x61, 0x1b, 0xb7, 0x74, 0x05, 0x17, 0x57, 0x42, 0x60, 0x40, 0x42, 0x20,
0x62, 0xa9, 0x3c, 0x01, 0x49, 0x91, 0x1a, 0x04, 0x55, 0xb0, 0x55, 0x44, 0xe1, 0x80, 0xd6, 0xce,
0x60, 0x2f, 0xb2, 0x77, 0xdd, 0x9d, 0x71, 0xff, 0xbd, 0x01, 0x6f, 0x8d, 0xe2, 0x75, 0xd2, 0x18,
0x39, 0xc4, 0x96, 0xb8, 0x79, 0x67, 0xbe, 0xf9, 0xed, 0xcc, 0x7e, 0x63, 0xe6, 0x20, 0x98, 0x2b,
0x19, 0xc3, 0xb8, 0x30, 0x9a, 0x34, 0x7f, 0x98, 0xcb, 0xec, 0xaa, 0x44, 0x7b, 0x1a, 0xd7, 0x39,
0x77, 0x14, 0xeb, 0x3c, 0xd7, 0xca, 0x46, 0xdd, 0xc3, 0x3a, 0xfc, 0x23, 0xc7, 0xa4, 0x0e, 0x8d,
0x30, 0x4e, 0x21, 0x17, 0xf6, 0x74, 0xfc, 0x7b, 0x8f, 0x39, 0x9f, 0x2a, 0x4e, 0x68, 0x95, 0xfc,
0x2b, 0x7b, 0x30, 0x35, 0x20, 0x08, 0xa6, 0x3a, 0xcb, 0x20, 0x26, 0xa9, 0x15, 0x7f, 0x31, 0x6e,
0xde, 0x65, 0x09, 0xf7, 0x82, 0xb0, 0x0a, 0xb8, 0x47, 0x4d, 0x59, 0xdd, 0x49, 0x48, 0x82, 0x4a,
0xf4, 0x06, 0xfc, 0x9c, 0xed, 0x9f, 0x18, 0x5d, 0x6c, 0x70, 0x9f, 0x8f, 0xdb, 0x66, 0xd8, 0x00,
0x9f, 0x89, 0x1c, 0x76, 0x61, 0xbf, 0x33, 0xe7, 0x54, 0x60, 0x6f, 0xaa, 0xd7, 0xae, 0x9a, 0x68,
0x9d, 0x05, 0x80, 0x85, 0x56, 0x08, 0xde, 0x80, 0x4b, 0xc6, 0x4f, 0x00, 0x63, 0x23, 0x23, 0xe8,
0x7d, 0xc3, 0xeb, 0x5d, 0x2a, 0x4b, 0x2e, 0x96, 0x9f, 0xde, 0x80, 0x5f, 0xb0, 0x83, 0x30, 0xd5,
0xd7, 0xf7, 0x69, 0xe4, 0x6e, 0xeb, 0xe4, 0xef, 0xf3, 0x82, 0x6e, 0xdd, 0x97, 0xed, 0xf4, 0x90,
0x8c, 0x54, 0xc9, 0x47, 0x89, 0xb4, 0x31, 0xc5, 0x39, 0x3b, 0xb0, 0x9e, 0xce, 0x85, 0x21, 0x59,
0x8d, 0xf0, 0xac, 0xbd, 0x7c, 0x2d, 0xe8, 0xf2, 0xf2, 0x21, 0x73, 0x96, 0x86, 0xfe, 0x5f, 0xe8,
0x05, 0x1b, 0x9d, 0x0a, 0xec, 0xc9, 0xec, 0x66, 0xe6, 0x4f, 0x76, 0xb8, 0x32, 0xb3, 0x27, 0xff,
0xd5, 0x0e, 0x51, 0xd3, 0xc9, 0x88, 0xed, 0x2f, 0x9d, 0x5c, 0x67, 0xb1, 0xe3, 0xc2, 0xf4, 0xb1,
0xf4, 0x0b, 0x1b, 0xce, 0x14, 0x82, 0x21, 0xfe, 0xb8, 0xbd, 0x2a, 0xd0, 0xd7, 0x13, 0x41, 0x71,
0xba, 0xad, 0xf7, 0x99, 0x22, 0x48, 0xc0, 0x04, 0x42, 0x25, 0xb0, 0xc1, 0xfd, 0xc0, 0x86, 0x21,
0x08, 0x13, 0xa7, 0xfc, 0xa8, 0xbd, 0xee, 0x73, 0x09, 0xe6, 0xd6, 0x7d, 0xfa, 0x8f, 0x64, 0x00,
0x58, 0x66, 0xe4, 0x0d, 0xf8, 0x19, 0xdb, 0xb3, 0x6b, 0x37, 0x53, 0x0b, 0xb8, 0xe1, 0x4f, 0xb6,
0x35, 0xb2, 0x80, 0x9b, 0xb9, 0x30, 0x22, 0xdf, 0xb5, 0x1a, 0xbf, 0x98, 0xb3, 0xf2, 0xcf, 0x12,
0xb7, 0x8c, 0xd6, 0x10, 0x05, 0x70, 0x59, 0x02, 0xd2, 0xb6, 0xbf, 0xf1, 0x2f, 0xed, 0xfa, 0x1d,
0x2e, 0xd9, 0xa3, 0x46, 0x6a, 0x6e, 0x74, 0x62, 0x00, 0x91, 0x1f, 0x77, 0xe0, 0xac, 0xc4, 0xab,
0xbb, 0x3b, 0xad, 0xe7, 0x64, 0xfa, 0xed, 0x5d, 0x22, 0x29, 0x2d, 0xa3, 0xe5, 0xe0, 0xfe, 0x9d,
0xcc, 0x32, 0x79, 0x47, 0x10, 0xa7, 0xbe, 0x2d, 0x7e, 0xb3, 0x90, 0x48, 0x46, 0x46, 0x25, 0xc1,
0xc2, 0x97, 0x8a, 0xc0, 0x28, 0x91, 0xf9, 0x15, 0xd1, 0xaf, 0x89, 0x45, 0x14, 0x0d, 0xab, 0xc0,
0xdb, 0x3f, 0x01, 0x00, 0x00, 0xff, 0xff, 0x71, 0xd7, 0x7f, 0xec, 0x2d, 0x06, 0x00, 0x00,
}
// Reference imports to suppress errors if they are not otherwise used.
......@@ -160,14 +161,14 @@ type MilvusServiceClient interface {
// @param IndexParam, target index.
//
// @return IndexParam
DescribeIndex(ctx context.Context, in *IndexParam, opts ...grpc.CallOption) (*DescribeIndexResponse, error)
DescribeIndex(ctx context.Context, in *DescribeIndexRequest, opts ...grpc.CallOption) (*DescribeIndexResponse, error)
//*
// @brief This method is used to query index building progress
//
// @param IndexParam, target index.
//
// @return IndexParam
DescribeIndexProgress(ctx context.Context, in *IndexParam, opts ...grpc.CallOption) (*BoolResponse, error)
DescribeIndexProgress(ctx context.Context, in *DescribeIndexProgressRequest, opts ...grpc.CallOption) (*BoolResponse, error)
}
type milvusServiceClient struct {
......@@ -295,7 +296,7 @@ func (c *milvusServiceClient) CreateIndex(ctx context.Context, in *IndexParam, o
return out, nil
}
func (c *milvusServiceClient) DescribeIndex(ctx context.Context, in *IndexParam, opts ...grpc.CallOption) (*DescribeIndexResponse, error) {
func (c *milvusServiceClient) DescribeIndex(ctx context.Context, in *DescribeIndexRequest, opts ...grpc.CallOption) (*DescribeIndexResponse, error) {
out := new(DescribeIndexResponse)
err := c.cc.Invoke(ctx, "/milvus.proto.service.MilvusService/DescribeIndex", in, out, opts...)
if err != nil {
......@@ -304,7 +305,7 @@ func (c *milvusServiceClient) DescribeIndex(ctx context.Context, in *IndexParam,
return out, nil
}
func (c *milvusServiceClient) DescribeIndexProgress(ctx context.Context, in *IndexParam, opts ...grpc.CallOption) (*BoolResponse, error) {
func (c *milvusServiceClient) DescribeIndexProgress(ctx context.Context, in *DescribeIndexProgressRequest, opts ...grpc.CallOption) (*BoolResponse, error) {
out := new(BoolResponse)
err := c.cc.Invoke(ctx, "/milvus.proto.service.MilvusService/DescribeIndexProgress", in, out, opts...)
if err != nil {
......@@ -402,14 +403,14 @@ type MilvusServiceServer interface {
// @param IndexParam, target index.
//
// @return IndexParam
DescribeIndex(context.Context, *IndexParam) (*DescribeIndexResponse, error)
DescribeIndex(context.Context, *DescribeIndexRequest) (*DescribeIndexResponse, error)
//*
// @brief This method is used to query index building progress
//
// @param IndexParam, target index.
//
// @return IndexParam
DescribeIndexProgress(context.Context, *IndexParam) (*BoolResponse, error)
DescribeIndexProgress(context.Context, *DescribeIndexProgressRequest) (*BoolResponse, error)
}
// UnimplementedMilvusServiceServer can be embedded to have forward compatible implementations.
......@@ -455,10 +456,10 @@ func (*UnimplementedMilvusServiceServer) Search(ctx context.Context, req *Query)
func (*UnimplementedMilvusServiceServer) CreateIndex(ctx context.Context, req *IndexParam) (*commonpb.Status, error) {
return nil, status.Errorf(codes.Unimplemented, "method CreateIndex not implemented")
}
func (*UnimplementedMilvusServiceServer) DescribeIndex(ctx context.Context, req *IndexParam) (*DescribeIndexResponse, error) {
func (*UnimplementedMilvusServiceServer) DescribeIndex(ctx context.Context, req *DescribeIndexRequest) (*DescribeIndexResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method DescribeIndex not implemented")
}
func (*UnimplementedMilvusServiceServer) DescribeIndexProgress(ctx context.Context, req *IndexParam) (*BoolResponse, error) {
func (*UnimplementedMilvusServiceServer) DescribeIndexProgress(ctx context.Context, req *DescribeIndexProgressRequest) (*BoolResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method DescribeIndexProgress not implemented")
}
......@@ -701,7 +702,7 @@ func _MilvusService_CreateIndex_Handler(srv interface{}, ctx context.Context, de
}
func _MilvusService_DescribeIndex_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(IndexParam)
in := new(DescribeIndexRequest)
if err := dec(in); err != nil {
return nil, err
}
......@@ -713,13 +714,13 @@ func _MilvusService_DescribeIndex_Handler(srv interface{}, ctx context.Context,
FullMethod: "/milvus.proto.service.MilvusService/DescribeIndex",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MilvusServiceServer).DescribeIndex(ctx, req.(*IndexParam))
return srv.(MilvusServiceServer).DescribeIndex(ctx, req.(*DescribeIndexRequest))
}
return interceptor(ctx, in, info, handler)
}
func _MilvusService_DescribeIndexProgress_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(IndexParam)
in := new(DescribeIndexProgressRequest)
if err := dec(in); err != nil {
return nil, err
}
......@@ -731,7 +732,7 @@ func _MilvusService_DescribeIndexProgress_Handler(srv interface{}, ctx context.C
FullMethod: "/milvus.proto.service.MilvusService/DescribeIndexProgress",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MilvusServiceServer).DescribeIndexProgress(ctx, req.(*IndexParam))
return srv.(MilvusServiceServer).DescribeIndexProgress(ctx, req.(*DescribeIndexProgressRequest))
}
return interceptor(ctx, in, info, handler)
}
......
......@@ -969,12 +969,105 @@ func (m *IndexParam) GetExtraParams() []*commonpb.KeyValuePair {
return nil
}
type DescribeIndexRequest struct {
CollectionName string `protobuf:"bytes,1,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
FieldName string `protobuf:"bytes,2,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *DescribeIndexRequest) Reset() { *m = DescribeIndexRequest{} }
func (m *DescribeIndexRequest) String() string { return proto.CompactTextString(m) }
func (*DescribeIndexRequest) ProtoMessage() {}
func (*DescribeIndexRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_b4b40b84dd2f74cb, []int{17}
}
func (m *DescribeIndexRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DescribeIndexRequest.Unmarshal(m, b)
}
func (m *DescribeIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DescribeIndexRequest.Marshal(b, m, deterministic)
}
func (m *DescribeIndexRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_DescribeIndexRequest.Merge(m, src)
}
func (m *DescribeIndexRequest) XXX_Size() int {
return xxx_messageInfo_DescribeIndexRequest.Size(m)
}
func (m *DescribeIndexRequest) XXX_DiscardUnknown() {
xxx_messageInfo_DescribeIndexRequest.DiscardUnknown(m)
}
var xxx_messageInfo_DescribeIndexRequest proto.InternalMessageInfo
func (m *DescribeIndexRequest) GetCollectionName() string {
if m != nil {
return m.CollectionName
}
return ""
}
func (m *DescribeIndexRequest) GetFieldName() string {
if m != nil {
return m.FieldName
}
return ""
}
type DescribeIndexProgressRequest struct {
CollectionName string `protobuf:"bytes,1,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
FieldName string `protobuf:"bytes,2,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *DescribeIndexProgressRequest) Reset() { *m = DescribeIndexProgressRequest{} }
func (m *DescribeIndexProgressRequest) String() string { return proto.CompactTextString(m) }
func (*DescribeIndexProgressRequest) ProtoMessage() {}
func (*DescribeIndexProgressRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_b4b40b84dd2f74cb, []int{18}
}
func (m *DescribeIndexProgressRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DescribeIndexProgressRequest.Unmarshal(m, b)
}
func (m *DescribeIndexProgressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DescribeIndexProgressRequest.Marshal(b, m, deterministic)
}
func (m *DescribeIndexProgressRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_DescribeIndexProgressRequest.Merge(m, src)
}
func (m *DescribeIndexProgressRequest) XXX_Size() int {
return xxx_messageInfo_DescribeIndexProgressRequest.Size(m)
}
func (m *DescribeIndexProgressRequest) XXX_DiscardUnknown() {
xxx_messageInfo_DescribeIndexProgressRequest.DiscardUnknown(m)
}
var xxx_messageInfo_DescribeIndexProgressRequest proto.InternalMessageInfo
func (m *DescribeIndexProgressRequest) GetCollectionName() string {
if m != nil {
return m.CollectionName
}
return ""
}
func (m *DescribeIndexProgressRequest) GetFieldName() string {
if m != nil {
return m.FieldName
}
return ""
}
type DescribeIndexResponse struct {
Status *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
CollectionName string `protobuf:"bytes,2,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
FieldName string `protobuf:"bytes,3,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
IndexName string `protobuf:"bytes,4,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
ExtraParams []*commonpb.KeyValuePair `protobuf:"bytes,5,rep,name=extra_params,json=extraParams,proto3" json:"extra_params,omitempty"`
ExtraParams []*commonpb.KeyValuePair `protobuf:"bytes,4,rep,name=extra_params,json=extraParams,proto3" json:"extra_params,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
......@@ -984,7 +1077,7 @@ func (m *DescribeIndexResponse) Reset() { *m = DescribeIndexResponse{} }
func (m *DescribeIndexResponse) String() string { return proto.CompactTextString(m) }
func (*DescribeIndexResponse) ProtoMessage() {}
func (*DescribeIndexResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_b4b40b84dd2f74cb, []int{17}
return fileDescriptor_b4b40b84dd2f74cb, []int{19}
}
func (m *DescribeIndexResponse) XXX_Unmarshal(b []byte) error {
......@@ -1026,13 +1119,6 @@ func (m *DescribeIndexResponse) GetFieldName() string {
return ""
}
func (m *DescribeIndexResponse) GetIndexName() string {
if m != nil {
return m.IndexName
}
return ""
}
func (m *DescribeIndexResponse) GetExtraParams() []*commonpb.KeyValuePair {
if m != nil {
return m.ExtraParams
......@@ -1059,65 +1145,68 @@ func init() {
proto.RegisterType((*Hits)(nil), "milvus.proto.service.Hits")
proto.RegisterType((*QueryResult)(nil), "milvus.proto.service.QueryResult")
proto.RegisterType((*IndexParam)(nil), "milvus.proto.service.IndexParam")
proto.RegisterType((*DescribeIndexRequest)(nil), "milvus.proto.service.DescribeIndexRequest")
proto.RegisterType((*DescribeIndexProgressRequest)(nil), "milvus.proto.service.DescribeIndexProgressRequest")
proto.RegisterType((*DescribeIndexResponse)(nil), "milvus.proto.service.DescribeIndexResponse")
}
func init() { proto.RegisterFile("service_msg.proto", fileDescriptor_b4b40b84dd2f74cb) }
var fileDescriptor_b4b40b84dd2f74cb = []byte{
// 854 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x55, 0xdd, 0x6e, 0xdb, 0x36,
0x14, 0x9e, 0x2c, 0x27, 0xb3, 0x8f, 0x65, 0xd7, 0xe1, 0xd2, 0xc2, 0x6d, 0x51, 0xc0, 0x53, 0xd1,
0xcd, 0xd8, 0x30, 0x1b, 0x48, 0x07, 0x0c, 0xbd, 0x18, 0xb0, 0x38, 0xe9, 0xb6, 0x34, 0x45, 0x92,
0x31, 0x41, 0x80, 0x6e, 0xc0, 0x04, 0x5a, 0x62, 0x25, 0x62, 0x92, 0x28, 0x90, 0x54, 0x52, 0xf7,
0x41, 0x76, 0xb1, 0x57, 0xd8, 0x83, 0xec, 0x6e, 0xef, 0xb3, 0xbb, 0x41, 0xa4, 0x22, 0xdb, 0x99,
0x87, 0x3a, 0x71, 0xee, 0xc8, 0x43, 0x9d, 0xf3, 0x9d, 0xef, 0xfc, 0x7c, 0x82, 0x2d, 0x49, 0xc5,
0x05, 0xf3, 0xa9, 0x97, 0xc8, 0x70, 0x98, 0x09, 0xae, 0x38, 0xda, 0x4e, 0x58, 0x7c, 0x91, 0x4b,
0x73, 0x1b, 0x96, 0xef, 0x8f, 0x1c, 0x9f, 0x27, 0x09, 0x4f, 0x8d, 0xf5, 0x91, 0x23, 0xfd, 0x88,
0x26, 0xc4, 0xdc, 0xdc, 0x17, 0xd0, 0xd9, 0xe3, 0x71, 0x4c, 0x7d, 0xc5, 0x78, 0x7a, 0x44, 0x12,
0x8a, 0x3e, 0x87, 0x7b, 0x7e, 0x65, 0xf1, 0x52, 0x92, 0xd0, 0x9e, 0xd5, 0xb7, 0x06, 0x4d, 0xdc,
0xf1, 0x17, 0x3e, 0x74, 0x5f, 0x41, 0xfb, 0x84, 0x08, 0xc5, 0x6e, 0xec, 0x89, 0xba, 0x60, 0x2b,
0x12, 0xf6, 0x6a, 0xfa, 0xb1, 0x38, 0xba, 0x7f, 0x5a, 0xd0, 0xc0, 0xfc, 0x72, 0x4c, 0x94, 0x1f,
0xad, 0x1e, 0xe7, 0x29, 0xb4, 0xb3, 0xab, 0x0c, 0xbc, 0x59, 0x44, 0xa7, 0x32, 0x9e, 0x91, 0x10,
0x7d, 0x0d, 0x0d, 0xc1, 0x2f, 0xbd, 0x80, 0x28, 0xd2, 0xb3, 0xfb, 0xf6, 0xa0, 0xb5, 0xf3, 0x70,
0xb8, 0x50, 0xa6, 0xb2, 0x3a, 0xe3, 0x98, 0x4f, 0xf0, 0xc7, 0x82, 0x5f, 0xee, 0x13, 0x45, 0xd0,
0x63, 0x68, 0x46, 0x44, 0x46, 0xde, 0x6f, 0x74, 0x2a, 0x7b, 0xf5, 0xbe, 0x3d, 0x68, 0xe3, 0x46,
0x61, 0x38, 0xa4, 0x53, 0xe9, 0x5e, 0x42, 0xf7, 0x24, 0x26, 0x3e, 0x8d, 0x78, 0x1c, 0x50, 0x71,
0x4e, 0xe2, 0xbc, 0xe2, 0x64, 0x55, 0x9c, 0xd0, 0x0b, 0xa8, 0xab, 0x69, 0x46, 0x75, 0x52, 0x9d,
0x9d, 0x67, 0xc3, 0x65, 0xbd, 0x19, 0xce, 0xc5, 0x39, 0x9b, 0x66, 0x14, 0x6b, 0x17, 0xf4, 0x00,
0x36, 0x2f, 0x8a, 0xa8, 0x52, 0x67, 0xec, 0xe0, 0xf2, 0xe6, 0xfe, 0xba, 0x00, 0xfc, 0x83, 0xe0,
0x79, 0x86, 0x5e, 0x81, 0x93, 0xcd, 0x6c, 0xb2, 0x67, 0x69, 0x8e, 0x9f, 0x7d, 0x10, 0x4e, 0xa7,
0x8d, 0x17, 0x7c, 0xdd, 0xdf, 0x2d, 0xd8, 0xf8, 0x29, 0xa7, 0x62, 0xba, 0x7a, 0x0f, 0x9e, 0x41,
0x67, 0xa1, 0x07, 0xb2, 0x57, 0xeb, 0xdb, 0x83, 0x26, 0x6e, 0xcf, 0x37, 0x41, 0x16, 0xe5, 0x09,
0x64, 0xdc, 0xb3, 0x4d, 0x79, 0x02, 0x19, 0xa3, 0x2f, 0x61, 0x6b, 0x0e, 0xdb, 0x0b, 0x0b, 0x32,
0xbd, 0x7a, 0xdf, 0x1a, 0x38, 0xb8, 0x9b, 0x5d, 0x23, 0xe9, 0xfe, 0x02, 0x9d, 0x53, 0x25, 0x58,
0x1a, 0x62, 0x2a, 0x33, 0x9e, 0x4a, 0x8a, 0x9e, 0xc3, 0xa6, 0x54, 0x44, 0xe5, 0x52, 0xe7, 0xd5,
0xda, 0x79, 0xbc, 0xb4, 0xa9, 0xa7, 0xfa, 0x13, 0x5c, 0x7e, 0x8a, 0xb6, 0x61, 0x43, 0x57, 0xb2,
0x1c, 0x14, 0x73, 0x71, 0xdf, 0x80, 0x33, 0xe6, 0x3c, 0xbe, 0xc3, 0xd0, 0x8d, 0xab, 0xd0, 0x04,
0x90, 0xc9, 0xfb, 0x35, 0x93, 0x6a, 0x3d, 0x80, 0xd9, 0x4c, 0x98, 0x02, 0x5f, 0xcd, 0xc4, 0x04,
0x3e, 0x39, 0x48, 0x15, 0x0d, 0xa9, 0xb8, 0x6b, 0x0c, 0xbb, 0xc2, 0x90, 0xb0, 0x5d, 0x62, 0x60,
0x92, 0x86, 0x74, 0xed, 0x4a, 0x4d, 0x68, 0xc8, 0x52, 0x5d, 0x29, 0x1b, 0x9b, 0x4b, 0x31, 0x20,
0x34, 0x0d, 0xf4, 0x80, 0xd8, 0xb8, 0x38, 0xba, 0x7f, 0x5b, 0x70, 0x7f, 0xa6, 0x4d, 0xfb, 0x54,
0xfa, 0x82, 0x65, 0xc5, 0xf1, 0x76, 0xb0, 0xdf, 0xc2, 0xa6, 0x51, 0x3e, 0x8d, 0xdb, 0xfa, 0xcf,
0x42, 0x1a, 0x55, 0x9c, 0x01, 0x9e, 0x6a, 0x03, 0x2e, 0x9d, 0xd0, 0x2e, 0x40, 0x11, 0x88, 0x49,
0xc5, 0x7c, 0x59, 0x0a, 0xc9, 0xa7, 0x4b, 0x71, 0x0f, 0xe9, 0x54, 0xef, 0xd6, 0x09, 0x61, 0x02,
0xcf, 0x39, 0xb9, 0x7f, 0x59, 0xb0, 0x5d, 0x29, 0xe6, 0xda, 0x7c, 0xbe, 0x81, 0xba, 0x5e, 0x4b,
0xc3, 0xe6, 0xe9, 0xff, 0xec, 0xfb, 0xbc, 0x40, 0x63, 0xed, 0x70, 0x17, 0x4c, 0x14, 0x6c, 0x9d,
0x4e, 0xe5, 0x1e, 0x4f, 0xdf, 0xb2, 0x35, 0x37, 0x12, 0x41, 0x5d, 0x4b, 0xac, 0x99, 0x69, 0x7d,
0xbe, 0xa6, 0x7e, 0xb3, 0x49, 0x3f, 0x84, 0xfa, 0x8f, 0x4c, 0x69, 0x2d, 0x39, 0xd8, 0x37, 0x42,
0x67, 0xe3, 0xe2, 0x88, 0x1e, 0xce, 0x69, 0x7c, 0x4d, 0x2b, 0x66, 0x25, 0xe4, 0x0f, 0x8a, 0xb6,
0x73, 0x51, 0x06, 0xab, 0xe1, 0xf2, 0xe6, 0x9e, 0x43, 0x4b, 0x2b, 0x1d, 0xa6, 0x32, 0x8f, 0xd5,
0xad, 0x93, 0x8f, 0x98, 0x92, 0x25, 0xa4, 0x3e, 0xbb, 0x7f, 0x58, 0x00, 0x07, 0x69, 0x40, 0xdf,
0x9d, 0x10, 0x41, 0x92, 0xd5, 0x75, 0xf4, 0x09, 0xc0, 0x5b, 0x46, 0xe3, 0xc0, 0xab, 0x9a, 0xda,
0xc4, 0x4d, 0x6d, 0xd1, 0xcf, 0xfb, 0xe0, 0xd0, 0x77, 0x4a, 0x10, 0x2f, 0x2b, 0xc2, 0xde, 0xa0,
0x6d, 0x2d, 0xed, 0xa6, 0x93, 0x91, 0xee, 0x3f, 0x16, 0xdc, 0x37, 0x83, 0x37, 0xa1, 0x3a, 0xc9,
0xf5, 0x9a, 0xb7, 0x84, 0x5c, 0x6d, 0x05, 0x72, 0xf6, 0x75, 0x72, 0x4f, 0x00, 0x58, 0x91, 0x8d,
0x79, 0xae, 0x9b, 0x67, 0x6d, 0x59, 0xca, 0x7d, 0xe3, 0x36, 0xdc, 0xbf, 0xf8, 0x0e, 0xee, 0x5d,
0xfb, 0xd9, 0xa2, 0x06, 0xd4, 0x8f, 0x8e, 0x8f, 0x5e, 0x76, 0x3f, 0x42, 0x5b, 0xd0, 0x3e, 0x7f,
0xb9, 0x77, 0x76, 0x8c, 0xbd, 0xf1, 0xc1, 0xd1, 0x2e, 0x7e, 0xd3, 0x0d, 0x50, 0x17, 0x9c, 0xd2,
0xf4, 0xfd, 0xeb, 0xe3, 0xdd, 0xb3, 0x2e, 0x1d, 0xef, 0xfd, 0xbc, 0x1b, 0x32, 0x15, 0xe5, 0x93,
0x02, 0x6c, 0xf4, 0x9e, 0xc5, 0x31, 0x7b, 0xaf, 0xa8, 0x1f, 0x8d, 0x4c, 0x22, 0x5f, 0x05, 0x4c,
0x2a, 0xc1, 0x26, 0xb9, 0xa2, 0xc1, 0x88, 0xa5, 0x8a, 0x8a, 0x94, 0xc4, 0x23, 0x9d, 0xdd, 0xa8,
0xdc, 0xc7, 0x6c, 0x32, 0xd9, 0xd4, 0x86, 0xe7, 0xff, 0x06, 0x00, 0x00, 0xff, 0xff, 0x2b, 0x24,
0x3d, 0xc8, 0xbe, 0x09, 0x00, 0x00,
// 868 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x56, 0xdd, 0x6e, 0x1b, 0x45,
0x14, 0x66, 0xbd, 0x6e, 0xb0, 0x8f, 0xd7, 0xae, 0x33, 0xb8, 0x95, 0xdb, 0x82, 0x64, 0xb6, 0x2a,
0x58, 0x20, 0x6c, 0x29, 0x45, 0x42, 0xbd, 0x40, 0x22, 0x4e, 0x0a, 0xa4, 0xa9, 0x12, 0x33, 0x89,
0x22, 0x15, 0x24, 0x56, 0xe3, 0xdd, 0x93, 0xf5, 0x88, 0xf5, 0xce, 0x32, 0x33, 0x9b, 0xd4, 0x7d,
0x10, 0x2e, 0x78, 0x05, 0x1e, 0x84, 0x3b, 0x1e, 0x80, 0xa7, 0x41, 0x3b, 0xbb, 0xf1, 0x4f, 0x48,
0x55, 0x37, 0xf6, 0xdd, 0x9c, 0xb3, 0x73, 0xce, 0xf7, 0x9d, 0x9f, 0xf9, 0x6c, 0xd8, 0x56, 0x28,
0x2f, 0xb8, 0x8f, 0xde, 0x44, 0x85, 0xbd, 0x44, 0x0a, 0x2d, 0x48, 0x6b, 0xc2, 0xa3, 0x8b, 0x54,
0xe5, 0x56, 0xaf, 0xf8, 0xfe, 0xd0, 0xf1, 0xc5, 0x64, 0x22, 0xe2, 0xdc, 0xfb, 0xd0, 0x51, 0xfe,
0x18, 0x27, 0x2c, 0xb7, 0xdc, 0x67, 0xd0, 0xd8, 0x13, 0x51, 0x84, 0xbe, 0xe6, 0x22, 0x3e, 0x62,
0x13, 0x24, 0x9f, 0xc3, 0x5d, 0x7f, 0xe6, 0xf1, 0x62, 0x36, 0xc1, 0xb6, 0xd5, 0xb1, 0xba, 0x55,
0xda, 0xf0, 0x97, 0x2e, 0xba, 0x2f, 0xa0, 0x3e, 0x64, 0x52, 0xf3, 0xf7, 0x8e, 0x24, 0x4d, 0xb0,
0x35, 0x0b, 0xdb, 0x25, 0xf3, 0x31, 0x3b, 0xba, 0x7f, 0x59, 0x50, 0xa1, 0xe2, 0x72, 0xc0, 0xb4,
0x3f, 0x5e, 0x3d, 0xcf, 0x63, 0xa8, 0x27, 0x57, 0x0c, 0xbc, 0x79, 0x46, 0x67, 0xe6, 0x3c, 0x65,
0x21, 0xf9, 0x1a, 0x2a, 0x52, 0x5c, 0x7a, 0x01, 0xd3, 0xac, 0x6d, 0x77, 0xec, 0x6e, 0x6d, 0xe7,
0x41, 0x6f, 0xa9, 0x4d, 0x45, 0x77, 0x06, 0x91, 0x18, 0xd1, 0x0f, 0xa5, 0xb8, 0xdc, 0x67, 0x9a,
0x91, 0x47, 0x50, 0x1d, 0x33, 0x35, 0xf6, 0x7e, 0xc3, 0xa9, 0x6a, 0x97, 0x3b, 0x76, 0xb7, 0x4e,
0x2b, 0x99, 0xe3, 0x10, 0xa7, 0xca, 0xbd, 0x84, 0xe6, 0x30, 0x62, 0x3e, 0x8e, 0x45, 0x14, 0xa0,
0x3c, 0x63, 0x51, 0x3a, 0xab, 0xc9, 0x9a, 0xd5, 0x44, 0x9e, 0x41, 0x59, 0x4f, 0x13, 0x34, 0xa4,
0x1a, 0x3b, 0x4f, 0x7a, 0x37, 0xcd, 0xa6, 0xb7, 0x90, 0xe7, 0x74, 0x9a, 0x20, 0x35, 0x21, 0xe4,
0x3e, 0x6c, 0x5d, 0x64, 0x59, 0x95, 0x61, 0xec, 0xd0, 0xc2, 0x72, 0x7f, 0x5d, 0x02, 0xfe, 0x41,
0x8a, 0x34, 0x21, 0x2f, 0xc0, 0x49, 0xe6, 0x3e, 0xd5, 0xb6, 0x4c, 0x8d, 0x9f, 0xbd, 0x13, 0xce,
0xd0, 0xa6, 0x4b, 0xb1, 0xee, 0x1f, 0x16, 0xdc, 0xf9, 0x29, 0x45, 0x39, 0x5d, 0x7d, 0x06, 0x4f,
0xa0, 0xb1, 0x34, 0x03, 0xd5, 0x2e, 0x75, 0xec, 0x6e, 0x95, 0xd6, 0x17, 0x87, 0xa0, 0xb2, 0xf6,
0x04, 0x2a, 0x6a, 0xdb, 0x79, 0x7b, 0x02, 0x15, 0x91, 0x2f, 0x61, 0x7b, 0x01, 0xdb, 0x0b, 0xb3,
0x62, 0xda, 0xe5, 0x8e, 0xd5, 0x75, 0x68, 0x33, 0xb9, 0x56, 0xa4, 0xfb, 0x0b, 0x34, 0x4e, 0xb4,
0xe4, 0x71, 0x48, 0x51, 0x25, 0x22, 0x56, 0x48, 0x9e, 0xc2, 0x96, 0xd2, 0x4c, 0xa7, 0xca, 0xf0,
0xaa, 0xed, 0x3c, 0xba, 0x71, 0xa8, 0x27, 0xe6, 0x0a, 0x2d, 0xae, 0x92, 0x16, 0xdc, 0x31, 0x9d,
0x2c, 0x16, 0x25, 0x37, 0xdc, 0x57, 0xe0, 0x0c, 0x84, 0x88, 0x36, 0x98, 0xba, 0x72, 0x95, 0x9a,
0x01, 0xc9, 0x79, 0xbf, 0xe4, 0x4a, 0xaf, 0x07, 0x30, 0xdf, 0x89, 0xbc, 0xc1, 0x57, 0x3b, 0x31,
0x82, 0x8f, 0x0e, 0x62, 0x8d, 0x21, 0xca, 0x4d, 0x63, 0xd8, 0x33, 0x0c, 0x05, 0xad, 0x02, 0x83,
0xb2, 0x38, 0xc4, 0xb5, 0x3b, 0x35, 0xc2, 0x90, 0xc7, 0xa6, 0x53, 0x36, 0xcd, 0x8d, 0x6c, 0x41,
0x30, 0x0e, 0xcc, 0x82, 0xd8, 0x34, 0x3b, 0xba, 0xff, 0x58, 0x70, 0x6f, 0xae, 0x4d, 0xfb, 0xa8,
0x7c, 0xc9, 0x93, 0xec, 0x78, 0x3b, 0xd8, 0x6f, 0x61, 0x2b, 0x57, 0x3e, 0x83, 0x5b, 0xfb, 0xdf,
0x83, 0xcc, 0x55, 0x71, 0x0e, 0x78, 0x62, 0x1c, 0xb4, 0x08, 0x22, 0xbb, 0x00, 0x59, 0x22, 0xae,
0x34, 0xf7, 0x55, 0x21, 0x24, 0x9f, 0xde, 0x88, 0x7b, 0x88, 0x53, 0xf3, 0xb6, 0x86, 0x8c, 0x4b,
0xba, 0x10, 0xe4, 0xfe, 0x6d, 0x41, 0x6b, 0xa6, 0x98, 0x6b, 0xd7, 0xf3, 0x0d, 0x94, 0xcd, 0xb3,
0xcc, 0xab, 0x79, 0xfc, 0x96, 0xf7, 0xbe, 0x28, 0xd0, 0xd4, 0x04, 0x6c, 0xa2, 0x12, 0x0d, 0xdb,
0x27, 0x53, 0xb5, 0x27, 0xe2, 0x73, 0xbe, 0xe6, 0x8b, 0x24, 0x50, 0x36, 0x12, 0x9b, 0xef, 0xb4,
0x39, 0x5f, 0x53, 0xbf, 0xf9, 0xa6, 0x1f, 0x42, 0xf9, 0x47, 0xae, 0x8d, 0x96, 0x1c, 0xec, 0xe7,
0x42, 0x67, 0xd3, 0xec, 0x48, 0x1e, 0x2c, 0x68, 0x7c, 0xc9, 0x28, 0xe6, 0x4c, 0xc8, 0xef, 0x67,
0x63, 0x17, 0xb2, 0x48, 0x56, 0xa2, 0x85, 0xe5, 0x9e, 0x41, 0xcd, 0x28, 0x1d, 0x45, 0x95, 0x46,
0xfa, 0xd6, 0xe4, 0xc7, 0x5c, 0xab, 0x02, 0xd2, 0x9c, 0xdd, 0x3f, 0x2d, 0x80, 0x83, 0x38, 0xc0,
0xd7, 0x43, 0x26, 0xd9, 0x64, 0x75, 0x1d, 0xfd, 0x04, 0xe0, 0x9c, 0x63, 0x14, 0x78, 0xb3, 0xa1,
0x56, 0x69, 0xd5, 0x78, 0xcc, 0xe7, 0x7d, 0x70, 0xf0, 0xb5, 0x96, 0xcc, 0x4b, 0xb2, 0xb4, 0xef,
0x31, 0xb6, 0x9a, 0x09, 0x33, 0x64, 0xb2, 0xdf, 0x8f, 0x56, 0xbe, 0x77, 0x23, 0x34, 0x1c, 0x29,
0xfe, 0x9e, 0xa2, 0xd2, 0x9b, 0x62, 0xe9, 0x9e, 0xc3, 0xc7, 0x4b, 0xf9, 0x87, 0x52, 0x84, 0x12,
0x95, 0xda, 0x34, 0xce, 0xbf, 0x16, 0xdc, 0xbb, 0x56, 0xc8, 0x3a, 0x4b, 0x78, 0x03, 0xad, 0xd2,
0x0a, 0xb4, 0xec, 0x77, 0x0d, 0xa9, 0x7c, 0x9b, 0x21, 0x7d, 0xf1, 0x1d, 0xdc, 0xbd, 0xf6, 0xaf,
0x80, 0x54, 0xa0, 0x7c, 0x74, 0x7c, 0xf4, 0xbc, 0xf9, 0x01, 0xd9, 0x86, 0xfa, 0xd9, 0xf3, 0xbd,
0xd3, 0x63, 0xea, 0x0d, 0x0e, 0x8e, 0x76, 0xe9, 0xab, 0x66, 0x40, 0x9a, 0xe0, 0x14, 0xae, 0xef,
0x5f, 0x1e, 0xef, 0x9e, 0x36, 0x71, 0xb0, 0xf7, 0xf3, 0x6e, 0xc8, 0xf5, 0x38, 0x1d, 0x65, 0x60,
0xfd, 0x37, 0x3c, 0x8a, 0xf8, 0x1b, 0x8d, 0xfe, 0xb8, 0x9f, 0x13, 0xf9, 0x2a, 0xe0, 0x4a, 0x4b,
0x3e, 0x4a, 0x35, 0x06, 0x7d, 0x1e, 0x6b, 0x94, 0x31, 0x8b, 0xfa, 0x86, 0x5d, 0xbf, 0x10, 0x8e,
0x64, 0x34, 0xda, 0x32, 0x8e, 0xa7, 0xff, 0x05, 0x00, 0x00, 0xff, 0xff, 0xb6, 0x3b, 0x6a, 0xb9,
0x67, 0x0a, 0x00, 0x00,
}
......@@ -595,6 +595,7 @@ func (p *Proxy) ShowPartitions(ctx context.Context, req *servicepb.CollectionNam
}
func (p *Proxy) CreateIndex(ctx context.Context, indexParam *servicepb.IndexParam) (*commonpb.Status, error) {
log.Println("create index for: ", indexParam.FieldName)
cit := &CreateIndexTask{
Condition: NewTaskCondition(ctx),
CreateIndexRequest: internalpb.CreateIndexRequest{
......@@ -637,10 +638,104 @@ func (p *Proxy) CreateIndex(ctx context.Context, indexParam *servicepb.IndexPara
return cit.result, nil
}
func (p *Proxy) DescribeIndex(context.Context, *servicepb.IndexParam) (*servicepb.DescribeIndexResponse, error) {
return nil, nil
func (p *Proxy) DescribeIndex(ctx context.Context, req *servicepb.DescribeIndexRequest) (*servicepb.DescribeIndexResponse, error) {
log.Println("Describe index for: ", req.FieldName)
dit := &DescribeIndexTask{
Condition: NewTaskCondition(ctx),
DescribeIndexRequest: internalpb.DescribeIndexRequest{
MsgType: internalpb.MsgType_kDescribeIndex,
CollectionName: req.CollectionName,
FieldName: req.FieldName,
},
masterClient: p.masterClient,
}
var cancel func()
dit.ctx, cancel = context.WithTimeout(ctx, reqTimeoutInterval)
defer cancel()
fn := func() error {
select {
case <-ctx.Done():
return errors.New("create index timeout")
default:
return p.sched.DdQueue.Enqueue(dit)
}
}
err := fn()
if err != nil {
return &servicepb.DescribeIndexResponse{
Status: &commonpb.Status{
ErrorCode: commonpb.ErrorCode_UNEXPECTED_ERROR,
Reason: err.Error(),
},
CollectionName: req.CollectionName,
FieldName: req.FieldName,
ExtraParams: nil,
}, nil
}
err = dit.WaitToFinish()
if err != nil {
return &servicepb.DescribeIndexResponse{
Status: &commonpb.Status{
ErrorCode: commonpb.ErrorCode_UNEXPECTED_ERROR,
Reason: err.Error(),
},
CollectionName: req.CollectionName,
FieldName: req.FieldName,
ExtraParams: nil,
}, nil
}
return dit.result, nil
}
func (p *Proxy) DescribeIndexProgress(context.Context, *servicepb.IndexParam) (*servicepb.BoolResponse, error) {
return nil, nil
func (p *Proxy) DescribeIndexProgress(ctx context.Context, req *servicepb.DescribeIndexProgressRequest) (*servicepb.BoolResponse, error) {
log.Println("Describe index progress for: ", req.FieldName)
dipt := &DescribeIndexProgressTask{
Condition: NewTaskCondition(ctx),
DescribeIndexProgressRequest: internalpb.DescribeIndexProgressRequest{
MsgType: internalpb.MsgType_kDescribeIndexProgress,
CollectionName: req.CollectionName,
FieldName: req.FieldName,
},
masterClient: p.masterClient,
}
var cancel func()
dipt.ctx, cancel = context.WithTimeout(ctx, reqTimeoutInterval)
defer cancel()
fn := func() error {
select {
case <-ctx.Done():
return errors.New("create index timeout")
default:
return p.sched.DdQueue.Enqueue(dipt)
}
}
err := fn()
if err != nil {
return &servicepb.BoolResponse{
Status: &commonpb.Status{
ErrorCode: commonpb.ErrorCode_UNEXPECTED_ERROR,
Reason: err.Error(),
},
Value: false,
}, nil
}
err = dipt.WaitToFinish()
if err != nil {
return &servicepb.BoolResponse{
Status: &commonpb.Status{
ErrorCode: commonpb.ErrorCode_UNEXPECTED_ERROR,
Reason: err.Error(),
},
Value: false,
}, nil
}
return dipt.result, nil
}
......@@ -180,6 +180,29 @@ func dropCollection(t *testing.T, name string) {
assert.Equal(t, resp.ErrorCode, commonpb.ErrorCode_SUCCESS, msg)
}
func createIndex(t *testing.T, collectionName, fieldName string) {
req := &servicepb.IndexParam{
CollectionName: collectionName,
FieldName: fieldName,
ExtraParams: []*commonpb.KeyValuePair{
{
Key: "nlist",
Value: "1024",
},
{
Key: "metric_type",
Value: "L2",
},
},
}
resp, err := proxyClient.CreateIndex(ctx, req)
assert.Nil(t, err)
msg := "Create Index for " + fieldName + " should succeed!"
assert.Equal(t, resp.ErrorCode, commonpb.ErrorCode_SUCCESS, msg)
}
func TestProxy_CreateCollection(t *testing.T) {
var wg sync.WaitGroup
for i := 0; i < testNum; i++ {
......@@ -451,6 +474,22 @@ func TestProxy_PartitionGRPC(t *testing.T) {
dropCollection(t, collName)
}
// func TestProxy_CreateIndex(t *testing.T) {
// var wg sync.WaitGroup
// for i := 0; i < testNum; i++ {
// i := i
// collectionName := "Collection" + strconv.FormatInt(int64(i), 10)
// fieldName := "Field" + strconv.FormatInt(int64(i), 10)
// wg.Add(1)
// go func(group *sync.WaitGroup) {
// defer group.Done()
// createIndex(t, collectionName, fieldName)
// // dropIndex(t, collectionName, fieldName, indexName)
// }(&wg)
// }
// wg.Wait()
// }
func TestMain(m *testing.M) {
setup()
code := m.Run()
......
......@@ -7,10 +7,7 @@ import (
"math"
"strconv"
"github.com/zilliztech/milvus-distributed/internal/util/typeutil"
"github.com/golang/protobuf/proto"
"github.com/zilliztech/milvus-distributed/internal/allocator"
"github.com/zilliztech/milvus-distributed/internal/msgstream"
"github.com/zilliztech/milvus-distributed/internal/proto/commonpb"
......@@ -18,6 +15,7 @@ import (
"github.com/zilliztech/milvus-distributed/internal/proto/masterpb"
"github.com/zilliztech/milvus-distributed/internal/proto/schemapb"
"github.com/zilliztech/milvus-distributed/internal/proto/servicepb"
"github.com/zilliztech/milvus-distributed/internal/util/typeutil"
)
type task interface {
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment