milvus.pb.go

// Code generated by protoc-gen-go. DO NOT EDIT.
// source: milvus.proto

package milvuspb

import (
	context "context"
	fmt "fmt"
	proto "github.com/golang/protobuf/proto"
	commonpb "github.com/zilliztech/milvus-distributed/internal/proto/commonpb"
	schemapb "github.com/zilliztech/milvus-distributed/internal/proto/schemapb"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
	math "math"
)

// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf

// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package

type PlaceholderType int32

const (
	PlaceholderType_NONE          PlaceholderType = 0
	PlaceholderType_VECTOR_BINARY PlaceholderType = 100
	PlaceholderType_VECTOR_FLOAT  PlaceholderType = 101
)

var PlaceholderType_name = map[int32]string{
	0:   "NONE",
	100: "VECTOR_BINARY",
	101: "VECTOR_FLOAT",
}

var PlaceholderType_value = map[string]int32{
	"NONE":          0,
	"VECTOR_BINARY": 100,
	"VECTOR_FLOAT":  101,
}

func (x PlaceholderType) String() string {
	return proto.EnumName(PlaceholderType_name, int32(x))
}

func (PlaceholderType) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{0}
}

type CreateCollectionRequest struct {
	Base           *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName         string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName string            `protobuf:"bytes,3,opt,name=collectionName,proto3" json:"collectionName,omitempty"`
	// `schema` is the serialized `schema.CollectionSchema`
	Schema               []byte   `protobuf:"bytes,4,opt,name=schema,proto3" json:"schema,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *CreateCollectionRequest) Reset()         { *m = CreateCollectionRequest{} }
func (m *CreateCollectionRequest) String() string { return proto.CompactTextString(m) }
func (*CreateCollectionRequest) ProtoMessage()    {}
func (*CreateCollectionRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{0}
}

func (m *CreateCollectionRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreateCollectionRequest.Unmarshal(m, b)
}
func (m *CreateCollectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreateCollectionRequest.Marshal(b, m, deterministic)
}
func (m *CreateCollectionRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreateCollectionRequest.Merge(m, src)
}
func (m *CreateCollectionRequest) XXX_Size() int {
	return xxx_messageInfo_CreateCollectionRequest.Size(m)
}
func (m *CreateCollectionRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_CreateCollectionRequest.DiscardUnknown(m)
}

var xxx_messageInfo_CreateCollectionRequest proto.InternalMessageInfo

func (m *CreateCollectionRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *CreateCollectionRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

func (m *CreateCollectionRequest) GetCollectionName() string {
	if m != nil {
		return m.CollectionName
	}
	return ""
}

func (m *CreateCollectionRequest) GetSchema() []byte {
	if m != nil {
		return m.Schema
	}
	return nil
}

type DropCollectionRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string            `protobuf:"bytes,3,opt,name=collectionName,proto3" json:"collectionName,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *DropCollectionRequest) Reset()         { *m = DropCollectionRequest{} }
func (m *DropCollectionRequest) String() string { return proto.CompactTextString(m) }
func (*DropCollectionRequest) ProtoMessage()    {}
func (*DropCollectionRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{1}
}

func (m *DropCollectionRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DropCollectionRequest.Unmarshal(m, b)
}
func (m *DropCollectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DropCollectionRequest.Marshal(b, m, deterministic)
}
func (m *DropCollectionRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DropCollectionRequest.Merge(m, src)
}
func (m *DropCollectionRequest) XXX_Size() int {
	return xxx_messageInfo_DropCollectionRequest.Size(m)
}
func (m *DropCollectionRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_DropCollectionRequest.DiscardUnknown(m)
}

var xxx_messageInfo_DropCollectionRequest proto.InternalMessageInfo

func (m *DropCollectionRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *DropCollectionRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

func (m *DropCollectionRequest) GetCollectionName() string {
	if m != nil {
		return m.CollectionName
	}
	return ""
}

type HasCollectionRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *HasCollectionRequest) Reset()         { *m = HasCollectionRequest{} }
func (m *HasCollectionRequest) String() string { return proto.CompactTextString(m) }
func (*HasCollectionRequest) ProtoMessage()    {}
func (*HasCollectionRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{2}
}

func (m *HasCollectionRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_HasCollectionRequest.Unmarshal(m, b)
}
func (m *HasCollectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_HasCollectionRequest.Marshal(b, m, deterministic)
}
func (m *HasCollectionRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_HasCollectionRequest.Merge(m, src)
}
func (m *HasCollectionRequest) XXX_Size() int {
	return xxx_messageInfo_HasCollectionRequest.Size(m)
}
func (m *HasCollectionRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_HasCollectionRequest.DiscardUnknown(m)
}

var xxx_messageInfo_HasCollectionRequest proto.InternalMessageInfo

func (m *HasCollectionRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *HasCollectionRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

func (m *HasCollectionRequest) GetCollectionName() string {
	if m != nil {
		return m.CollectionName
	}
	return ""
}

type BoolResponse struct {
	Status               *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Value                bool             `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (m *BoolResponse) Reset()         { *m = BoolResponse{} }
func (m *BoolResponse) String() string { return proto.CompactTextString(m) }
func (*BoolResponse) ProtoMessage()    {}
func (*BoolResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{3}
}

func (m *BoolResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_BoolResponse.Unmarshal(m, b)
}
func (m *BoolResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_BoolResponse.Marshal(b, m, deterministic)
}
func (m *BoolResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_BoolResponse.Merge(m, src)
}
func (m *BoolResponse) XXX_Size() int {
	return xxx_messageInfo_BoolResponse.Size(m)
}
func (m *BoolResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_BoolResponse.DiscardUnknown(m)
}

var xxx_messageInfo_BoolResponse proto.InternalMessageInfo

func (m *BoolResponse) GetStatus() *commonpb.Status {
	if m != nil {
		return m.Status
	}
	return nil
}

func (m *BoolResponse) GetValue() bool {
	if m != nil {
		return m.Value
	}
	return false
}

type DescribeCollectionRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *DescribeCollectionRequest) Reset()         { *m = DescribeCollectionRequest{} }
func (m *DescribeCollectionRequest) String() string { return proto.CompactTextString(m) }
func (*DescribeCollectionRequest) ProtoMessage()    {}
func (*DescribeCollectionRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{4}
}

func (m *DescribeCollectionRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DescribeCollectionRequest.Unmarshal(m, b)
}
func (m *DescribeCollectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DescribeCollectionRequest.Marshal(b, m, deterministic)
}
func (m *DescribeCollectionRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DescribeCollectionRequest.Merge(m, src)
}
func (m *DescribeCollectionRequest) XXX_Size() int {
	return xxx_messageInfo_DescribeCollectionRequest.Size(m)
}
func (m *DescribeCollectionRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_DescribeCollectionRequest.DiscardUnknown(m)
}

var xxx_messageInfo_DescribeCollectionRequest proto.InternalMessageInfo

func (m *DescribeCollectionRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *DescribeCollectionRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

func (m *DescribeCollectionRequest) GetCollectionName() string {
	if m != nil {
		return m.CollectionName
	}
	return ""
}

type DescribeCollectionResponse struct {
	Status               *commonpb.Status           `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Schema               *schemapb.CollectionSchema `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (m *DescribeCollectionResponse) Reset()         { *m = DescribeCollectionResponse{} }
func (m *DescribeCollectionResponse) String() string { return proto.CompactTextString(m) }
func (*DescribeCollectionResponse) ProtoMessage()    {}
func (*DescribeCollectionResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{5}
}

func (m *DescribeCollectionResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DescribeCollectionResponse.Unmarshal(m, b)
}
func (m *DescribeCollectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DescribeCollectionResponse.Marshal(b, m, deterministic)
}
func (m *DescribeCollectionResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DescribeCollectionResponse.Merge(m, src)
}
func (m *DescribeCollectionResponse) XXX_Size() int {
	return xxx_messageInfo_DescribeCollectionResponse.Size(m)
}
func (m *DescribeCollectionResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_DescribeCollectionResponse.DiscardUnknown(m)
}

var xxx_messageInfo_DescribeCollectionResponse proto.InternalMessageInfo

func (m *DescribeCollectionResponse) GetStatus() *commonpb.Status {
	if m != nil {
		return m.Status
	}
	return nil
}

func (m *DescribeCollectionResponse) GetSchema() *schemapb.CollectionSchema {
	if m != nil {
		return m.Schema
	}
	return nil
}

type LoadCollectionRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *LoadCollectionRequest) Reset()         { *m = LoadCollectionRequest{} }
func (m *LoadCollectionRequest) String() string { return proto.CompactTextString(m) }
func (*LoadCollectionRequest) ProtoMessage()    {}
func (*LoadCollectionRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{6}
}

func (m *LoadCollectionRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_LoadCollectionRequest.Unmarshal(m, b)
}
func (m *LoadCollectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_LoadCollectionRequest.Marshal(b, m, deterministic)
}
func (m *LoadCollectionRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_LoadCollectionRequest.Merge(m, src)
}
func (m *LoadCollectionRequest) XXX_Size() int {
	return xxx_messageInfo_LoadCollectionRequest.Size(m)
}
func (m *LoadCollectionRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_LoadCollectionRequest.DiscardUnknown(m)
}

var xxx_messageInfo_LoadCollectionRequest proto.InternalMessageInfo

func (m *LoadCollectionRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *LoadCollectionRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

func (m *LoadCollectionRequest) GetCollectionName() string {
	if m != nil {
		return m.CollectionName
	}
	return ""
}

type ReleaseCollectionRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *ReleaseCollectionRequest) Reset()         { *m = ReleaseCollectionRequest{} }
func (m *ReleaseCollectionRequest) String() string { return proto.CompactTextString(m) }
func (*ReleaseCollectionRequest) ProtoMessage()    {}
func (*ReleaseCollectionRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{7}
}

func (m *ReleaseCollectionRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ReleaseCollectionRequest.Unmarshal(m, b)
}
func (m *ReleaseCollectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ReleaseCollectionRequest.Marshal(b, m, deterministic)
}
func (m *ReleaseCollectionRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ReleaseCollectionRequest.Merge(m, src)
}
func (m *ReleaseCollectionRequest) XXX_Size() int {
	return xxx_messageInfo_ReleaseCollectionRequest.Size(m)
}
func (m *ReleaseCollectionRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ReleaseCollectionRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ReleaseCollectionRequest proto.InternalMessageInfo

func (m *ReleaseCollectionRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *ReleaseCollectionRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

func (m *ReleaseCollectionRequest) GetCollectionName() string {
	if m != nil {
		return m.CollectionName
	}
	return ""
}

type CollectionStatsRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *CollectionStatsRequest) Reset()         { *m = CollectionStatsRequest{} }
func (m *CollectionStatsRequest) String() string { return proto.CompactTextString(m) }
func (*CollectionStatsRequest) ProtoMessage()    {}
func (*CollectionStatsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{8}
}

func (m *CollectionStatsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CollectionStatsRequest.Unmarshal(m, b)
}
func (m *CollectionStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CollectionStatsRequest.Marshal(b, m, deterministic)
}
func (m *CollectionStatsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CollectionStatsRequest.Merge(m, src)
}
func (m *CollectionStatsRequest) XXX_Size() int {
	return xxx_messageInfo_CollectionStatsRequest.Size(m)
}
func (m *CollectionStatsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_CollectionStatsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_CollectionStatsRequest proto.InternalMessageInfo

func (m *CollectionStatsRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *CollectionStatsRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

func (m *CollectionStatsRequest) GetCollectionName() string {
	if m != nil {
		return m.CollectionName
	}
	return ""
}

type CollectionStatsResponse struct {
	Stats                []*commonpb.KeyValuePair `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats,omitempty"`
	Status               *commonpb.Status         `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (m *CollectionStatsResponse) Reset()         { *m = CollectionStatsResponse{} }
func (m *CollectionStatsResponse) String() string { return proto.CompactTextString(m) }
func (*CollectionStatsResponse) ProtoMessage()    {}
func (*CollectionStatsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{9}
}

func (m *CollectionStatsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CollectionStatsResponse.Unmarshal(m, b)
}
func (m *CollectionStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CollectionStatsResponse.Marshal(b, m, deterministic)
}
func (m *CollectionStatsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CollectionStatsResponse.Merge(m, src)
}
func (m *CollectionStatsResponse) XXX_Size() int {
	return xxx_messageInfo_CollectionStatsResponse.Size(m)
}
func (m *CollectionStatsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_CollectionStatsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_CollectionStatsResponse proto.InternalMessageInfo

func (m *CollectionStatsResponse) GetStats() []*commonpb.KeyValuePair {
	if m != nil {
		return m.Stats
	}
	return nil
}

func (m *CollectionStatsResponse) GetStatus() *commonpb.Status {
	if m != nil {
		return m.Status
	}
	return nil
}

type ShowCollectionRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *ShowCollectionRequest) Reset()         { *m = ShowCollectionRequest{} }
func (m *ShowCollectionRequest) String() string { return proto.CompactTextString(m) }
func (*ShowCollectionRequest) ProtoMessage()    {}
func (*ShowCollectionRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{10}
}

func (m *ShowCollectionRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ShowCollectionRequest.Unmarshal(m, b)
}
func (m *ShowCollectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ShowCollectionRequest.Marshal(b, m, deterministic)
}
func (m *ShowCollectionRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ShowCollectionRequest.Merge(m, src)
}
func (m *ShowCollectionRequest) XXX_Size() int {
	return xxx_messageInfo_ShowCollectionRequest.Size(m)
}
func (m *ShowCollectionRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ShowCollectionRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ShowCollectionRequest proto.InternalMessageInfo

func (m *ShowCollectionRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *ShowCollectionRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

type ShowCollectionResponse struct {
	CollectionNames      []string         `protobuf:"bytes,1,rep,name=collection_names,json=collectionNames,proto3" json:"collection_names,omitempty"`
	Status               *commonpb.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (m *ShowCollectionResponse) Reset()         { *m = ShowCollectionResponse{} }
func (m *ShowCollectionResponse) String() string { return proto.CompactTextString(m) }
func (*ShowCollectionResponse) ProtoMessage()    {}
func (*ShowCollectionResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{11}
}

func (m *ShowCollectionResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ShowCollectionResponse.Unmarshal(m, b)
}
func (m *ShowCollectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ShowCollectionResponse.Marshal(b, m, deterministic)
}
func (m *ShowCollectionResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ShowCollectionResponse.Merge(m, src)
}
func (m *ShowCollectionResponse) XXX_Size() int {
	return xxx_messageInfo_ShowCollectionResponse.Size(m)
}
func (m *ShowCollectionResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ShowCollectionResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ShowCollectionResponse proto.InternalMessageInfo

func (m *ShowCollectionResponse) GetCollectionNames() []string {
	if m != nil {
		return m.CollectionNames
	}
	return nil
}

func (m *ShowCollectionResponse) GetStatus() *commonpb.Status {
	if m != nil {
		return m.Status
	}
	return nil
}

type CreatePartitionRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	PartitionName        string            `protobuf:"bytes,4,opt,name=partition_name,json=partitionName,proto3" json:"partition_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *CreatePartitionRequest) Reset()         { *m = CreatePartitionRequest{} }
func (m *CreatePartitionRequest) String() string { return proto.CompactTextString(m) }
func (*CreatePartitionRequest) ProtoMessage()    {}
func (*CreatePartitionRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{12}
}

func (m *CreatePartitionRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreatePartitionRequest.Unmarshal(m, b)
}
func (m *CreatePartitionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreatePartitionRequest.Marshal(b, m, deterministic)
}
func (m *CreatePartitionRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreatePartitionRequest.Merge(m, src)
}
func (m *CreatePartitionRequest) XXX_Size() int {
	return xxx_messageInfo_CreatePartitionRequest.Size(m)
}
func (m *CreatePartitionRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_CreatePartitionRequest.DiscardUnknown(m)
}

var xxx_messageInfo_CreatePartitionRequest proto.InternalMessageInfo

func (m *CreatePartitionRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *CreatePartitionRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

func (m *CreatePartitionRequest) GetCollectionName() string {
	if m != nil {
		return m.CollectionName
	}
	return ""
}

func (m *CreatePartitionRequest) GetPartitionName() string {
	if m != nil {
		return m.PartitionName
	}
	return ""
}

type DropPartitionRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	PartitionName        string            `protobuf:"bytes,4,opt,name=partition_name,json=partitionName,proto3" json:"partition_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *DropPartitionRequest) Reset()         { *m = DropPartitionRequest{} }
func (m *DropPartitionRequest) String() string { return proto.CompactTextString(m) }
func (*DropPartitionRequest) ProtoMessage()    {}
func (*DropPartitionRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{13}
}

func (m *DropPartitionRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DropPartitionRequest.Unmarshal(m, b)
}
func (m *DropPartitionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DropPartitionRequest.Marshal(b, m, deterministic)
}
func (m *DropPartitionRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DropPartitionRequest.Merge(m, src)
}
func (m *DropPartitionRequest) XXX_Size() int {
	return xxx_messageInfo_DropPartitionRequest.Size(m)
}
func (m *DropPartitionRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_DropPartitionRequest.DiscardUnknown(m)
}

var xxx_messageInfo_DropPartitionRequest proto.InternalMessageInfo

func (m *DropPartitionRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *DropPartitionRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

func (m *DropPartitionRequest) GetCollectionName() string {
	if m != nil {
		return m.CollectionName
	}
	return ""
}

func (m *DropPartitionRequest) GetPartitionName() string {
	if m != nil {
		return m.PartitionName
	}
	return ""
}

type HasPartitionRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	PartitionName        string            `protobuf:"bytes,4,opt,name=partition_name,json=partitionName,proto3" json:"partition_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *HasPartitionRequest) Reset()         { *m = HasPartitionRequest{} }
func (m *HasPartitionRequest) String() string { return proto.CompactTextString(m) }
func (*HasPartitionRequest) ProtoMessage()    {}
func (*HasPartitionRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{14}
}

func (m *HasPartitionRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_HasPartitionRequest.Unmarshal(m, b)
}
func (m *HasPartitionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_HasPartitionRequest.Marshal(b, m, deterministic)
}
func (m *HasPartitionRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_HasPartitionRequest.Merge(m, src)
}
func (m *HasPartitionRequest) XXX_Size() int {
	return xxx_messageInfo_HasPartitionRequest.Size(m)
}
func (m *HasPartitionRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_HasPartitionRequest.DiscardUnknown(m)
}

var xxx_messageInfo_HasPartitionRequest proto.InternalMessageInfo

func (m *HasPartitionRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *HasPartitionRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

func (m *HasPartitionRequest) GetCollectionName() string {
	if m != nil {
		return m.CollectionName
	}
	return ""
}

func (m *HasPartitionRequest) GetPartitionName() string {
	if m != nil {
		return m.PartitionName
	}
	return ""
}

type LoadPartitonRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	PartitionNames       []string          `protobuf:"bytes,4,rep,name=partition_names,json=partitionNames,proto3" json:"partition_names,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *LoadPartitonRequest) Reset()         { *m = LoadPartitonRequest{} }
func (m *LoadPartitonRequest) String() string { return proto.CompactTextString(m) }
func (*LoadPartitonRequest) ProtoMessage()    {}
func (*LoadPartitonRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{15}
}

func (m *LoadPartitonRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_LoadPartitonRequest.Unmarshal(m, b)
}
func (m *LoadPartitonRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_LoadPartitonRequest.Marshal(b, m, deterministic)
}
func (m *LoadPartitonRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_LoadPartitonRequest.Merge(m, src)
}
func (m *LoadPartitonRequest) XXX_Size() int {
	return xxx_messageInfo_LoadPartitonRequest.Size(m)
}
func (m *LoadPartitonRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_LoadPartitonRequest.DiscardUnknown(m)
}

var xxx_messageInfo_LoadPartitonRequest proto.InternalMessageInfo

func (m *LoadPartitonRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *LoadPartitonRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

func (m *LoadPartitonRequest) GetCollectionName() string {
	if m != nil {
		return m.CollectionName
	}
	return ""
}

func (m *LoadPartitonRequest) GetPartitionNames() []string {
	if m != nil {
		return m.PartitionNames
	}
	return nil
}

type ReleasePartitionRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	PartitionNames       []string          `protobuf:"bytes,4,rep,name=partition_names,json=partitionNames,proto3" json:"partition_names,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *ReleasePartitionRequest) Reset()         { *m = ReleasePartitionRequest{} }
func (m *ReleasePartitionRequest) String() string { return proto.CompactTextString(m) }
func (*ReleasePartitionRequest) ProtoMessage()    {}
func (*ReleasePartitionRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{16}
}

func (m *ReleasePartitionRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ReleasePartitionRequest.Unmarshal(m, b)
}
func (m *ReleasePartitionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ReleasePartitionRequest.Marshal(b, m, deterministic)
}
func (m *ReleasePartitionRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ReleasePartitionRequest.Merge(m, src)
}
func (m *ReleasePartitionRequest) XXX_Size() int {
	return xxx_messageInfo_ReleasePartitionRequest.Size(m)
}
func (m *ReleasePartitionRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ReleasePartitionRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ReleasePartitionRequest proto.InternalMessageInfo

func (m *ReleasePartitionRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *ReleasePartitionRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

func (m *ReleasePartitionRequest) GetCollectionName() string {
	if m != nil {
		return m.CollectionName
	}
	return ""
}

func (m *ReleasePartitionRequest) GetPartitionNames() []string {
	if m != nil {
		return m.PartitionNames
	}
	return nil
}

type PartitionStatsRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	PartitionName        string            `protobuf:"bytes,4,opt,name=partition_name,json=partitionName,proto3" json:"partition_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *PartitionStatsRequest) Reset()         { *m = PartitionStatsRequest{} }
func (m *PartitionStatsRequest) String() string { return proto.CompactTextString(m) }
func (*PartitionStatsRequest) ProtoMessage()    {}
func (*PartitionStatsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{17}
}

func (m *PartitionStatsRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_PartitionStatsRequest.Unmarshal(m, b)
}
func (m *PartitionStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_PartitionStatsRequest.Marshal(b, m, deterministic)
}
func (m *PartitionStatsRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_PartitionStatsRequest.Merge(m, src)
}
func (m *PartitionStatsRequest) XXX_Size() int {
	return xxx_messageInfo_PartitionStatsRequest.Size(m)
}
func (m *PartitionStatsRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_PartitionStatsRequest.DiscardUnknown(m)
}

var xxx_messageInfo_PartitionStatsRequest proto.InternalMessageInfo

func (m *PartitionStatsRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *PartitionStatsRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

func (m *PartitionStatsRequest) GetCollectionName() string {
	if m != nil {
		return m.CollectionName
	}
	return ""
}

func (m *PartitionStatsRequest) GetPartitionName() string {
	if m != nil {
		return m.PartitionName
	}
	return ""
}

type PartitionStatsResponse struct {
	Stats                []*commonpb.KeyValuePair `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats,omitempty"`
	Status               *commonpb.Status         `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (m *PartitionStatsResponse) Reset()         { *m = PartitionStatsResponse{} }
func (m *PartitionStatsResponse) String() string { return proto.CompactTextString(m) }
func (*PartitionStatsResponse) ProtoMessage()    {}
func (*PartitionStatsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{18}
}

func (m *PartitionStatsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_PartitionStatsResponse.Unmarshal(m, b)
}
func (m *PartitionStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_PartitionStatsResponse.Marshal(b, m, deterministic)
}
func (m *PartitionStatsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_PartitionStatsResponse.Merge(m, src)
}
func (m *PartitionStatsResponse) XXX_Size() int {
	return xxx_messageInfo_PartitionStatsResponse.Size(m)
}
func (m *PartitionStatsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_PartitionStatsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_PartitionStatsResponse proto.InternalMessageInfo

func (m *PartitionStatsResponse) GetStats() []*commonpb.KeyValuePair {
	if m != nil {
		return m.Stats
	}
	return nil
}

func (m *PartitionStatsResponse) GetStatus() *commonpb.Status {
	if m != nil {
		return m.Status
	}
	return nil
}

type ShowPartitionRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	CollectionID         int64             `protobuf:"varint,4,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *ShowPartitionRequest) Reset()         { *m = ShowPartitionRequest{} }
func (m *ShowPartitionRequest) String() string { return proto.CompactTextString(m) }
func (*ShowPartitionRequest) ProtoMessage()    {}
func (*ShowPartitionRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{19}
}

func (m *ShowPartitionRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ShowPartitionRequest.Unmarshal(m, b)
}
func (m *ShowPartitionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ShowPartitionRequest.Marshal(b, m, deterministic)
}
func (m *ShowPartitionRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ShowPartitionRequest.Merge(m, src)
}
func (m *ShowPartitionRequest) XXX_Size() int {
	return xxx_messageInfo_ShowPartitionRequest.Size(m)
}
func (m *ShowPartitionRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ShowPartitionRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ShowPartitionRequest proto.InternalMessageInfo

func (m *ShowPartitionRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *ShowPartitionRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

func (m *ShowPartitionRequest) GetCollectionName() string {
	if m != nil {
		return m.CollectionName
	}
	return ""
}

func (m *ShowPartitionRequest) GetCollectionID() int64 {
	if m != nil {
		return m.CollectionID
	}
	return 0
}

type ShowPartitionResponse struct {
	PartitionNames       []string         `protobuf:"bytes,1,rep,name=partition_names,json=partitionNames,proto3" json:"partition_names,omitempty"`
	PartitionIDs         []int64          `protobuf:"varint,2,rep,packed,name=partitionIDs,proto3" json:"partitionIDs,omitempty"`
	Status               *commonpb.Status `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (m *ShowPartitionResponse) Reset()         { *m = ShowPartitionResponse{} }
func (m *ShowPartitionResponse) String() string { return proto.CompactTextString(m) }
func (*ShowPartitionResponse) ProtoMessage()    {}
func (*ShowPartitionResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{20}
}

func (m *ShowPartitionResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ShowPartitionResponse.Unmarshal(m, b)
}
func (m *ShowPartitionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ShowPartitionResponse.Marshal(b, m, deterministic)
}
func (m *ShowPartitionResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ShowPartitionResponse.Merge(m, src)
}
func (m *ShowPartitionResponse) XXX_Size() int {
	return xxx_messageInfo_ShowPartitionResponse.Size(m)
}
func (m *ShowPartitionResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ShowPartitionResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ShowPartitionResponse proto.InternalMessageInfo

func (m *ShowPartitionResponse) GetPartitionNames() []string {
	if m != nil {
		return m.PartitionNames
	}
	return nil
}

func (m *ShowPartitionResponse) GetPartitionIDs() []int64 {
	if m != nil {
		return m.PartitionIDs
	}
	return nil
}

func (m *ShowPartitionResponse) GetStatus() *commonpb.Status {
	if m != nil {
		return m.Status
	}
	return nil
}

type DescribeSegmentRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	CollectionID         int64             `protobuf:"varint,2,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	SegmentID            int64             `protobuf:"varint,3,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *DescribeSegmentRequest) Reset()         { *m = DescribeSegmentRequest{} }
func (m *DescribeSegmentRequest) String() string { return proto.CompactTextString(m) }
func (*DescribeSegmentRequest) ProtoMessage()    {}
func (*DescribeSegmentRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{21}
}

func (m *DescribeSegmentRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DescribeSegmentRequest.Unmarshal(m, b)
}
func (m *DescribeSegmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DescribeSegmentRequest.Marshal(b, m, deterministic)
}
func (m *DescribeSegmentRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DescribeSegmentRequest.Merge(m, src)
}
func (m *DescribeSegmentRequest) XXX_Size() int {
	return xxx_messageInfo_DescribeSegmentRequest.Size(m)
}
func (m *DescribeSegmentRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_DescribeSegmentRequest.DiscardUnknown(m)
}

var xxx_messageInfo_DescribeSegmentRequest proto.InternalMessageInfo

func (m *DescribeSegmentRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *DescribeSegmentRequest) GetCollectionID() int64 {
	if m != nil {
		return m.CollectionID
	}
	return 0
}

func (m *DescribeSegmentRequest) GetSegmentID() int64 {
	if m != nil {
		return m.SegmentID
	}
	return 0
}

type DescribeSegmentResponse 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"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (m *DescribeSegmentResponse) Reset()         { *m = DescribeSegmentResponse{} }
func (m *DescribeSegmentResponse) String() string { return proto.CompactTextString(m) }
func (*DescribeSegmentResponse) ProtoMessage()    {}
func (*DescribeSegmentResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{22}
}

func (m *DescribeSegmentResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DescribeSegmentResponse.Unmarshal(m, b)
}
func (m *DescribeSegmentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DescribeSegmentResponse.Marshal(b, m, deterministic)
}
func (m *DescribeSegmentResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DescribeSegmentResponse.Merge(m, src)
}
func (m *DescribeSegmentResponse) XXX_Size() int {
	return xxx_messageInfo_DescribeSegmentResponse.Size(m)
}
func (m *DescribeSegmentResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_DescribeSegmentResponse.DiscardUnknown(m)
}

var xxx_messageInfo_DescribeSegmentResponse proto.InternalMessageInfo

func (m *DescribeSegmentResponse) GetStatus() *commonpb.Status {
	if m != nil {
		return m.Status
	}
	return nil
}

func (m *DescribeSegmentResponse) GetIndexID() int64 {
	if m != nil {
		return m.IndexID
	}
	return 0
}

type ShowSegmentRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	CollectionID         int64             `protobuf:"varint,2,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionID          int64             `protobuf:"varint,3,opt,name=partitionID,proto3" json:"partitionID,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *ShowSegmentRequest) Reset()         { *m = ShowSegmentRequest{} }
func (m *ShowSegmentRequest) String() string { return proto.CompactTextString(m) }
func (*ShowSegmentRequest) ProtoMessage()    {}
func (*ShowSegmentRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{23}
}

func (m *ShowSegmentRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ShowSegmentRequest.Unmarshal(m, b)
}
func (m *ShowSegmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ShowSegmentRequest.Marshal(b, m, deterministic)
}
func (m *ShowSegmentRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ShowSegmentRequest.Merge(m, src)
}
func (m *ShowSegmentRequest) XXX_Size() int {
	return xxx_messageInfo_ShowSegmentRequest.Size(m)
}
func (m *ShowSegmentRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ShowSegmentRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ShowSegmentRequest proto.InternalMessageInfo

func (m *ShowSegmentRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *ShowSegmentRequest) GetCollectionID() int64 {
	if m != nil {
		return m.CollectionID
	}
	return 0
}

func (m *ShowSegmentRequest) GetPartitionID() int64 {
	if m != nil {
		return m.PartitionID
	}
	return 0
}

type ShowSegmentResponse struct {
	Status               *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	SegmentIDs           []int64          `protobuf:"varint,2,rep,packed,name=segmentIDs,proto3" json:"segmentIDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (m *ShowSegmentResponse) Reset()         { *m = ShowSegmentResponse{} }
func (m *ShowSegmentResponse) String() string { return proto.CompactTextString(m) }
func (*ShowSegmentResponse) ProtoMessage()    {}
func (*ShowSegmentResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{24}
}

func (m *ShowSegmentResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ShowSegmentResponse.Unmarshal(m, b)
}
func (m *ShowSegmentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ShowSegmentResponse.Marshal(b, m, deterministic)
}
func (m *ShowSegmentResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ShowSegmentResponse.Merge(m, src)
}
func (m *ShowSegmentResponse) XXX_Size() int {
	return xxx_messageInfo_ShowSegmentResponse.Size(m)
}
func (m *ShowSegmentResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ShowSegmentResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ShowSegmentResponse proto.InternalMessageInfo

func (m *ShowSegmentResponse) GetStatus() *commonpb.Status {
	if m != nil {
		return m.Status
	}
	return nil
}

func (m *ShowSegmentResponse) GetSegmentIDs() []int64 {
	if m != nil {
		return m.SegmentIDs
	}
	return nil
}

type CreateIndexRequest struct {
	Base                 *commonpb.MsgBase        `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string                   `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string                   `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	FieldName            string                   `protobuf:"bytes,4,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	ExtraParams          []*commonpb.KeyValuePair `protobuf:"bytes,5,rep,name=extra_params,json=extraParams,proto3" json:"extra_params,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (m *CreateIndexRequest) Reset()         { *m = CreateIndexRequest{} }
func (m *CreateIndexRequest) String() string { return proto.CompactTextString(m) }
func (*CreateIndexRequest) ProtoMessage()    {}
func (*CreateIndexRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{25}
}

func (m *CreateIndexRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreateIndexRequest.Unmarshal(m, b)
}
func (m *CreateIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreateIndexRequest.Marshal(b, m, deterministic)
}
func (m *CreateIndexRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreateIndexRequest.Merge(m, src)
}
func (m *CreateIndexRequest) XXX_Size() int {
	return xxx_messageInfo_CreateIndexRequest.Size(m)
}
func (m *CreateIndexRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_CreateIndexRequest.DiscardUnknown(m)
}

var xxx_messageInfo_CreateIndexRequest proto.InternalMessageInfo

func (m *CreateIndexRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *CreateIndexRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

func (m *CreateIndexRequest) GetCollectionName() string {
	if m != nil {
		return m.CollectionName
	}
	return ""
}

func (m *CreateIndexRequest) GetFieldName() string {
	if m != nil {
		return m.FieldName
	}
	return ""
}

func (m *CreateIndexRequest) GetExtraParams() []*commonpb.KeyValuePair {
	if m != nil {
		return m.ExtraParams
	}
	return nil
}

type DescribeIndexRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	FieldName            string            `protobuf:"bytes,4,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	IndexName            string            `protobuf:"bytes,5,opt,name=index_name,json=indexName,proto3" json:"index_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_02345ba45cc0e303, []int{26}
}

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) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *DescribeIndexRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

func (m *DescribeIndexRequest) GetCollectionName() string {
	if m != nil {
		return m.CollectionName
	}
	return ""
}

func (m *DescribeIndexRequest) GetFieldName() string {
	if m != nil {
		return m.FieldName
	}
	return ""
}

func (m *DescribeIndexRequest) GetIndexName() string {
	if m != nil {
		return m.IndexName
	}
	return ""
}

type IndexDescription struct {
	IndexName            string                   `protobuf:"bytes,1,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	Params               []*commonpb.KeyValuePair `protobuf:"bytes,2,rep,name=params,proto3" json:"params,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (m *IndexDescription) Reset()         { *m = IndexDescription{} }
func (m *IndexDescription) String() string { return proto.CompactTextString(m) }
func (*IndexDescription) ProtoMessage()    {}
func (*IndexDescription) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{27}
}

func (m *IndexDescription) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_IndexDescription.Unmarshal(m, b)
}
func (m *IndexDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_IndexDescription.Marshal(b, m, deterministic)
}
func (m *IndexDescription) XXX_Merge(src proto.Message) {
	xxx_messageInfo_IndexDescription.Merge(m, src)
}
func (m *IndexDescription) XXX_Size() int {
	return xxx_messageInfo_IndexDescription.Size(m)
}
func (m *IndexDescription) XXX_DiscardUnknown() {
	xxx_messageInfo_IndexDescription.DiscardUnknown(m)
}

var xxx_messageInfo_IndexDescription proto.InternalMessageInfo

func (m *IndexDescription) GetIndexName() string {
	if m != nil {
		return m.IndexName
	}
	return ""
}

func (m *IndexDescription) GetParams() []*commonpb.KeyValuePair {
	if m != nil {
		return m.Params
	}
	return nil
}

type DescribeIndexResponse struct {
	Status               *commonpb.Status    `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	IndexDescriptions    []*IndexDescription `protobuf:"bytes,2,rep,name=index_descriptions,json=indexDescriptions,proto3" json:"index_descriptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

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_02345ba45cc0e303, []int{28}
}

func (m *DescribeIndexResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DescribeIndexResponse.Unmarshal(m, b)
}
func (m *DescribeIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DescribeIndexResponse.Marshal(b, m, deterministic)
}
func (m *DescribeIndexResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DescribeIndexResponse.Merge(m, src)
}
func (m *DescribeIndexResponse) XXX_Size() int {
	return xxx_messageInfo_DescribeIndexResponse.Size(m)
}
func (m *DescribeIndexResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_DescribeIndexResponse.DiscardUnknown(m)
}

var xxx_messageInfo_DescribeIndexResponse proto.InternalMessageInfo

func (m *DescribeIndexResponse) GetStatus() *commonpb.Status {
	if m != nil {
		return m.Status
	}
	return nil
}

func (m *DescribeIndexResponse) GetIndexDescriptions() []*IndexDescription {
	if m != nil {
		return m.IndexDescriptions
	}
	return nil
}

type IndexStateRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	FieldName            string            `protobuf:"bytes,4,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	IndexName            string            `protobuf:"bytes,5,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *IndexStateRequest) Reset()         { *m = IndexStateRequest{} }
func (m *IndexStateRequest) String() string { return proto.CompactTextString(m) }
func (*IndexStateRequest) ProtoMessage()    {}
func (*IndexStateRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{29}
}

func (m *IndexStateRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_IndexStateRequest.Unmarshal(m, b)
}
func (m *IndexStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_IndexStateRequest.Marshal(b, m, deterministic)
}
func (m *IndexStateRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_IndexStateRequest.Merge(m, src)
}
func (m *IndexStateRequest) XXX_Size() int {
	return xxx_messageInfo_IndexStateRequest.Size(m)
}
func (m *IndexStateRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_IndexStateRequest.DiscardUnknown(m)
}

var xxx_messageInfo_IndexStateRequest proto.InternalMessageInfo

func (m *IndexStateRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *IndexStateRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

func (m *IndexStateRequest) GetCollectionName() string {
	if m != nil {
		return m.CollectionName
	}
	return ""
}

func (m *IndexStateRequest) GetFieldName() string {
	if m != nil {
		return m.FieldName
	}
	return ""
}

func (m *IndexStateRequest) GetIndexName() string {
	if m != nil {
		return m.IndexName
	}
	return ""
}

type IndexStateResponse struct {
	Status               *commonpb.Status    `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	State                commonpb.IndexState `protobuf:"varint,2,opt,name=state,proto3,enum=milvus.proto.common.IndexState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (m *IndexStateResponse) Reset()         { *m = IndexStateResponse{} }
func (m *IndexStateResponse) String() string { return proto.CompactTextString(m) }
func (*IndexStateResponse) ProtoMessage()    {}
func (*IndexStateResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{30}
}

func (m *IndexStateResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_IndexStateResponse.Unmarshal(m, b)
}
func (m *IndexStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_IndexStateResponse.Marshal(b, m, deterministic)
}
func (m *IndexStateResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_IndexStateResponse.Merge(m, src)
}
func (m *IndexStateResponse) XXX_Size() int {
	return xxx_messageInfo_IndexStateResponse.Size(m)
}
func (m *IndexStateResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_IndexStateResponse.DiscardUnknown(m)
}

var xxx_messageInfo_IndexStateResponse proto.InternalMessageInfo

func (m *IndexStateResponse) GetStatus() *commonpb.Status {
	if m != nil {
		return m.Status
	}
	return nil
}

func (m *IndexStateResponse) GetState() commonpb.IndexState {
	if m != nil {
		return m.State
	}
	return commonpb.IndexState_NONE
}

type InsertRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	PartitionName        string            `protobuf:"bytes,4,opt,name=partition_name,json=partitionName,proto3" json:"partition_name,omitempty"`
	RowData              []*commonpb.Blob  `protobuf:"bytes,5,rep,name=row_data,json=rowData,proto3" json:"row_data,omitempty"`
	HashKeys             []uint32          `protobuf:"varint,6,rep,packed,name=hash_keys,json=hashKeys,proto3" json:"hash_keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *InsertRequest) Reset()         { *m = InsertRequest{} }
func (m *InsertRequest) String() string { return proto.CompactTextString(m) }
func (*InsertRequest) ProtoMessage()    {}
func (*InsertRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{31}
}

func (m *InsertRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_InsertRequest.Unmarshal(m, b)
}
func (m *InsertRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_InsertRequest.Marshal(b, m, deterministic)
}
func (m *InsertRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_InsertRequest.Merge(m, src)
}
func (m *InsertRequest) XXX_Size() int {
	return xxx_messageInfo_InsertRequest.Size(m)
}
func (m *InsertRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_InsertRequest.DiscardUnknown(m)
}

var xxx_messageInfo_InsertRequest proto.InternalMessageInfo

func (m *InsertRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *InsertRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

func (m *InsertRequest) GetCollectionName() string {
	if m != nil {
		return m.CollectionName
	}
	return ""
}

func (m *InsertRequest) GetPartitionName() string {
	if m != nil {
		return m.PartitionName
	}
	return ""
}

func (m *InsertRequest) GetRowData() []*commonpb.Blob {
	if m != nil {
		return m.RowData
	}
	return nil
}

func (m *InsertRequest) GetHashKeys() []uint32 {
	if m != nil {
		return m.HashKeys
	}
	return nil
}

type InsertResponse struct {
	RowIDBegin           int64            `protobuf:"varint,1,opt,name=rowID_begin,json=rowIDBegin,proto3" json:"rowID_begin,omitempty"`
	RowIDEnd             int64            `protobuf:"varint,2,opt,name=rowID_end,json=rowIDEnd,proto3" json:"rowID_end,omitempty"`
	Status               *commonpb.Status `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (m *InsertResponse) Reset()         { *m = InsertResponse{} }
func (m *InsertResponse) String() string { return proto.CompactTextString(m) }
func (*InsertResponse) ProtoMessage()    {}
func (*InsertResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{32}
}

func (m *InsertResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_InsertResponse.Unmarshal(m, b)
}
func (m *InsertResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_InsertResponse.Marshal(b, m, deterministic)
}
func (m *InsertResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_InsertResponse.Merge(m, src)
}
func (m *InsertResponse) XXX_Size() int {
	return xxx_messageInfo_InsertResponse.Size(m)
}
func (m *InsertResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_InsertResponse.DiscardUnknown(m)
}

var xxx_messageInfo_InsertResponse proto.InternalMessageInfo

func (m *InsertResponse) GetRowIDBegin() int64 {
	if m != nil {
		return m.RowIDBegin
	}
	return 0
}

func (m *InsertResponse) GetRowIDEnd() int64 {
	if m != nil {
		return m.RowIDEnd
	}
	return 0
}

func (m *InsertResponse) GetStatus() *commonpb.Status {
	if m != nil {
		return m.Status
	}
	return nil
}

type PlaceholderValue struct {
	Tag  string          `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	Type PlaceholderType `protobuf:"varint,2,opt,name=type,proto3,enum=milvus.proto.milvus.PlaceholderType" json:"type,omitempty"`
	// values is a 2d-array, every array contains a vector
	Values               [][]byte `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *PlaceholderValue) Reset()         { *m = PlaceholderValue{} }
func (m *PlaceholderValue) String() string { return proto.CompactTextString(m) }
func (*PlaceholderValue) ProtoMessage()    {}
func (*PlaceholderValue) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{33}
}

func (m *PlaceholderValue) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_PlaceholderValue.Unmarshal(m, b)
}
func (m *PlaceholderValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_PlaceholderValue.Marshal(b, m, deterministic)
}
func (m *PlaceholderValue) XXX_Merge(src proto.Message) {
	xxx_messageInfo_PlaceholderValue.Merge(m, src)
}
func (m *PlaceholderValue) XXX_Size() int {
	return xxx_messageInfo_PlaceholderValue.Size(m)
}
func (m *PlaceholderValue) XXX_DiscardUnknown() {
	xxx_messageInfo_PlaceholderValue.DiscardUnknown(m)
}

var xxx_messageInfo_PlaceholderValue proto.InternalMessageInfo

func (m *PlaceholderValue) GetTag() string {
	if m != nil {
		return m.Tag
	}
	return ""
}

func (m *PlaceholderValue) GetType() PlaceholderType {
	if m != nil {
		return m.Type
	}
	return PlaceholderType_NONE
}

func (m *PlaceholderValue) GetValues() [][]byte {
	if m != nil {
		return m.Values
	}
	return nil
}

type PlaceholderGroup struct {
	Placeholders         []*PlaceholderValue `protobuf:"bytes,1,rep,name=placeholders,proto3" json:"placeholders,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (m *PlaceholderGroup) Reset()         { *m = PlaceholderGroup{} }
func (m *PlaceholderGroup) String() string { return proto.CompactTextString(m) }
func (*PlaceholderGroup) ProtoMessage()    {}
func (*PlaceholderGroup) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{34}
}

func (m *PlaceholderGroup) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_PlaceholderGroup.Unmarshal(m, b)
}
func (m *PlaceholderGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_PlaceholderGroup.Marshal(b, m, deterministic)
}
func (m *PlaceholderGroup) XXX_Merge(src proto.Message) {
	xxx_messageInfo_PlaceholderGroup.Merge(m, src)
}
func (m *PlaceholderGroup) XXX_Size() int {
	return xxx_messageInfo_PlaceholderGroup.Size(m)
}
func (m *PlaceholderGroup) XXX_DiscardUnknown() {
	xxx_messageInfo_PlaceholderGroup.DiscardUnknown(m)
}

var xxx_messageInfo_PlaceholderGroup proto.InternalMessageInfo

func (m *PlaceholderGroup) GetPlaceholders() []*PlaceholderValue {
	if m != nil {
		return m.Placeholders
	}
	return nil
}

type SearchRequest struct {
	Base           *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName         string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	PartitionNames []string          `protobuf:"bytes,4,rep,name=partition_names,json=partitionNames,proto3" json:"partition_names,omitempty"`
	Dsl            string            `protobuf:"bytes,5,opt,name=dsl,proto3" json:"dsl,omitempty"`
	// serialized `PlaceholderGroup`
	PlaceholderGroup     []byte   `protobuf:"bytes,6,opt,name=placeholder_group,json=placeholderGroup,proto3" json:"placeholder_group,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *SearchRequest) Reset()         { *m = SearchRequest{} }
func (m *SearchRequest) String() string { return proto.CompactTextString(m) }
func (*SearchRequest) ProtoMessage()    {}
func (*SearchRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{35}
}

func (m *SearchRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SearchRequest.Unmarshal(m, b)
}
func (m *SearchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SearchRequest.Marshal(b, m, deterministic)
}
func (m *SearchRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SearchRequest.Merge(m, src)
}
func (m *SearchRequest) XXX_Size() int {
	return xxx_messageInfo_SearchRequest.Size(m)
}
func (m *SearchRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_SearchRequest.DiscardUnknown(m)
}

var xxx_messageInfo_SearchRequest proto.InternalMessageInfo

func (m *SearchRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *SearchRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

func (m *SearchRequest) GetCollectionName() string {
	if m != nil {
		return m.CollectionName
	}
	return ""
}

func (m *SearchRequest) GetPartitionNames() []string {
	if m != nil {
		return m.PartitionNames
	}
	return nil
}

func (m *SearchRequest) GetDsl() string {
	if m != nil {
		return m.Dsl
	}
	return ""
}

func (m *SearchRequest) GetPlaceholderGroup() []byte {
	if m != nil {
		return m.PlaceholderGroup
	}
	return nil
}

type Hits struct {
	IDs                  []int64   `protobuf:"varint,1,rep,packed,name=IDs,proto3" json:"IDs,omitempty"`
	RowData              [][]byte  `protobuf:"bytes,2,rep,name=row_data,json=rowData,proto3" json:"row_data,omitempty"`
	Scores               []float32 `protobuf:"fixed32,3,rep,packed,name=scores,proto3" json:"scores,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (m *Hits) Reset()         { *m = Hits{} }
func (m *Hits) String() string { return proto.CompactTextString(m) }
func (*Hits) ProtoMessage()    {}
func (*Hits) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{36}
}

func (m *Hits) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_Hits.Unmarshal(m, b)
}
func (m *Hits) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_Hits.Marshal(b, m, deterministic)
}
func (m *Hits) XXX_Merge(src proto.Message) {
	xxx_messageInfo_Hits.Merge(m, src)
}
func (m *Hits) XXX_Size() int {
	return xxx_messageInfo_Hits.Size(m)
}
func (m *Hits) XXX_DiscardUnknown() {
	xxx_messageInfo_Hits.DiscardUnknown(m)
}

var xxx_messageInfo_Hits proto.InternalMessageInfo

func (m *Hits) GetIDs() []int64 {
	if m != nil {
		return m.IDs
	}
	return nil
}

func (m *Hits) GetRowData() [][]byte {
	if m != nil {
		return m.RowData
	}
	return nil
}

func (m *Hits) GetScores() []float32 {
	if m != nil {
		return m.Scores
	}
	return nil
}

type SearchResults struct {
	Status               *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Hits                 [][]byte         `protobuf:"bytes,2,rep,name=hits,proto3" json:"hits,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (m *SearchResults) Reset()         { *m = SearchResults{} }
func (m *SearchResults) String() string { return proto.CompactTextString(m) }
func (*SearchResults) ProtoMessage()    {}
func (*SearchResults) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{37}
}

func (m *SearchResults) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SearchResults.Unmarshal(m, b)
}
func (m *SearchResults) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SearchResults.Marshal(b, m, deterministic)
}
func (m *SearchResults) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SearchResults.Merge(m, src)
}
func (m *SearchResults) XXX_Size() int {
	return xxx_messageInfo_SearchResults.Size(m)
}
func (m *SearchResults) XXX_DiscardUnknown() {
	xxx_messageInfo_SearchResults.DiscardUnknown(m)
}

var xxx_messageInfo_SearchResults proto.InternalMessageInfo

func (m *SearchResults) GetStatus() *commonpb.Status {
	if m != nil {
		return m.Status
	}
	return nil
}

func (m *SearchResults) GetHits() [][]byte {
	if m != nil {
		return m.Hits
	}
	return nil
}

type FlushRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *FlushRequest) Reset()         { *m = FlushRequest{} }
func (m *FlushRequest) String() string { return proto.CompactTextString(m) }
func (*FlushRequest) ProtoMessage()    {}
func (*FlushRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_02345ba45cc0e303, []int{38}
}

func (m *FlushRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_FlushRequest.Unmarshal(m, b)
}
func (m *FlushRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_FlushRequest.Marshal(b, m, deterministic)
}
func (m *FlushRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_FlushRequest.Merge(m, src)
}
func (m *FlushRequest) XXX_Size() int {
	return xxx_messageInfo_FlushRequest.Size(m)
}
func (m *FlushRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_FlushRequest.DiscardUnknown(m)
}

var xxx_messageInfo_FlushRequest proto.InternalMessageInfo

func (m *FlushRequest) GetBase() *commonpb.MsgBase {
	if m != nil {
		return m.Base
	}
	return nil
}

func (m *FlushRequest) GetDbName() string {
	if m != nil {
		return m.DbName
	}
	return ""
}

func (m *FlushRequest) GetCollectionName() string {
	if m != nil {
		return m.CollectionName
	}
	return ""
}

func init() {
	proto.RegisterEnum("milvus.proto.milvus.PlaceholderType", PlaceholderType_name, PlaceholderType_value)
	proto.RegisterType((*CreateCollectionRequest)(nil), "milvus.proto.milvus.CreateCollectionRequest")
	proto.RegisterType((*DropCollectionRequest)(nil), "milvus.proto.milvus.DropCollectionRequest")
	proto.RegisterType((*HasCollectionRequest)(nil), "milvus.proto.milvus.HasCollectionRequest")
	proto.RegisterType((*BoolResponse)(nil), "milvus.proto.milvus.BoolResponse")
	proto.RegisterType((*DescribeCollectionRequest)(nil), "milvus.proto.milvus.DescribeCollectionRequest")
	proto.RegisterType((*DescribeCollectionResponse)(nil), "milvus.proto.milvus.DescribeCollectionResponse")
	proto.RegisterType((*LoadCollectionRequest)(nil), "milvus.proto.milvus.LoadCollectionRequest")
	proto.RegisterType((*ReleaseCollectionRequest)(nil), "milvus.proto.milvus.ReleaseCollectionRequest")
	proto.RegisterType((*CollectionStatsRequest)(nil), "milvus.proto.milvus.CollectionStatsRequest")
	proto.RegisterType((*CollectionStatsResponse)(nil), "milvus.proto.milvus.CollectionStatsResponse")
	proto.RegisterType((*ShowCollectionRequest)(nil), "milvus.proto.milvus.ShowCollectionRequest")
	proto.RegisterType((*ShowCollectionResponse)(nil), "milvus.proto.milvus.ShowCollectionResponse")
	proto.RegisterType((*CreatePartitionRequest)(nil), "milvus.proto.milvus.CreatePartitionRequest")
	proto.RegisterType((*DropPartitionRequest)(nil), "milvus.proto.milvus.DropPartitionRequest")
	proto.RegisterType((*HasPartitionRequest)(nil), "milvus.proto.milvus.HasPartitionRequest")
	proto.RegisterType((*LoadPartitonRequest)(nil), "milvus.proto.milvus.LoadPartitonRequest")
	proto.RegisterType((*ReleasePartitionRequest)(nil), "milvus.proto.milvus.ReleasePartitionRequest")
	proto.RegisterType((*PartitionStatsRequest)(nil), "milvus.proto.milvus.PartitionStatsRequest")
	proto.RegisterType((*PartitionStatsResponse)(nil), "milvus.proto.milvus.PartitionStatsResponse")
	proto.RegisterType((*ShowPartitionRequest)(nil), "milvus.proto.milvus.ShowPartitionRequest")
	proto.RegisterType((*ShowPartitionResponse)(nil), "milvus.proto.milvus.ShowPartitionResponse")
	proto.RegisterType((*DescribeSegmentRequest)(nil), "milvus.proto.milvus.DescribeSegmentRequest")
	proto.RegisterType((*DescribeSegmentResponse)(nil), "milvus.proto.milvus.DescribeSegmentResponse")
	proto.RegisterType((*ShowSegmentRequest)(nil), "milvus.proto.milvus.ShowSegmentRequest")
	proto.RegisterType((*ShowSegmentResponse)(nil), "milvus.proto.milvus.ShowSegmentResponse")
	proto.RegisterType((*CreateIndexRequest)(nil), "milvus.proto.milvus.CreateIndexRequest")
	proto.RegisterType((*DescribeIndexRequest)(nil), "milvus.proto.milvus.DescribeIndexRequest")
	proto.RegisterType((*IndexDescription)(nil), "milvus.proto.milvus.IndexDescription")
	proto.RegisterType((*DescribeIndexResponse)(nil), "milvus.proto.milvus.DescribeIndexResponse")
	proto.RegisterType((*IndexStateRequest)(nil), "milvus.proto.milvus.IndexStateRequest")
	proto.RegisterType((*IndexStateResponse)(nil), "milvus.proto.milvus.IndexStateResponse")
	proto.RegisterType((*InsertRequest)(nil), "milvus.proto.milvus.InsertRequest")
	proto.RegisterType((*InsertResponse)(nil), "milvus.proto.milvus.InsertResponse")
	proto.RegisterType((*PlaceholderValue)(nil), "milvus.proto.milvus.PlaceholderValue")
	proto.RegisterType((*PlaceholderGroup)(nil), "milvus.proto.milvus.PlaceholderGroup")
	proto.RegisterType((*SearchRequest)(nil), "milvus.proto.milvus.SearchRequest")
	proto.RegisterType((*Hits)(nil), "milvus.proto.milvus.Hits")
	proto.RegisterType((*SearchResults)(nil), "milvus.proto.milvus.SearchResults")
	proto.RegisterType((*FlushRequest)(nil), "milvus.proto.milvus.FlushRequest")
}

func init() { proto.RegisterFile("milvus.proto", fileDescriptor_02345ba45cc0e303) }

var fileDescriptor_02345ba45cc0e303 = []byte{
	// 1575 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xd4, 0x58, 0xdd, 0x6e, 0x1b, 0x45,
	0x14, 0xce, 0xd8, 0x8e, 0x9b, 0x9c, 0xd8, 0x8e, 0x33, 0xf9, 0x73, 0xdd, 0x96, 0xa6, 0x0b, 0x6d,
	0xdc, 0xbf, 0x04, 0xa5, 0x20, 0xe0, 0x02, 0xa9, 0x75, 0xdd, 0xa6, 0x56, 0xdb, 0x34, 0x5a, 0x87,
	0x8a, 0x80, 0x2a, 0x33, 0xf6, 0x0e, 0xf1, 0xc2, 0xda, 0x6b, 0x76, 0xd6, 0x49, 0xd3, 0x2b, 0x04,
	0x12, 0x48, 0x80, 0x80, 0x5b, 0x24, 0xae, 0x10, 0xd7, 0x08, 0x8a, 0xc4, 0x1b, 0x20, 0xf1, 0x2e,
	0x88, 0x47, 0x40, 0x42, 0x33, 0xbb, 0x5e, 0xef, 0x6e, 0x66, 0x63, 0xb7, 0x51, 0xb1, 0x73, 0xe7,
	0x39, 0x3e, 0x73, 0xce, 0x77, 0x7e, 0x66, 0xf6, 0xcc, 0x07, 0xa9, 0xa6, 0x6e, 0xec, 0x76, 0xd8,
	0x4a, 0xdb, 0x32, 0x6d, 0x13, 0xcf, 0xfa, 0x57, 0x2b, 0xce, 0x22, 0x9f, 0xaa, 0x9b, 0xcd, 0xa6,
	0xd9, 0x72, 0x84, 0xf9, 0x14, 0xab, 0x37, 0x68, 0x93, 0x38, 0x2b, 0xe5, 0x67, 0x04, 0x8b, 0x37,
	0x2d, 0x4a, 0x6c, 0x7a, 0xd3, 0x34, 0x0c, 0x5a, 0xb7, 0x75, 0xb3, 0xa5, 0xd2, 0x4f, 0x3a, 0x94,
	0xd9, 0xf8, 0x55, 0x48, 0xd4, 0x08, 0xa3, 0x39, 0xb4, 0x84, 0x0a, 0x53, 0x6b, 0xa7, 0x57, 0x02,
	0xb6, 0x5d, 0x9b, 0xf7, 0xd9, 0x4e, 0x91, 0x30, 0xaa, 0x0a, 0x4d, 0xbc, 0x08, 0x27, 0xb4, 0x5a,
	0xb5, 0x45, 0x9a, 0x34, 0x17, 0x5b, 0x42, 0x85, 0x49, 0x35, 0xa9, 0xd5, 0x36, 0x48, 0x93, 0xe2,
	0x0b, 0x90, 0xa9, 0x7b, 0xf6, 0xb9, 0x24, 0x17, 0x17, 0xff, 0x87, 0xa4, 0x78, 0x01, 0x92, 0x0e,
	0xbc, 0x5c, 0x62, 0x09, 0x15, 0x52, 0xaa, 0xbb, 0x52, 0xbe, 0x42, 0x30, 0x5f, 0xb2, 0xcc, 0xf6,
	0x28, 0x80, 0xe4, 0x60, 0xe6, 0xee, 0x10, 0xf6, 0x42, 0xb1, 0x2c, 0xc3, 0x74, 0xcf, 0xab, 0xa3,
	0x20, 0x07, 0xb3, 0x0d, 0xa9, 0xa2, 0x69, 0x1a, 0x2a, 0x65, 0x6d, 0xb3, 0xc5, 0x28, 0xbe, 0x06,
	0x49, 0x66, 0x13, 0xbb, 0xc3, 0x5c, 0x14, 0xa7, 0xa4, 0x28, 0x2a, 0x42, 0x45, 0x75, 0x55, 0xf1,
	0x1c, 0x8c, 0xef, 0x12, 0xa3, 0xe3, 0x80, 0x98, 0x50, 0x9d, 0x85, 0xf2, 0x1d, 0x82, 0x93, 0x25,
	0xca, 0xea, 0x96, 0x5e, 0xa3, 0xa3, 0x11, 0xec, 0xf7, 0x08, 0xf2, 0x32, 0x44, 0x47, 0x89, 0xfd,
	0x6d, 0xaf, 0xe5, 0x62, 0x62, 0xd3, 0xf9, 0xe0, 0x26, 0xf7, 0xb4, 0xf4, 0xbc, 0x55, 0x84, 0xc0,
	0xeb, 0xcc, 0xaf, 0x11, 0xcc, 0xdf, 0x33, 0x89, 0x36, 0x1a, 0x09, 0xfa, 0x16, 0x41, 0x4e, 0xa5,
	0x06, 0x25, 0x6c, 0x44, 0x2a, 0xf6, 0x0d, 0x82, 0x05, 0x5f, 0xee, 0x6c, 0x62, 0xb3, 0x61, 0xc2,
	0xf9, 0x92, 0x5f, 0x77, 0x61, 0x38, 0x6e, 0xf7, 0xbc, 0x01, 0xe3, 0xbc, 0x25, 0x78, 0xf3, 0xc4,
	0x0b, 0x53, 0x6b, 0xe7, 0xa4, 0x80, 0xee, 0xd2, 0xfd, 0x87, 0xfc, 0x70, 0x6c, 0x12, 0xdd, 0x52,
	0x1d, 0x7d, 0x5f, 0xdb, 0xc5, 0x06, 0x6e, 0x3b, 0xa5, 0x06, 0xf3, 0x95, 0x86, 0xb9, 0xf7, 0x22,
	0xab, 0xa4, 0x3c, 0x86, 0x85, 0xb0, 0x0f, 0x37, 0xd6, 0x8b, 0x90, 0x0d, 0x25, 0xcc, 0x09, 0x7b,
	0x52, 0x9d, 0x0e, 0x66, 0xec, 0x39, 0xa3, 0xfb, 0x9d, 0x97, 0x5d, 0x7c, 0x56, 0x36, 0x89, 0x65,
	0xeb, 0x43, 0xee, 0x42, 0x7c, 0x1e, 0x32, 0xed, 0x2e, 0x0e, 0x47, 0x2f, 0x21, 0xf4, 0xd2, 0x9e,
	0x54, 0xe4, 0xeb, 0x37, 0x04, 0x73, 0xfc, 0x2b, 0x73, 0x9c, 0x30, 0xff, 0x8a, 0x60, 0xf6, 0x0e,
	0x61, 0xc7, 0x09, 0xf2, 0x53, 0x04, 0xb3, 0xfc, 0xca, 0x74, 0x30, 0x0f, 0x17, 0xf2, 0x32, 0x4c,
	0x07, 0x21, 0xb3, 0x5c, 0x42, 0x9c, 0x83, 0x4c, 0x00, 0x33, 0x53, 0xfe, 0x40, 0xb0, 0xe8, 0xde,
	0xac, 0x23, 0x91, 0xeb, 0x81, 0x81, 0x3f, 0x45, 0x30, 0xef, 0x21, 0x1e, 0xf6, 0x05, 0x3c, 0x68,
	0x8b, 0x7c, 0x81, 0x60, 0x21, 0x0c, 0x7a, 0x28, 0xd7, 0xf4, 0x2f, 0x08, 0xe6, 0xf8, 0x1d, 0x3a,
	0x12, 0x35, 0x57, 0x20, 0xd5, 0x93, 0x94, 0x4b, 0x22, 0x75, 0x71, 0x35, 0x20, 0x53, 0x7e, 0x40,
	0xce, 0x87, 0xc5, 0x07, 0xd8, 0x4d, 0x9c, 0xa4, 0x63, 0x90, 0xac, 0x63, 0xb8, 0x1b, 0x4f, 0x52,
	0x2e, 0xf1, 0x74, 0xc5, 0xb9, 0x1b, 0xbf, 0xcc, 0x97, 0xcc, 0xf8, 0xe0, 0xc9, 0xe4, 0xc3, 0x40,
	0x77, 0x7c, 0xab, 0xd0, 0x9d, 0x26, 0x6d, 0xd9, 0xcf, 0x9f, 0xce, 0x70, 0x32, 0x62, 0x07, 0x93,
	0x81, 0x4f, 0xc3, 0x24, 0x73, 0xfc, 0x94, 0x4b, 0x02, 0x68, 0x5c, 0xed, 0x09, 0x94, 0x06, 0x2c,
	0x1e, 0x40, 0x73, 0x94, 0x49, 0x32, 0x07, 0x27, 0xf4, 0x96, 0x46, 0x1f, 0x7b, 0x60, 0xba, 0x4b,
	0x1e, 0x38, 0xe6, 0x45, 0xf9, 0x5f, 0x82, 0x5e, 0x82, 0x29, 0x5f, 0xa9, 0xdc, 0xb0, 0xfd, 0x22,
	0xe5, 0x23, 0x98, 0x0d, 0xa0, 0x39, 0x4a, 0xd0, 0x2f, 0x01, 0x78, 0x19, 0xed, 0xb6, 0x8a, 0x4f,
	0xa2, 0xfc, 0x83, 0x00, 0x3b, 0x93, 0x40, 0x99, 0x27, 0x63, 0x98, 0xc7, 0xe7, 0x0c, 0xc0, 0x87,
	0x3a, 0x35, 0x34, 0xff, 0xbd, 0x33, 0x29, 0x24, 0xe2, 0xef, 0x12, 0xa4, 0xe8, 0x63, 0xdb, 0x22,
	0xd5, 0x36, 0xb1, 0x48, 0x93, 0xe5, 0xc6, 0x07, 0xbd, 0x5f, 0xa6, 0xc4, 0xb6, 0x4d, 0xb1, 0x4b,
	0xf9, 0x8b, 0xcf, 0x10, 0x6e, 0x57, 0x8d, 0x7a, 0xc4, 0x67, 0x00, 0x44, 0x87, 0x3a, 0x7f, 0x8f,
	0x3b, 0x7f, 0x0b, 0x89, 0xb8, 0x84, 0x0d, 0xc8, 0x8a, 0x08, 0x9c, 0x70, 0xda, 0xdc, 0x6a, 0x68,
	0x0b, 0x0a, 0x6d, 0xc1, 0x6f, 0x41, 0xd2, 0xcd, 0x5e, 0x6c, 0xd0, 0xec, 0xb9, 0x1b, 0x94, 0x9f,
	0xf8, 0x13, 0x3f, 0x98, 0xb8, 0xa3, 0xf4, 0xe5, 0x16, 0x60, 0x07, 0xa8, 0xd6, 0x43, 0xdf, 0x45,
	0x15, 0x7a, 0xe2, 0xb9, 0x8b, 0x70, 0xac, 0xea, 0x8c, 0x1e, 0x92, 0x30, 0xe5, 0x4f, 0x04, 0x33,
	0x42, 0x8f, 0x7b, 0xa3, 0xc7, 0xb7, 0xb4, 0x9f, 0x22, 0xc0, 0xfe, 0x38, 0x8e, 0x92, 0xe9, 0xd7,
	0x9d, 0x0f, 0xb2, 0x13, 0x49, 0x66, 0xed, 0xac, 0x74, 0x8f, 0xcf, 0x99, 0xa3, 0xad, 0xfc, 0x8b,
	0x20, 0x5d, 0x6e, 0x31, 0x6a, 0xd9, 0xa3, 0x3f, 0x8f, 0xe0, 0xd7, 0x60, 0xc2, 0x32, 0xf7, 0xaa,
	0x1a, 0xb1, 0x89, 0x7b, 0x2f, 0x9c, 0x94, 0xc2, 0x2b, 0x1a, 0x66, 0x4d, 0x3d, 0x61, 0x99, 0x7b,
	0x25, 0x62, 0x13, 0x7c, 0x0a, 0x26, 0x1b, 0x84, 0x35, 0xaa, 0x1f, 0xd3, 0x7d, 0x96, 0x4b, 0x2e,
	0xc5, 0x0b, 0x69, 0x75, 0x82, 0x0b, 0xee, 0xd2, 0x7d, 0xa6, 0x7c, 0x8e, 0x20, 0xd3, 0x8d, 0xdf,
	0x4d, 0xff, 0x59, 0x98, 0xb2, 0xcc, 0xbd, 0x72, 0xa9, 0x5a, 0xa3, 0x3b, 0x7a, 0x4b, 0xe4, 0x21,
	0xae, 0x82, 0x10, 0x15, 0xb9, 0x84, 0x1b, 0x74, 0x14, 0x68, 0x4b, 0x73, 0xef, 0xfe, 0x09, 0x21,
	0xb8, 0xd5, 0xd2, 0x9e, 0xef, 0x93, 0xbc, 0x0b, 0xd9, 0x4d, 0x83, 0xd4, 0x69, 0xc3, 0x34, 0x34,
	0x6a, 0x89, 0x53, 0x89, 0xb3, 0x10, 0xb7, 0xc9, 0x8e, 0x7b, 0xb8, 0xf9, 0x4f, 0xfc, 0x26, 0x24,
	0xec, 0xfd, 0x76, 0xb7, 0xc2, 0xaf, 0x48, 0x8f, 0x8f, 0xcf, 0xcc, 0xd6, 0x7e, 0x9b, 0xaa, 0x62,
	0x07, 0x5e, 0x80, 0xa4, 0x20, 0x93, 0x38, 0xa8, 0x78, 0x21, 0xa5, 0xba, 0x2b, 0xe5, 0x51, 0xc0,
	0xef, 0xba, 0x65, 0x76, 0xda, 0xb8, 0x0c, 0xa9, 0x76, 0x4f, 0xd6, 0x1d, 0xf0, 0xce, 0xf7, 0xf3,
	0x26, 0x40, 0xab, 0x81, 0xad, 0xca, 0xdf, 0x08, 0xd2, 0x15, 0x4a, 0xac, 0x7a, 0xe3, 0x38, 0xcc,
	0xe8, 0x3c, 0xe3, 0x1a, 0x33, 0xdc, 0x63, 0xca, 0x7f, 0xe2, 0xcb, 0x30, 0xe3, 0x0b, 0xa8, 0xba,
	0xc3, 0x13, 0x94, 0x4b, 0x0a, 0x4e, 0x34, 0xdb, 0x0e, 0x25, 0x4e, 0xb9, 0x0b, 0x89, 0x3b, 0xba,
	0x2d, 0xcc, 0xf0, 0x8f, 0x30, 0x12, 0x1f, 0x61, 0xfe, 0x13, 0x9f, 0xf4, 0xf5, 0x6d, 0x4c, 0x14,
	0xc0, 0x6b, 0x4e, 0x41, 0xb5, 0x9a, 0x96, 0x5b, 0x99, 0x98, 0xea, 0xae, 0x94, 0x77, 0x7b, 0x99,
	0x63, 0x1d, 0x23, 0x30, 0x37, 0x3f, 0xc3, 0xa5, 0x80, 0x21, 0xd1, 0xd0, 0x6d, 0xe6, 0x3a, 0x15,
	0xbf, 0x95, 0xcf, 0x10, 0xa4, 0x6e, 0x1b, 0x1d, 0x36, 0xcc, 0x9a, 0x5c, 0xba, 0x0e, 0xd3, 0xa1,
	0x4e, 0xc5, 0x13, 0x90, 0xd8, 0x78, 0xb0, 0x71, 0x2b, 0x3b, 0x86, 0x67, 0x20, 0xfd, 0xf0, 0xd6,
	0xcd, 0xad, 0x07, 0x6a, 0xb5, 0x58, 0xde, 0xb8, 0xa1, 0x6e, 0x67, 0x35, 0x9c, 0x85, 0x94, 0x2b,
	0xba, 0x7d, 0xef, 0xc1, 0x8d, 0xad, 0x2c, 0x5d, 0xfb, 0x31, 0x0b, 0xe9, 0xfb, 0x02, 0x69, 0x85,
	0x5a, 0xbb, 0x7a, 0x9d, 0xe2, 0x2a, 0x64, 0xc3, 0x1c, 0x3a, 0xbe, 0x22, 0x6d, 0xdb, 0x08, 0xaa,
	0x3d, 0x7f, 0x58, 0x4e, 0x95, 0x31, 0xfc, 0x3e, 0x64, 0x82, 0xec, 0x37, 0xbe, 0x24, 0x35, 0x2f,
	0xa5, 0xc8, 0xfb, 0x19, 0xaf, 0x42, 0x3a, 0xc0, 0x66, 0xe3, 0x8b, 0x52, 0xdb, 0x32, 0xc6, 0x3b,
	0x7f, 0x4e, 0xaa, 0xea, 0x27, 0xa4, 0x1d, 0xf4, 0x41, 0x86, 0x34, 0x02, 0xbd, 0x94, 0x46, 0xed,
	0x87, 0x9e, 0xc0, 0xcc, 0x01, 0xc2, 0x13, 0x5f, 0x95, 0xda, 0x8f, 0x22, 0x46, 0xfb, 0xb9, 0xd8,
	0x03, 0x7c, 0x90, 0x74, 0xc6, 0x2b, 0xf2, 0x0a, 0x44, 0xf1, 0xe5, 0xf9, 0xd5, 0x81, 0xf5, 0xbd,
	0xc4, 0xed, 0xc2, 0xe2, 0x3a, 0xb5, 0x83, 0x7c, 0xa5, 0xce, 0x6c, 0xbd, 0xce, 0xf0, 0x65, 0x79,
	0x7b, 0x49, 0x99, 0xd6, 0xfc, 0x95, 0xc1, 0x94, 0x3d, 0xbf, 0x06, 0x4c, 0x07, 0x79, 0x43, 0x16,
	0x51, 0x31, 0x29, 0x83, 0x99, 0xbf, 0x3c, 0x90, 0xae, 0xe7, 0xed, 0x11, 0x4c, 0x87, 0xa8, 0xc2,
	0xa8, 0xe8, 0xa4, 0x84, 0x62, 0xbf, 0xea, 0x6d, 0x43, 0x3a, 0xc0, 0xe9, 0x45, 0xb4, 0xb7, 0x8c,
	0xf7, 0xeb, 0x67, 0xfa, 0x11, 0xa4, 0xfc, 0xd4, 0x1b, 0x2e, 0x44, 0x1d, 0x9c, 0x03, 0x86, 0x07,
	0x3a, 0x37, 0xdb, 0xce, 0xb9, 0xf1, 0x36, 0xb3, 0x08, 0x07, 0x12, 0x2e, 0xad, 0x1f, 0xf2, 0x0f,
	0xbc, 0x53, 0xe3, 0xb3, 0x7e, 0xe5, 0xb0, 0x53, 0xf3, 0xac, 0xb9, 0x61, 0xb0, 0xb0, 0x4e, 0xed,
	0x00, 0x87, 0xe3, 0xb6, 0xae, 0xbc, 0x95, 0xa4, 0x14, 0x55, 0x44, 0x2b, 0xc9, 0x99, 0x21, 0x65,
	0x0c, 0xeb, 0x90, 0x09, 0x70, 0x1f, 0x2c, 0xa2, 0xd8, 0x32, 0x46, 0x27, 0x7f, 0x69, 0x10, 0x55,
	0xcf, 0xd5, 0x3b, 0x30, 0xe5, 0x7b, 0xd6, 0xe2, 0xe5, 0x43, 0x3a, 0xd6, 0xff, 0x0c, 0xec, 0x97,
	0xb6, 0x06, 0xa4, 0x03, 0x8f, 0xa0, 0xa8, 0x6e, 0x95, 0xbc, 0x30, 0x23, 0x02, 0x90, 0xbe, 0xa9,
	0x94, 0x31, 0x5c, 0x83, 0xf4, 0x3a, 0xb5, 0x7b, 0x73, 0x39, 0xbe, 0x10, 0xfd, 0x2a, 0xf2, 0xbf,
	0x76, 0xf2, 0xcb, 0x7d, 0xf5, 0x3c, 0x1f, 0x15, 0x48, 0x3a, 0x23, 0x2e, 0x56, 0x22, 0x36, 0xf9,
	0xe6, 0xff, 0xfc, 0xcb, 0x87, 0xea, 0x78, 0x46, 0x55, 0x48, 0x3a, 0x03, 0x4a, 0x84, 0xd1, 0xc0,
	0xdc, 0x97, 0x3f, 0x5c, 0x47, 0x4c, 0x38, 0xca, 0x18, 0x2e, 0xc3, 0xb8, 0x98, 0x4c, 0xb0, 0xfc,
	0x60, 0xfa, 0xa7, 0x96, 0x3e, 0x15, 0x2c, 0x16, 0xdf, 0xbb, 0xbe, 0xa3, 0xdb, 0x8d, 0x4e, 0x8d,
	0xff, 0xb3, 0xfa, 0x44, 0x37, 0x0c, 0xfd, 0x89, 0x4d, 0xeb, 0x8d, 0x55, 0x67, 0xd7, 0x55, 0x4d,
	0x67, 0xb6, 0xa5, 0xd7, 0x3a, 0x36, 0xd5, 0x56, 0xf5, 0x96, 0x4d, 0xad, 0x16, 0x31, 0x56, 0x85,
	0x29, 0x57, 0xa3, 0x5d, 0xab, 0x25, 0xc5, 0xfa, 0xda, 0x7f, 0x01, 0x00, 0x00, 0xff, 0xff, 0xa4,
	0x89, 0x87, 0x99, 0xdd, 0x1f, 0x00, 0x00,
}

// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4

// MilvusServiceClient is the client API for MilvusService service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type MilvusServiceClient interface {
	CreateCollection(ctx context.Context, in *CreateCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	DropCollection(ctx context.Context, in *DropCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	HasCollection(ctx context.Context, in *HasCollectionRequest, opts ...grpc.CallOption) (*BoolResponse, error)
	LoadCollection(ctx context.Context, in *LoadCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	ReleaseCollection(ctx context.Context, in *ReleaseCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	DescribeCollection(ctx context.Context, in *DescribeCollectionRequest, opts ...grpc.CallOption) (*DescribeCollectionResponse, error)
	GetCollectionStatistics(ctx context.Context, in *CollectionStatsRequest, opts ...grpc.CallOption) (*CollectionStatsResponse, error)
	ShowCollections(ctx context.Context, in *ShowCollectionRequest, opts ...grpc.CallOption) (*ShowCollectionResponse, error)
	CreatePartition(ctx context.Context, in *CreatePartitionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	DropPartition(ctx context.Context, in *DropPartitionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	HasPartition(ctx context.Context, in *HasPartitionRequest, opts ...grpc.CallOption) (*BoolResponse, error)
	LoadPartitions(ctx context.Context, in *LoadPartitonRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	ReleasePartitions(ctx context.Context, in *ReleasePartitionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	GetPartitionStatistics(ctx context.Context, in *PartitionStatsRequest, opts ...grpc.CallOption) (*PartitionStatsResponse, error)
	ShowPartitions(ctx context.Context, in *ShowPartitionRequest, opts ...grpc.CallOption) (*ShowPartitionResponse, error)
	CreateIndex(ctx context.Context, in *CreateIndexRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	DescribeIndex(ctx context.Context, in *DescribeIndexRequest, opts ...grpc.CallOption) (*DescribeIndexResponse, error)
	GetIndexState(ctx context.Context, in *IndexStateRequest, opts ...grpc.CallOption) (*IndexStateResponse, error)
	Insert(ctx context.Context, in *InsertRequest, opts ...grpc.CallOption) (*InsertResponse, error)
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResults, error)
	Flush(ctx context.Context, in *FlushRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
}

type milvusServiceClient struct {
	cc *grpc.ClientConn
}

func NewMilvusServiceClient(cc *grpc.ClientConn) MilvusServiceClient {
	return &milvusServiceClient{cc}
}

func (c *milvusServiceClient) CreateCollection(ctx context.Context, in *CreateCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error) {
	out := new(commonpb.Status)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/CreateCollection", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *milvusServiceClient) DropCollection(ctx context.Context, in *DropCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error) {
	out := new(commonpb.Status)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/DropCollection", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *milvusServiceClient) HasCollection(ctx context.Context, in *HasCollectionRequest, opts ...grpc.CallOption) (*BoolResponse, error) {
	out := new(BoolResponse)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/HasCollection", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *milvusServiceClient) LoadCollection(ctx context.Context, in *LoadCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error) {
	out := new(commonpb.Status)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/LoadCollection", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *milvusServiceClient) ReleaseCollection(ctx context.Context, in *ReleaseCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error) {
	out := new(commonpb.Status)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/ReleaseCollection", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *milvusServiceClient) DescribeCollection(ctx context.Context, in *DescribeCollectionRequest, opts ...grpc.CallOption) (*DescribeCollectionResponse, error) {
	out := new(DescribeCollectionResponse)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/DescribeCollection", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *milvusServiceClient) GetCollectionStatistics(ctx context.Context, in *CollectionStatsRequest, opts ...grpc.CallOption) (*CollectionStatsResponse, error) {
	out := new(CollectionStatsResponse)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/GetCollectionStatistics", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *milvusServiceClient) ShowCollections(ctx context.Context, in *ShowCollectionRequest, opts ...grpc.CallOption) (*ShowCollectionResponse, error) {
	out := new(ShowCollectionResponse)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/ShowCollections", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *milvusServiceClient) CreatePartition(ctx context.Context, in *CreatePartitionRequest, opts ...grpc.CallOption) (*commonpb.Status, error) {
	out := new(commonpb.Status)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/CreatePartition", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *milvusServiceClient) DropPartition(ctx context.Context, in *DropPartitionRequest, opts ...grpc.CallOption) (*commonpb.Status, error) {
	out := new(commonpb.Status)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/DropPartition", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *milvusServiceClient) HasPartition(ctx context.Context, in *HasPartitionRequest, opts ...grpc.CallOption) (*BoolResponse, error) {
	out := new(BoolResponse)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/HasPartition", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *milvusServiceClient) LoadPartitions(ctx context.Context, in *LoadPartitonRequest, opts ...grpc.CallOption) (*commonpb.Status, error) {
	out := new(commonpb.Status)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/LoadPartitions", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *milvusServiceClient) ReleasePartitions(ctx context.Context, in *ReleasePartitionRequest, opts ...grpc.CallOption) (*commonpb.Status, error) {
	out := new(commonpb.Status)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/ReleasePartitions", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *milvusServiceClient) GetPartitionStatistics(ctx context.Context, in *PartitionStatsRequest, opts ...grpc.CallOption) (*PartitionStatsResponse, error) {
	out := new(PartitionStatsResponse)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/GetPartitionStatistics", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *milvusServiceClient) ShowPartitions(ctx context.Context, in *ShowPartitionRequest, opts ...grpc.CallOption) (*ShowPartitionResponse, error) {
	out := new(ShowPartitionResponse)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/ShowPartitions", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *milvusServiceClient) CreateIndex(ctx context.Context, in *CreateIndexRequest, opts ...grpc.CallOption) (*commonpb.Status, error) {
	out := new(commonpb.Status)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/CreateIndex", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *milvusServiceClient) DescribeIndex(ctx context.Context, in *DescribeIndexRequest, opts ...grpc.CallOption) (*DescribeIndexResponse, error) {
	out := new(DescribeIndexResponse)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/DescribeIndex", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *milvusServiceClient) GetIndexState(ctx context.Context, in *IndexStateRequest, opts ...grpc.CallOption) (*IndexStateResponse, error) {
	out := new(IndexStateResponse)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/GetIndexState", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *milvusServiceClient) Insert(ctx context.Context, in *InsertRequest, opts ...grpc.CallOption) (*InsertResponse, error) {
	out := new(InsertResponse)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/Insert", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *milvusServiceClient) Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResults, error) {
	out := new(SearchResults)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/Search", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *milvusServiceClient) Flush(ctx context.Context, in *FlushRequest, opts ...grpc.CallOption) (*commonpb.Status, error) {
	out := new(commonpb.Status)
	err := c.cc.Invoke(ctx, "/milvus.proto.milvus.MilvusService/Flush", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// MilvusServiceServer is the server API for MilvusService service.
type MilvusServiceServer interface {
	CreateCollection(context.Context, *CreateCollectionRequest) (*commonpb.Status, error)
	DropCollection(context.Context, *DropCollectionRequest) (*commonpb.Status, error)
	HasCollection(context.Context, *HasCollectionRequest) (*BoolResponse, error)
	LoadCollection(context.Context, *LoadCollectionRequest) (*commonpb.Status, error)
	ReleaseCollection(context.Context, *ReleaseCollectionRequest) (*commonpb.Status, error)
	DescribeCollection(context.Context, *DescribeCollectionRequest) (*DescribeCollectionResponse, error)
	GetCollectionStatistics(context.Context, *CollectionStatsRequest) (*CollectionStatsResponse, error)
	ShowCollections(context.Context, *ShowCollectionRequest) (*ShowCollectionResponse, error)
	CreatePartition(context.Context, *CreatePartitionRequest) (*commonpb.Status, error)
	DropPartition(context.Context, *DropPartitionRequest) (*commonpb.Status, error)
	HasPartition(context.Context, *HasPartitionRequest) (*BoolResponse, error)
	LoadPartitions(context.Context, *LoadPartitonRequest) (*commonpb.Status, error)
	ReleasePartitions(context.Context, *ReleasePartitionRequest) (*commonpb.Status, error)
	GetPartitionStatistics(context.Context, *PartitionStatsRequest) (*PartitionStatsResponse, error)
	ShowPartitions(context.Context, *ShowPartitionRequest) (*ShowPartitionResponse, error)
	CreateIndex(context.Context, *CreateIndexRequest) (*commonpb.Status, error)
	DescribeIndex(context.Context, *DescribeIndexRequest) (*DescribeIndexResponse, error)
	GetIndexState(context.Context, *IndexStateRequest) (*IndexStateResponse, error)
	Insert(context.Context, *InsertRequest) (*InsertResponse, error)
	Search(context.Context, *SearchRequest) (*SearchResults, error)
	Flush(context.Context, *FlushRequest) (*commonpb.Status, error)
}

// UnimplementedMilvusServiceServer can be embedded to have forward compatible implementations.
type UnimplementedMilvusServiceServer struct {
}

func (*UnimplementedMilvusServiceServer) CreateCollection(ctx context.Context, req *CreateCollectionRequest) (*commonpb.Status, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateCollection not implemented")
}
func (*UnimplementedMilvusServiceServer) DropCollection(ctx context.Context, req *DropCollectionRequest) (*commonpb.Status, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DropCollection not implemented")
}
func (*UnimplementedMilvusServiceServer) HasCollection(ctx context.Context, req *HasCollectionRequest) (*BoolResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method HasCollection not implemented")
}
func (*UnimplementedMilvusServiceServer) LoadCollection(ctx context.Context, req *LoadCollectionRequest) (*commonpb.Status, error) {
	return nil, status.Errorf(codes.Unimplemented, "method LoadCollection not implemented")
}
func (*UnimplementedMilvusServiceServer) ReleaseCollection(ctx context.Context, req *ReleaseCollectionRequest) (*commonpb.Status, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ReleaseCollection not implemented")
}
func (*UnimplementedMilvusServiceServer) DescribeCollection(ctx context.Context, req *DescribeCollectionRequest) (*DescribeCollectionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DescribeCollection not implemented")
}
func (*UnimplementedMilvusServiceServer) GetCollectionStatistics(ctx context.Context, req *CollectionStatsRequest) (*CollectionStatsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetCollectionStatistics not implemented")
}
func (*UnimplementedMilvusServiceServer) ShowCollections(ctx context.Context, req *ShowCollectionRequest) (*ShowCollectionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ShowCollections not implemented")
}
func (*UnimplementedMilvusServiceServer) CreatePartition(ctx context.Context, req *CreatePartitionRequest) (*commonpb.Status, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreatePartition not implemented")
}
func (*UnimplementedMilvusServiceServer) DropPartition(ctx context.Context, req *DropPartitionRequest) (*commonpb.Status, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DropPartition not implemented")
}
func (*UnimplementedMilvusServiceServer) HasPartition(ctx context.Context, req *HasPartitionRequest) (*BoolResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method HasPartition not implemented")
}
func (*UnimplementedMilvusServiceServer) LoadPartitions(ctx context.Context, req *LoadPartitonRequest) (*commonpb.Status, error) {
	return nil, status.Errorf(codes.Unimplemented, "method LoadPartitions not implemented")
}
func (*UnimplementedMilvusServiceServer) ReleasePartitions(ctx context.Context, req *ReleasePartitionRequest) (*commonpb.Status, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ReleasePartitions not implemented")
}
func (*UnimplementedMilvusServiceServer) GetPartitionStatistics(ctx context.Context, req *PartitionStatsRequest) (*PartitionStatsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetPartitionStatistics not implemented")
}
func (*UnimplementedMilvusServiceServer) ShowPartitions(ctx context.Context, req *ShowPartitionRequest) (*ShowPartitionResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ShowPartitions not implemented")
}
func (*UnimplementedMilvusServiceServer) CreateIndex(ctx context.Context, req *CreateIndexRequest) (*commonpb.Status, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateIndex not implemented")
}
func (*UnimplementedMilvusServiceServer) DescribeIndex(ctx context.Context, req *DescribeIndexRequest) (*DescribeIndexResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DescribeIndex not implemented")
}
func (*UnimplementedMilvusServiceServer) GetIndexState(ctx context.Context, req *IndexStateRequest) (*IndexStateResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetIndexState not implemented")
}
func (*UnimplementedMilvusServiceServer) Insert(ctx context.Context, req *InsertRequest) (*InsertResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Insert not implemented")
}
func (*UnimplementedMilvusServiceServer) Search(ctx context.Context, req *SearchRequest) (*SearchResults, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Search not implemented")
}
func (*UnimplementedMilvusServiceServer) Flush(ctx context.Context, req *FlushRequest) (*commonpb.Status, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Flush not implemented")
}

func RegisterMilvusServiceServer(s *grpc.Server, srv MilvusServiceServer) {
	s.RegisterService(&_MilvusService_serviceDesc, srv)
}

func _MilvusService_CreateCollection_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateCollectionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).CreateCollection(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/CreateCollection",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).CreateCollection(ctx, req.(*CreateCollectionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _MilvusService_DropCollection_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DropCollectionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).DropCollection(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/DropCollection",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).DropCollection(ctx, req.(*DropCollectionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _MilvusService_HasCollection_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(HasCollectionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).HasCollection(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/HasCollection",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).HasCollection(ctx, req.(*HasCollectionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _MilvusService_LoadCollection_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(LoadCollectionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).LoadCollection(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/LoadCollection",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).LoadCollection(ctx, req.(*LoadCollectionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _MilvusService_ReleaseCollection_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ReleaseCollectionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).ReleaseCollection(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/ReleaseCollection",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).ReleaseCollection(ctx, req.(*ReleaseCollectionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _MilvusService_DescribeCollection_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DescribeCollectionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).DescribeCollection(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/DescribeCollection",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).DescribeCollection(ctx, req.(*DescribeCollectionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _MilvusService_GetCollectionStatistics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CollectionStatsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).GetCollectionStatistics(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/GetCollectionStatistics",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).GetCollectionStatistics(ctx, req.(*CollectionStatsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _MilvusService_ShowCollections_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ShowCollectionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).ShowCollections(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/ShowCollections",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).ShowCollections(ctx, req.(*ShowCollectionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _MilvusService_CreatePartition_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreatePartitionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).CreatePartition(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/CreatePartition",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).CreatePartition(ctx, req.(*CreatePartitionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _MilvusService_DropPartition_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DropPartitionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).DropPartition(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/DropPartition",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).DropPartition(ctx, req.(*DropPartitionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _MilvusService_HasPartition_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(HasPartitionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).HasPartition(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/HasPartition",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).HasPartition(ctx, req.(*HasPartitionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _MilvusService_LoadPartitions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(LoadPartitonRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).LoadPartitions(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/LoadPartitions",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).LoadPartitions(ctx, req.(*LoadPartitonRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _MilvusService_ReleasePartitions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ReleasePartitionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).ReleasePartitions(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/ReleasePartitions",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).ReleasePartitions(ctx, req.(*ReleasePartitionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _MilvusService_GetPartitionStatistics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PartitionStatsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).GetPartitionStatistics(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/GetPartitionStatistics",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).GetPartitionStatistics(ctx, req.(*PartitionStatsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _MilvusService_ShowPartitions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ShowPartitionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).ShowPartitions(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/ShowPartitions",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).ShowPartitions(ctx, req.(*ShowPartitionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _MilvusService_CreateIndex_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateIndexRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).CreateIndex(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/CreateIndex",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).CreateIndex(ctx, req.(*CreateIndexRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _MilvusService_DescribeIndex_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DescribeIndexRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).DescribeIndex(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/DescribeIndex",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).DescribeIndex(ctx, req.(*DescribeIndexRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _MilvusService_GetIndexState_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IndexStateRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).GetIndexState(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/GetIndexState",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).GetIndexState(ctx, req.(*IndexStateRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _MilvusService_Insert_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(InsertRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).Insert(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/Insert",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).Insert(ctx, req.(*InsertRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _MilvusService_Search_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SearchRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).Search(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/Search",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).Search(ctx, req.(*SearchRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _MilvusService_Flush_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(FlushRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(MilvusServiceServer).Flush(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/milvus.proto.milvus.MilvusService/Flush",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(MilvusServiceServer).Flush(ctx, req.(*FlushRequest))
	}
	return interceptor(ctx, in, info, handler)
}

var _MilvusService_serviceDesc = grpc.ServiceDesc{
	ServiceName: "milvus.proto.milvus.MilvusService",
	HandlerType: (*MilvusServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateCollection",
			Handler:    _MilvusService_CreateCollection_Handler,
		},
		{
			MethodName: "DropCollection",
			Handler:    _MilvusService_DropCollection_Handler,
		},
		{
			MethodName: "HasCollection",
			Handler:    _MilvusService_HasCollection_Handler,
		},
		{
			MethodName: "LoadCollection",
			Handler:    _MilvusService_LoadCollection_Handler,
		},
		{
			MethodName: "ReleaseCollection",
			Handler:    _MilvusService_ReleaseCollection_Handler,
		},
		{
			MethodName: "DescribeCollection",
			Handler:    _MilvusService_DescribeCollection_Handler,
		},
		{
			MethodName: "GetCollectionStatistics",
			Handler:    _MilvusService_GetCollectionStatistics_Handler,
		},
		{
			MethodName: "ShowCollections",
			Handler:    _MilvusService_ShowCollections_Handler,
		},
		{
			MethodName: "CreatePartition",
			Handler:    _MilvusService_CreatePartition_Handler,
		},
		{
			MethodName: "DropPartition",
			Handler:    _MilvusService_DropPartition_Handler,
		},
		{
			MethodName: "HasPartition",
			Handler:    _MilvusService_HasPartition_Handler,
		},
		{
			MethodName: "LoadPartitions",
			Handler:    _MilvusService_LoadPartitions_Handler,
		},
		{
			MethodName: "ReleasePartitions",
			Handler:    _MilvusService_ReleasePartitions_Handler,
		},
		{
			MethodName: "GetPartitionStatistics",
			Handler:    _MilvusService_GetPartitionStatistics_Handler,
		},
		{
			MethodName: "ShowPartitions",
			Handler:    _MilvusService_ShowPartitions_Handler,
		},
		{
			MethodName: "CreateIndex",
			Handler:    _MilvusService_CreateIndex_Handler,
		},
		{
			MethodName: "DescribeIndex",
			Handler:    _MilvusService_DescribeIndex_Handler,
		},
		{
			MethodName: "GetIndexState",
			Handler:    _MilvusService_GetIndexState_Handler,
		},
		{
			MethodName: "Insert",
			Handler:    _MilvusService_Insert_Handler,
		},
		{
			MethodName: "Search",
			Handler:    _MilvusService_Search_Handler,
		},
		{
			MethodName: "Flush",
			Handler:    _MilvusService_Flush_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "milvus.proto",
}