server

package
Version: v2.0.0-alpha.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 14, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var PlaceholderType_name = map[int32]string{
	0:   "None",
	100: "BinaryVector",
	101: "FloatVector",
}
View Source
var PlaceholderType_value = map[string]int32{
	"None":         0,
	"BinaryVector": 100,
	"FloatVector":  101,
}
View Source
var ShowType_name = map[int32]string{
	0: "All",
	1: "InMemory",
}
View Source
var ShowType_value = map[string]int32{
	"All":      0,
	"InMemory": 1,
}

Functions

func RegisterMilvusServiceServer

func RegisterMilvusServiceServer(s *grpc.Server, srv MilvusServiceServer)

func RegisterProxyServiceServer

func RegisterProxyServiceServer(s *grpc.Server, srv ProxyServiceServer)

Types

type BoolResponse

type BoolResponse struct {
	Status               *common.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 (*BoolResponse) Descriptor

func (*BoolResponse) Descriptor() ([]byte, []int)

func (*BoolResponse) GetStatus

func (m *BoolResponse) GetStatus() *common.Status

func (*BoolResponse) GetValue

func (m *BoolResponse) GetValue() bool

func (*BoolResponse) ProtoMessage

func (*BoolResponse) ProtoMessage()

func (*BoolResponse) Reset

func (m *BoolResponse) Reset()

func (*BoolResponse) String

func (m *BoolResponse) String() string

func (*BoolResponse) XXX_DiscardUnknown

func (m *BoolResponse) XXX_DiscardUnknown()

func (*BoolResponse) XXX_Marshal

func (m *BoolResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BoolResponse) XXX_Merge

func (m *BoolResponse) XXX_Merge(src proto.Message)

func (*BoolResponse) XXX_Size

func (m *BoolResponse) XXX_Size() int

func (*BoolResponse) XXX_Unmarshal

func (m *BoolResponse) XXX_Unmarshal(b []byte) error

type CalcDistanceRequest

type CalcDistanceRequest struct {
	Base                 *common.MsgBase        `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	OpLeft               *VectorsArray          `protobuf:"bytes,2,opt,name=op_left,json=opLeft,proto3" json:"op_left,omitempty"`
	OpRight              *VectorsArray          `protobuf:"bytes,3,opt,name=op_right,json=opRight,proto3" json:"op_right,omitempty"`
	Params               []*common.KeyValuePair `protobuf:"bytes,4,rep,name=params,proto3" json:"params,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*CalcDistanceRequest) Descriptor

func (*CalcDistanceRequest) Descriptor() ([]byte, []int)

func (*CalcDistanceRequest) GetBase

func (m *CalcDistanceRequest) GetBase() *common.MsgBase

func (*CalcDistanceRequest) GetOpLeft

func (m *CalcDistanceRequest) GetOpLeft() *VectorsArray

func (*CalcDistanceRequest) GetOpRight

func (m *CalcDistanceRequest) GetOpRight() *VectorsArray

func (*CalcDistanceRequest) GetParams

func (m *CalcDistanceRequest) GetParams() []*common.KeyValuePair

func (*CalcDistanceRequest) ProtoMessage

func (*CalcDistanceRequest) ProtoMessage()

func (*CalcDistanceRequest) Reset

func (m *CalcDistanceRequest) Reset()

func (*CalcDistanceRequest) String

func (m *CalcDistanceRequest) String() string

func (*CalcDistanceRequest) XXX_DiscardUnknown

func (m *CalcDistanceRequest) XXX_DiscardUnknown()

func (*CalcDistanceRequest) XXX_Marshal

func (m *CalcDistanceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CalcDistanceRequest) XXX_Merge

func (m *CalcDistanceRequest) XXX_Merge(src proto.Message)

func (*CalcDistanceRequest) XXX_Size

func (m *CalcDistanceRequest) XXX_Size() int

func (*CalcDistanceRequest) XXX_Unmarshal

func (m *CalcDistanceRequest) XXX_Unmarshal(b []byte) error

type CalcDistanceResults

type CalcDistanceResults struct {
	Status *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// num(op_left)*num(op_right) distance values, "HAMMIN" return integer distance
	//
	// Types that are valid to be assigned to Array:
	//	*CalcDistanceResults_IntDist
	//	*CalcDistanceResults_FloatDist
	Array                isCalcDistanceResults_Array `protobuf_oneof:"array"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*CalcDistanceResults) Descriptor

func (*CalcDistanceResults) Descriptor() ([]byte, []int)

func (*CalcDistanceResults) GetArray

func (m *CalcDistanceResults) GetArray() isCalcDistanceResults_Array

func (*CalcDistanceResults) GetFloatDist

func (m *CalcDistanceResults) GetFloatDist() *schema.FloatArray

func (*CalcDistanceResults) GetIntDist

func (m *CalcDistanceResults) GetIntDist() *schema.IntArray

func (*CalcDistanceResults) GetStatus

func (m *CalcDistanceResults) GetStatus() *common.Status

func (*CalcDistanceResults) ProtoMessage

func (*CalcDistanceResults) ProtoMessage()

func (*CalcDistanceResults) Reset

func (m *CalcDistanceResults) Reset()

func (*CalcDistanceResults) String

func (m *CalcDistanceResults) String() string

func (*CalcDistanceResults) XXX_DiscardUnknown

func (m *CalcDistanceResults) XXX_DiscardUnknown()

func (*CalcDistanceResults) XXX_Marshal

func (m *CalcDistanceResults) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CalcDistanceResults) XXX_Merge

func (m *CalcDistanceResults) XXX_Merge(src proto.Message)

func (*CalcDistanceResults) XXX_OneofWrappers

func (*CalcDistanceResults) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*CalcDistanceResults) XXX_Size

func (m *CalcDistanceResults) XXX_Size() int

func (*CalcDistanceResults) XXX_Unmarshal

func (m *CalcDistanceResults) XXX_Unmarshal(b []byte) error

type CalcDistanceResults_FloatDist

type CalcDistanceResults_FloatDist struct {
	FloatDist *schema.FloatArray `protobuf:"bytes,3,opt,name=float_dist,json=floatDist,proto3,oneof"`
}

type CalcDistanceResults_IntDist

type CalcDistanceResults_IntDist struct {
	IntDist *schema.IntArray `protobuf:"bytes,2,opt,name=int_dist,json=intDist,proto3,oneof"`
}

type CreateCollectionRequest

type CreateCollectionRequest struct {
	Base           *common.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"`
	// `schema` is the serialized `schema.CollectionSchema`
	Schema               []byte   `protobuf:"bytes,4,opt,name=schema,proto3" json:"schema,omitempty"`
	ShardsNum            int32    `protobuf:"varint,5,opt,name=shards_num,json=shardsNum,proto3" json:"shards_num,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateCollectionRequest) Descriptor

func (*CreateCollectionRequest) Descriptor() ([]byte, []int)

func (*CreateCollectionRequest) GetBase

func (m *CreateCollectionRequest) GetBase() *common.MsgBase

func (*CreateCollectionRequest) GetCollectionName

func (m *CreateCollectionRequest) GetCollectionName() string

func (*CreateCollectionRequest) GetDbName

func (m *CreateCollectionRequest) GetDbName() string

func (*CreateCollectionRequest) GetSchema

func (m *CreateCollectionRequest) GetSchema() []byte

func (*CreateCollectionRequest) GetShardsNum

func (m *CreateCollectionRequest) GetShardsNum() int32

func (*CreateCollectionRequest) ProtoMessage

func (*CreateCollectionRequest) ProtoMessage()

func (*CreateCollectionRequest) Reset

func (m *CreateCollectionRequest) Reset()

func (*CreateCollectionRequest) String

func (m *CreateCollectionRequest) String() string

func (*CreateCollectionRequest) XXX_DiscardUnknown

func (m *CreateCollectionRequest) XXX_DiscardUnknown()

func (*CreateCollectionRequest) XXX_Marshal

func (m *CreateCollectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateCollectionRequest) XXX_Merge

func (m *CreateCollectionRequest) XXX_Merge(src proto.Message)

func (*CreateCollectionRequest) XXX_Size

func (m *CreateCollectionRequest) XXX_Size() int

func (*CreateCollectionRequest) XXX_Unmarshal

func (m *CreateCollectionRequest) XXX_Unmarshal(b []byte) error

type CreateIndexRequest

type CreateIndexRequest struct {
	Base                 *common.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          []*common.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 (*CreateIndexRequest) Descriptor

func (*CreateIndexRequest) Descriptor() ([]byte, []int)

func (*CreateIndexRequest) GetBase

func (m *CreateIndexRequest) GetBase() *common.MsgBase

func (*CreateIndexRequest) GetCollectionName

func (m *CreateIndexRequest) GetCollectionName() string

func (*CreateIndexRequest) GetDbName

func (m *CreateIndexRequest) GetDbName() string

func (*CreateIndexRequest) GetExtraParams

func (m *CreateIndexRequest) GetExtraParams() []*common.KeyValuePair

func (*CreateIndexRequest) GetFieldName

func (m *CreateIndexRequest) GetFieldName() string

func (*CreateIndexRequest) ProtoMessage

func (*CreateIndexRequest) ProtoMessage()

func (*CreateIndexRequest) Reset

func (m *CreateIndexRequest) Reset()

func (*CreateIndexRequest) String

func (m *CreateIndexRequest) String() string

func (*CreateIndexRequest) XXX_DiscardUnknown

func (m *CreateIndexRequest) XXX_DiscardUnknown()

func (*CreateIndexRequest) XXX_Marshal

func (m *CreateIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateIndexRequest) XXX_Merge

func (m *CreateIndexRequest) XXX_Merge(src proto.Message)

func (*CreateIndexRequest) XXX_Size

func (m *CreateIndexRequest) XXX_Size() int

func (*CreateIndexRequest) XXX_Unmarshal

func (m *CreateIndexRequest) XXX_Unmarshal(b []byte) error

type CreatePartitionRequest

type CreatePartitionRequest struct {
	Base                 *common.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 (*CreatePartitionRequest) Descriptor

func (*CreatePartitionRequest) Descriptor() ([]byte, []int)

func (*CreatePartitionRequest) GetBase

func (m *CreatePartitionRequest) GetBase() *common.MsgBase

func (*CreatePartitionRequest) GetCollectionName

func (m *CreatePartitionRequest) GetCollectionName() string

func (*CreatePartitionRequest) GetDbName

func (m *CreatePartitionRequest) GetDbName() string

func (*CreatePartitionRequest) GetPartitionName

func (m *CreatePartitionRequest) GetPartitionName() string

func (*CreatePartitionRequest) ProtoMessage

func (*CreatePartitionRequest) ProtoMessage()

func (*CreatePartitionRequest) Reset

func (m *CreatePartitionRequest) Reset()

func (*CreatePartitionRequest) String

func (m *CreatePartitionRequest) String() string

func (*CreatePartitionRequest) XXX_DiscardUnknown

func (m *CreatePartitionRequest) XXX_DiscardUnknown()

func (*CreatePartitionRequest) XXX_Marshal

func (m *CreatePartitionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreatePartitionRequest) XXX_Merge

func (m *CreatePartitionRequest) XXX_Merge(src proto.Message)

func (*CreatePartitionRequest) XXX_Size

func (m *CreatePartitionRequest) XXX_Size() int

func (*CreatePartitionRequest) XXX_Unmarshal

func (m *CreatePartitionRequest) XXX_Unmarshal(b []byte) error

type DeleteRequest

type DeleteRequest struct {
	Base                 *common.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"`
	Expr                 string          `protobuf:"bytes,5,opt,name=expr,proto3" json:"expr,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*DeleteRequest) Descriptor

func (*DeleteRequest) Descriptor() ([]byte, []int)

func (*DeleteRequest) GetBase

func (m *DeleteRequest) GetBase() *common.MsgBase

func (*DeleteRequest) GetCollectionName

func (m *DeleteRequest) GetCollectionName() string

func (*DeleteRequest) GetDbName

func (m *DeleteRequest) GetDbName() string

func (*DeleteRequest) GetExpr

func (m *DeleteRequest) GetExpr() string

func (*DeleteRequest) GetPartitionName

func (m *DeleteRequest) GetPartitionName() string

func (*DeleteRequest) ProtoMessage

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String

func (m *DeleteRequest) String() string

func (*DeleteRequest) XXX_DiscardUnknown

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal

func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteRequest) XXX_Merge

func (m *DeleteRequest) XXX_Merge(src proto.Message)

func (*DeleteRequest) XXX_Size

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal

func (m *DeleteRequest) XXX_Unmarshal(b []byte) error

type DescribeCollectionRequest

type DescribeCollectionRequest struct {
	Base                 *common.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"`
	TimeStamp            uint64          `protobuf:"varint,5,opt,name=time_stamp,json=timeStamp,proto3" json:"time_stamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*DescribeCollectionRequest) Descriptor

func (*DescribeCollectionRequest) Descriptor() ([]byte, []int)

func (*DescribeCollectionRequest) GetBase

func (*DescribeCollectionRequest) GetCollectionID

func (m *DescribeCollectionRequest) GetCollectionID() int64

func (*DescribeCollectionRequest) GetCollectionName

func (m *DescribeCollectionRequest) GetCollectionName() string

func (*DescribeCollectionRequest) GetDbName

func (m *DescribeCollectionRequest) GetDbName() string

func (*DescribeCollectionRequest) GetTimeStamp

func (m *DescribeCollectionRequest) GetTimeStamp() uint64

func (*DescribeCollectionRequest) ProtoMessage

func (*DescribeCollectionRequest) ProtoMessage()

func (*DescribeCollectionRequest) Reset

func (m *DescribeCollectionRequest) Reset()

func (*DescribeCollectionRequest) String

func (m *DescribeCollectionRequest) String() string

func (*DescribeCollectionRequest) XXX_DiscardUnknown

func (m *DescribeCollectionRequest) XXX_DiscardUnknown()

func (*DescribeCollectionRequest) XXX_Marshal

func (m *DescribeCollectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeCollectionRequest) XXX_Merge

func (m *DescribeCollectionRequest) XXX_Merge(src proto.Message)

func (*DescribeCollectionRequest) XXX_Size

func (m *DescribeCollectionRequest) XXX_Size() int

func (*DescribeCollectionRequest) XXX_Unmarshal

func (m *DescribeCollectionRequest) XXX_Unmarshal(b []byte) error

type DescribeCollectionResponse

type DescribeCollectionResponse struct {
	Status               *common.Status           `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Schema               *schema.CollectionSchema `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	CollectionID         int64                    `protobuf:"varint,3,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	VirtualChannelNames  []string                 `protobuf:"bytes,4,rep,name=virtual_channel_names,json=virtualChannelNames,proto3" json:"virtual_channel_names,omitempty"`
	PhysicalChannelNames []string                 `protobuf:"bytes,5,rep,name=physical_channel_names,json=physicalChannelNames,proto3" json:"physical_channel_names,omitempty"`
	CreatedTimestamp     uint64                   `protobuf:"varint,6,opt,name=created_timestamp,json=createdTimestamp,proto3" json:"created_timestamp,omitempty"`
	CreatedUtcTimestamp  uint64                   `protobuf:"varint,7,opt,name=created_utc_timestamp,json=createdUtcTimestamp,proto3" json:"created_utc_timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*DescribeCollectionResponse) Descriptor

func (*DescribeCollectionResponse) Descriptor() ([]byte, []int)

func (*DescribeCollectionResponse) GetCollectionID

func (m *DescribeCollectionResponse) GetCollectionID() int64

func (*DescribeCollectionResponse) GetCreatedTimestamp

func (m *DescribeCollectionResponse) GetCreatedTimestamp() uint64

func (*DescribeCollectionResponse) GetCreatedUtcTimestamp

func (m *DescribeCollectionResponse) GetCreatedUtcTimestamp() uint64

func (*DescribeCollectionResponse) GetPhysicalChannelNames

func (m *DescribeCollectionResponse) GetPhysicalChannelNames() []string

func (*DescribeCollectionResponse) GetSchema

func (*DescribeCollectionResponse) GetStatus

func (m *DescribeCollectionResponse) GetStatus() *common.Status

func (*DescribeCollectionResponse) GetVirtualChannelNames

func (m *DescribeCollectionResponse) GetVirtualChannelNames() []string

func (*DescribeCollectionResponse) ProtoMessage

func (*DescribeCollectionResponse) ProtoMessage()

func (*DescribeCollectionResponse) Reset

func (m *DescribeCollectionResponse) Reset()

func (*DescribeCollectionResponse) String

func (m *DescribeCollectionResponse) String() string

func (*DescribeCollectionResponse) XXX_DiscardUnknown

func (m *DescribeCollectionResponse) XXX_DiscardUnknown()

func (*DescribeCollectionResponse) XXX_Marshal

func (m *DescribeCollectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeCollectionResponse) XXX_Merge

func (m *DescribeCollectionResponse) XXX_Merge(src proto.Message)

func (*DescribeCollectionResponse) XXX_Size

func (m *DescribeCollectionResponse) XXX_Size() int

func (*DescribeCollectionResponse) XXX_Unmarshal

func (m *DescribeCollectionResponse) XXX_Unmarshal(b []byte) error

type DescribeIndexRequest

type DescribeIndexRequest struct {
	Base                 *common.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 (*DescribeIndexRequest) Descriptor

func (*DescribeIndexRequest) Descriptor() ([]byte, []int)

func (*DescribeIndexRequest) GetBase

func (m *DescribeIndexRequest) GetBase() *common.MsgBase

func (*DescribeIndexRequest) GetCollectionName

func (m *DescribeIndexRequest) GetCollectionName() string

func (*DescribeIndexRequest) GetDbName

func (m *DescribeIndexRequest) GetDbName() string

func (*DescribeIndexRequest) GetFieldName

func (m *DescribeIndexRequest) GetFieldName() string

func (*DescribeIndexRequest) GetIndexName

func (m *DescribeIndexRequest) GetIndexName() string

func (*DescribeIndexRequest) ProtoMessage

func (*DescribeIndexRequest) ProtoMessage()

func (*DescribeIndexRequest) Reset

func (m *DescribeIndexRequest) Reset()

func (*DescribeIndexRequest) String

func (m *DescribeIndexRequest) String() string

func (*DescribeIndexRequest) XXX_DiscardUnknown

func (m *DescribeIndexRequest) XXX_DiscardUnknown()

func (*DescribeIndexRequest) XXX_Marshal

func (m *DescribeIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeIndexRequest) XXX_Merge

func (m *DescribeIndexRequest) XXX_Merge(src proto.Message)

func (*DescribeIndexRequest) XXX_Size

func (m *DescribeIndexRequest) XXX_Size() int

func (*DescribeIndexRequest) XXX_Unmarshal

func (m *DescribeIndexRequest) XXX_Unmarshal(b []byte) error

type DescribeIndexResponse

type DescribeIndexResponse struct {
	Status               *common.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 (*DescribeIndexResponse) Descriptor

func (*DescribeIndexResponse) Descriptor() ([]byte, []int)

func (*DescribeIndexResponse) GetIndexDescriptions

func (m *DescribeIndexResponse) GetIndexDescriptions() []*IndexDescription

func (*DescribeIndexResponse) GetStatus

func (m *DescribeIndexResponse) GetStatus() *common.Status

func (*DescribeIndexResponse) ProtoMessage

func (*DescribeIndexResponse) ProtoMessage()

func (*DescribeIndexResponse) Reset

func (m *DescribeIndexResponse) Reset()

func (*DescribeIndexResponse) String

func (m *DescribeIndexResponse) String() string

func (*DescribeIndexResponse) XXX_DiscardUnknown

func (m *DescribeIndexResponse) XXX_DiscardUnknown()

func (*DescribeIndexResponse) XXX_Marshal

func (m *DescribeIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeIndexResponse) XXX_Merge

func (m *DescribeIndexResponse) XXX_Merge(src proto.Message)

func (*DescribeIndexResponse) XXX_Size

func (m *DescribeIndexResponse) XXX_Size() int

func (*DescribeIndexResponse) XXX_Unmarshal

func (m *DescribeIndexResponse) XXX_Unmarshal(b []byte) error

type DescribeSegmentRequest

type DescribeSegmentRequest struct {
	Base                 *common.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 (*DescribeSegmentRequest) Descriptor

func (*DescribeSegmentRequest) Descriptor() ([]byte, []int)

func (*DescribeSegmentRequest) GetBase

func (m *DescribeSegmentRequest) GetBase() *common.MsgBase

func (*DescribeSegmentRequest) GetCollectionID

func (m *DescribeSegmentRequest) GetCollectionID() int64

func (*DescribeSegmentRequest) GetSegmentID

func (m *DescribeSegmentRequest) GetSegmentID() int64

func (*DescribeSegmentRequest) ProtoMessage

func (*DescribeSegmentRequest) ProtoMessage()

func (*DescribeSegmentRequest) Reset

func (m *DescribeSegmentRequest) Reset()

func (*DescribeSegmentRequest) String

func (m *DescribeSegmentRequest) String() string

func (*DescribeSegmentRequest) XXX_DiscardUnknown

func (m *DescribeSegmentRequest) XXX_DiscardUnknown()

func (*DescribeSegmentRequest) XXX_Marshal

func (m *DescribeSegmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeSegmentRequest) XXX_Merge

func (m *DescribeSegmentRequest) XXX_Merge(src proto.Message)

func (*DescribeSegmentRequest) XXX_Size

func (m *DescribeSegmentRequest) XXX_Size() int

func (*DescribeSegmentRequest) XXX_Unmarshal

func (m *DescribeSegmentRequest) XXX_Unmarshal(b []byte) error

type DescribeSegmentResponse

type DescribeSegmentResponse struct {
	Status               *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	IndexID              int64          `protobuf:"varint,2,opt,name=indexID,proto3" json:"indexID,omitempty"`
	BuildID              int64          `protobuf:"varint,3,opt,name=buildID,proto3" json:"buildID,omitempty"`
	EnableIndex          bool           `protobuf:"varint,4,opt,name=enable_index,json=enableIndex,proto3" json:"enable_index,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*DescribeSegmentResponse) Descriptor

func (*DescribeSegmentResponse) Descriptor() ([]byte, []int)

func (*DescribeSegmentResponse) GetBuildID

func (m *DescribeSegmentResponse) GetBuildID() int64

func (*DescribeSegmentResponse) GetEnableIndex

func (m *DescribeSegmentResponse) GetEnableIndex() bool

func (*DescribeSegmentResponse) GetIndexID

func (m *DescribeSegmentResponse) GetIndexID() int64

func (*DescribeSegmentResponse) GetStatus

func (m *DescribeSegmentResponse) GetStatus() *common.Status

func (*DescribeSegmentResponse) ProtoMessage

func (*DescribeSegmentResponse) ProtoMessage()

func (*DescribeSegmentResponse) Reset

func (m *DescribeSegmentResponse) Reset()

func (*DescribeSegmentResponse) String

func (m *DescribeSegmentResponse) String() string

func (*DescribeSegmentResponse) XXX_DiscardUnknown

func (m *DescribeSegmentResponse) XXX_DiscardUnknown()

func (*DescribeSegmentResponse) XXX_Marshal

func (m *DescribeSegmentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeSegmentResponse) XXX_Merge

func (m *DescribeSegmentResponse) XXX_Merge(src proto.Message)

func (*DescribeSegmentResponse) XXX_Size

func (m *DescribeSegmentResponse) XXX_Size() int

func (*DescribeSegmentResponse) XXX_Unmarshal

func (m *DescribeSegmentResponse) XXX_Unmarshal(b []byte) error

type DropCollectionRequest

type DropCollectionRequest struct {
	Base                 *common.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 (*DropCollectionRequest) Descriptor

func (*DropCollectionRequest) Descriptor() ([]byte, []int)

func (*DropCollectionRequest) GetBase

func (m *DropCollectionRequest) GetBase() *common.MsgBase

func (*DropCollectionRequest) GetCollectionName

func (m *DropCollectionRequest) GetCollectionName() string

func (*DropCollectionRequest) GetDbName

func (m *DropCollectionRequest) GetDbName() string

func (*DropCollectionRequest) ProtoMessage

func (*DropCollectionRequest) ProtoMessage()

func (*DropCollectionRequest) Reset

func (m *DropCollectionRequest) Reset()

func (*DropCollectionRequest) String

func (m *DropCollectionRequest) String() string

func (*DropCollectionRequest) XXX_DiscardUnknown

func (m *DropCollectionRequest) XXX_DiscardUnknown()

func (*DropCollectionRequest) XXX_Marshal

func (m *DropCollectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropCollectionRequest) XXX_Merge

func (m *DropCollectionRequest) XXX_Merge(src proto.Message)

func (*DropCollectionRequest) XXX_Size

func (m *DropCollectionRequest) XXX_Size() int

func (*DropCollectionRequest) XXX_Unmarshal

func (m *DropCollectionRequest) XXX_Unmarshal(b []byte) error

type DropIndexRequest

type DropIndexRequest struct {
	Base                 *common.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 (*DropIndexRequest) Descriptor

func (*DropIndexRequest) Descriptor() ([]byte, []int)

func (*DropIndexRequest) GetBase

func (m *DropIndexRequest) GetBase() *common.MsgBase

func (*DropIndexRequest) GetCollectionName

func (m *DropIndexRequest) GetCollectionName() string

func (*DropIndexRequest) GetDbName

func (m *DropIndexRequest) GetDbName() string

func (*DropIndexRequest) GetFieldName

func (m *DropIndexRequest) GetFieldName() string

func (*DropIndexRequest) GetIndexName

func (m *DropIndexRequest) GetIndexName() string

func (*DropIndexRequest) ProtoMessage

func (*DropIndexRequest) ProtoMessage()

func (*DropIndexRequest) Reset

func (m *DropIndexRequest) Reset()

func (*DropIndexRequest) String

func (m *DropIndexRequest) String() string

func (*DropIndexRequest) XXX_DiscardUnknown

func (m *DropIndexRequest) XXX_DiscardUnknown()

func (*DropIndexRequest) XXX_Marshal

func (m *DropIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropIndexRequest) XXX_Merge

func (m *DropIndexRequest) XXX_Merge(src proto.Message)

func (*DropIndexRequest) XXX_Size

func (m *DropIndexRequest) XXX_Size() int

func (*DropIndexRequest) XXX_Unmarshal

func (m *DropIndexRequest) XXX_Unmarshal(b []byte) error

type DropPartitionRequest

type DropPartitionRequest struct {
	Base                 *common.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 (*DropPartitionRequest) Descriptor

func (*DropPartitionRequest) Descriptor() ([]byte, []int)

func (*DropPartitionRequest) GetBase

func (m *DropPartitionRequest) GetBase() *common.MsgBase

func (*DropPartitionRequest) GetCollectionName

func (m *DropPartitionRequest) GetCollectionName() string

func (*DropPartitionRequest) GetDbName

func (m *DropPartitionRequest) GetDbName() string

func (*DropPartitionRequest) GetPartitionName

func (m *DropPartitionRequest) GetPartitionName() string

func (*DropPartitionRequest) ProtoMessage

func (*DropPartitionRequest) ProtoMessage()

func (*DropPartitionRequest) Reset

func (m *DropPartitionRequest) Reset()

func (*DropPartitionRequest) String

func (m *DropPartitionRequest) String() string

func (*DropPartitionRequest) XXX_DiscardUnknown

func (m *DropPartitionRequest) XXX_DiscardUnknown()

func (*DropPartitionRequest) XXX_Marshal

func (m *DropPartitionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropPartitionRequest) XXX_Merge

func (m *DropPartitionRequest) XXX_Merge(src proto.Message)

func (*DropPartitionRequest) XXX_Size

func (m *DropPartitionRequest) XXX_Size() int

func (*DropPartitionRequest) XXX_Unmarshal

func (m *DropPartitionRequest) XXX_Unmarshal(b []byte) error

type DummyRequest

type DummyRequest struct {
	RequestType          string   `protobuf:"bytes,1,opt,name=request_type,json=requestType,proto3" json:"request_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DummyRequest) Descriptor

func (*DummyRequest) Descriptor() ([]byte, []int)

func (*DummyRequest) GetRequestType

func (m *DummyRequest) GetRequestType() string

func (*DummyRequest) ProtoMessage

func (*DummyRequest) ProtoMessage()

func (*DummyRequest) Reset

func (m *DummyRequest) Reset()

func (*DummyRequest) String

func (m *DummyRequest) String() string

func (*DummyRequest) XXX_DiscardUnknown

func (m *DummyRequest) XXX_DiscardUnknown()

func (*DummyRequest) XXX_Marshal

func (m *DummyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DummyRequest) XXX_Merge

func (m *DummyRequest) XXX_Merge(src proto.Message)

func (*DummyRequest) XXX_Size

func (m *DummyRequest) XXX_Size() int

func (*DummyRequest) XXX_Unmarshal

func (m *DummyRequest) XXX_Unmarshal(b []byte) error

type DummyResponse

type DummyResponse struct {
	Response             string   `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DummyResponse) Descriptor

func (*DummyResponse) Descriptor() ([]byte, []int)

func (*DummyResponse) GetResponse

func (m *DummyResponse) GetResponse() string

func (*DummyResponse) ProtoMessage

func (*DummyResponse) ProtoMessage()

func (*DummyResponse) Reset

func (m *DummyResponse) Reset()

func (*DummyResponse) String

func (m *DummyResponse) String() string

func (*DummyResponse) XXX_DiscardUnknown

func (m *DummyResponse) XXX_DiscardUnknown()

func (*DummyResponse) XXX_Marshal

func (m *DummyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DummyResponse) XXX_Merge

func (m *DummyResponse) XXX_Merge(src proto.Message)

func (*DummyResponse) XXX_Size

func (m *DummyResponse) XXX_Size() int

func (*DummyResponse) XXX_Unmarshal

func (m *DummyResponse) XXX_Unmarshal(b []byte) error

type FlushRequest

type FlushRequest struct {
	Base                 *common.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"`
	CollectionNames      []string        `protobuf:"bytes,3,rep,name=collection_names,json=collectionNames,proto3" json:"collection_names,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*FlushRequest) Descriptor

func (*FlushRequest) Descriptor() ([]byte, []int)

func (*FlushRequest) GetBase

func (m *FlushRequest) GetBase() *common.MsgBase

func (*FlushRequest) GetCollectionNames

func (m *FlushRequest) GetCollectionNames() []string

func (*FlushRequest) GetDbName

func (m *FlushRequest) GetDbName() string

func (*FlushRequest) ProtoMessage

func (*FlushRequest) ProtoMessage()

func (*FlushRequest) Reset

func (m *FlushRequest) Reset()

func (*FlushRequest) String

func (m *FlushRequest) String() string

func (*FlushRequest) XXX_DiscardUnknown

func (m *FlushRequest) XXX_DiscardUnknown()

func (*FlushRequest) XXX_Marshal

func (m *FlushRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlushRequest) XXX_Merge

func (m *FlushRequest) XXX_Merge(src proto.Message)

func (*FlushRequest) XXX_Size

func (m *FlushRequest) XXX_Size() int

func (*FlushRequest) XXX_Unmarshal

func (m *FlushRequest) XXX_Unmarshal(b []byte) error

type FlushResponse

type FlushResponse struct {
	Status               *common.Status               `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	DbName               string                       `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollSegIDs           map[string]*schema.LongArray `` /* 179-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*FlushResponse) Descriptor

func (*FlushResponse) Descriptor() ([]byte, []int)

func (*FlushResponse) GetCollSegIDs

func (m *FlushResponse) GetCollSegIDs() map[string]*schema.LongArray

func (*FlushResponse) GetDbName

func (m *FlushResponse) GetDbName() string

func (*FlushResponse) GetStatus

func (m *FlushResponse) GetStatus() *common.Status

func (*FlushResponse) ProtoMessage

func (*FlushResponse) ProtoMessage()

func (*FlushResponse) Reset

func (m *FlushResponse) Reset()

func (*FlushResponse) String

func (m *FlushResponse) String() string

func (*FlushResponse) XXX_DiscardUnknown

func (m *FlushResponse) XXX_DiscardUnknown()

func (*FlushResponse) XXX_Marshal

func (m *FlushResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlushResponse) XXX_Merge

func (m *FlushResponse) XXX_Merge(src proto.Message)

func (*FlushResponse) XXX_Size

func (m *FlushResponse) XXX_Size() int

func (*FlushResponse) XXX_Unmarshal

func (m *FlushResponse) XXX_Unmarshal(b []byte) error

type GetCollectionStatisticsRequest

type GetCollectionStatisticsRequest struct {
	Base                 *common.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 (*GetCollectionStatisticsRequest) Descriptor

func (*GetCollectionStatisticsRequest) Descriptor() ([]byte, []int)

func (*GetCollectionStatisticsRequest) GetBase

func (*GetCollectionStatisticsRequest) GetCollectionName

func (m *GetCollectionStatisticsRequest) GetCollectionName() string

func (*GetCollectionStatisticsRequest) GetDbName

func (m *GetCollectionStatisticsRequest) GetDbName() string

func (*GetCollectionStatisticsRequest) ProtoMessage

func (*GetCollectionStatisticsRequest) ProtoMessage()

func (*GetCollectionStatisticsRequest) Reset

func (m *GetCollectionStatisticsRequest) Reset()

func (*GetCollectionStatisticsRequest) String

func (*GetCollectionStatisticsRequest) XXX_DiscardUnknown

func (m *GetCollectionStatisticsRequest) XXX_DiscardUnknown()

func (*GetCollectionStatisticsRequest) XXX_Marshal

func (m *GetCollectionStatisticsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCollectionStatisticsRequest) XXX_Merge

func (m *GetCollectionStatisticsRequest) XXX_Merge(src proto.Message)

func (*GetCollectionStatisticsRequest) XXX_Size

func (m *GetCollectionStatisticsRequest) XXX_Size() int

func (*GetCollectionStatisticsRequest) XXX_Unmarshal

func (m *GetCollectionStatisticsRequest) XXX_Unmarshal(b []byte) error

type GetCollectionStatisticsResponse

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

func (*GetCollectionStatisticsResponse) Descriptor

func (*GetCollectionStatisticsResponse) Descriptor() ([]byte, []int)

func (*GetCollectionStatisticsResponse) GetStats

func (*GetCollectionStatisticsResponse) GetStatus

func (*GetCollectionStatisticsResponse) ProtoMessage

func (*GetCollectionStatisticsResponse) ProtoMessage()

func (*GetCollectionStatisticsResponse) Reset

func (*GetCollectionStatisticsResponse) String

func (*GetCollectionStatisticsResponse) XXX_DiscardUnknown

func (m *GetCollectionStatisticsResponse) XXX_DiscardUnknown()

func (*GetCollectionStatisticsResponse) XXX_Marshal

func (m *GetCollectionStatisticsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCollectionStatisticsResponse) XXX_Merge

func (m *GetCollectionStatisticsResponse) XXX_Merge(src proto.Message)

func (*GetCollectionStatisticsResponse) XXX_Size

func (m *GetCollectionStatisticsResponse) XXX_Size() int

func (*GetCollectionStatisticsResponse) XXX_Unmarshal

func (m *GetCollectionStatisticsResponse) XXX_Unmarshal(b []byte) error

type GetIndexBuildProgressRequest

type GetIndexBuildProgressRequest struct {
	Base                 *common.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 (*GetIndexBuildProgressRequest) Descriptor

func (*GetIndexBuildProgressRequest) Descriptor() ([]byte, []int)

func (*GetIndexBuildProgressRequest) GetBase

func (*GetIndexBuildProgressRequest) GetCollectionName

func (m *GetIndexBuildProgressRequest) GetCollectionName() string

func (*GetIndexBuildProgressRequest) GetDbName

func (m *GetIndexBuildProgressRequest) GetDbName() string

func (*GetIndexBuildProgressRequest) GetFieldName

func (m *GetIndexBuildProgressRequest) GetFieldName() string

func (*GetIndexBuildProgressRequest) GetIndexName

func (m *GetIndexBuildProgressRequest) GetIndexName() string

func (*GetIndexBuildProgressRequest) ProtoMessage

func (*GetIndexBuildProgressRequest) ProtoMessage()

func (*GetIndexBuildProgressRequest) Reset

func (m *GetIndexBuildProgressRequest) Reset()

func (*GetIndexBuildProgressRequest) String

func (*GetIndexBuildProgressRequest) XXX_DiscardUnknown

func (m *GetIndexBuildProgressRequest) XXX_DiscardUnknown()

func (*GetIndexBuildProgressRequest) XXX_Marshal

func (m *GetIndexBuildProgressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetIndexBuildProgressRequest) XXX_Merge

func (m *GetIndexBuildProgressRequest) XXX_Merge(src proto.Message)

func (*GetIndexBuildProgressRequest) XXX_Size

func (m *GetIndexBuildProgressRequest) XXX_Size() int

func (*GetIndexBuildProgressRequest) XXX_Unmarshal

func (m *GetIndexBuildProgressRequest) XXX_Unmarshal(b []byte) error

type GetIndexBuildProgressResponse

type GetIndexBuildProgressResponse struct {
	Status               *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	IndexedRows          int64          `protobuf:"varint,2,opt,name=indexed_rows,json=indexedRows,proto3" json:"indexed_rows,omitempty"`
	TotalRows            int64          `protobuf:"varint,3,opt,name=total_rows,json=totalRows,proto3" json:"total_rows,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetIndexBuildProgressResponse) Descriptor

func (*GetIndexBuildProgressResponse) Descriptor() ([]byte, []int)

func (*GetIndexBuildProgressResponse) GetIndexedRows

func (m *GetIndexBuildProgressResponse) GetIndexedRows() int64

func (*GetIndexBuildProgressResponse) GetStatus

func (*GetIndexBuildProgressResponse) GetTotalRows

func (m *GetIndexBuildProgressResponse) GetTotalRows() int64

func (*GetIndexBuildProgressResponse) ProtoMessage

func (*GetIndexBuildProgressResponse) ProtoMessage()

func (*GetIndexBuildProgressResponse) Reset

func (m *GetIndexBuildProgressResponse) Reset()

func (*GetIndexBuildProgressResponse) String

func (*GetIndexBuildProgressResponse) XXX_DiscardUnknown

func (m *GetIndexBuildProgressResponse) XXX_DiscardUnknown()

func (*GetIndexBuildProgressResponse) XXX_Marshal

func (m *GetIndexBuildProgressResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetIndexBuildProgressResponse) XXX_Merge

func (m *GetIndexBuildProgressResponse) XXX_Merge(src proto.Message)

func (*GetIndexBuildProgressResponse) XXX_Size

func (m *GetIndexBuildProgressResponse) XXX_Size() int

func (*GetIndexBuildProgressResponse) XXX_Unmarshal

func (m *GetIndexBuildProgressResponse) XXX_Unmarshal(b []byte) error

type GetIndexStateRequest

type GetIndexStateRequest struct {
	Base                 *common.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 (*GetIndexStateRequest) Descriptor

func (*GetIndexStateRequest) Descriptor() ([]byte, []int)

func (*GetIndexStateRequest) GetBase

func (m *GetIndexStateRequest) GetBase() *common.MsgBase

func (*GetIndexStateRequest) GetCollectionName

func (m *GetIndexStateRequest) GetCollectionName() string

func (*GetIndexStateRequest) GetDbName

func (m *GetIndexStateRequest) GetDbName() string

func (*GetIndexStateRequest) GetFieldName

func (m *GetIndexStateRequest) GetFieldName() string

func (*GetIndexStateRequest) GetIndexName

func (m *GetIndexStateRequest) GetIndexName() string

func (*GetIndexStateRequest) ProtoMessage

func (*GetIndexStateRequest) ProtoMessage()

func (*GetIndexStateRequest) Reset

func (m *GetIndexStateRequest) Reset()

func (*GetIndexStateRequest) String

func (m *GetIndexStateRequest) String() string

func (*GetIndexStateRequest) XXX_DiscardUnknown

func (m *GetIndexStateRequest) XXX_DiscardUnknown()

func (*GetIndexStateRequest) XXX_Marshal

func (m *GetIndexStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetIndexStateRequest) XXX_Merge

func (m *GetIndexStateRequest) XXX_Merge(src proto.Message)

func (*GetIndexStateRequest) XXX_Size

func (m *GetIndexStateRequest) XXX_Size() int

func (*GetIndexStateRequest) XXX_Unmarshal

func (m *GetIndexStateRequest) XXX_Unmarshal(b []byte) error

type GetIndexStateResponse

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

func (*GetIndexStateResponse) Descriptor

func (*GetIndexStateResponse) Descriptor() ([]byte, []int)

func (*GetIndexStateResponse) GetFailReason

func (m *GetIndexStateResponse) GetFailReason() string

func (*GetIndexStateResponse) GetState

func (m *GetIndexStateResponse) GetState() common.IndexState

func (*GetIndexStateResponse) GetStatus

func (m *GetIndexStateResponse) GetStatus() *common.Status

func (*GetIndexStateResponse) ProtoMessage

func (*GetIndexStateResponse) ProtoMessage()

func (*GetIndexStateResponse) Reset

func (m *GetIndexStateResponse) Reset()

func (*GetIndexStateResponse) String

func (m *GetIndexStateResponse) String() string

func (*GetIndexStateResponse) XXX_DiscardUnknown

func (m *GetIndexStateResponse) XXX_DiscardUnknown()

func (*GetIndexStateResponse) XXX_Marshal

func (m *GetIndexStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetIndexStateResponse) XXX_Merge

func (m *GetIndexStateResponse) XXX_Merge(src proto.Message)

func (*GetIndexStateResponse) XXX_Size

func (m *GetIndexStateResponse) XXX_Size() int

func (*GetIndexStateResponse) XXX_Unmarshal

func (m *GetIndexStateResponse) XXX_Unmarshal(b []byte) error

type GetMetricsRequest

type GetMetricsRequest struct {
	Base                 *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	Request              string          `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetMetricsRequest) Descriptor

func (*GetMetricsRequest) Descriptor() ([]byte, []int)

func (*GetMetricsRequest) GetBase

func (m *GetMetricsRequest) GetBase() *common.MsgBase

func (*GetMetricsRequest) GetRequest

func (m *GetMetricsRequest) GetRequest() string

func (*GetMetricsRequest) ProtoMessage

func (*GetMetricsRequest) ProtoMessage()

func (*GetMetricsRequest) Reset

func (m *GetMetricsRequest) Reset()

func (*GetMetricsRequest) String

func (m *GetMetricsRequest) String() string

func (*GetMetricsRequest) XXX_DiscardUnknown

func (m *GetMetricsRequest) XXX_DiscardUnknown()

func (*GetMetricsRequest) XXX_Marshal

func (m *GetMetricsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetMetricsRequest) XXX_Merge

func (m *GetMetricsRequest) XXX_Merge(src proto.Message)

func (*GetMetricsRequest) XXX_Size

func (m *GetMetricsRequest) XXX_Size() int

func (*GetMetricsRequest) XXX_Unmarshal

func (m *GetMetricsRequest) XXX_Unmarshal(b []byte) error

type GetMetricsResponse

type GetMetricsResponse struct {
	Status               *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Response             string         `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
	ComponentName        string         `protobuf:"bytes,3,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetMetricsResponse) Descriptor

func (*GetMetricsResponse) Descriptor() ([]byte, []int)

func (*GetMetricsResponse) GetComponentName

func (m *GetMetricsResponse) GetComponentName() string

func (*GetMetricsResponse) GetResponse

func (m *GetMetricsResponse) GetResponse() string

func (*GetMetricsResponse) GetStatus

func (m *GetMetricsResponse) GetStatus() *common.Status

func (*GetMetricsResponse) ProtoMessage

func (*GetMetricsResponse) ProtoMessage()

func (*GetMetricsResponse) Reset

func (m *GetMetricsResponse) Reset()

func (*GetMetricsResponse) String

func (m *GetMetricsResponse) String() string

func (*GetMetricsResponse) XXX_DiscardUnknown

func (m *GetMetricsResponse) XXX_DiscardUnknown()

func (*GetMetricsResponse) XXX_Marshal

func (m *GetMetricsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetMetricsResponse) XXX_Merge

func (m *GetMetricsResponse) XXX_Merge(src proto.Message)

func (*GetMetricsResponse) XXX_Size

func (m *GetMetricsResponse) XXX_Size() int

func (*GetMetricsResponse) XXX_Unmarshal

func (m *GetMetricsResponse) XXX_Unmarshal(b []byte) error

type GetPartitionStatisticsRequest

type GetPartitionStatisticsRequest struct {
	Base                 *common.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 (*GetPartitionStatisticsRequest) Descriptor

func (*GetPartitionStatisticsRequest) Descriptor() ([]byte, []int)

func (*GetPartitionStatisticsRequest) GetBase

func (*GetPartitionStatisticsRequest) GetCollectionName

func (m *GetPartitionStatisticsRequest) GetCollectionName() string

func (*GetPartitionStatisticsRequest) GetDbName

func (m *GetPartitionStatisticsRequest) GetDbName() string

func (*GetPartitionStatisticsRequest) GetPartitionName

func (m *GetPartitionStatisticsRequest) GetPartitionName() string

func (*GetPartitionStatisticsRequest) ProtoMessage

func (*GetPartitionStatisticsRequest) ProtoMessage()

func (*GetPartitionStatisticsRequest) Reset

func (m *GetPartitionStatisticsRequest) Reset()

func (*GetPartitionStatisticsRequest) String

func (*GetPartitionStatisticsRequest) XXX_DiscardUnknown

func (m *GetPartitionStatisticsRequest) XXX_DiscardUnknown()

func (*GetPartitionStatisticsRequest) XXX_Marshal

func (m *GetPartitionStatisticsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPartitionStatisticsRequest) XXX_Merge

func (m *GetPartitionStatisticsRequest) XXX_Merge(src proto.Message)

func (*GetPartitionStatisticsRequest) XXX_Size

func (m *GetPartitionStatisticsRequest) XXX_Size() int

func (*GetPartitionStatisticsRequest) XXX_Unmarshal

func (m *GetPartitionStatisticsRequest) XXX_Unmarshal(b []byte) error

type GetPartitionStatisticsResponse

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

func (*GetPartitionStatisticsResponse) Descriptor

func (*GetPartitionStatisticsResponse) Descriptor() ([]byte, []int)

func (*GetPartitionStatisticsResponse) GetStats

func (*GetPartitionStatisticsResponse) GetStatus

func (*GetPartitionStatisticsResponse) ProtoMessage

func (*GetPartitionStatisticsResponse) ProtoMessage()

func (*GetPartitionStatisticsResponse) Reset

func (m *GetPartitionStatisticsResponse) Reset()

func (*GetPartitionStatisticsResponse) String

func (*GetPartitionStatisticsResponse) XXX_DiscardUnknown

func (m *GetPartitionStatisticsResponse) XXX_DiscardUnknown()

func (*GetPartitionStatisticsResponse) XXX_Marshal

func (m *GetPartitionStatisticsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPartitionStatisticsResponse) XXX_Merge

func (m *GetPartitionStatisticsResponse) XXX_Merge(src proto.Message)

func (*GetPartitionStatisticsResponse) XXX_Size

func (m *GetPartitionStatisticsResponse) XXX_Size() int

func (*GetPartitionStatisticsResponse) XXX_Unmarshal

func (m *GetPartitionStatisticsResponse) XXX_Unmarshal(b []byte) error

type GetPersistentSegmentInfoRequest

type GetPersistentSegmentInfoRequest struct {
	Base                 *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string          `protobuf:"bytes,2,opt,name=dbName,proto3" json:"dbName,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 (*GetPersistentSegmentInfoRequest) Descriptor

func (*GetPersistentSegmentInfoRequest) Descriptor() ([]byte, []int)

func (*GetPersistentSegmentInfoRequest) GetBase

func (*GetPersistentSegmentInfoRequest) GetCollectionName

func (m *GetPersistentSegmentInfoRequest) GetCollectionName() string

func (*GetPersistentSegmentInfoRequest) GetDbName

func (m *GetPersistentSegmentInfoRequest) GetDbName() string

func (*GetPersistentSegmentInfoRequest) ProtoMessage

func (*GetPersistentSegmentInfoRequest) ProtoMessage()

func (*GetPersistentSegmentInfoRequest) Reset

func (*GetPersistentSegmentInfoRequest) String

func (*GetPersistentSegmentInfoRequest) XXX_DiscardUnknown

func (m *GetPersistentSegmentInfoRequest) XXX_DiscardUnknown()

func (*GetPersistentSegmentInfoRequest) XXX_Marshal

func (m *GetPersistentSegmentInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPersistentSegmentInfoRequest) XXX_Merge

func (m *GetPersistentSegmentInfoRequest) XXX_Merge(src proto.Message)

func (*GetPersistentSegmentInfoRequest) XXX_Size

func (m *GetPersistentSegmentInfoRequest) XXX_Size() int

func (*GetPersistentSegmentInfoRequest) XXX_Unmarshal

func (m *GetPersistentSegmentInfoRequest) XXX_Unmarshal(b []byte) error

type GetPersistentSegmentInfoResponse

type GetPersistentSegmentInfoResponse struct {
	Status               *common.Status           `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Infos                []*PersistentSegmentInfo `protobuf:"bytes,2,rep,name=infos,proto3" json:"infos,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*GetPersistentSegmentInfoResponse) Descriptor

func (*GetPersistentSegmentInfoResponse) Descriptor() ([]byte, []int)

func (*GetPersistentSegmentInfoResponse) GetInfos

func (*GetPersistentSegmentInfoResponse) GetStatus

func (*GetPersistentSegmentInfoResponse) ProtoMessage

func (*GetPersistentSegmentInfoResponse) ProtoMessage()

func (*GetPersistentSegmentInfoResponse) Reset

func (*GetPersistentSegmentInfoResponse) String

func (*GetPersistentSegmentInfoResponse) XXX_DiscardUnknown

func (m *GetPersistentSegmentInfoResponse) XXX_DiscardUnknown()

func (*GetPersistentSegmentInfoResponse) XXX_Marshal

func (m *GetPersistentSegmentInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPersistentSegmentInfoResponse) XXX_Merge

func (*GetPersistentSegmentInfoResponse) XXX_Size

func (m *GetPersistentSegmentInfoResponse) XXX_Size() int

func (*GetPersistentSegmentInfoResponse) XXX_Unmarshal

func (m *GetPersistentSegmentInfoResponse) XXX_Unmarshal(b []byte) error

type GetQuerySegmentInfoRequest

type GetQuerySegmentInfoRequest struct {
	Base                 *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string          `protobuf:"bytes,2,opt,name=dbName,proto3" json:"dbName,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 (*GetQuerySegmentInfoRequest) Descriptor

func (*GetQuerySegmentInfoRequest) Descriptor() ([]byte, []int)

func (*GetQuerySegmentInfoRequest) GetBase

func (*GetQuerySegmentInfoRequest) GetCollectionName

func (m *GetQuerySegmentInfoRequest) GetCollectionName() string

func (*GetQuerySegmentInfoRequest) GetDbName

func (m *GetQuerySegmentInfoRequest) GetDbName() string

func (*GetQuerySegmentInfoRequest) ProtoMessage

func (*GetQuerySegmentInfoRequest) ProtoMessage()

func (*GetQuerySegmentInfoRequest) Reset

func (m *GetQuerySegmentInfoRequest) Reset()

func (*GetQuerySegmentInfoRequest) String

func (m *GetQuerySegmentInfoRequest) String() string

func (*GetQuerySegmentInfoRequest) XXX_DiscardUnknown

func (m *GetQuerySegmentInfoRequest) XXX_DiscardUnknown()

func (*GetQuerySegmentInfoRequest) XXX_Marshal

func (m *GetQuerySegmentInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetQuerySegmentInfoRequest) XXX_Merge

func (m *GetQuerySegmentInfoRequest) XXX_Merge(src proto.Message)

func (*GetQuerySegmentInfoRequest) XXX_Size

func (m *GetQuerySegmentInfoRequest) XXX_Size() int

func (*GetQuerySegmentInfoRequest) XXX_Unmarshal

func (m *GetQuerySegmentInfoRequest) XXX_Unmarshal(b []byte) error

type GetQuerySegmentInfoResponse

type GetQuerySegmentInfoResponse struct {
	Status               *common.Status      `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Infos                []*QuerySegmentInfo `protobuf:"bytes,2,rep,name=infos,proto3" json:"infos,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*GetQuerySegmentInfoResponse) Descriptor

func (*GetQuerySegmentInfoResponse) Descriptor() ([]byte, []int)

func (*GetQuerySegmentInfoResponse) GetInfos

func (*GetQuerySegmentInfoResponse) GetStatus

func (m *GetQuerySegmentInfoResponse) GetStatus() *common.Status

func (*GetQuerySegmentInfoResponse) ProtoMessage

func (*GetQuerySegmentInfoResponse) ProtoMessage()

func (*GetQuerySegmentInfoResponse) Reset

func (m *GetQuerySegmentInfoResponse) Reset()

func (*GetQuerySegmentInfoResponse) String

func (m *GetQuerySegmentInfoResponse) String() string

func (*GetQuerySegmentInfoResponse) XXX_DiscardUnknown

func (m *GetQuerySegmentInfoResponse) XXX_DiscardUnknown()

func (*GetQuerySegmentInfoResponse) XXX_Marshal

func (m *GetQuerySegmentInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetQuerySegmentInfoResponse) XXX_Merge

func (m *GetQuerySegmentInfoResponse) XXX_Merge(src proto.Message)

func (*GetQuerySegmentInfoResponse) XXX_Size

func (m *GetQuerySegmentInfoResponse) XXX_Size() int

func (*GetQuerySegmentInfoResponse) XXX_Unmarshal

func (m *GetQuerySegmentInfoResponse) XXX_Unmarshal(b []byte) error

type HasCollectionRequest

type HasCollectionRequest struct {
	Base                 *common.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"`
	TimeStamp            uint64          `protobuf:"varint,4,opt,name=time_stamp,json=timeStamp,proto3" json:"time_stamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*HasCollectionRequest) Descriptor

func (*HasCollectionRequest) Descriptor() ([]byte, []int)

func (*HasCollectionRequest) GetBase

func (m *HasCollectionRequest) GetBase() *common.MsgBase

func (*HasCollectionRequest) GetCollectionName

func (m *HasCollectionRequest) GetCollectionName() string

func (*HasCollectionRequest) GetDbName

func (m *HasCollectionRequest) GetDbName() string

func (*HasCollectionRequest) GetTimeStamp

func (m *HasCollectionRequest) GetTimeStamp() uint64

func (*HasCollectionRequest) ProtoMessage

func (*HasCollectionRequest) ProtoMessage()

func (*HasCollectionRequest) Reset

func (m *HasCollectionRequest) Reset()

func (*HasCollectionRequest) String

func (m *HasCollectionRequest) String() string

func (*HasCollectionRequest) XXX_DiscardUnknown

func (m *HasCollectionRequest) XXX_DiscardUnknown()

func (*HasCollectionRequest) XXX_Marshal

func (m *HasCollectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HasCollectionRequest) XXX_Merge

func (m *HasCollectionRequest) XXX_Merge(src proto.Message)

func (*HasCollectionRequest) XXX_Size

func (m *HasCollectionRequest) XXX_Size() int

func (*HasCollectionRequest) XXX_Unmarshal

func (m *HasCollectionRequest) XXX_Unmarshal(b []byte) error

type HasPartitionRequest

type HasPartitionRequest struct {
	Base                 *common.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 (*HasPartitionRequest) Descriptor

func (*HasPartitionRequest) Descriptor() ([]byte, []int)

func (*HasPartitionRequest) GetBase

func (m *HasPartitionRequest) GetBase() *common.MsgBase

func (*HasPartitionRequest) GetCollectionName

func (m *HasPartitionRequest) GetCollectionName() string

func (*HasPartitionRequest) GetDbName

func (m *HasPartitionRequest) GetDbName() string

func (*HasPartitionRequest) GetPartitionName

func (m *HasPartitionRequest) GetPartitionName() string

func (*HasPartitionRequest) ProtoMessage

func (*HasPartitionRequest) ProtoMessage()

func (*HasPartitionRequest) Reset

func (m *HasPartitionRequest) Reset()

func (*HasPartitionRequest) String

func (m *HasPartitionRequest) String() string

func (*HasPartitionRequest) XXX_DiscardUnknown

func (m *HasPartitionRequest) XXX_DiscardUnknown()

func (*HasPartitionRequest) XXX_Marshal

func (m *HasPartitionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HasPartitionRequest) XXX_Merge

func (m *HasPartitionRequest) XXX_Merge(src proto.Message)

func (*HasPartitionRequest) XXX_Size

func (m *HasPartitionRequest) XXX_Size() int

func (*HasPartitionRequest) XXX_Unmarshal

func (m *HasPartitionRequest) XXX_Unmarshal(b []byte) error

type Hits

type Hits struct {
	IDs                  []int64   `protobuf:"varint,1,rep,packed,name=IDs,json=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 (*Hits) Descriptor

func (*Hits) Descriptor() ([]byte, []int)

func (*Hits) GetIDs

func (m *Hits) GetIDs() []int64

func (*Hits) GetRowData

func (m *Hits) GetRowData() [][]byte

func (*Hits) GetScores

func (m *Hits) GetScores() []float32

func (*Hits) ProtoMessage

func (*Hits) ProtoMessage()

func (*Hits) Reset

func (m *Hits) Reset()

func (*Hits) String

func (m *Hits) String() string

func (*Hits) XXX_DiscardUnknown

func (m *Hits) XXX_DiscardUnknown()

func (*Hits) XXX_Marshal

func (m *Hits) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Hits) XXX_Merge

func (m *Hits) XXX_Merge(src proto.Message)

func (*Hits) XXX_Size

func (m *Hits) XXX_Size() int

func (*Hits) XXX_Unmarshal

func (m *Hits) XXX_Unmarshal(b []byte) error

type IndexDescription

type IndexDescription struct {
	IndexName            string                 `protobuf:"bytes,1,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	IndexID              int64                  `protobuf:"varint,2,opt,name=indexID,proto3" json:"indexID,omitempty"`
	Params               []*common.KeyValuePair `protobuf:"bytes,3,rep,name=params,proto3" json:"params,omitempty"`
	FieldName            string                 `protobuf:"bytes,4,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*IndexDescription) Descriptor

func (*IndexDescription) Descriptor() ([]byte, []int)

func (*IndexDescription) GetFieldName

func (m *IndexDescription) GetFieldName() string

func (*IndexDescription) GetIndexID

func (m *IndexDescription) GetIndexID() int64

func (*IndexDescription) GetIndexName

func (m *IndexDescription) GetIndexName() string

func (*IndexDescription) GetParams

func (m *IndexDescription) GetParams() []*common.KeyValuePair

func (*IndexDescription) ProtoMessage

func (*IndexDescription) ProtoMessage()

func (*IndexDescription) Reset

func (m *IndexDescription) Reset()

func (*IndexDescription) String

func (m *IndexDescription) String() string

func (*IndexDescription) XXX_DiscardUnknown

func (m *IndexDescription) XXX_DiscardUnknown()

func (*IndexDescription) XXX_Marshal

func (m *IndexDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexDescription) XXX_Merge

func (m *IndexDescription) XXX_Merge(src proto.Message)

func (*IndexDescription) XXX_Size

func (m *IndexDescription) XXX_Size() int

func (*IndexDescription) XXX_Unmarshal

func (m *IndexDescription) XXX_Unmarshal(b []byte) error

type InsertRequest

type InsertRequest struct {
	Base                 *common.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"`
	FieldsData           []*schema.FieldData `protobuf:"bytes,5,rep,name=fields_data,json=fieldsData,proto3" json:"fields_data,omitempty"`
	HashKeys             []uint32            `protobuf:"varint,6,rep,packed,name=hash_keys,json=hashKeys,proto3" json:"hash_keys,omitempty"`
	NumRows              uint32              `protobuf:"varint,7,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*InsertRequest) Descriptor

func (*InsertRequest) Descriptor() ([]byte, []int)

func (*InsertRequest) GetBase

func (m *InsertRequest) GetBase() *common.MsgBase

func (*InsertRequest) GetCollectionName

func (m *InsertRequest) GetCollectionName() string

func (*InsertRequest) GetDbName

func (m *InsertRequest) GetDbName() string

func (*InsertRequest) GetFieldsData

func (m *InsertRequest) GetFieldsData() []*schema.FieldData

func (*InsertRequest) GetHashKeys

func (m *InsertRequest) GetHashKeys() []uint32

func (*InsertRequest) GetNumRows

func (m *InsertRequest) GetNumRows() uint32

func (*InsertRequest) GetPartitionName

func (m *InsertRequest) GetPartitionName() string

func (*InsertRequest) ProtoMessage

func (*InsertRequest) ProtoMessage()

func (*InsertRequest) Reset

func (m *InsertRequest) Reset()

func (*InsertRequest) String

func (m *InsertRequest) String() string

func (*InsertRequest) XXX_DiscardUnknown

func (m *InsertRequest) XXX_DiscardUnknown()

func (*InsertRequest) XXX_Marshal

func (m *InsertRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InsertRequest) XXX_Merge

func (m *InsertRequest) XXX_Merge(src proto.Message)

func (*InsertRequest) XXX_Size

func (m *InsertRequest) XXX_Size() int

func (*InsertRequest) XXX_Unmarshal

func (m *InsertRequest) XXX_Unmarshal(b []byte) error

type LoadCollectionRequest

type LoadCollectionRequest struct {
	Base                 *common.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 (*LoadCollectionRequest) Descriptor

func (*LoadCollectionRequest) Descriptor() ([]byte, []int)

func (*LoadCollectionRequest) GetBase

func (m *LoadCollectionRequest) GetBase() *common.MsgBase

func (*LoadCollectionRequest) GetCollectionName

func (m *LoadCollectionRequest) GetCollectionName() string

func (*LoadCollectionRequest) GetDbName

func (m *LoadCollectionRequest) GetDbName() string

func (*LoadCollectionRequest) ProtoMessage

func (*LoadCollectionRequest) ProtoMessage()

func (*LoadCollectionRequest) Reset

func (m *LoadCollectionRequest) Reset()

func (*LoadCollectionRequest) String

func (m *LoadCollectionRequest) String() string

func (*LoadCollectionRequest) XXX_DiscardUnknown

func (m *LoadCollectionRequest) XXX_DiscardUnknown()

func (*LoadCollectionRequest) XXX_Marshal

func (m *LoadCollectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadCollectionRequest) XXX_Merge

func (m *LoadCollectionRequest) XXX_Merge(src proto.Message)

func (*LoadCollectionRequest) XXX_Size

func (m *LoadCollectionRequest) XXX_Size() int

func (*LoadCollectionRequest) XXX_Unmarshal

func (m *LoadCollectionRequest) XXX_Unmarshal(b []byte) error

type LoadPartitionsRequest

type LoadPartitionsRequest struct {
	Base                 *common.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 (*LoadPartitionsRequest) Descriptor

func (*LoadPartitionsRequest) Descriptor() ([]byte, []int)

func (*LoadPartitionsRequest) GetBase

func (m *LoadPartitionsRequest) GetBase() *common.MsgBase

func (*LoadPartitionsRequest) GetCollectionName

func (m *LoadPartitionsRequest) GetCollectionName() string

func (*LoadPartitionsRequest) GetDbName

func (m *LoadPartitionsRequest) GetDbName() string

func (*LoadPartitionsRequest) GetPartitionNames

func (m *LoadPartitionsRequest) GetPartitionNames() []string

func (*LoadPartitionsRequest) ProtoMessage

func (*LoadPartitionsRequest) ProtoMessage()

func (*LoadPartitionsRequest) Reset

func (m *LoadPartitionsRequest) Reset()

func (*LoadPartitionsRequest) String

func (m *LoadPartitionsRequest) String() string

func (*LoadPartitionsRequest) XXX_DiscardUnknown

func (m *LoadPartitionsRequest) XXX_DiscardUnknown()

func (*LoadPartitionsRequest) XXX_Marshal

func (m *LoadPartitionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadPartitionsRequest) XXX_Merge

func (m *LoadPartitionsRequest) XXX_Merge(src proto.Message)

func (*LoadPartitionsRequest) XXX_Size

func (m *LoadPartitionsRequest) XXX_Size() int

func (*LoadPartitionsRequest) XXX_Unmarshal

func (m *LoadPartitionsRequest) XXX_Unmarshal(b []byte) error

type MilvusServiceClient

type MilvusServiceClient interface {
	CreateCollection(ctx context.Context, in *CreateCollectionRequest, opts ...grpc.CallOption) (*common.Status, error)
	DropCollection(ctx context.Context, in *DropCollectionRequest, opts ...grpc.CallOption) (*common.Status, error)
	HasCollection(ctx context.Context, in *HasCollectionRequest, opts ...grpc.CallOption) (*BoolResponse, error)
	LoadCollection(ctx context.Context, in *LoadCollectionRequest, opts ...grpc.CallOption) (*common.Status, error)
	ReleaseCollection(ctx context.Context, in *ReleaseCollectionRequest, opts ...grpc.CallOption) (*common.Status, error)
	DescribeCollection(ctx context.Context, in *DescribeCollectionRequest, opts ...grpc.CallOption) (*DescribeCollectionResponse, error)
	GetCollectionStatistics(ctx context.Context, in *GetCollectionStatisticsRequest, opts ...grpc.CallOption) (*GetCollectionStatisticsResponse, error)
	ShowCollections(ctx context.Context, in *ShowCollectionsRequest, opts ...grpc.CallOption) (*ShowCollectionsResponse, error)
	CreatePartition(ctx context.Context, in *CreatePartitionRequest, opts ...grpc.CallOption) (*common.Status, error)
	DropPartition(ctx context.Context, in *DropPartitionRequest, opts ...grpc.CallOption) (*common.Status, error)
	HasPartition(ctx context.Context, in *HasPartitionRequest, opts ...grpc.CallOption) (*BoolResponse, error)
	LoadPartitions(ctx context.Context, in *LoadPartitionsRequest, opts ...grpc.CallOption) (*common.Status, error)
	ReleasePartitions(ctx context.Context, in *ReleasePartitionsRequest, opts ...grpc.CallOption) (*common.Status, error)
	GetPartitionStatistics(ctx context.Context, in *GetPartitionStatisticsRequest, opts ...grpc.CallOption) (*GetPartitionStatisticsResponse, error)
	ShowPartitions(ctx context.Context, in *ShowPartitionsRequest, opts ...grpc.CallOption) (*ShowPartitionsResponse, error)
	CreateIndex(ctx context.Context, in *CreateIndexRequest, opts ...grpc.CallOption) (*common.Status, error)
	DescribeIndex(ctx context.Context, in *DescribeIndexRequest, opts ...grpc.CallOption) (*DescribeIndexResponse, error)
	GetIndexState(ctx context.Context, in *GetIndexStateRequest, opts ...grpc.CallOption) (*GetIndexStateResponse, error)
	GetIndexBuildProgress(ctx context.Context, in *GetIndexBuildProgressRequest, opts ...grpc.CallOption) (*GetIndexBuildProgressResponse, error)
	DropIndex(ctx context.Context, in *DropIndexRequest, opts ...grpc.CallOption) (*common.Status, error)
	Insert(ctx context.Context, in *InsertRequest, opts ...grpc.CallOption) (*MutationResult, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*MutationResult, error)
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResults, error)
	Flush(ctx context.Context, in *FlushRequest, opts ...grpc.CallOption) (*FlushResponse, error)
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResults, error)
	CalcDistance(ctx context.Context, in *CalcDistanceRequest, opts ...grpc.CallOption) (*CalcDistanceResults, error)
	GetPersistentSegmentInfo(ctx context.Context, in *GetPersistentSegmentInfoRequest, opts ...grpc.CallOption) (*GetPersistentSegmentInfoResponse, error)
	GetQuerySegmentInfo(ctx context.Context, in *GetQuerySegmentInfoRequest, opts ...grpc.CallOption) (*GetQuerySegmentInfoResponse, error)
	Dummy(ctx context.Context, in *DummyRequest, opts ...grpc.CallOption) (*DummyResponse, error)
	// TODO: remove
	RegisterLink(ctx context.Context, in *RegisterLinkRequest, opts ...grpc.CallOption) (*RegisterLinkResponse, error)
	// https://wiki.lfaidata.foundation/display/MIL/MEP+8+--+Add+metrics+for+proxy
	GetMetrics(ctx context.Context, in *GetMetricsRequest, opts ...grpc.CallOption) (*GetMetricsResponse, error)
}

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.

func NewMilvusServiceClient

func NewMilvusServiceClient(cc *grpc.ClientConn) MilvusServiceClient

type MilvusServiceServer

type MilvusServiceServer interface {
	CreateCollection(context.Context, *CreateCollectionRequest) (*common.Status, error)
	DropCollection(context.Context, *DropCollectionRequest) (*common.Status, error)
	HasCollection(context.Context, *HasCollectionRequest) (*BoolResponse, error)
	LoadCollection(context.Context, *LoadCollectionRequest) (*common.Status, error)
	ReleaseCollection(context.Context, *ReleaseCollectionRequest) (*common.Status, error)
	DescribeCollection(context.Context, *DescribeCollectionRequest) (*DescribeCollectionResponse, error)
	GetCollectionStatistics(context.Context, *GetCollectionStatisticsRequest) (*GetCollectionStatisticsResponse, error)
	ShowCollections(context.Context, *ShowCollectionsRequest) (*ShowCollectionsResponse, error)
	CreatePartition(context.Context, *CreatePartitionRequest) (*common.Status, error)
	DropPartition(context.Context, *DropPartitionRequest) (*common.Status, error)
	HasPartition(context.Context, *HasPartitionRequest) (*BoolResponse, error)
	LoadPartitions(context.Context, *LoadPartitionsRequest) (*common.Status, error)
	ReleasePartitions(context.Context, *ReleasePartitionsRequest) (*common.Status, error)
	GetPartitionStatistics(context.Context, *GetPartitionStatisticsRequest) (*GetPartitionStatisticsResponse, error)
	ShowPartitions(context.Context, *ShowPartitionsRequest) (*ShowPartitionsResponse, error)
	CreateIndex(context.Context, *CreateIndexRequest) (*common.Status, error)
	DescribeIndex(context.Context, *DescribeIndexRequest) (*DescribeIndexResponse, error)
	GetIndexState(context.Context, *GetIndexStateRequest) (*GetIndexStateResponse, error)
	GetIndexBuildProgress(context.Context, *GetIndexBuildProgressRequest) (*GetIndexBuildProgressResponse, error)
	DropIndex(context.Context, *DropIndexRequest) (*common.Status, error)
	Insert(context.Context, *InsertRequest) (*MutationResult, error)
	Delete(context.Context, *DeleteRequest) (*MutationResult, error)
	Search(context.Context, *SearchRequest) (*SearchResults, error)
	Flush(context.Context, *FlushRequest) (*FlushResponse, error)
	Query(context.Context, *QueryRequest) (*QueryResults, error)
	CalcDistance(context.Context, *CalcDistanceRequest) (*CalcDistanceResults, error)
	GetPersistentSegmentInfo(context.Context, *GetPersistentSegmentInfoRequest) (*GetPersistentSegmentInfoResponse, error)
	GetQuerySegmentInfo(context.Context, *GetQuerySegmentInfoRequest) (*GetQuerySegmentInfoResponse, error)
	Dummy(context.Context, *DummyRequest) (*DummyResponse, error)
	// TODO: remove
	RegisterLink(context.Context, *RegisterLinkRequest) (*RegisterLinkResponse, error)
	// https://wiki.lfaidata.foundation/display/MIL/MEP+8+--+Add+metrics+for+proxy
	GetMetrics(context.Context, *GetMetricsRequest) (*GetMetricsResponse, error)
}

MilvusServiceServer is the server API for MilvusService service.

type MutationResult

type MutationResult struct {
	Status               *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	IDs                  *schema.IDs    `protobuf:"bytes,2,opt,name=IDs,json=iDs,proto3" json:"IDs,omitempty"`
	SuccIndex            []uint32       `protobuf:"varint,3,rep,packed,name=succ_index,json=succIndex,proto3" json:"succ_index,omitempty"`
	ErrIndex             []uint32       `protobuf:"varint,4,rep,packed,name=err_index,json=errIndex,proto3" json:"err_index,omitempty"`
	Acknowledged         bool           `protobuf:"varint,5,opt,name=acknowledged,proto3" json:"acknowledged,omitempty"`
	InsertCnt            int64          `protobuf:"varint,6,opt,name=insert_cnt,json=insertCnt,proto3" json:"insert_cnt,omitempty"`
	DeleteCnt            int64          `protobuf:"varint,7,opt,name=delete_cnt,json=deleteCnt,proto3" json:"delete_cnt,omitempty"`
	UpsertCnt            int64          `protobuf:"varint,8,opt,name=upsert_cnt,json=upsertCnt,proto3" json:"upsert_cnt,omitempty"`
	Timestamp            uint64         `protobuf:"varint,9,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*MutationResult) Descriptor

func (*MutationResult) Descriptor() ([]byte, []int)

func (*MutationResult) GetAcknowledged

func (m *MutationResult) GetAcknowledged() bool

func (*MutationResult) GetDeleteCnt

func (m *MutationResult) GetDeleteCnt() int64

func (*MutationResult) GetErrIndex

func (m *MutationResult) GetErrIndex() []uint32

func (*MutationResult) GetIDs

func (m *MutationResult) GetIDs() *schema.IDs

func (*MutationResult) GetInsertCnt

func (m *MutationResult) GetInsertCnt() int64

func (*MutationResult) GetStatus

func (m *MutationResult) GetStatus() *common.Status

func (*MutationResult) GetSuccIndex

func (m *MutationResult) GetSuccIndex() []uint32

func (*MutationResult) GetTimestamp

func (m *MutationResult) GetTimestamp() uint64

func (*MutationResult) GetUpsertCnt

func (m *MutationResult) GetUpsertCnt() int64

func (*MutationResult) ProtoMessage

func (*MutationResult) ProtoMessage()

func (*MutationResult) Reset

func (m *MutationResult) Reset()

func (*MutationResult) String

func (m *MutationResult) String() string

func (*MutationResult) XXX_DiscardUnknown

func (m *MutationResult) XXX_DiscardUnknown()

func (*MutationResult) XXX_Marshal

func (m *MutationResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MutationResult) XXX_Merge

func (m *MutationResult) XXX_Merge(src proto.Message)

func (*MutationResult) XXX_Size

func (m *MutationResult) XXX_Size() int

func (*MutationResult) XXX_Unmarshal

func (m *MutationResult) XXX_Unmarshal(b []byte) error

type PersistentSegmentInfo

type PersistentSegmentInfo struct {
	SegmentID            int64               `protobuf:"varint,1,opt,name=segmentID,proto3" json:"segmentID,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"`
	NumRows              int64               `protobuf:"varint,4,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
	State                common.SegmentState `protobuf:"varint,5,opt,name=state,proto3,enum=milvus.proto.common.SegmentState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*PersistentSegmentInfo) Descriptor

func (*PersistentSegmentInfo) Descriptor() ([]byte, []int)

func (*PersistentSegmentInfo) GetCollectionID

func (m *PersistentSegmentInfo) GetCollectionID() int64

func (*PersistentSegmentInfo) GetNumRows

func (m *PersistentSegmentInfo) GetNumRows() int64

func (*PersistentSegmentInfo) GetPartitionID

func (m *PersistentSegmentInfo) GetPartitionID() int64

func (*PersistentSegmentInfo) GetSegmentID

func (m *PersistentSegmentInfo) GetSegmentID() int64

func (*PersistentSegmentInfo) GetState

func (*PersistentSegmentInfo) ProtoMessage

func (*PersistentSegmentInfo) ProtoMessage()

func (*PersistentSegmentInfo) Reset

func (m *PersistentSegmentInfo) Reset()

func (*PersistentSegmentInfo) String

func (m *PersistentSegmentInfo) String() string

func (*PersistentSegmentInfo) XXX_DiscardUnknown

func (m *PersistentSegmentInfo) XXX_DiscardUnknown()

func (*PersistentSegmentInfo) XXX_Marshal

func (m *PersistentSegmentInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PersistentSegmentInfo) XXX_Merge

func (m *PersistentSegmentInfo) XXX_Merge(src proto.Message)

func (*PersistentSegmentInfo) XXX_Size

func (m *PersistentSegmentInfo) XXX_Size() int

func (*PersistentSegmentInfo) XXX_Unmarshal

func (m *PersistentSegmentInfo) XXX_Unmarshal(b []byte) error

type PlaceholderGroup

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 (*PlaceholderGroup) Descriptor

func (*PlaceholderGroup) Descriptor() ([]byte, []int)

func (*PlaceholderGroup) GetPlaceholders

func (m *PlaceholderGroup) GetPlaceholders() []*PlaceholderValue

func (*PlaceholderGroup) ProtoMessage

func (*PlaceholderGroup) ProtoMessage()

func (*PlaceholderGroup) Reset

func (m *PlaceholderGroup) Reset()

func (*PlaceholderGroup) String

func (m *PlaceholderGroup) String() string

func (*PlaceholderGroup) XXX_DiscardUnknown

func (m *PlaceholderGroup) XXX_DiscardUnknown()

func (*PlaceholderGroup) XXX_Marshal

func (m *PlaceholderGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PlaceholderGroup) XXX_Merge

func (m *PlaceholderGroup) XXX_Merge(src proto.Message)

func (*PlaceholderGroup) XXX_Size

func (m *PlaceholderGroup) XXX_Size() int

func (*PlaceholderGroup) XXX_Unmarshal

func (m *PlaceholderGroup) XXX_Unmarshal(b []byte) error

type PlaceholderType

type PlaceholderType int32
const (
	PlaceholderType_None         PlaceholderType = 0
	PlaceholderType_BinaryVector PlaceholderType = 100
	PlaceholderType_FloatVector  PlaceholderType = 101
)

func (PlaceholderType) EnumDescriptor

func (PlaceholderType) EnumDescriptor() ([]byte, []int)

func (PlaceholderType) String

func (x PlaceholderType) String() string

type PlaceholderValue

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 (*PlaceholderValue) Descriptor

func (*PlaceholderValue) Descriptor() ([]byte, []int)

func (*PlaceholderValue) GetTag

func (m *PlaceholderValue) GetTag() string

func (*PlaceholderValue) GetType

func (m *PlaceholderValue) GetType() PlaceholderType

func (*PlaceholderValue) GetValues

func (m *PlaceholderValue) GetValues() [][]byte

func (*PlaceholderValue) ProtoMessage

func (*PlaceholderValue) ProtoMessage()

func (*PlaceholderValue) Reset

func (m *PlaceholderValue) Reset()

func (*PlaceholderValue) String

func (m *PlaceholderValue) String() string

func (*PlaceholderValue) XXX_DiscardUnknown

func (m *PlaceholderValue) XXX_DiscardUnknown()

func (*PlaceholderValue) XXX_Marshal

func (m *PlaceholderValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PlaceholderValue) XXX_Merge

func (m *PlaceholderValue) XXX_Merge(src proto.Message)

func (*PlaceholderValue) XXX_Size

func (m *PlaceholderValue) XXX_Size() int

func (*PlaceholderValue) XXX_Unmarshal

func (m *PlaceholderValue) XXX_Unmarshal(b []byte) error

type ProxyServiceClient

type ProxyServiceClient interface {
	RegisterLink(ctx context.Context, in *RegisterLinkRequest, opts ...grpc.CallOption) (*RegisterLinkResponse, error)
}

ProxyServiceClient is the client API for ProxyService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewProxyServiceClient

func NewProxyServiceClient(cc *grpc.ClientConn) ProxyServiceClient

type ProxyServiceServer

type ProxyServiceServer interface {
	RegisterLink(context.Context, *RegisterLinkRequest) (*RegisterLinkResponse, error)
}

ProxyServiceServer is the server API for ProxyService service.

type QueryRequest

type QueryRequest struct {
	Base                 *common.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"`
	Expr                 string          `protobuf:"bytes,4,opt,name=expr,proto3" json:"expr,omitempty"`
	OutputFields         []string        `protobuf:"bytes,5,rep,name=output_fields,json=outputFields,proto3" json:"output_fields,omitempty"`
	PartitionNames       []string        `protobuf:"bytes,6,rep,name=partition_names,json=partitionNames,proto3" json:"partition_names,omitempty"`
	TravelTimestamp      uint64          `protobuf:"varint,7,opt,name=travel_timestamp,json=travelTimestamp,proto3" json:"travel_timestamp,omitempty"`
	GuaranteeTimestamp   uint64          `protobuf:"varint,8,opt,name=guarantee_timestamp,json=guaranteeTimestamp,proto3" json:"guarantee_timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*QueryRequest) Descriptor

func (*QueryRequest) Descriptor() ([]byte, []int)

func (*QueryRequest) GetBase

func (m *QueryRequest) GetBase() *common.MsgBase

func (*QueryRequest) GetCollectionName

func (m *QueryRequest) GetCollectionName() string

func (*QueryRequest) GetDbName

func (m *QueryRequest) GetDbName() string

func (*QueryRequest) GetExpr

func (m *QueryRequest) GetExpr() string

func (*QueryRequest) GetGuaranteeTimestamp

func (m *QueryRequest) GetGuaranteeTimestamp() uint64

func (*QueryRequest) GetOutputFields

func (m *QueryRequest) GetOutputFields() []string

func (*QueryRequest) GetPartitionNames

func (m *QueryRequest) GetPartitionNames() []string

func (*QueryRequest) GetTravelTimestamp

func (m *QueryRequest) GetTravelTimestamp() uint64

func (*QueryRequest) ProtoMessage

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset

func (m *QueryRequest) Reset()

func (*QueryRequest) String

func (m *QueryRequest) String() string

func (*QueryRequest) XXX_DiscardUnknown

func (m *QueryRequest) XXX_DiscardUnknown()

func (*QueryRequest) XXX_Marshal

func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryRequest) XXX_Merge

func (m *QueryRequest) XXX_Merge(src proto.Message)

func (*QueryRequest) XXX_Size

func (m *QueryRequest) XXX_Size() int

func (*QueryRequest) XXX_Unmarshal

func (m *QueryRequest) XXX_Unmarshal(b []byte) error

type QueryResults

type QueryResults struct {
	Status               *common.Status      `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	FieldsData           []*schema.FieldData `protobuf:"bytes,2,rep,name=fields_data,json=fieldsData,proto3" json:"fields_data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*QueryResults) Descriptor

func (*QueryResults) Descriptor() ([]byte, []int)

func (*QueryResults) GetFieldsData

func (m *QueryResults) GetFieldsData() []*schema.FieldData

func (*QueryResults) GetStatus

func (m *QueryResults) GetStatus() *common.Status

func (*QueryResults) ProtoMessage

func (*QueryResults) ProtoMessage()

func (*QueryResults) Reset

func (m *QueryResults) Reset()

func (*QueryResults) String

func (m *QueryResults) String() string

func (*QueryResults) XXX_DiscardUnknown

func (m *QueryResults) XXX_DiscardUnknown()

func (*QueryResults) XXX_Marshal

func (m *QueryResults) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryResults) XXX_Merge

func (m *QueryResults) XXX_Merge(src proto.Message)

func (*QueryResults) XXX_Size

func (m *QueryResults) XXX_Size() int

func (*QueryResults) XXX_Unmarshal

func (m *QueryResults) XXX_Unmarshal(b []byte) error

type QuerySegmentInfo

type QuerySegmentInfo struct {
	SegmentID            int64    `protobuf:"varint,1,opt,name=segmentID,proto3" json:"segmentID,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"`
	MemSize              int64    `protobuf:"varint,4,opt,name=mem_size,json=memSize,proto3" json:"mem_size,omitempty"`
	NumRows              int64    `protobuf:"varint,5,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
	IndexName            string   `protobuf:"bytes,6,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	IndexID              int64    `protobuf:"varint,7,opt,name=indexID,proto3" json:"indexID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QuerySegmentInfo) Descriptor

func (*QuerySegmentInfo) Descriptor() ([]byte, []int)

func (*QuerySegmentInfo) GetCollectionID

func (m *QuerySegmentInfo) GetCollectionID() int64

func (*QuerySegmentInfo) GetIndexID

func (m *QuerySegmentInfo) GetIndexID() int64

func (*QuerySegmentInfo) GetIndexName

func (m *QuerySegmentInfo) GetIndexName() string

func (*QuerySegmentInfo) GetMemSize

func (m *QuerySegmentInfo) GetMemSize() int64

func (*QuerySegmentInfo) GetNumRows

func (m *QuerySegmentInfo) GetNumRows() int64

func (*QuerySegmentInfo) GetPartitionID

func (m *QuerySegmentInfo) GetPartitionID() int64

func (*QuerySegmentInfo) GetSegmentID

func (m *QuerySegmentInfo) GetSegmentID() int64

func (*QuerySegmentInfo) ProtoMessage

func (*QuerySegmentInfo) ProtoMessage()

func (*QuerySegmentInfo) Reset

func (m *QuerySegmentInfo) Reset()

func (*QuerySegmentInfo) String

func (m *QuerySegmentInfo) String() string

func (*QuerySegmentInfo) XXX_DiscardUnknown

func (m *QuerySegmentInfo) XXX_DiscardUnknown()

func (*QuerySegmentInfo) XXX_Marshal

func (m *QuerySegmentInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QuerySegmentInfo) XXX_Merge

func (m *QuerySegmentInfo) XXX_Merge(src proto.Message)

func (*QuerySegmentInfo) XXX_Size

func (m *QuerySegmentInfo) XXX_Size() int

func (*QuerySegmentInfo) XXX_Unmarshal

func (m *QuerySegmentInfo) XXX_Unmarshal(b []byte) error

type RegisterLinkRequest

type RegisterLinkRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterLinkRequest) Descriptor

func (*RegisterLinkRequest) Descriptor() ([]byte, []int)

func (*RegisterLinkRequest) ProtoMessage

func (*RegisterLinkRequest) ProtoMessage()

func (*RegisterLinkRequest) Reset

func (m *RegisterLinkRequest) Reset()

func (*RegisterLinkRequest) String

func (m *RegisterLinkRequest) String() string

func (*RegisterLinkRequest) XXX_DiscardUnknown

func (m *RegisterLinkRequest) XXX_DiscardUnknown()

func (*RegisterLinkRequest) XXX_Marshal

func (m *RegisterLinkRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterLinkRequest) XXX_Merge

func (m *RegisterLinkRequest) XXX_Merge(src proto.Message)

func (*RegisterLinkRequest) XXX_Size

func (m *RegisterLinkRequest) XXX_Size() int

func (*RegisterLinkRequest) XXX_Unmarshal

func (m *RegisterLinkRequest) XXX_Unmarshal(b []byte) error

type RegisterLinkResponse

type RegisterLinkResponse struct {
	Address              *common.Address `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Status               *common.Status  `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*RegisterLinkResponse) Descriptor

func (*RegisterLinkResponse) Descriptor() ([]byte, []int)

func (*RegisterLinkResponse) GetAddress

func (m *RegisterLinkResponse) GetAddress() *common.Address

func (*RegisterLinkResponse) GetStatus

func (m *RegisterLinkResponse) GetStatus() *common.Status

func (*RegisterLinkResponse) ProtoMessage

func (*RegisterLinkResponse) ProtoMessage()

func (*RegisterLinkResponse) Reset

func (m *RegisterLinkResponse) Reset()

func (*RegisterLinkResponse) String

func (m *RegisterLinkResponse) String() string

func (*RegisterLinkResponse) XXX_DiscardUnknown

func (m *RegisterLinkResponse) XXX_DiscardUnknown()

func (*RegisterLinkResponse) XXX_Marshal

func (m *RegisterLinkResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterLinkResponse) XXX_Merge

func (m *RegisterLinkResponse) XXX_Merge(src proto.Message)

func (*RegisterLinkResponse) XXX_Size

func (m *RegisterLinkResponse) XXX_Size() int

func (*RegisterLinkResponse) XXX_Unmarshal

func (m *RegisterLinkResponse) XXX_Unmarshal(b []byte) error

type ReleaseCollectionRequest

type ReleaseCollectionRequest struct {
	Base                 *common.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 (*ReleaseCollectionRequest) Descriptor

func (*ReleaseCollectionRequest) Descriptor() ([]byte, []int)

func (*ReleaseCollectionRequest) GetBase

func (m *ReleaseCollectionRequest) GetBase() *common.MsgBase

func (*ReleaseCollectionRequest) GetCollectionName

func (m *ReleaseCollectionRequest) GetCollectionName() string

func (*ReleaseCollectionRequest) GetDbName

func (m *ReleaseCollectionRequest) GetDbName() string

func (*ReleaseCollectionRequest) ProtoMessage

func (*ReleaseCollectionRequest) ProtoMessage()

func (*ReleaseCollectionRequest) Reset

func (m *ReleaseCollectionRequest) Reset()

func (*ReleaseCollectionRequest) String

func (m *ReleaseCollectionRequest) String() string

func (*ReleaseCollectionRequest) XXX_DiscardUnknown

func (m *ReleaseCollectionRequest) XXX_DiscardUnknown()

func (*ReleaseCollectionRequest) XXX_Marshal

func (m *ReleaseCollectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReleaseCollectionRequest) XXX_Merge

func (m *ReleaseCollectionRequest) XXX_Merge(src proto.Message)

func (*ReleaseCollectionRequest) XXX_Size

func (m *ReleaseCollectionRequest) XXX_Size() int

func (*ReleaseCollectionRequest) XXX_Unmarshal

func (m *ReleaseCollectionRequest) XXX_Unmarshal(b []byte) error

type ReleasePartitionsRequest

type ReleasePartitionsRequest struct {
	Base                 *common.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 (*ReleasePartitionsRequest) Descriptor

func (*ReleasePartitionsRequest) Descriptor() ([]byte, []int)

func (*ReleasePartitionsRequest) GetBase

func (m *ReleasePartitionsRequest) GetBase() *common.MsgBase

func (*ReleasePartitionsRequest) GetCollectionName

func (m *ReleasePartitionsRequest) GetCollectionName() string

func (*ReleasePartitionsRequest) GetDbName

func (m *ReleasePartitionsRequest) GetDbName() string

func (*ReleasePartitionsRequest) GetPartitionNames

func (m *ReleasePartitionsRequest) GetPartitionNames() []string

func (*ReleasePartitionsRequest) ProtoMessage

func (*ReleasePartitionsRequest) ProtoMessage()

func (*ReleasePartitionsRequest) Reset

func (m *ReleasePartitionsRequest) Reset()

func (*ReleasePartitionsRequest) String

func (m *ReleasePartitionsRequest) String() string

func (*ReleasePartitionsRequest) XXX_DiscardUnknown

func (m *ReleasePartitionsRequest) XXX_DiscardUnknown()

func (*ReleasePartitionsRequest) XXX_Marshal

func (m *ReleasePartitionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReleasePartitionsRequest) XXX_Merge

func (m *ReleasePartitionsRequest) XXX_Merge(src proto.Message)

func (*ReleasePartitionsRequest) XXX_Size

func (m *ReleasePartitionsRequest) XXX_Size() int

func (*ReleasePartitionsRequest) XXX_Unmarshal

func (m *ReleasePartitionsRequest) XXX_Unmarshal(b []byte) error

type SearchRequest

type SearchRequest struct {
	Base           *common.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"`
	DslType              common.DslType         `protobuf:"varint,7,opt,name=dsl_type,json=dslType,proto3,enum=milvus.proto.common.DslType" json:"dsl_type,omitempty"`
	OutputFields         []string               `protobuf:"bytes,8,rep,name=output_fields,json=outputFields,proto3" json:"output_fields,omitempty"`
	SearchParams         []*common.KeyValuePair `protobuf:"bytes,9,rep,name=search_params,json=searchParams,proto3" json:"search_params,omitempty"`
	TravelTimestamp      uint64                 `protobuf:"varint,10,opt,name=travel_timestamp,json=travelTimestamp,proto3" json:"travel_timestamp,omitempty"`
	GuaranteeTimestamp   uint64                 `protobuf:"varint,11,opt,name=guarantee_timestamp,json=guaranteeTimestam