milvuspb

package
v0.0.0-...-a92b242 Latest Latest
Warning

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

 Go to latest Published: Oct 16, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var E_MilvusExtObj = &proto.ExtensionDesc{
	ExtendedType:  (*descriptor.FileOptions)(nil),
	ExtensionType: (*MilvusExt)(nil),
	Field:         1001,
	Name:          "milvus.proto.milvus.milvus_ext_obj",
	Tag:           "bytes,1001,opt,name=milvus_ext_obj",
	Filename:      "milvus.proto",
}
View Source 
var OperatePrivilegeType_name = map[int32]string{
	0: "Grant",
	1: "Revoke",
}
View Source 
var OperatePrivilegeType_value = map[string]int32{
	"Grant":  0,
	"Revoke": 1,
}
View Source 
var OperateUserRoleType_name = map[int32]string{
	0: "AddUserToRole",
	1: "RemoveUserFromRole",
}
View Source 
var OperateUserRoleType_value = map[string]int32{
	"AddUserToRole":      0,
	"RemoveUserFromRole": 1,
}
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 AlterAliasRequest 

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

func (*AlterAliasRequest) Descriptor 

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

func (*AlterAliasRequest) GetAlias 

func (m *AlterAliasRequest) GetAlias() string

func (*AlterAliasRequest) GetBase 

func (m *AlterAliasRequest) GetBase() *commonpb.MsgBase

func (*AlterAliasRequest) GetCollectionName 

func (m *AlterAliasRequest) GetCollectionName() string

func (*AlterAliasRequest) GetDbName 

func (m *AlterAliasRequest) GetDbName() string

func (*AlterAliasRequest) ProtoMessage 

func (*AlterAliasRequest) ProtoMessage()

func (*AlterAliasRequest) Reset 

func (m *AlterAliasRequest) Reset()

func (*AlterAliasRequest) String 

func (m *AlterAliasRequest) String() string

func (*AlterAliasRequest) XXX_DiscardUnknown 

func (m *AlterAliasRequest) XXX_DiscardUnknown()

func (*AlterAliasRequest) XXX_Marshal 

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

func (*AlterAliasRequest) XXX_Merge 

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

func (*AlterAliasRequest) XXX_Size 

func (m *AlterAliasRequest) XXX_Size() int

func (*AlterAliasRequest) XXX_Unmarshal 

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

type AlterCollectionRequest 

type AlterCollectionRequest struct {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// The unique collection name in milvus.(Required)
	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"`
	Properties           []*commonpb.KeyValuePair `protobuf:"bytes,5,rep,name=properties,proto3" json:"properties,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

* Alter collection in milvus

func (*AlterCollectionRequest) Descriptor 

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

func (*AlterCollectionRequest) GetBase 

func (m *AlterCollectionRequest) GetBase() *commonpb.MsgBase

func (*AlterCollectionRequest) GetCollectionID 

func (m *AlterCollectionRequest) GetCollectionID() int64

func (*AlterCollectionRequest) GetCollectionName 

func (m *AlterCollectionRequest) GetCollectionName() string

func (*AlterCollectionRequest) GetDbName 

func (m *AlterCollectionRequest) GetDbName() string

func (*AlterCollectionRequest) GetProperties 

func (m *AlterCollectionRequest) GetProperties() []*commonpb.KeyValuePair

func (*AlterCollectionRequest) ProtoMessage 

func (*AlterCollectionRequest) ProtoMessage()

func (*AlterCollectionRequest) Reset 

func (m *AlterCollectionRequest) Reset()

func (*AlterCollectionRequest) String 

func (m *AlterCollectionRequest) String() string

func (*AlterCollectionRequest) XXX_DiscardUnknown 

func (m *AlterCollectionRequest) XXX_DiscardUnknown()

func (*AlterCollectionRequest) XXX_Marshal 

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

func (*AlterCollectionRequest) XXX_Merge 

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

func (*AlterCollectionRequest) XXX_Size 

func (m *AlterCollectionRequest) XXX_Size() int

func (*AlterCollectionRequest) XXX_Unmarshal 

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

type BoolResponse 

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

func (*BoolResponse) Descriptor 

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

func (*BoolResponse) GetStatus 

func (m *BoolResponse) GetStatus() *commonpb.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                 *commonpb.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               []*commonpb.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() *commonpb.MsgBase

func (*CalcDistanceRequest) GetOpLeft 

func (m *CalcDistanceRequest) GetOpLeft() *VectorsArray

func (*CalcDistanceRequest) GetOpRight 

func (m *CalcDistanceRequest) GetOpRight() *VectorsArray

func (*CalcDistanceRequest) GetParams 

func (m *CalcDistanceRequest) GetParams() []*commonpb.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 *commonpb.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() *schemapb.FloatArray

func (*CalcDistanceResults) GetIntDist 

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

func (*CalcDistanceResults) GetStatus 

func (m *CalcDistanceResults) GetStatus() *commonpb.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 *schemapb.FloatArray `protobuf:"bytes,3,opt,name=float_dist,json=floatDist,proto3,oneof"`
}

type CalcDistanceResults_IntDist 

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

type CompactionMergeInfo 

type CompactionMergeInfo struct {
	Sources              []int64  `protobuf:"varint,1,rep,packed,name=sources,proto3" json:"sources,omitempty"`
	Target               int64    `protobuf:"varint,2,opt,name=target,proto3" json:"target,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CompactionMergeInfo) Descriptor 

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

func (*CompactionMergeInfo) GetSources 

func (m *CompactionMergeInfo) GetSources() []int64

func (*CompactionMergeInfo) GetTarget 

func (m *CompactionMergeInfo) GetTarget() int64

func (*CompactionMergeInfo) ProtoMessage 

func (*CompactionMergeInfo) ProtoMessage()

func (*CompactionMergeInfo) Reset 

func (m *CompactionMergeInfo) Reset()

func (*CompactionMergeInfo) String 

func (m *CompactionMergeInfo) String() string

func (*CompactionMergeInfo) XXX_DiscardUnknown 

func (m *CompactionMergeInfo) XXX_DiscardUnknown()

func (*CompactionMergeInfo) XXX_Marshal 

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

func (*CompactionMergeInfo) XXX_Merge 

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

func (*CompactionMergeInfo) XXX_Size 

func (m *CompactionMergeInfo) XXX_Size() int

func (*CompactionMergeInfo) XXX_Unmarshal 

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

type ComponentInfo 

type ComponentInfo struct {
	NodeID               int64                    `protobuf:"varint,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	Role                 string                   `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"`
	StateCode            commonpb.StateCode       `protobuf:"varint,3,opt,name=state_code,json=stateCode,proto3,enum=milvus.proto.common.StateCode" json:"state_code,omitempty"`
	ExtraInfo            []*commonpb.KeyValuePair `protobuf:"bytes,4,rep,name=extra_info,json=extraInfo,proto3" json:"extra_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*ComponentInfo) Descriptor 

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

func (*ComponentInfo) GetExtraInfo 

func (m *ComponentInfo) GetExtraInfo() []*commonpb.KeyValuePair

func (*ComponentInfo) GetNodeID 

func (m *ComponentInfo) GetNodeID() int64

func (*ComponentInfo) GetRole 

func (m *ComponentInfo) GetRole() string

func (*ComponentInfo) GetStateCode 

func (m *ComponentInfo) GetStateCode() commonpb.StateCode

func (*ComponentInfo) ProtoMessage 

func (*ComponentInfo) ProtoMessage()

func (*ComponentInfo) Reset 

func (m *ComponentInfo) Reset()

func (*ComponentInfo) String 

func (m *ComponentInfo) String() string

func (*ComponentInfo) XXX_DiscardUnknown 

func (m *ComponentInfo) XXX_DiscardUnknown()

func (*ComponentInfo) XXX_Marshal 

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

func (*ComponentInfo) XXX_Merge 

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

func (*ComponentInfo) XXX_Size 

func (m *ComponentInfo) XXX_Size() int

func (*ComponentInfo) XXX_Unmarshal 

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

type ComponentStates 

type ComponentStates struct {
	State                *ComponentInfo   `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	SubcomponentStates   []*ComponentInfo `protobuf:"bytes,2,rep,name=subcomponent_states,json=subcomponentStates,proto3" json:"subcomponent_states,omitempty"`
	Status               *commonpb.Status `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ComponentStates) Descriptor 

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

func (*ComponentStates) GetState 

func (m *ComponentStates) GetState() *ComponentInfo

func (*ComponentStates) GetStatus 

func (m *ComponentStates) GetStatus() *commonpb.Status

func (*ComponentStates) GetSubcomponentStates 

func (m *ComponentStates) GetSubcomponentStates() []*ComponentInfo

func (*ComponentStates) ProtoMessage 

func (*ComponentStates) ProtoMessage()

func (*ComponentStates) Reset 

func (m *ComponentStates) Reset()

func (*ComponentStates) String 

func (m *ComponentStates) String() string

func (*ComponentStates) XXX_DiscardUnknown 

func (m *ComponentStates) XXX_DiscardUnknown()

func (*ComponentStates) XXX_Marshal 

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

func (*ComponentStates) XXX_Merge 

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

func (*ComponentStates) XXX_Size 

func (m *ComponentStates) XXX_Size() int

func (*ComponentStates) XXX_Unmarshal 

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

type CreateAliasRequest 

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

func (*CreateAliasRequest) Descriptor 

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

func (*CreateAliasRequest) GetAlias 

func (m *CreateAliasRequest) GetAlias() string

func (*CreateAliasRequest) GetBase 

func (m *CreateAliasRequest) GetBase() *commonpb.MsgBase

func (*CreateAliasRequest) GetCollectionName 

func (m *CreateAliasRequest) GetCollectionName() string

func (*CreateAliasRequest) GetDbName 

func (m *CreateAliasRequest) GetDbName() string

func (*CreateAliasRequest) ProtoMessage 

func (*CreateAliasRequest) ProtoMessage()

func (*CreateAliasRequest) Reset 

func (m *CreateAliasRequest) Reset()

func (*CreateAliasRequest) String 

func (m *CreateAliasRequest) String() string

func (*CreateAliasRequest) XXX_DiscardUnknown 

func (m *CreateAliasRequest) XXX_DiscardUnknown()

func (*CreateAliasRequest) XXX_Marshal 

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

func (*CreateAliasRequest) XXX_Merge 

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

func (*CreateAliasRequest) XXX_Size 

func (m *CreateAliasRequest) XXX_Size() int

func (*CreateAliasRequest) XXX_Unmarshal 

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

type CreateCollectionRequest 

type CreateCollectionRequest struct {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// The unique collection name in milvus.(Required)
	CollectionName string `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	// The serialized `schema.CollectionSchema`(Required)
	Schema []byte `protobuf:"bytes,4,opt,name=schema,proto3" json:"schema,omitempty"`
	// Once set, no modification is allowed (Optional)
	// https://github.com/milvus-io/milvus/issues/6690
	ShardsNum int32 `protobuf:"varint,5,opt,name=shards_num,json=shardsNum,proto3" json:"shards_num,omitempty"`
	// The consistency level that the collection used, modification is not supported now.
	ConsistencyLevel     commonpb.ConsistencyLevel `` /* 152-byte string literal not displayed */
	Properties           []*commonpb.KeyValuePair  `protobuf:"bytes,7,rep,name=properties,proto3" json:"properties,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

* Create collection in milvus

func (*CreateCollectionRequest) Descriptor 

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

func (*CreateCollectionRequest) GetBase 

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

func (*CreateCollectionRequest) GetCollectionName 

func (m *CreateCollectionRequest) GetCollectionName() string

func (*CreateCollectionRequest) GetConsistencyLevel 

func (m *CreateCollectionRequest) GetConsistencyLevel() commonpb.ConsistencyLevel

func (*CreateCollectionRequest) GetDbName 

func (m *CreateCollectionRequest) GetDbName() string

func (*CreateCollectionRequest) GetProperties 

func (m *CreateCollectionRequest) GetProperties() []*commonpb.KeyValuePair

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 CreateCredentialRequest 

type CreateCredentialRequest struct {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// username
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	// ciphertext password
	Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	// create time
	CreatedUtcTimestamps uint64 `protobuf:"varint,4,opt,name=created_utc_timestamps,json=createdUtcTimestamps,proto3" json:"created_utc_timestamps,omitempty"`
	// modify time
	ModifiedUtcTimestamps uint64   `` /* 127-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

func (*CreateCredentialRequest) Descriptor 

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

func (*CreateCredentialRequest) GetBase 

func (m *CreateCredentialRequest) GetBase() *commonpb.MsgBase

func (*CreateCredentialRequest) GetCreatedUtcTimestamps 

func (m *CreateCredentialRequest) GetCreatedUtcTimestamps() uint64

func (*CreateCredentialRequest) GetModifiedUtcTimestamps 

func (m *CreateCredentialRequest) GetModifiedUtcTimestamps() uint64

func (*CreateCredentialRequest) GetPassword 

func (m *CreateCredentialRequest) GetPassword() string

func (*CreateCredentialRequest) GetUsername 

func (m *CreateCredentialRequest) GetUsername() string

func (*CreateCredentialRequest) ProtoMessage 

func (*CreateCredentialRequest) ProtoMessage()

func (*CreateCredentialRequest) Reset 

func (m *CreateCredentialRequest) Reset()

func (*CreateCredentialRequest) String 

func (m *CreateCredentialRequest) String() string

func (*CreateCredentialRequest) XXX_DiscardUnknown 

func (m *CreateCredentialRequest) XXX_DiscardUnknown()

func (*CreateCredentialRequest) XXX_Marshal 

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

func (*CreateCredentialRequest) XXX_Merge 

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

func (*CreateCredentialRequest) XXX_Size 

func (m *CreateCredentialRequest) XXX_Size() int

func (*CreateCredentialRequest) XXX_Unmarshal 

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

type CreateIndexRequest 

type CreateIndexRequest struct {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// The particular collection name you want to create index.
	CollectionName string `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	// The vector field name in this particular collection
	FieldName string `protobuf:"bytes,4,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	// Support keys: index_type,metric_type, params. Different index_type may has different params.
	ExtraParams []*commonpb.KeyValuePair `protobuf:"bytes,5,rep,name=extra_params,json=extraParams,proto3" json:"extra_params,omitempty"`
	// Version before 2.0.2 doesn't contain index_name, we use default index name.
	IndexName            string   `protobuf:"bytes,6,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Create index for vector datas

func (*CreateIndexRequest) Descriptor 

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

func (*CreateIndexRequest) GetBase 

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

func (*CreateIndexRequest) GetCollectionName 

func (m *CreateIndexRequest) GetCollectionName() string

func (*CreateIndexRequest) GetDbName 

func (m *CreateIndexRequest) GetDbName() string

func (*CreateIndexRequest) GetExtraParams 

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

func (*CreateIndexRequest) GetFieldName 

func (m *CreateIndexRequest) GetFieldName() string

func (*CreateIndexRequest) GetIndexName 

func (m *CreateIndexRequest) GetIndexName() 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 {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// The collection name in milvus
	CollectionName string `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	// The partition name you want to create.
	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:"-"`
}

Create partition in created collection.

func (*CreatePartitionRequest) Descriptor 

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

func (*CreatePartitionRequest) GetBase 

func (m *CreatePartitionRequest) GetBase() *commonpb.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 CreateRoleRequest 

type CreateRoleRequest struct {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// role
	Entity               *RoleEntity `protobuf:"bytes,2,opt,name=entity,proto3" json:"entity,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*CreateRoleRequest) Descriptor 

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

func (*CreateRoleRequest) GetBase 

func (m *CreateRoleRequest) GetBase() *commonpb.MsgBase

func (*CreateRoleRequest) GetEntity 

func (m *CreateRoleRequest) GetEntity() *RoleEntity

func (*CreateRoleRequest) ProtoMessage 

func (*CreateRoleRequest) ProtoMessage()

func (*CreateRoleRequest) Reset 

func (m *CreateRoleRequest) Reset()

func (*CreateRoleRequest) String 

func (m *CreateRoleRequest) String() string

func (*CreateRoleRequest) XXX_DiscardUnknown 

func (m *CreateRoleRequest) XXX_DiscardUnknown()

func (*CreateRoleRequest) XXX_Marshal 

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

func (*CreateRoleRequest) XXX_Merge 

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

func (*CreateRoleRequest) XXX_Size 

func (m *CreateRoleRequest) XXX_Size() int

func (*CreateRoleRequest) XXX_Unmarshal 

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

type DeleteCredentialRequest 

type DeleteCredentialRequest struct {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	Username             string   `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteCredentialRequest) Descriptor 

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

func (*DeleteCredentialRequest) GetBase 

func (m *DeleteCredentialRequest) GetBase() *commonpb.MsgBase

func (*DeleteCredentialRequest) GetUsername 

func (m *DeleteCredentialRequest) GetUsername() string

func (*DeleteCredentialRequest) ProtoMessage 

func (*DeleteCredentialRequest) ProtoMessage()

func (*DeleteCredentialRequest) Reset 

func (m *DeleteCredentialRequest) Reset()

func (*DeleteCredentialRequest) String 

func (m *DeleteCredentialRequest) String() string

func (*DeleteCredentialRequest) XXX_DiscardUnknown 

func (m *DeleteCredentialRequest) XXX_DiscardUnknown()

func (*DeleteCredentialRequest) XXX_Marshal 

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

func (*DeleteCredentialRequest) XXX_Merge 

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

func (*DeleteCredentialRequest) XXX_Size 

func (m *DeleteCredentialRequest) XXX_Size() int

func (*DeleteCredentialRequest) XXX_Unmarshal 

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

type DeleteRequest 

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

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetBase 

func (m *DeleteRequest) GetBase() *commonpb.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) GetHashKeys 

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

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 {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// The collection name you want to describe, you can pass collection_name or collectionID
	CollectionName string `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	// The collection ID you want to describe
	CollectionID int64 `protobuf:"varint,4,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	// If time_stamp is not zero, will describe collection success when time_stamp >= created collection timestamp, otherwise will throw error.
	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:"-"`
}

* Get collection meta datas like: schema, collectionID, shards number ...

func (*DescribeCollectionRequest) Descriptor 

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

func (*DescribeCollectionRequest) GetBase 

func (m *DescribeCollectionRequest) GetBase() *commonpb.MsgBase

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 {
	// Contain error_code and reason
	Status *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// The schema param when you created collection.
	Schema *schemapb.CollectionSchema `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	// The collection id
	CollectionID int64 `protobuf:"varint,3,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	// System design related, users should not perceive
	VirtualChannelNames []string `protobuf:"bytes,4,rep,name=virtual_channel_names,json=virtualChannelNames,proto3" json:"virtual_channel_names,omitempty"`
	// System design related, users should not perceive
	PhysicalChannelNames []string `protobuf:"bytes,5,rep,name=physical_channel_names,json=physicalChannelNames,proto3" json:"physical_channel_names,omitempty"`
	// Hybrid timestamp in milvus
	CreatedTimestamp uint64 `protobuf:"varint,6,opt,name=created_timestamp,json=createdTimestamp,proto3" json:"created_timestamp,omitempty"`
	// The utc timestamp calculated by created_timestamp
	CreatedUtcTimestamp uint64 `protobuf:"varint,7,opt,name=created_utc_timestamp,json=createdUtcTimestamp,proto3" json:"created_utc_timestamp,omitempty"`
	// The shards number you set.
	ShardsNum int32 `protobuf:"varint,8,opt,name=shards_num,json=shardsNum,proto3" json:"shards_num,omitempty"`
	// The aliases of this collection
	Aliases []string `protobuf:"bytes,9,rep,name=aliases,proto3" json:"aliases,omitempty"`
	// The message ID/posititon when collection is created
	StartPositions []*commonpb.KeyDataPair `protobuf:"bytes,10,rep,name=start_positions,json=startPositions,proto3" json:"start_positions,omitempty"`
	// The consistency level that the collection used, modification is not supported now.
	ConsistencyLevel commonpb.ConsistencyLevel `` /* 153-byte string literal not displayed */
	// The collection name
	CollectionName       string                   `protobuf:"bytes,12,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	Properties           []*commonpb.KeyValuePair `protobuf:"bytes,13,rep,name=properties,proto3" json:"properties,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

* DescribeCollection Response

func (*DescribeCollectionResponse) Descriptor 

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

func (*DescribeCollectionResponse) GetAliases 

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

func (*DescribeCollectionResponse) GetCollectionID 

func (m *DescribeCollectionResponse) GetCollectionID() int64

func (*DescribeCollectionResponse) GetCollectionName 

func (m *DescribeCollectionResponse) GetCollectionName() string

func (*DescribeCollectionResponse) GetConsistencyLevel 

func (m *DescribeCollectionResponse) GetConsistencyLevel() commonpb.ConsistencyLevel

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) GetProperties 

func (m *DescribeCollectionResponse) GetProperties() []*commonpb.KeyValuePair

func (*DescribeCollectionResponse) GetSchema 

func (m *DescribeCollectionResponse) GetSchema() *schemapb.CollectionSchema

func (*DescribeCollectionResponse) GetShardsNum 

func (m *DescribeCollectionResponse) GetShardsNum() int32

func (*DescribeCollectionResponse) GetStartPositions 

func (m *DescribeCollectionResponse) GetStartPositions() []*commonpb.KeyDataPair

func (*DescribeCollectionResponse) GetStatus 

func (m *DescribeCollectionResponse) GetStatus() *commonpb.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 {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// The particular collection name in Milvus
	CollectionName string `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	// The vector field name in this particular collection
	FieldName string `protobuf:"bytes,4,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	// No need to set up for now @2021.06.30
	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:"-"`
}

Get created index information. Current release of Milvus only supports showing latest built index.

func (*DescribeIndexRequest) Descriptor 

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

func (*DescribeIndexRequest) GetBase 

func (m *DescribeIndexRequest) GetBase() *commonpb.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 {
	// Response status
	Status *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// All index informations, for now only return tha latest index you created for the collection.
	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:"-"`
}

Describe index response

func (*DescribeIndexResponse) Descriptor 

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

func (*DescribeIndexResponse) GetIndexDescriptions 

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

func (*DescribeIndexResponse) GetStatus 

func (m *DescribeIndexResponse) GetStatus() *commonpb.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                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	CollectionID         int64             `protobuf:"varint,2,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	SegmentID            int64             `protobuf:"varint,3,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DescribeSegmentRequest) Descriptor 

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

func (*DescribeSegmentRequest) GetBase 

func (m *DescribeSegmentRequest) GetBase() *commonpb.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               *commonpb.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"`
	FieldID              int64            `protobuf:"varint,5,opt,name=fieldID,proto3" json:"fieldID,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) GetFieldID 

func (m *DescribeSegmentResponse) GetFieldID() int64

func (*DescribeSegmentResponse) GetIndexID 

func (m *DescribeSegmentResponse) GetIndexID() int64

func (*DescribeSegmentResponse) GetStatus 

func (m *DescribeSegmentResponse) GetStatus() *commonpb.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 DropAliasRequest 

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

func (*DropAliasRequest) Descriptor 

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

func (*DropAliasRequest) GetAlias 

func (m *DropAliasRequest) GetAlias() string

func (*DropAliasRequest) GetBase 

func (m *DropAliasRequest) GetBase() *commonpb.MsgBase

func (*DropAliasRequest) GetDbName 

func (m *DropAliasRequest) GetDbName() string

func (*DropAliasRequest) ProtoMessage 

func (*DropAliasRequest) ProtoMessage()

func (*DropAliasRequest) Reset 

func (m *DropAliasRequest) Reset()

func (*DropAliasRequest) String 

func (m *DropAliasRequest) String() string

func (*DropAliasRequest) XXX_DiscardUnknown 

func (m *DropAliasRequest) XXX_DiscardUnknown()

func (*DropAliasRequest) XXX_Marshal 

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

func (*DropAliasRequest) XXX_Merge 

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

func (*DropAliasRequest) XXX_Size 

func (m *DropAliasRequest) XXX_Size() int

func (*DropAliasRequest) XXX_Unmarshal 

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

type DropCollectionRequest 

type DropCollectionRequest struct {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// The unique collection name in milvus.(Required)
	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:"-"`
}

* Drop collection in milvus, also will drop data in collection.

func (*DropCollectionRequest) Descriptor 

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

func (*DropCollectionRequest) GetBase 

func (m *DropCollectionRequest) GetBase() *commonpb.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                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	FieldName            string            `protobuf:"bytes,4,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	IndexName            string            `protobuf:"bytes,5,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DropIndexRequest) Descriptor 

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

func (*DropIndexRequest) GetBase 

func (m *DropIndexRequest) GetBase() *commonpb.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 {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// The collection name in milvus
	CollectionName string `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	// The partition name you want to drop
	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:"-"`
}

Drop partition in created collection.

func (*DropPartitionRequest) Descriptor 

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

func (*DropPartitionRequest) GetBase 

func (m *DropPartitionRequest) GetBase() *commonpb.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 DropRoleRequest 

type DropRoleRequest struct {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// role name
	RoleName             string   `protobuf:"bytes,2,opt,name=role_name,json=roleName,proto3" json:"role_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DropRoleRequest) Descriptor 

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

func (*DropRoleRequest) GetBase 

func (m *DropRoleRequest) GetBase() *commonpb.MsgBase

func (*DropRoleRequest) GetRoleName 

func (m *DropRoleRequest) GetRoleName() string

func (*DropRoleRequest) ProtoMessage 

func (*DropRoleRequest) ProtoMessage()

func (*DropRoleRequest) Reset 

func (m *DropRoleRequest) Reset()

func (*DropRoleRequest) String 

func (m *DropRoleRequest) String() string

func (*DropRoleRequest) XXX_DiscardUnknown 

func (m *DropRoleRequest) XXX_DiscardUnknown()

func (*DropRoleRequest) XXX_Marshal 

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

func (*DropRoleRequest) XXX_Merge 

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

func (*DropRoleRequest) XXX_Size 

func (m *DropRoleRequest) XXX_Size() int

func (*DropRoleRequest) XXX_Unmarshal 

func (m *DropRoleRequest) 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                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	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() *commonpb.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               *commonpb.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]*schemapb.LongArray `` /* 179-byte string literal not displayed */
	FlushCollSegIDs      map[string]*schemapb.LongArray `` /* 196-byte string literal not displayed */
	CollSealTimes        map[string]int64               `` /* 191-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) GetCollSealTimes 

func (m *FlushResponse) GetCollSealTimes() map[string]int64

func (*FlushResponse) GetCollSegIDs 

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

func (*FlushResponse) GetDbName 

func (m *FlushResponse) GetDbName() string

func (*FlushResponse) GetFlushCollSegIDs 

func (m *FlushResponse) GetFlushCollSegIDs() map[string]*schemapb.LongArray

func (*FlushResponse) GetStatus 

func (m *FlushResponse) GetStatus() *commonpb.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 {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// The collection name you want get statistics
	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:"-"`
}

* Get collection statistics like row_count.

func (*GetCollectionStatisticsRequest) Descriptor 

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

func (*GetCollectionStatisticsRequest) GetBase 

func (m *GetCollectionStatisticsRequest) GetBase() *commonpb.MsgBase

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 (m *GetCollectionStatisticsRequest) String() 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 {
	// Contain error_code and reason
	Status *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Collection statistics data
	Stats                []*commonpb.KeyValuePair `protobuf:"bytes,2,rep,name=stats,proto3" json:"stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

* Will return collection statistics in stats field like [{key:"row_count",value:"1"}]

func (*GetCollectionStatisticsResponse) Descriptor 

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

func (*GetCollectionStatisticsResponse) GetStats 

func (m *GetCollectionStatisticsResponse) GetStats() []*commonpb.KeyValuePair

func (*GetCollectionStatisticsResponse) GetStatus 

func (m *GetCollectionStatisticsResponse) GetStatus() *commonpb.Status

func (*GetCollectionStatisticsResponse) ProtoMessage 

func (*GetCollectionStatisticsResponse) ProtoMessage()

func (*GetCollectionStatisticsResponse) Reset 

func (m *GetCollectionStatisticsResponse) Reset()

func (*GetCollectionStatisticsResponse) String 

func (m *GetCollectionStatisticsResponse) String() 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 GetCompactionPlansRequest 

type GetCompactionPlansRequest struct {
	CompactionID         int64    `protobuf:"varint,1,opt,name=compactionID,proto3" json:"compactionID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetCompactionPlansRequest) Descriptor 

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

func (*GetCompactionPlansRequest) GetCompactionID 

func (m *GetCompactionPlansRequest) GetCompactionID() int64

func (*GetCompactionPlansRequest) ProtoMessage 

func (*GetCompactionPlansRequest) ProtoMessage()

func (*GetCompactionPlansRequest) Reset 

func (m *GetCompactionPlansRequest) Reset()

func (*GetCompactionPlansRequest) String 

func (m *GetCompactionPlansRequest) String() string

func (*GetCompactionPlansRequest) XXX_DiscardUnknown 

func (m *GetCompactionPlansRequest) XXX_DiscardUnknown()

func (*GetCompactionPlansRequest) XXX_Marshal 

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

func (*GetCompactionPlansRequest) XXX_Merge 

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

func (*GetCompactionPlansRequest) XXX_Size 

func (m *GetCompactionPlansRequest) XXX_Size() int

func (*GetCompactionPlansRequest) XXX_Unmarshal 

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

type GetCompactionPlansResponse 

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

func (*GetCompactionPlansResponse) Descriptor 

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

func (*GetCompactionPlansResponse) GetMergeInfos 

func (m *GetCompactionPlansResponse) GetMergeInfos() []*CompactionMergeInfo

func (*GetCompactionPlansResponse) GetState 

func (m *GetCompactionPlansResponse) GetState() commonpb.CompactionState

func (*GetCompactionPlansResponse) GetStatus 

func (m *GetCompactionPlansResponse) GetStatus() *commonpb.Status

func (*GetCompactionPlansResponse) ProtoMessage 

func (*GetCompactionPlansResponse) ProtoMessage()

func (*GetCompactionPlansResponse) Reset 

func (m *GetCompactionPlansResponse) Reset()

func (*GetCompactionPlansResponse) String 

func (m *GetCompactionPlansResponse) String() string

func (*GetCompactionPlansResponse) XXX_DiscardUnknown 

func (m *GetCompactionPlansResponse) XXX_DiscardUnknown()

func (*GetCompactionPlansResponse) XXX_Marshal 

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

func (*GetCompactionPlansResponse) XXX_Merge 

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

func (*GetCompactionPlansResponse) XXX_Size 

func (m *GetCompactionPlansResponse) XXX_Size() int

func (*GetCompactionPlansResponse) XXX_Unmarshal 

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

type GetCompactionStateRequest 

type GetCompactionStateRequest struct {
	CompactionID         int64    `protobuf:"varint,1,opt,name=compactionID,proto3" json:"compactionID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetCompactionStateRequest) Descriptor 

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

func (*GetCompactionStateRequest) GetCompactionID 

func (m *GetCompactionStateRequest) GetCompactionID() int64

func (*GetCompactionStateRequest) ProtoMessage 

func (*GetCompactionStateRequest) ProtoMessage()

func (*GetCompactionStateRequest) Reset 

func (m *GetCompactionStateRequest) Reset()

func (*GetCompactionStateRequest) String 

func (m *GetCompactionStateRequest) String() string

func (*GetCompactionStateRequest) XXX_DiscardUnknown 

func (m *GetCompactionStateRequest) XXX_DiscardUnknown()

func (*GetCompactionStateRequest) XXX_Marshal 

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

func (*GetCompactionStateRequest) XXX_Merge 

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

func (*GetCompactionStateRequest) XXX_Size 

func (m *GetCompactionStateRequest) XXX_Size() int

func (*GetCompactionStateRequest) XXX_Unmarshal 

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

type GetCompactionStateResponse 

type GetCompactionStateResponse struct {
	Status               *commonpb.Status         `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	State                commonpb.CompactionState `protobuf:"varint,2,opt,name=state,proto3,enum=milvus.proto.common.CompactionState" json:"state,omitempty"`
	ExecutingPlanNo      int64                    `protobuf:"varint,3,opt,name=executingPlanNo,proto3" json:"executingPlanNo,omitempty"`
	TimeoutPlanNo        int64                    `protobuf:"varint,4,opt,name=timeoutPlanNo,proto3" json:"timeoutPlanNo,omitempty"`
	CompletedPlanNo      int64                    `protobuf:"varint,5,opt,name=completedPlanNo,proto3" json:"completedPlanNo,omitempty"`
	FailedPlanNo         int64                    `protobuf:"varint,6,opt,name=failedPlanNo,proto3" json:"failedPlanNo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*GetCompactionStateResponse) Descriptor 

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

func (*GetCompactionStateResponse) GetCompletedPlanNo 

func (m *GetCompactionStateResponse) GetCompletedPlanNo() int64

func (*GetCompactionStateResponse) GetExecutingPlanNo 

func (m *GetCompactionStateResponse) GetExecutingPlanNo() int64

func (*GetCompactionStateResponse) GetFailedPlanNo 

func (m *GetCompactionStateResponse) GetFailedPlanNo() int64

func (*GetCompactionStateResponse) GetState 

func (m *GetCompactionStateResponse) GetState() commonpb.CompactionState

func (*GetCompactionStateResponse) GetStatus 

func (m *GetCompactionStateResponse) GetStatus() *commonpb.Status

func (*GetCompactionStateResponse) GetTimeoutPlanNo 

func (m *GetCompactionStateResponse) GetTimeoutPlanNo() int64

func (*GetCompactionStateResponse) ProtoMessage 

func (*GetCompactionStateResponse) ProtoMessage()

func (*GetCompactionStateResponse) Reset 

func (m *GetCompactionStateResponse) Reset()

func (*GetCompactionStateResponse) String 

func (m *GetCompactionStateResponse) String() string

func (*GetCompactionStateResponse) XXX_DiscardUnknown 

func (m *GetCompactionStateResponse) XXX_DiscardUnknown()

func (*GetCompactionStateResponse) XXX_Marshal 

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

func (*GetCompactionStateResponse) XXX_Merge 

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

func (*GetCompactionStateResponse) XXX_Size 

func (m *GetCompactionStateResponse) XXX_Size() int

func (*GetCompactionStateResponse) XXX_Unmarshal 

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

type GetComponentStatesRequest 

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

func (*GetComponentStatesRequest) Descriptor 

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

func (*GetComponentStatesRequest) ProtoMessage 

func (*GetComponentStatesRequest) ProtoMessage()

func (*GetComponentStatesRequest) Reset 

func (m *GetComponentStatesRequest) Reset()

func (*GetComponentStatesRequest) String 

func (m *GetComponentStatesRequest) String() string

func (*GetComponentStatesRequest) XXX_DiscardUnknown 

func (m *GetComponentStatesRequest) XXX_DiscardUnknown()

func (*GetComponentStatesRequest) XXX_Marshal 

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

func (*GetComponentStatesRequest) XXX_Merge 

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

func (*GetComponentStatesRequest) XXX_Size 

func (m *GetComponentStatesRequest) XXX_Size() int

func (*GetComponentStatesRequest) XXX_Unmarshal 

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

type GetFlushStateRequest 

type GetFlushStateRequest struct {
	SegmentIDs           []int64  `protobuf:"varint,1,rep,packed,name=segmentIDs,proto3" json:"segmentIDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetFlushStateRequest) Descriptor 

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

func (*GetFlushStateRequest) GetSegmentIDs 

func (m *GetFlushStateRequest) GetSegmentIDs() []int64

func (*GetFlushStateRequest) ProtoMessage 

func (*GetFlushStateRequest) ProtoMessage()

func (*GetFlushStateRequest) Reset 

func (m *GetFlushStateRequest) Reset()

func (*GetFlushStateRequest) String 

func (m *GetFlushStateRequest) String() string

func (*GetFlushStateRequest) XXX_DiscardUnknown 

func (m *GetFlushStateRequest) XXX_DiscardUnknown()

func (*GetFlushStateRequest) XXX_Marshal 

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

func (*GetFlushStateRequest) XXX_Merge 

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

func (*GetFlushStateRequest) XXX_Size 

func (m *GetFlushStateRequest) XXX_Size() int

func (*GetFlushStateRequest) XXX_Unmarshal 

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

type GetFlushStateResponse 

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

func (*GetFlushStateResponse) Descriptor 

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

func (*GetFlushStateResponse) GetFlushed 

func (m *GetFlushStateResponse) GetFlushed() bool

func (*GetFlushStateResponse) GetStatus 

func (m *GetFlushStateResponse) GetStatus() *commonpb.Status

func (*GetFlushStateResponse) ProtoMessage 

func (*GetFlushStateResponse) ProtoMessage()

func (*GetFlushStateResponse) Reset 

func (m *GetFlushStateResponse) Reset()

func (*GetFlushStateResponse) String 

func (m *GetFlushStateResponse) String() string

func (*GetFlushStateResponse) XXX_DiscardUnknown 

func (m *GetFlushStateResponse) XXX_DiscardUnknown()

func (*GetFlushStateResponse) XXX_Marshal 

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

func (*GetFlushStateResponse) XXX_Merge 

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

func (*GetFlushStateResponse) XXX_Size 

func (m *GetFlushStateResponse) XXX_Size() int

func (*GetFlushStateResponse) XXX_Unmarshal 

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

type GetImportStateRequest 

type GetImportStateRequest struct {
	Task                 int64    `protobuf:"varint,1,opt,name=task,proto3" json:"task,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetImportStateRequest) Descriptor 

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

func (*GetImportStateRequest) GetTask 

func (m *GetImportStateRequest) GetTask() int64

func (*GetImportStateRequest) ProtoMessage 

func (*GetImportStateRequest) ProtoMessage()

func (*GetImportStateRequest) Reset 

func (m *GetImportStateRequest) Reset()

func (*GetImportStateRequest) String 

func (m *GetImportStateRequest) String() string

func (*GetImportStateRequest) XXX_DiscardUnknown 

func (m *GetImportStateRequest) XXX_DiscardUnknown()

func (*GetImportStateRequest) XXX_Marshal 

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

func (*GetImportStateRequest) XXX_Merge 

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

func (*GetImportStateRequest) XXX_Size 

func (m *GetImportStateRequest) XXX_Size() int

func (*GetImportStateRequest) XXX_Unmarshal 

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

type GetImportStateResponse 

type GetImportStateResponse struct {
	Status               *commonpb.Status         `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	State                commonpb.ImportState     `protobuf:"varint,2,opt,name=state,proto3,enum=milvus.proto.common.ImportState" json:"state,omitempty"`
	RowCount             int64                    `protobuf:"varint,3,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
	IdList               []int64                  `protobuf:"varint,4,rep,packed,name=id_list,json=idList,proto3" json:"id_list,omitempty"`
	Infos                []*commonpb.KeyValuePair `protobuf:"bytes,5,rep,name=infos,proto3" json:"infos,omitempty"`
	Id                   int64                    `protobuf:"varint,6,opt,name=id,proto3" json:"id,omitempty"`
	CollectionId         int64                    `protobuf:"varint,7,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	SegmentIds           []int64                  `protobuf:"varint,8,rep,packed,name=segment_ids,json=segmentIds,proto3" json:"segment_ids,omitempty"`
	CreateTs             int64                    `protobuf:"varint,9,opt,name=create_ts,json=createTs,proto3" json:"create_ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*GetImportStateResponse) Descriptor 

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

func (*GetImportStateResponse) GetCollectionId 

func (m *GetImportStateResponse) GetCollectionId() int64

func (*GetImportStateResponse) GetCreateTs 

func (m *GetImportStateResponse) GetCreateTs() int64

func (*GetImportStateResponse) GetId 

func (m *GetImportStateResponse) GetId() int64

func (*GetImportStateResponse) GetIdList 

func (m *GetImportStateResponse) GetIdList() []int64

func (*GetImportStateResponse) GetInfos 

func (m *GetImportStateResponse) GetInfos() []*commonpb.KeyValuePair

func (*GetImportStateResponse) GetRowCount 

func (m *GetImportStateResponse) GetRowCount() int64

func (*GetImportStateResponse) GetSegmentIds 

func (m *GetImportStateResponse) GetSegmentIds() []int64

func (*GetImportStateResponse) GetState 

func (m *GetImportStateResponse) GetState() commonpb.ImportState

func (*GetImportStateResponse) GetStatus 

func (m *GetImportStateResponse) GetStatus() *commonpb.Status

func (*GetImportStateResponse) ProtoMessage 

func (*GetImportStateResponse) ProtoMessage()

func (*GetImportStateResponse) Reset 

func (m *GetImportStateResponse) Reset()

func (*GetImportStateResponse) String 

func (m *GetImportStateResponse) String() string

func (*GetImportStateResponse) XXX_DiscardUnknown 

func (m *GetImportStateResponse) XXX_DiscardUnknown()

func (*GetImportStateResponse) XXX_Marshal 

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

func (*GetImportStateResponse) XXX_Merge 

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

func (*GetImportStateResponse) XXX_Size 

func (m *GetImportStateResponse) XXX_Size() int

func (*GetImportStateResponse) XXX_Unmarshal 

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

type GetIndexBuildProgressRequest 

type GetIndexBuildProgressRequest struct {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// The collection name in milvus
	CollectionName string `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	// The vector field name in this collection
	FieldName string `protobuf:"bytes,4,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	// Not useful for now
	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:"-"`
}

Get index building progress

func (*GetIndexBuildProgressRequest) Descriptor 

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

func (*GetIndexBuildProgressRequest) GetBase 

func (m *GetIndexBuildProgressRequest) GetBase() *commonpb.MsgBase

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 (m *GetIndexBuildProgressRequest) String() 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               *commonpb.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 (m *GetIndexBuildProgressResponse) GetStatus() *commonpb.Status

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 (m *GetIndexBuildProgressResponse) String() 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                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	FieldName            string            `protobuf:"bytes,4,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	IndexName            string            `protobuf:"bytes,5,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetIndexStateRequest) Descriptor 

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

func (*GetIndexStateRequest) GetBase 

func (m *GetIndexStateRequest) GetBase() *commonpb.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               *commonpb.Status    `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	State                commonpb.IndexState `protobuf:"varint,2,opt,name=state,proto3,enum=milvus.proto.common.IndexState" json:"state,omitempty"`
	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() commonpb.IndexState

func (*GetIndexStateResponse) GetStatus 

func (m *GetIndexStateResponse) GetStatus() *commonpb.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 GetLoadingProgressRequest 

type GetLoadingProgressRequest struct {
	// Not useful for now
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	CollectionName       string            `protobuf:"bytes,2,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	PartitionNames       []string          `protobuf:"bytes,3,rep,name=partition_names,json=partitionNames,proto3" json:"partition_names,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetLoadingProgressRequest) Descriptor 

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

func (*GetLoadingProgressRequest) GetBase 

func (m *GetLoadingProgressRequest) GetBase() *commonpb.MsgBase

func (*GetLoadingProgressRequest) GetCollectionName 

func (m *GetLoadingProgressRequest) GetCollectionName() string

func (*GetLoadingProgressRequest) GetPartitionNames 

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

func (*GetLoadingProgressRequest) ProtoMessage 

func (*GetLoadingProgressRequest) ProtoMessage()

func (*GetLoadingProgressRequest) Reset 

func (m *GetLoadingProgressRequest) Reset()

func (*GetLoadingProgressRequest) String 

func (m *GetLoadingProgressRequest) String() string

func (*GetLoadingProgressRequest) XXX_DiscardUnknown 

func (m *GetLoadingProgressRequest) XXX_DiscardUnknown()

func (*GetLoadingProgressRequest) XXX_Marshal 

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

func (*GetLoadingProgressRequest) XXX_Merge 

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

func (*GetLoadingProgressRequest) XXX_Size 

func (m *GetLoadingProgressRequest) XXX_Size() int

func (*GetLoadingProgressRequest) XXX_Unmarshal 

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

type GetLoadingProgressResponse 

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

func (*GetLoadingProgressResponse) Descriptor 

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

func (*GetLoadingProgressResponse) GetProgress 

func (m *GetLoadingProgressResponse) GetProgress() int64

func (*GetLoadingProgressResponse) GetStatus 

func (m *GetLoadingProgressResponse) GetStatus() *commonpb.Status

func (*GetLoadingProgressResponse) ProtoMessage 

func (*GetLoadingProgressResponse) ProtoMessage()

func (*GetLoadingProgressResponse) Reset 

func (m *GetLoadingProgressResponse) Reset()

func (*GetLoadingProgressResponse) String 

func (m *GetLoadingProgressResponse) String() string

func (*GetLoadingProgressResponse) XXX_DiscardUnknown 

func (m *GetLoadingProgressResponse) XXX_DiscardUnknown()

func (*GetLoadingProgressResponse) XXX_Marshal 

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

func (*GetLoadingProgressResponse) XXX_Merge 

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

func (*GetLoadingProgressResponse) XXX_Size 

func (m *GetLoadingProgressResponse) XXX_Size() int

func (*GetLoadingProgressResponse) XXX_Unmarshal 

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

type GetMetricsRequest 

type GetMetricsRequest struct {
	Base                 *commonpb.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() *commonpb.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               *commonpb.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() *commonpb.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 {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// The collection name in milvus
	CollectionName string `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	// The partition name you want to collect statistics
	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:"-"`
}

Get partition statistics like row_count.

func (*GetPartitionStatisticsRequest) Descriptor 

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

func (*GetPartitionStatisticsRequest) GetBase 

func (m *GetPartitionStatisticsRequest) GetBase() *commonpb.MsgBase

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 (m *GetPartitionStatisticsRequest) String() 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               *commonpb.Status         `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Stats                []*commonpb.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 (m *GetPartitionStatisticsResponse) GetStats() []*commonpb.KeyValuePair

func (*GetPartitionStatisticsResponse) GetStatus 

func (m *GetPartitionStatisticsResponse) GetStatus() *commonpb.Status

func (*GetPartitionStatisticsResponse) ProtoMessage 

func (*GetPartitionStatisticsResponse) ProtoMessage()

func (*GetPartitionStatisticsResponse) Reset 

func (m *GetPartitionStatisticsResponse) Reset()

func (*GetPartitionStatisticsResponse) String 

func (m *GetPartitionStatisticsResponse) String() 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                 *commonpb.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 (m *GetPersistentSegmentInfoRequest) GetBase() *commonpb.MsgBase

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 (m *GetPersistentSegmentInfoRequest) Reset()

func (*GetPersistentSegmentInfoRequest) String 

func (m *GetPersistentSegmentInfoRequest) String() 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               *commonpb.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 (m *GetPersistentSegmentInfoResponse) GetInfos() []*PersistentSegmentInfo

func (*GetPersistentSegmentInfoResponse) GetStatus 

func (m *GetPersistentSegmentInfoResponse) GetStatus() *commonpb.Status

func (*GetPersistentSegmentInfoResponse) ProtoMessage 

func (*GetPersistentSegmentInfoResponse) ProtoMessage()

func (*GetPersistentSegmentInfoResponse) Reset 

func (m *GetPersistentSegmentInfoResponse) Reset()

func (*GetPersistentSegmentInfoResponse) String 

func (m *GetPersistentSegmentInfoResponse) String() 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 (m *GetPersistentSegmentInfoResponse) XXX_Merge(src proto.Message)

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                 *commonpb.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 (m *GetQuerySegmentInfoRequest) GetBase() *commonpb.MsgBase

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               *commonpb.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 (m *GetQuerySegmentInfoResponse) GetInfos() []*QuerySegmentInfo

func (*GetQuerySegmentInfoResponse) GetStatus 

func (m *GetQuerySegmentInfoResponse) GetStatus() *commonpb.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 GetReplicasRequest 

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

func (*GetReplicasRequest) Descriptor 

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

func (*GetReplicasRequest) GetBase 

func (m *GetReplicasRequest) GetBase() *commonpb.MsgBase

func (*GetReplicasRequest) GetCollectionID 

func (m *GetReplicasRequest) GetCollectionID() int64

func (*GetReplicasRequest) GetWithShardNodes 

func (m *GetReplicasRequest) GetWithShardNodes() bool

func (*GetReplicasRequest) ProtoMessage 

func (*GetReplicasRequest) ProtoMessage()

func (*GetReplicasRequest) Reset 

func (m *GetReplicasRequest) Reset()

func (*GetReplicasRequest) String 

func (m *GetReplicasRequest) String() string

func (*GetReplicasRequest) XXX_DiscardUnknown 

func (m *GetReplicasRequest) XXX_DiscardUnknown()

func (*GetReplicasRequest) XXX_Marshal 

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

func (*GetReplicasRequest) XXX_Merge 

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

func (*GetReplicasRequest) XXX_Size 

func (m *GetReplicasRequest) XXX_Size() int

func (*GetReplicasRequest) XXX_Unmarshal 

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

type GetReplicasResponse 

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

func (*GetReplicasResponse) Descriptor 

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

func (*GetReplicasResponse) GetReplicas 

func (m *GetReplicasResponse) GetReplicas() []*ReplicaInfo

func (*GetReplicasResponse) GetStatus 

func (m *GetReplicasResponse) GetStatus() *commonpb.Status

func (*GetReplicasResponse) ProtoMessage 

func (*GetReplicasResponse) ProtoMessage()

func (*GetReplicasResponse) Reset 

func (m *GetReplicasResponse) Reset()

func (*GetReplicasResponse) String 

func (m *GetReplicasResponse) String() string

func (*GetReplicasResponse) XXX_DiscardUnknown 

func (m *GetReplicasResponse) XXX_DiscardUnknown()

func (*GetReplicasResponse) XXX_Marshal 

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

func (*GetReplicasResponse) XXX_Merge 

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

func (*GetReplicasResponse) XXX_Size 

func (m *GetReplicasResponse) XXX_Size() int

func (*GetReplicasResponse) XXX_Unmarshal 

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

type GetStatisticsRequest 

type GetStatisticsRequest struct {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// The collection name you want get statistics
	CollectionName string `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	// The partition names you want get statistics, empty for all partitions
	PartitionNames []string `protobuf:"bytes,4,rep,name=partition_names,json=partitionNames,proto3" json:"partition_names,omitempty"`
	// Not useful for now, reserved for future
	GuaranteeTimestamp   uint64   `protobuf:"varint,5,opt,name=guarantee_timestamp,json=guaranteeTimestamp,proto3" json:"guarantee_timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Get statistics like row_count. WARNING: This API is experimental and not useful for now.

func (*GetStatisticsRequest) Descriptor 

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

func (*GetStatisticsRequest) GetBase 

func (m *GetStatisticsRequest) GetBase() *commonpb.MsgBase

func (*GetStatisticsRequest) GetCollectionName 

func (m *GetStatisticsRequest) GetCollectionName() string

func (*GetStatisticsRequest) GetDbName 

func (m *GetStatisticsRequest) GetDbName() string

func (*GetStatisticsRequest) GetGuaranteeTimestamp 

func (m *GetStatisticsRequest) GetGuaranteeTimestamp() uint64

func (*GetStatisticsRequest) GetPartitionNames 

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

func (*GetStatisticsRequest) ProtoMessage 

func (*GetStatisticsRequest) ProtoMessage()

func (*GetStatisticsRequest) Reset 

func (m *GetStatisticsRequest) Reset()

func (*GetStatisticsRequest) String 

func (m *GetStatisticsRequest) String() string

func (*GetStatisticsRequest) XXX_DiscardUnknown 

func (m *GetStatisticsRequest) XXX_DiscardUnknown()

func (*GetStatisticsRequest) XXX_Marshal 

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

func (*GetStatisticsRequest) XXX_Merge 

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

func (*GetStatisticsRequest) XXX_Size 

func (m *GetStatisticsRequest) XXX_Size() int

func (*GetStatisticsRequest) XXX_Unmarshal 

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

type GetStatisticsResponse 

type GetStatisticsResponse struct {
	// Contain error_code and reason
	Status *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Collection statistics data
	Stats                []*commonpb.KeyValuePair `protobuf:"bytes,2,rep,name=stats,proto3" json:"stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

* Will return statistics in stats field like [{key:"row_count",value:"1"}] WARNING: This API is experimental and not useful for now.

func (*GetStatisticsResponse) Descriptor 

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

func (*GetStatisticsResponse) GetStats 

func (m *GetStatisticsResponse) GetStats() []*commonpb.KeyValuePair

func (*GetStatisticsResponse) GetStatus 

func (m *GetStatisticsResponse) GetStatus() *commonpb.Status

func (*GetStatisticsResponse) ProtoMessage 

func (*GetStatisticsResponse) ProtoMessage()

func (*GetStatisticsResponse) Reset 

func (m *GetStatisticsResponse) Reset()

func (*GetStatisticsResponse) String 

func (m *GetStatisticsResponse) String() string

func (*GetStatisticsResponse) XXX_DiscardUnknown 

func (m *GetStatisticsResponse) XXX_DiscardUnknown()

func (*GetStatisticsResponse) XXX_Marshal 

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

func (*GetStatisticsResponse) XXX_Merge 

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

func (*GetStatisticsResponse) XXX_Size 

func (m *GetStatisticsResponse) XXX_Size() int

func (*GetStatisticsResponse) XXX_Unmarshal 

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

type GetVersionRequest 

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

func (*GetVersionRequest) Descriptor 

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

func (*GetVersionRequest) ProtoMessage 

func (*GetVersionRequest) ProtoMessage()

func (*GetVersionRequest) Reset 

func (m *GetVersionRequest) Reset()

func (*GetVersionRequest) String 

func (m *GetVersionRequest) String() string

func (*GetVersionRequest) XXX_DiscardUnknown 

func (m *GetVersionRequest) XXX_DiscardUnknown()

func (*GetVersionRequest) XXX_Marshal 

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

func (*GetVersionRequest) XXX_Merge 

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

func (*GetVersionRequest) XXX_Size 

func (m *GetVersionRequest) XXX_Size() int

func (*GetVersionRequest) XXX_Unmarshal 

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

type GetVersionResponse 

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

func (*GetVersionResponse) Descriptor 

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

func (*GetVersionResponse) GetVersion 

func (m *GetVersionResponse) GetVersion() string

func (*GetVersionResponse) ProtoMessage 

func (*GetVersionResponse) ProtoMessage()

func (*GetVersionResponse) Reset 

func (m *GetVersionResponse) Reset()

func (*GetVersionResponse) String 

func (m *GetVersionResponse) String() string

func (*GetVersionResponse) XXX_DiscardUnknown 

func (m *GetVersionResponse) XXX_DiscardUnknown()

func (*GetVersionResponse) XXX_Marshal 

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

func (*GetVersionResponse) XXX_Merge 

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

func (*GetVersionResponse) XXX_Size 

func (m *GetVersionResponse) XXX_Size() int

func (*GetVersionResponse) XXX_Unmarshal 

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

type GrantEntity 

type GrantEntity struct {
	// role
	Role *RoleEntity `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"`
	// object
	Object *ObjectEntity `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
	// object name
	ObjectName string `protobuf:"bytes,3,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
	// privilege
	Grantor              *GrantorEntity `protobuf:"bytes,4,opt,name=grantor,proto3" json:"grantor,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GrantEntity) Descriptor 

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

func (*GrantEntity) GetGrantor 

func (m *GrantEntity) GetGrantor() *GrantorEntity

func (*GrantEntity) GetObject 

func (m *GrantEntity) GetObject() *ObjectEntity

func (*GrantEntity) GetObjectName 

func (m *GrantEntity) GetObjectName() string

func (*GrantEntity) GetRole 

func (m *GrantEntity) GetRole() *RoleEntity

func (*GrantEntity) ProtoMessage 

func (*GrantEntity) ProtoMessage()

func (*GrantEntity) Reset 

func (m *GrantEntity) Reset()

func (*GrantEntity) String 

func (m *GrantEntity) String() string

func (*GrantEntity) XXX_DiscardUnknown 

func (m *GrantEntity) XXX_DiscardUnknown()

func (*GrantEntity) XXX_Marshal 

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

func (*GrantEntity) XXX_Merge 

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

func (*GrantEntity) XXX_Size 

func (m *GrantEntity) XXX_Size() int

func (*GrantEntity) XXX_Unmarshal 

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

type GrantPrivilegeEntity 

type GrantPrivilegeEntity struct {
	Entities             []*GrantorEntity `protobuf:"bytes,1,rep,name=entities,proto3" json:"entities,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*GrantPrivilegeEntity) Descriptor 

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

func (*GrantPrivilegeEntity) GetEntities 

func (m *GrantPrivilegeEntity) GetEntities() []*GrantorEntity

func (*GrantPrivilegeEntity) ProtoMessage 

func (*GrantPrivilegeEntity) ProtoMessage()

func (*GrantPrivilegeEntity) Reset 

func (m *GrantPrivilegeEntity) Reset()

func (*GrantPrivilegeEntity) String 

func (m *GrantPrivilegeEntity) String() string

func (*GrantPrivilegeEntity) XXX_DiscardUnknown 

func (m *GrantPrivilegeEntity) XXX_DiscardUnknown()

func (*GrantPrivilegeEntity) XXX_Marshal 

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

func (*GrantPrivilegeEntity) XXX_Merge 

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

func (*GrantPrivilegeEntity) XXX_Size 

func (m *GrantPrivilegeEntity) XXX_Size() int

func (*GrantPrivilegeEntity) XXX_Unmarshal 

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

type GrantorEntity 

type GrantorEntity struct {
	User                 *UserEntity      `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Privilege            *PrivilegeEntity `protobuf:"bytes,2,opt,name=privilege,proto3" json:"privilege,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*GrantorEntity) Descriptor 

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

func (*GrantorEntity) GetPrivilege 

func (m *GrantorEntity) GetPrivilege() *PrivilegeEntity

func (*GrantorEntity) GetUser 

func (m *GrantorEntity) GetUser() *UserEntity

func (*GrantorEntity) ProtoMessage 

func (*GrantorEntity) ProtoMessage()

func (*GrantorEntity) Reset 

func (m *GrantorEntity) Reset()

func (*GrantorEntity) String 

func (m *GrantorEntity) String() string

func (*GrantorEntity) XXX_DiscardUnknown 

func (m *GrantorEntity) XXX_DiscardUnknown()

func (*GrantorEntity) XXX_Marshal 

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

func (*GrantorEntity) XXX_Merge 

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

func (*GrantorEntity) XXX_Size 

func (m *GrantorEntity) XXX_Size() int

func (*GrantorEntity) XXX_Unmarshal 

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

type HasCollectionRequest 

type HasCollectionRequest struct {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// The collection name you want to check.
	CollectionName string `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	// If time_stamp is not zero, will return true when time_stamp >= created collection timestamp, otherwise will return false.
	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:"-"`
}

* Check collection exist in milvus or not.

func (*HasCollectionRequest) Descriptor 

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

func (*HasCollectionRequest) GetBase 

func (m *HasCollectionRequest) GetBase() *commonpb.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 {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// The collection name in milvus
	CollectionName string `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	// The partition name you want to check
	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:"-"`
}

Check if partition exist in collection or not.

func (*HasPartitionRequest) Descriptor 

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

func (*HasPartitionRequest) GetBase 

func (m *HasPartitionRequest) GetBase() *commonpb.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,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 ImportRequest 

type ImportRequest struct {
	CollectionName       string                   `protobuf:"bytes,1,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	PartitionName        string                   `protobuf:"bytes,2,opt,name=partition_name,json=partitionName,proto3" json:"partition_name,omitempty"`
	ChannelNames         []string                 `protobuf:"bytes,3,rep,name=channel_names,json=channelNames,proto3" json:"channel_names,omitempty"`
	RowBased             bool                     `protobuf:"varint,4,opt,name=row_based,json=rowBased,proto3" json:"row_based,omitempty"`
	Files                []string                 `protobuf:"bytes,5,rep,name=files,proto3" json:"files,omitempty"`
	Options              []*commonpb.KeyValuePair `protobuf:"bytes,6,rep,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*ImportRequest) Descriptor 

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

func (*ImportRequest) GetChannelNames 

func (m *ImportRequest) GetChannelNames() []string

func (*ImportRequest) GetCollectionName 

func (m *ImportRequest) GetCollectionName() string

func (*ImportRequest) GetFiles 

func (m *ImportRequest) GetFiles() []string

func (*ImportRequest) GetOptions 

func (m *ImportRequest) GetOptions() []*commonpb.KeyValuePair

func (*ImportRequest) GetPartitionName 

func (m *ImportRequest) GetPartitionName() string

func (*ImportRequest) GetRowBased 

func (m *ImportRequest) GetRowBased() bool

func (*ImportRequest) ProtoMessage 

func (*ImportRequest) ProtoMessage()

func (*ImportRequest) Reset 

func (m *ImportRequest) Reset()

func (*ImportRequest) String 

func (m *ImportRequest) String() string

func (*ImportRequest) XXX_DiscardUnknown 

func (m *ImportRequest) XXX_DiscardUnknown()

func (*ImportRequest) XXX_Marshal 

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

func (*ImportRequest) XXX_Merge 

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

func (*ImportRequest) XXX_Size 

func (m *ImportRequest) XXX_Size() int

func (*ImportRequest) XXX_Unmarshal 

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

type ImportResponse 

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

func (*ImportResponse) Descriptor 

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

func (*ImportResponse) GetStatus 

func (m *ImportResponse) GetStatus() *commonpb.Status

func (*ImportResponse) GetTasks 

func (m *ImportResponse) GetTasks() []int64

func (*ImportResponse) ProtoMessage 

func (*ImportResponse) ProtoMessage()

func (*ImportResponse) Reset 

func (m *ImportResponse) Reset()

func (*ImportResponse) String 

func (m *ImportResponse) String() string

func (*ImportResponse) XXX_DiscardUnknown 

func (m *ImportResponse) XXX_DiscardUnknown()

func (*ImportResponse) XXX_Marshal 

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

func (*ImportResponse) XXX_Merge 

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

func (*ImportResponse) XXX_Size 

func (m *ImportResponse) XXX_Size() int

func (*ImportResponse) XXX_Unmarshal 

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

type IndexDescription 

type IndexDescription struct {
	// Index name
	IndexName string `protobuf:"bytes,1,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	// Index id
	IndexID int64 `protobuf:"varint,2,opt,name=indexID,proto3" json:"indexID,omitempty"`
	// Will return index_type, metric_type, params(like nlist).
	Params []*commonpb.KeyValuePair `protobuf:"bytes,3,rep,name=params,proto3" json:"params,omitempty"`
	// The vector field name
	FieldName string `protobuf:"bytes,4,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	// index build progress
	IndexedRows int64 `protobuf:"varint,5,opt,name=indexed_rows,json=indexedRows,proto3" json:"indexed_rows,omitempty"`
	TotalRows   int64 `protobuf:"varint,6,opt,name=total_rows,json=totalRows,proto3" json:"total_rows,omitempty"`
	// index state
	State                commonpb.IndexState `protobuf:"varint,7,opt,name=state,proto3,enum=milvus.proto.common.IndexState" json:"state,omitempty"`
	IndexStateFailReason string              `protobuf:"bytes,8,opt,name=index_state_fail_reason,json=indexStateFailReason,proto3" json:"index_state_fail_reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Index informations

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) GetIndexStateFailReason 

func (m *IndexDescription) GetIndexStateFailReason() string

func (*IndexDescription) GetIndexedRows 

func (m *IndexDescription) GetIndexedRows() int64

func (*IndexDescription) GetParams 

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

func (*IndexDescription) GetState 

func (m *IndexDescription) GetState() commonpb.IndexState

func (*IndexDescription) GetTotalRows 

func (m *IndexDescription) GetTotalRows() int64

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                 *commonpb.MsgBase     `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string                `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string                `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	PartitionName        string                `protobuf:"bytes,4,opt,name=partition_name,json=partitionName,proto3" json:"partition_name,omitempty"`
	FieldsData           []*schemapb.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() *commonpb.MsgBase

func (*InsertRequest) GetCollectionName 

func (m *InsertRequest) GetCollectionName() string

func (*InsertRequest) GetDbName 

func (m *InsertRequest) GetDbName() string

func (*InsertRequest) GetFieldsData 

func (m *InsertRequest) GetFieldsData() []*schemapb.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 ListCredUsersRequest 

type ListCredUsersRequest struct {
	// Not useful for now
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ListCredUsersRequest) Descriptor 

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

func (*ListCredUsersRequest) GetBase 

func (m *ListCredUsersRequest) GetBase() *commonpb.MsgBase

func (*ListCredUsersRequest) ProtoMessage 

func (*ListCredUsersRequest) ProtoMessage()

func (*ListCredUsersRequest) Reset 

func (m *ListCredUsersRequest) Reset()

func (*ListCredUsersRequest) String 

func (m *ListCredUsersRequest) String() string

func (*ListCredUsersRequest) XXX_DiscardUnknown 

func (m *ListCredUsersRequest) XXX_DiscardUnknown()

func (*ListCredUsersRequest) XXX_Marshal 

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

func (*ListCredUsersRequest) XXX_Merge 

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

func (*ListCredUsersRequest) XXX_Size 

func (m *ListCredUsersRequest) XXX_Size() int

func (*ListCredUsersRequest) XXX_Unmarshal 

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

type ListCredUsersResponse 

type ListCredUsersResponse struct {
	// Contain error_code and reason
	Status *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// username array
	Usernames            []string `protobuf:"bytes,2,rep,name=usernames,proto3" json:"usernames,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListCredUsersResponse) Descriptor 

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

func (*ListCredUsersResponse) GetStatus 

func (m *ListCredUsersResponse) GetStatus() *commonpb.Status

func (*ListCredUsersResponse) GetUsernames 

func (m *ListCredUsersResponse) GetUsernames() []string

func (*ListCredUsersResponse) ProtoMessage 

func (*ListCredUsersResponse) ProtoMessage()

func (*ListCredUsersResponse) Reset 

func (m *ListCredUsersResponse) Reset()

func (*ListCredUsersResponse) String 

func (m *ListCredUsersResponse) String() string

func (*ListCredUsersResponse) XXX_DiscardUnknown 

func (m *ListCredUsersResponse) XXX_DiscardUnknown()

func (*ListCredUsersResponse) XXX_Marshal 

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

func (*ListCredUsersResponse) XXX_Merge 

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

func (*ListCredUsersResponse) XXX_Size 

func (m *ListCredUsersResponse) XXX_Size() int

func (*ListCredUsersResponse) XXX_Unmarshal 

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

type ListImportTasksRequest 

type ListImportTasksRequest struct {
	CollectionName       string   `protobuf:"bytes,1,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	Limit                int64    `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListImportTasksRequest) Descriptor 

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

func (*ListImportTasksRequest) GetCollectionName 

func (m *ListImportTasksRequest) GetCollectionName() string

func (*ListImportTasksRequest) GetLimit 

func (m *ListImportTasksRequest) GetLimit() int64

func (*ListImportTasksRequest) ProtoMessage 

func (*ListImportTasksRequest) ProtoMessage()

func (*ListImportTasksRequest) Reset 

func (m *ListImportTasksRequest) Reset()

func (*ListImportTasksRequest) String 

func (m *ListImportTasksRequest) String() string

func (*ListImportTasksRequest) XXX_DiscardUnknown 

func (m *ListImportTasksRequest) XXX_DiscardUnknown()

func (*ListImportTasksRequest) XXX_Marshal 

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

func (*ListImportTasksRequest) XXX_Merge 

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

func (*ListImportTasksRequest) XXX_Size 

func (m *ListImportTasksRequest) XXX_Size() int

func (*ListImportTasksRequest) XXX_Unmarshal 

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

type ListImportTasksResponse 

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

func (*ListImportTasksResponse) Descriptor 

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

func (*ListImportTasksResponse) GetStatus 

func (m *ListImportTasksResponse) GetStatus() *commonpb.Status

func (*ListImportTasksResponse) GetTasks 

func (m *ListImportTasksResponse) GetTasks() []*GetImportStateResponse

func (*ListImportTasksResponse) ProtoMessage 

func (*ListImportTasksResponse) ProtoMessage()

func (*ListImportTasksResponse) Reset 

func (m *ListImportTasksResponse) Reset()

func (*ListImportTasksResponse) String 

func (m *ListImportTasksResponse) String() string

func (*ListImportTasksResponse) XXX_DiscardUnknown 

func (m *ListImportTasksResponse) XXX_DiscardUnknown()

func (*ListImportTasksResponse) XXX_Marshal 

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

func (*ListImportTasksResponse) XXX_Merge 

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

func (*ListImportTasksResponse) XXX_Size 

func (m *ListImportTasksResponse) XXX_Size() int

func (*ListImportTasksResponse) XXX_Unmarshal 

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

type LoadBalanceRequest 

type LoadBalanceRequest struct {
	Base                 *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	SrcNodeID            int64             `protobuf:"varint,2,opt,name=src_nodeID,json=srcNodeID,proto3" json:"src_nodeID,omitempty"`
	DstNodeIDs           []int64           `protobuf:"varint,3,rep,packed,name=dst_nodeIDs,json=dstNodeIDs,proto3" json:"dst_nodeIDs,omitempty"`
	SealedSegmentIDs     []int64           `protobuf:"varint,4,rep,packed,name=sealed_segmentIDs,json=sealedSegmentIDs,proto3" json:"sealed_segmentIDs,omitempty"`
	CollectionName       string            `protobuf:"bytes,5,opt,name=collectionName,proto3" json:"collectionName,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Do load balancing operation from src_nodeID to dst_nodeID.

func (*LoadBalanceRequest) Descriptor 

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

func (*LoadBalanceRequest) GetBase 

func (m *LoadBalanceRequest) GetBase() *commonpb.MsgBase

func (*LoadBalanceRequest) GetCollectionName 

func (m *LoadBalanceRequest) GetCollectionName() string

func (*LoadBalanceRequest) GetDstNodeIDs 

func (m *LoadBalanceRequest) GetDstNodeIDs() []int64

func (*LoadBalanceRequest) GetSealedSegmentIDs 

func (m *LoadBalanceRequest) GetSealedSegmentIDs() []int64

func (*LoadBalanceRequest) GetSrcNodeID 

func (m *LoadBalanceRequest) GetSrcNodeID() int64

func (*LoadBalanceRequest) ProtoMessage 

func (*LoadBalanceRequest) ProtoMessage()

func (*LoadBalanceRequest) Reset 

func (m *LoadBalanceRequest) Reset()

func (*LoadBalanceRequest) String 

func (m *LoadBalanceRequest) String() string

func (*LoadBalanceRequest) XXX_DiscardUnknown 

func (m *LoadBalanceRequest) XXX_DiscardUnknown()

func (*LoadBalanceRequest) XXX_Marshal 

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

func (*LoadBalanceRequest) XXX_Merge 

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

func (*LoadBalanceRequest) XXX_Size 

func (m *LoadBalanceRequest) XXX_Size() int

func (*LoadBalanceRequest) XXX_Unmarshal 

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

type LoadCollectionRequest 

type LoadCollectionRequest struct {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// The collection name you want to load
	CollectionName string `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	// The replica number to load, default by 1
	ReplicaNumber        int32    `protobuf:"varint,4,opt,name=replica_number,json=replicaNumber,proto3" json:"replica_number,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Load collection data into query nodes, then you can do vector search on this collection.

func (*LoadCollectionRequest) Descriptor 

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

func (*LoadCollectionRequest) GetBase 

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

func (*LoadCollectionRequest) GetCollectionName 

func (m *LoadCollectionRequest) GetCollectionName() string

func (*LoadCollectionRequest) GetDbName 

func (m *LoadCollectionRequest) GetDbName() string

func (*LoadCollectionRequest) GetReplicaNumber 

func (m *LoadCollectionRequest) GetReplicaNumber() int32

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 {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// The collection name in milvus
	CollectionName string `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	// The partition names you want to load
	PartitionNames []string `protobuf:"bytes,4,rep,name=partition_names,json=partitionNames,proto3" json:"partition_names,omitempty"`
	// The replicas number you would load, 1 by default
	ReplicaNumber        int32    `protobuf:"varint,5,opt,name=replica_number,json=replicaNumber,proto3" json:"replica_number,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Load specific partitions data of one collection into query nodes Then you can get these data as result when you do vector search on this collection.

func (*LoadPartitionsRequest) Descriptor 

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

func (*LoadPartitionsRequest) GetBase 

func (m *LoadPartitionsRequest) GetBase() *commonpb.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) GetReplicaNumber 

func (m *LoadPartitionsRequest) GetReplicaNumber() int32

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 ManualCompactionRequest 

type ManualCompactionRequest struct {
	CollectionID         int64    `protobuf:"varint,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	Timetravel           uint64   `protobuf:"varint,2,opt,name=timetravel,proto3" json:"timetravel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ManualCompactionRequest) Descriptor 

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

func (*ManualCompactionRequest) GetCollectionID 

func (m *ManualCompactionRequest) GetCollectionID() int64

func (*ManualCompactionRequest) GetTimetravel 

func (m *ManualCompactionRequest) GetTimetravel() uint64

func (*ManualCompactionRequest) ProtoMessage 

func (*ManualCompactionRequest) ProtoMessage()

func (*ManualCompactionRequest) Reset 

func (m *ManualCompactionRequest) Reset()

func (*ManualCompactionRequest) String 

func (m *ManualCompactionRequest) String() string

func (*ManualCompactionRequest) XXX_DiscardUnknown 

func (m *ManualCompactionRequest) XXX_DiscardUnknown()

func (*ManualCompactionRequest) XXX_Marshal 

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

func (*ManualCompactionRequest) XXX_Merge 

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

func (*ManualCompactionRequest) XXX_Size 

func (m *ManualCompactionRequest) XXX_Size() int

func (*ManualCompactionRequest) XXX_Unmarshal 

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

type ManualCompactionResponse 

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

func (*ManualCompactionResponse) Descriptor 

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

func (*ManualCompactionResponse) GetCompactionID 

func (m *ManualCompactionResponse) GetCompactionID() int64

func (*ManualCompactionResponse) GetStatus 

func (m *ManualCompactionResponse) GetStatus() *commonpb.Status

func (*ManualCompactionResponse) ProtoMessage 

func (*ManualCompactionResponse) ProtoMessage()

func (*ManualCompactionResponse) Reset 

func (m *ManualCompactionResponse) Reset()

func (*ManualCompactionResponse) String 

func (m *ManualCompactionResponse) String() string

func (*ManualCompactionResponse) XXX_DiscardUnknown 

func (m *ManualCompactionResponse) XXX_DiscardUnknown()

func (*ManualCompactionResponse) XXX_Marshal 

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

func (*ManualCompactionResponse) XXX_Merge 

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

func (*ManualCompactionResponse) XXX_Size 

func (m *ManualCompactionResponse) XXX_Size() int

func (*ManualCompactionResponse) XXX_Unmarshal 

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

type MilvusExt 

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

func (*MilvusExt) Descriptor 

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

func (*MilvusExt) GetVersion 

func (m *MilvusExt) GetVersion() string

func (*MilvusExt) ProtoMessage 

func (*MilvusExt) ProtoMessage()

func (*MilvusExt) Reset 

func (m *MilvusExt) Reset()

func (*MilvusExt) String 

func (m *MilvusExt) String() string

func (*MilvusExt) XXX_DiscardUnknown 

func (m *MilvusExt) XXX_DiscardUnknown()

func (*MilvusExt) XXX_Marshal 

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

func (*MilvusExt) XXX_Merge 

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

func (*MilvusExt) XXX_Size 

func (m *MilvusExt) XXX_Size() int

func (*MilvusExt) XXX_Unmarshal 

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

type MilvusServiceClient 

type MilvusServiceClient interface {
	CreateCollection(ctx context.Context, in *CreateCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	DropCollection(ctx context.Context, in *DropCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	HasCollection(ctx context.Context, in *HasCollectionRequest, opts ...grpc.CallOption) (*BoolResponse, error)
	LoadCollection(ctx context.Context, in *LoadCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	ReleaseCollection(ctx context.Context, in *ReleaseCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	DescribeCollection(ctx context.Context, in *DescribeCollectionRequest, opts ...grpc.CallOption) (*DescribeCollectionResponse, error)
	GetCollectionStatistics(ctx context.Context, in *GetCollectionStatisticsRequest, opts ...grpc.CallOption) (*GetCollectionStatisticsResponse, error)
	ShowCollections(ctx context.Context, in *ShowCollectionsRequest, opts ...grpc.CallOption) (*ShowCollectionsResponse, error)
	AlterCollection(ctx context.Context, in *AlterCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	CreatePartition(ctx context.Context, in *CreatePartitionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	DropPartition(ctx context.Context, in *DropPartitionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	HasPartition(ctx context.Context, in *HasPartitionRequest, opts ...grpc.CallOption) (*BoolResponse, error)
	LoadPartitions(ctx context.Context, in *LoadPartitionsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	ReleasePartitions(ctx context.Context, in *ReleasePartitionsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	GetPartitionStatistics(ctx context.Context, in *GetPartitionStatisticsRequest, opts ...grpc.CallOption) (*GetPartitionStatisticsResponse, error)
	ShowPartitions(ctx context.Context, in *ShowPartitionsRequest, opts ...grpc.CallOption) (*ShowPartitionsResponse, error)
	GetLoadingProgress(ctx context.Context, in *GetLoadingProgressRequest, opts ...grpc.CallOption) (*GetLoadingProgressResponse, error)
	CreateAlias(ctx context.Context, in *CreateAliasRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	DropAlias(ctx context.Context, in *DropAliasRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	AlterAlias(ctx context.Context, in *AlterAliasRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	CreateIndex(ctx context.Context, in *CreateIndexRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	DescribeIndex(ctx context.Context, in *DescribeIndexRequest, opts ...grpc.CallOption) (*DescribeIndexResponse, error)
	// Deprecated: use DescribeIndex instead
	GetIndexState(ctx context.Context, in *GetIndexStateRequest, opts ...grpc.CallOption) (*GetIndexStateResponse, error)
	// Deprecated: use DescribeIndex instead
	GetIndexBuildProgress(ctx context.Context, in *GetIndexBuildProgressRequest, opts ...grpc.CallOption) (*GetIndexBuildProgressResponse, error)
	DropIndex(ctx context.Context, in *DropIndexRequest, opts ...grpc.CallOption) (*commonpb.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)
	GetFlushState(ctx context.Context, in *GetFlushStateRequest, opts ...grpc.CallOption) (*GetFlushStateResponse, error)
	GetPersistentSegmentInfo(ctx context.Context, in *GetPersistentSegmentInfoRequest, opts ...grpc.CallOption) (*GetPersistentSegmentInfoResponse, error)
	GetQuerySegmentInfo(ctx context.Context, in *GetQuerySegmentInfoRequest, opts ...grpc.CallOption) (*GetQuerySegmentInfoResponse, error)
	GetReplicas(ctx context.Context, in *GetReplicasRequest, opts ...grpc.CallOption) (*GetReplicasResponse, 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)
	GetComponentStates(ctx context.Context, in *GetComponentStatesRequest, opts ...grpc.CallOption) (*ComponentStates, error)
	LoadBalance(ctx context.Context, in *LoadBalanceRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	GetCompactionState(ctx context.Context, in *GetCompactionStateRequest, opts ...grpc.CallOption) (*GetCompactionStateResponse, error)
	ManualCompaction(ctx context.Context, in *ManualCompactionRequest, opts ...grpc.CallOption) (*ManualCompactionResponse, error)
	GetCompactionStateWithPlans(ctx context.Context, in *GetCompactionPlansRequest, opts ...grpc.CallOption) (*GetCompactionPlansResponse, error)
	// https://wiki.lfaidata.foundation/display/MIL/MEP+24+--+Support+bulk+load
	Import(ctx context.Context, in *ImportRequest, opts ...grpc.CallOption) (*ImportResponse, error)
	GetImportState(ctx context.Context, in *GetImportStateRequest, opts ...grpc.CallOption) (*GetImportStateResponse, error)
	ListImportTasks(ctx context.Context, in *ListImportTasksRequest, opts ...grpc.CallOption) (*ListImportTasksResponse, error)
	// https://wiki.lfaidata.foundation/display/MIL/MEP+27+--+Support+Basic+Authentication
	CreateCredential(ctx context.Context, in *CreateCredentialRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	UpdateCredential(ctx context.Context, in *UpdateCredentialRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	DeleteCredential(ctx context.Context, in *DeleteCredentialRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	ListCredUsers(ctx context.Context, in *ListCredUsersRequest, opts ...grpc.CallOption) (*ListCredUsersResponse, error)
	// https://wiki.lfaidata.foundation/display/MIL/MEP+29+--+Support+Role-Based+Access+Control
	CreateRole(ctx context.Context, in *CreateRoleRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	DropRole(ctx context.Context, in *DropRoleRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	OperateUserRole(ctx context.Context, in *OperateUserRoleRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	SelectRole(ctx context.Context, in *SelectRoleRequest, opts ...grpc.CallOption) (*SelectRoleResponse, error)
	SelectUser(ctx context.Context, in *SelectUserRequest, opts ...grpc.CallOption) (*SelectUserResponse, error)
	OperatePrivilege(ctx context.Context, in *OperatePrivilegeRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
	SelectGrant(ctx context.Context, in *SelectGrantRequest, opts ...grpc.CallOption) (*SelectGrantResponse, error)
	GetVersion(ctx context.Context, in *GetVersionRequest, opts ...grpc.CallOption) (*GetVersionResponse, 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) (*commonpb.Status, error)
	DropCollection(context.Context, *DropCollectionRequest) (*commonpb.Status, error)
	HasCollection(context.Context, *HasCollectionRequest) (*BoolResponse, error)
	LoadCollection(context.Context, *LoadCollectionRequest) (*commonpb.Status, error)
	ReleaseCollection(context.Context, *ReleaseCollectionRequest) (*commonpb.Status, error)
	DescribeCollection(context.Context, *DescribeCollectionRequest) (*DescribeCollectionResponse, error)
	GetCollectionStatistics(context.Context, *GetCollectionStatisticsRequest) (*GetCollectionStatisticsResponse, error)
	ShowCollections(context.Context, *ShowCollectionsRequest) (*ShowCollectionsResponse, error)
	AlterCollection(context.Context, *AlterCollectionRequest) (*commonpb.Status, error)
	CreatePartition(context.Context, *CreatePartitionRequest) (*commonpb.Status, error)
	DropPartition(context.Context, *DropPartitionRequest) (*commonpb.Status, error)
	HasPartition(context.Context, *HasPartitionRequest) (*BoolResponse, error)
	LoadPartitions(context.Context, *LoadPartitionsRequest) (*commonpb.Status, error)
	ReleasePartitions(context.Context, *ReleasePartitionsRequest) (*commonpb.Status, error)
	GetPartitionStatistics(context.Context, *GetPartitionStatisticsRequest) (*GetPartitionStatisticsResponse, error)
	ShowPartitions(context.Context, *ShowPartitionsRequest) (*ShowPartitionsResponse, error)
	GetLoadingProgress(context.Context, *GetLoadingProgressRequest) (*GetLoadingProgressResponse, error)
	CreateAlias(context.Context, *CreateAliasRequest) (*commonpb.Status, error)
	DropAlias(context.Context, *DropAliasRequest) (*commonpb.Status, error)
	AlterAlias(context.Context, *AlterAliasRequest) (*commonpb.Status, error)
	CreateIndex(context.Context, *CreateIndexRequest) (*commonpb.Status, error)
	DescribeIndex(context.Context, *DescribeIndexRequest) (*DescribeIndexResponse, error)
	// Deprecated: use DescribeIndex instead
	GetIndexState(context.Context, *GetIndexStateRequest) (*GetIndexStateResponse, error)
	// Deprecated: use DescribeIndex instead
	GetIndexBuildProgress(context.Context, *GetIndexBuildProgressRequest) (*GetIndexBuildProgressResponse, error)
	DropIndex(context.Context, *DropIndexRequest) (*commonpb.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)
	GetFlushState(context.Context, *GetFlushStateRequest) (*GetFlushStateResponse, error)
	GetPersistentSegmentInfo(context.Context, *GetPersistentSegmentInfoRequest) (*GetPersistentSegmentInfoResponse, error)
	GetQuerySegmentInfo(context.Context, *GetQuerySegmentInfoRequest) (*GetQuerySegmentInfoResponse, error)
	GetReplicas(context.Context, *GetReplicasRequest) (*GetReplicasResponse, 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)
	GetComponentStates(context.Context, *GetComponentStatesRequest) (*ComponentStates, error)
	LoadBalance(context.Context, *LoadBalanceRequest) (*commonpb.Status, error)
	GetCompactionState(context.Context, *GetCompactionStateRequest) (*GetCompactionStateResponse, error)
	ManualCompaction(context.Context, *ManualCompactionRequest) (*ManualCompactionResponse, error)
	GetCompactionStateWithPlans(context.Context, *GetCompactionPlansRequest) (*GetCompactionPlansResponse, error)
	// https://wiki.lfaidata.foundation/display/MIL/MEP+24+--+Support+bulk+load
	Import(context.Context, *ImportRequest) (*ImportResponse, error)
	GetImportState(context.Context, *GetImportStateRequest) (*GetImportStateResponse, error)
	ListImportTasks(context.Context, *ListImportTasksRequest) (*ListImportTasksResponse, error)
	// https://wiki.lfaidata.foundation/display/MIL/MEP+27+--+Support+Basic+Authentication
	CreateCredential(context.Context, *CreateCredentialRequest) (*commonpb.Status, error)
	UpdateCredential(context.Context, *UpdateCredentialRequest) (*commonpb.Status, error)
	DeleteCredential(context.Context, *DeleteCredentialRequest) (*commonpb.Status, error)
	ListCredUsers(context.Context, *ListCredUsersRequest) (*ListCredUsersResponse, error)
	// https://wiki.lfaidata.foundation/display/MIL/MEP+29+--+Support+Role-Based+Access+Control
	CreateRole(context.Context, *CreateRoleRequest) (*commonpb.Status, error)
	DropRole(context.Context, *DropRoleRequest) (*commonpb.Status, error)
	OperateUserRole(context.Context, *OperateUserRoleRequest) (*commonpb.Status, error)
	SelectRole(context.Context, *SelectRoleRequest) (*SelectRoleResponse, error)
	SelectUser(context.Context, *SelectUserRequest) (*SelectUserResponse, error)
	OperatePrivilege(context.Context, *OperatePrivilegeRequest) (*commonpb.Status, error)
	SelectGrant(context.Context, *SelectGrantRequest) (*SelectGrantResponse, error)
	GetVersion(context.Context, *GetVersionRequest) (*GetVersionResponse, error)
}

MilvusServiceServer is the server API for MilvusService service.

type MutationResult 

type MutationResult struct {
	Status               *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	IDs                  *schemapb.IDs    `protobuf:"bytes,2,opt,name=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() *schemapb.IDs

func (*MutationResult) GetInsertCnt 

func (m *MutationResult) GetInsertCnt() int64

func (*MutationResult) GetStatus 

func (m *MutationResult) GetStatus() *commonpb.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 ObjectEntity 

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

func (*ObjectEntity) Descriptor 

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

func (*ObjectEntity) GetName 

func (m *ObjectEntity) GetName() string

func (*ObjectEntity) ProtoMessage 

func (*ObjectEntity) ProtoMessage()

func (*ObjectEntity) Reset 

func (m *ObjectEntity) Reset()

func (*ObjectEntity) String 

func (m *ObjectEntity) String() string

func (*ObjectEntity) XXX_DiscardUnknown 

func (m *ObjectEntity) XXX_DiscardUnknown()

func (*ObjectEntity) XXX_Marshal 

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

func (*ObjectEntity) XXX_Merge 

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

func (*ObjectEntity) XXX_Size 

func (m *ObjectEntity) XXX_Size() int

func (*ObjectEntity) XXX_Unmarshal 

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

type OperatePrivilegeRequest 

type OperatePrivilegeRequest struct {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// grant
	Entity *GrantEntity `protobuf:"bytes,2,opt,name=entity,proto3" json:"entity,omitempty"`
	// operation type
	Type                 OperatePrivilegeType `protobuf:"varint,3,opt,name=type,proto3,enum=milvus.proto.milvus.OperatePrivilegeType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*OperatePrivilegeRequest) Descriptor 

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

func (*OperatePrivilegeRequest) GetBase 

func (m *OperatePrivilegeRequest) GetBase() *commonpb.MsgBase

func (*OperatePrivilegeRequest) GetEntity 

func (m *OperatePrivilegeRequest) GetEntity() *GrantEntity

func (*OperatePrivilegeRequest) GetType 

func (m *OperatePrivilegeRequest) GetType() OperatePrivilegeType

func (*OperatePrivilegeRequest) ProtoMessage 

func (*OperatePrivilegeRequest) ProtoMessage()

func (*OperatePrivilegeRequest) Reset 

func (m *OperatePrivilegeRequest) Reset()

func (*OperatePrivilegeRequest) String 

func (m *OperatePrivilegeRequest) String() string

func (*OperatePrivilegeRequest) XXX_DiscardUnknown 

func (m *OperatePrivilegeRequest) XXX_DiscardUnknown()

func (*OperatePrivilegeRequest) XXX_Marshal 

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

func (*OperatePrivilegeRequest) XXX_Merge 

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

func (*OperatePrivilegeRequest) XXX_Size 

func (m *OperatePrivilegeRequest) XXX_Size() int

func (*OperatePrivilegeRequest) XXX_Unmarshal 

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

type OperatePrivilegeType 

type OperatePrivilegeType int32
const (
	OperatePrivilegeType_Grant  OperatePrivilegeType = 0
	OperatePrivilegeType_Revoke OperatePrivilegeType = 1
)

func (OperatePrivilegeType) EnumDescriptor 

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

func (OperatePrivilegeType) String 

func (x OperatePrivilegeType) String() string

type OperateUserRoleRequest 

type OperateUserRoleRequest struct {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// username
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	// role name
	RoleName string `protobuf:"bytes,3,opt,name=role_name,json=roleName,proto3" json:"role_name,omitempty"`
	// operation type
	Type                 OperateUserRoleType `protobuf:"varint,4,opt,name=type,proto3,enum=milvus.proto.milvus.OperateUserRoleType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*OperateUserRoleRequest) Descriptor 

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

func (*OperateUserRoleRequest) GetBase 

func (m *OperateUserRoleRequest) GetBase() *commonpb.MsgBase

func (*OperateUserRoleRequest) GetRoleName 

func (m *OperateUserRoleRequest) GetRoleName() string

func (*OperateUserRoleRequest) GetType 

func (m *OperateUserRoleRequest) GetType() OperateUserRoleType

func (*OperateUserRoleRequest) GetUsername 

func (m *OperateUserRoleRequest) GetUsername() string

func (*OperateUserRoleRequest) ProtoMessage 

func (*OperateUserRoleRequest) ProtoMessage()

func (*OperateUserRoleRequest) Reset 

func (m *OperateUserRoleRequest) Reset()

func (*OperateUserRoleRequest) String 

func (m *OperateUserRoleRequest) String() string

func (*OperateUserRoleRequest) XXX_DiscardUnknown 

func (m *OperateUserRoleRequest) XXX_DiscardUnknown()

func (*OperateUserRoleRequest) XXX_Marshal 

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

func (*OperateUserRoleRequest) XXX_Merge 

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

func (*OperateUserRoleRequest) XXX_Size 

func (m *OperateUserRoleRequest) XXX_Size() int

func (*OperateUserRoleRequest) XXX_Unmarshal 

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

type OperateUserRoleType 

type OperateUserRoleType int32
const (
	OperateUserRoleType_AddUserToRole      OperateUserRoleType = 0
	OperateUserRoleType_RemoveUserFromRole OperateUserRoleType = 1
)

func (OperateUserRoleType) EnumDescriptor 

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

func (OperateUserRoleType) String 

func (x OperateUserRoleType) String() string

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                commonpb.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 (m *PersistentSegmentInfo) GetState() commonpb.SegmentState

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 PrivilegeEntity 

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

func (*PrivilegeEntity) Descriptor 

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

func (*PrivilegeEntity) GetName 

func (m *PrivilegeEntity) GetName() string

func (*PrivilegeEntity) ProtoMessage 

func (*PrivilegeEntity) ProtoMessage()

func (*PrivilegeEntity) Reset 

func (m *PrivilegeEntity) Reset()

func (*PrivilegeEntity) String 

func (m *PrivilegeEntity) String() string

func (*PrivilegeEntity) XXX_DiscardUnknown 

func (m *PrivilegeEntity) XXX_DiscardUnknown()

func (*PrivilegeEntity) XXX_Marshal 

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

func (*PrivilegeEntity) XXX_Merge 

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

func (*PrivilegeEntity) XXX_Size 

func (m *PrivilegeEntity) XXX_Size() int

func (*PrivilegeEntity) XXX_Unmarshal 

func (m *PrivilegeEntity) 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                 *commonpb.MsgBase        `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName               string                   `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName       string                   `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	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"`
	QueryParams          []*commonpb.KeyValuePair `protobuf:"bytes,9,rep,name=query_params,json=queryParams,proto3" json:"query_params,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() *commonpb.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) GetQueryParams 

func (m *QueryRequest) GetQueryParams() []*commonpb.KeyValuePair

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               *commonpb.Status      `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	FieldsData           []*schemapb.FieldData `protobuf:"bytes,2,rep,name=fields_data,json=fieldsData,proto3" json:"fields_data,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 (*QueryResults) Descriptor 

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

func (*QueryResults) GetCollectionName 

func (m *QueryResults) GetCollectionName() string

func (*QueryResults) GetFieldsData 

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

func (*QueryResults) GetStatus 

func (m *QueryResults) GetStatus() *commonpb.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"`
	// deprecated, check node_ids(NodeIds) field
	NodeID               int64                 `protobuf:"varint,8,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	State                commonpb.SegmentState `protobuf:"varint,9,opt,name=state,proto3,enum=milvus.proto.common.SegmentState" json:"state,omitempty"`
	NodeIds              []int64               `protobuf:"varint,10,rep,packed,name=nodeIds,proto3" json:"nodeIds,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) GetNodeID 

func (m *QuerySegmentInfo) GetNodeID() int64

func (*QuerySegmentInfo) GetNodeIds 

func (m *QuerySegmentInfo) GetNodeIds() []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) GetState 

func (m *QuerySegmentInfo) GetState() commonpb.SegmentState

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              *commonpb.Address `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Status               *commonpb.Status  `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*RegisterLinkResponse) Descriptor 

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

func (*RegisterLinkResponse) GetAddress 

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

func (*RegisterLinkResponse) GetStatus 

func (m *RegisterLinkResponse) GetStatus() *commonpb.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 {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// The collection name you want to release
	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:"-"`
}

* Release collection data from query nodes, then you can't do vector search on this collection.

func (*ReleaseCollectionRequest) Descriptor 

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

func (*ReleaseCollectionRequest) GetBase 

func (m *ReleaseCollectionRequest) GetBase() *commonpb.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 {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// The collection name in milvus
	CollectionName string `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	// The partition names you want to release
	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:"-"`
}

Release specific partitions data of one collection from query nodes. Then you can not get these data as result when you do vector search on this collection.

func (*ReleasePartitionsRequest) Descriptor 

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

func (*ReleasePartitionsRequest) GetBase 

func (m *ReleasePartitionsRequest) GetBase() *commonpb.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 ReplicaInfo 

type ReplicaInfo struct {
	ReplicaID            int64           `protobuf:"varint,1,opt,name=replicaID,proto3" json:"replicaID,omitempty"`
	CollectionID         int64           `protobuf:"varint,2,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionIds         []int64         `protobuf:"varint,3,rep,packed,name=partition_ids,json=partitionIds,proto3" json:"partition_ids,omitempty"`
	ShardReplicas        []*ShardReplica `protobuf:"bytes,4,rep,name=shard_replicas,json=shardReplicas,proto3" json:"shard_replicas,omitempty"`
	NodeIds              []int64         `protobuf:"varint,5,rep,packed,name=node_ids,json=nodeIds,proto3" json:"node_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ReplicaInfo) Descriptor 

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

func (*ReplicaInfo) GetCollectionID 

func (m *ReplicaInfo) GetCollectionID() int64

func (*ReplicaInfo) GetNodeIds 

func (m *ReplicaInfo) GetNodeIds() []int64

func (*ReplicaInfo) GetPartitionIds 

func (m *ReplicaInfo) GetPartitionIds() []int64

func (*ReplicaInfo) GetReplicaID 

func (m *ReplicaInfo) GetReplicaID() int64

func (*ReplicaInfo) GetShardReplicas 

func (m *ReplicaInfo) GetShardReplicas() []*ShardReplica

func (*ReplicaInfo) ProtoMessage 

func (*ReplicaInfo) ProtoMessage()

func (*ReplicaInfo) Reset 

func (m *ReplicaInfo) Reset()

func (*ReplicaInfo) String 

func (m *ReplicaInfo) String() string

func (*ReplicaInfo) XXX_DiscardUnknown 

func (m *ReplicaInfo) XXX_DiscardUnknown()

func (*ReplicaInfo) XXX_Marshal 

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

func (*ReplicaInfo) XXX_Merge 

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

func (*ReplicaInfo) XXX_Size 

func (m *ReplicaInfo) XXX_Size() int

func (*ReplicaInfo) XXX_Unmarshal 

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

type RoleEntity 

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

https://wiki.lfaidata.foundation/display/MIL/MEP+29+--+Support+Role-Based+Access+Control

func (*RoleEntity) Descriptor 

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

func (*RoleEntity) GetName 

func (m *RoleEntity) GetName() string

func (*RoleEntity) ProtoMessage 

func (*RoleEntity) ProtoMessage()

func (*RoleEntity) Reset 

func (m *RoleEntity) Reset()

func (*RoleEntity) String 

func (m *RoleEntity) String() string

func (*RoleEntity) XXX_DiscardUnknown 

func (m *RoleEntity) XXX_DiscardUnknown()

func (*RoleEntity) XXX_Marshal 

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

func (*RoleEntity) XXX_Merge 

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

func (*RoleEntity) XXX_Size 

func (m *RoleEntity) XXX_Size() int

func (*RoleEntity) XXX_Unmarshal 

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

type RoleResult 

type RoleResult struct {
	Role                 *RoleEntity   `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"`
	Users                []*UserEntity `protobuf:"bytes,2,rep,name=users,proto3" json:"users,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*RoleResult) Descriptor 

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

func (*RoleResult) GetRole 

func (m *RoleResult) GetRole() *RoleEntity

func (*RoleResult) GetUsers 

func (m *RoleResult) GetUsers() []*UserEntity

func (*RoleResult) ProtoMessage 

func (*RoleResult) ProtoMessage()

func (*RoleResult) Reset 

func (m *RoleResult) Reset()

func (*RoleResult) String 

func (m *RoleResult) String() string

func (*RoleResult) XXX_DiscardUnknown 

func (m *RoleResult) XXX_DiscardUnknown()

func (*RoleResult) XXX_Marshal 

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

func (*RoleResult) XXX_Merge 

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

func (*RoleResult) XXX_Size 

func (m *RoleResult) XXX_Size() int

func (*RoleResult) XXX_Unmarshal 

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

type SearchRequest 

type SearchRequest struct {
	Base           *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName         string            `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName string            `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	PartitionNames []string          `protobuf:"bytes,4,rep,name=partition_names,json=partitionNames,proto3" json:"partition_names,omitempty"`
	Dsl            string            `protobuf:"bytes,5,opt,name=dsl,proto3" json:"dsl,omitempty"`
	// serialized `PlaceholderGroup`
	PlaceholderGroup     []byte                   `protobuf:"bytes,6,opt,name=placeholder_group,json=placeholderGroup,proto3" json:"placeholder_group,omitempty"`
	DslType              commonpb.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         []*commonpb.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=guaranteeTimestamp,proto3" json:"guarantee_timestamp,omitempty"`
	Nq                   int64                    `protobuf:"varint,12,opt,name=nq,proto3" json:"nq,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*SearchRequest) Descriptor 

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

func (*SearchRequest) GetBase 

func (m *SearchRequest) GetBase() *commonpb.MsgBase

func (*SearchRequest) GetCollectionName 

func (m *SearchRequest) GetCollectionName() string

func (*SearchRequest) GetDbName 

func (m *SearchRequest) GetDbName() string

func (*SearchRequest) GetDsl 

func (m *SearchRequest) GetDsl() string

func (*SearchRequest) GetDslType 

func (m *SearchRequest) GetDslType() commonpb.DslType

func (*SearchRequest) GetGuaranteeTimestamp 

func (m *SearchRequest) GetGuaranteeTimestamp() uint64

func (*SearchRequest) GetNq 

func (m *SearchRequest) GetNq() int64

func (*SearchRequest) GetOutputFields 

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

func (*SearchRequest) GetPartitionNames 

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

func (*SearchRequest) GetPlaceholderGroup 

func (m *SearchRequest) GetPlaceholderGroup() []byte

func (*SearchRequest) GetSearchParams 

func (m *SearchRequest) GetSearchParams() []*commonpb.KeyValuePair

func (*SearchRequest) GetTravelTimestamp 

func (m *SearchRequest) GetTravelTimestamp() uint64

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) Reset 

func (m *SearchRequest) Reset()

func (*SearchRequest) String 

func (m *SearchRequest) String() string

func (*SearchRequest) XXX_DiscardUnknown 

func (m *SearchRequest) XXX_DiscardUnknown()

func (*SearchRequest) XXX_Marshal 

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

func (*SearchRequest) XXX_Merge 

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

func (*SearchRequest) XXX_Size 

func (m *SearchRequest) XXX_Size() int

func (*SearchRequest) XXX_Unmarshal 

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

type SearchResults 

type SearchResults struct {
	Status               *commonpb.Status           `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Results              *schemapb.SearchResultData `protobuf:"bytes,2,opt,name=results,proto3" json:"results,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 (*SearchResults) Descriptor 

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

func (*SearchResults) GetCollectionName 

func (m *SearchResults) GetCollectionName() string

func (*SearchResults) GetResults 

func (m *SearchResults) GetResults() *schemapb.SearchResultData

func (*SearchResults) GetStatus 

func (m *SearchResults) GetStatus() *commonpb.Status

func (*SearchResults) ProtoMessage 

func (*SearchResults) ProtoMessage()

func (*SearchResults) Reset 

func (m *SearchResults) Reset()

func (*SearchResults) String 

func (m *SearchResults) String() string

func (*SearchResults) XXX_DiscardUnknown 

func (m *SearchResults) XXX_DiscardUnknown()

func (*SearchResults) XXX_Marshal 

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

func (*SearchResults) XXX_Merge 

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

func (*SearchResults) XXX_Size 

func (m *SearchResults) XXX_Size() int

func (*SearchResults) XXX_Unmarshal 

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

type SelectGrantRequest 

type SelectGrantRequest struct {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// grant
	Entity               *GrantEntity `protobuf:"bytes,2,opt,name=entity,proto3" json:"entity,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*SelectGrantRequest) Descriptor 

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

func (*SelectGrantRequest) GetBase 

func (m *SelectGrantRequest) GetBase() *commonpb.MsgBase

func (*SelectGrantRequest) GetEntity 

func (m *SelectGrantRequest) GetEntity() *GrantEntity

func (*SelectGrantRequest) ProtoMessage 

func (*SelectGrantRequest) ProtoMessage()

func (*SelectGrantRequest) Reset 

func (m *SelectGrantRequest) Reset()

func (*SelectGrantRequest) String 

func (m *SelectGrantRequest) String() string

func (*SelectGrantRequest) XXX_DiscardUnknown 

func (m *SelectGrantRequest) XXX_DiscardUnknown()

func (*SelectGrantRequest) XXX_Marshal 

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

func (*SelectGrantRequest) XXX_Merge 

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

func (*SelectGrantRequest) XXX_Size 

func (m *SelectGrantRequest) XXX_Size() int

func (*SelectGrantRequest) XXX_Unmarshal 

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

type SelectGrantResponse 

type SelectGrantResponse struct {
	// Not useful for now
	Status *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// grant info array
	Entities             []*GrantEntity `protobuf:"bytes,2,rep,name=entities,proto3" json:"entities,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*SelectGrantResponse) Descriptor 

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

func (*SelectGrantResponse) GetEntities 

func (m *SelectGrantResponse) GetEntities() []*GrantEntity

func (*SelectGrantResponse) GetStatus 

func (m *SelectGrantResponse) GetStatus() *commonpb.Status

func (*SelectGrantResponse) ProtoMessage 

func (*SelectGrantResponse) ProtoMessage()

func (*SelectGrantResponse) Reset 

func (m *SelectGrantResponse) Reset()

func (*SelectGrantResponse) String 

func (m *SelectGrantResponse) String() string

func (*SelectGrantResponse) XXX_DiscardUnknown 

func (m *SelectGrantResponse) XXX_DiscardUnknown()

func (*SelectGrantResponse) XXX_Marshal 

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

func (*SelectGrantResponse) XXX_Merge 

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

func (*SelectGrantResponse) XXX_Size 

func (m *SelectGrantResponse) XXX_Size() int

func (*SelectGrantResponse) XXX_Unmarshal 

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

type SelectRoleRequest 

type SelectRoleRequest struct {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// role
	Role *RoleEntity `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"`
	// include user info
	IncludeUserInfo      bool     `protobuf:"varint,3,opt,name=include_user_info,json=includeUserInfo,proto3" json:"include_user_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SelectRoleRequest) Descriptor 

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

func (*SelectRoleRequest) GetBase 

func (m *SelectRoleRequest) GetBase() *commonpb.MsgBase

func (*SelectRoleRequest) GetIncludeUserInfo 

func (m *SelectRoleRequest) GetIncludeUserInfo() bool

func (*SelectRoleRequest) GetRole 

func (m *SelectRoleRequest) GetRole() *RoleEntity

func (*SelectRoleRequest) ProtoMessage 

func (*SelectRoleRequest) ProtoMessage()

func (*SelectRoleRequest) Reset 

func (m *SelectRoleRequest) Reset()

func (*SelectRoleRequest) String 

func (m *SelectRoleRequest) String() string

func (*SelectRoleRequest) XXX_DiscardUnknown 

func (m *SelectRoleRequest) XXX_DiscardUnknown()

func (*SelectRoleRequest) XXX_Marshal 

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

func (*SelectRoleRequest) XXX_Merge 

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

func (*SelectRoleRequest) XXX_Size 

func (m *SelectRoleRequest) XXX_Size() int

func (*SelectRoleRequest) XXX_Unmarshal 

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

type SelectRoleResponse 

type SelectRoleResponse struct {
	// Not useful for now
	Status *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// role result array
	Results              []*RoleResult `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*SelectRoleResponse) Descriptor 

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

func (*SelectRoleResponse) GetResults 

func (m *SelectRoleResponse) GetResults() []*RoleResult

func (*SelectRoleResponse) GetStatus 

func (m *SelectRoleResponse) GetStatus() *commonpb.Status

func (*SelectRoleResponse) ProtoMessage 

func (*SelectRoleResponse) ProtoMessage()

func (*SelectRoleResponse) Reset 

func (m *SelectRoleResponse) Reset()

func (*SelectRoleResponse) String 

func (m *SelectRoleResponse) String() string

func (*SelectRoleResponse) XXX_DiscardUnknown 

func (m *SelectRoleResponse) XXX_DiscardUnknown()

func (*SelectRoleResponse) XXX_Marshal 

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

func (*SelectRoleResponse) XXX_Merge 

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

func (*SelectRoleResponse) XXX_Size 

func (m *SelectRoleResponse) XXX_Size() int

func (*SelectRoleResponse) XXX_Unmarshal 

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

type SelectUserRequest 

type SelectUserRequest struct {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// user
	User *UserEntity `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	// include user info
	IncludeRoleInfo      bool     `protobuf:"varint,3,opt,name=include_role_info,json=includeRoleInfo,proto3" json:"include_role_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SelectUserRequest) Descriptor 

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

func (*SelectUserRequest) GetBase 

func (m *SelectUserRequest) GetBase() *commonpb.MsgBase

func (*SelectUserRequest) GetIncludeRoleInfo 

func (m *SelectUserRequest) GetIncludeRoleInfo() bool

func (*SelectUserRequest) GetUser 

func (m *SelectUserRequest) GetUser() *UserEntity

func (*SelectUserRequest) ProtoMessage 

func (*SelectUserRequest) ProtoMessage()

func (*SelectUserRequest) Reset 

func (m *SelectUserRequest) Reset()

func (*SelectUserRequest) String 

func (m *SelectUserRequest) String() string

func (*SelectUserRequest) XXX_DiscardUnknown 

func (m *SelectUserRequest) XXX_DiscardUnknown()

func (*SelectUserRequest) XXX_Marshal 

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

func (*SelectUserRequest) XXX_Merge 

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

func (*SelectUserRequest) XXX_Size 

func (m *SelectUserRequest) XXX_Size() int

func (*SelectUserRequest) XXX_Unmarshal 

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

type SelectUserResponse 

type SelectUserResponse struct {
	// Not useful for now
	Status *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// user result array
	Results              []*UserResult `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*SelectUserResponse) Descriptor 

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

func (*SelectUserResponse) GetResults 

func (m *SelectUserResponse) GetResults() []*UserResult

func (*SelectUserResponse) GetStatus 

func (m *SelectUserResponse) GetStatus() *commonpb.Status

func (*SelectUserResponse) ProtoMessage 

func (*SelectUserResponse) ProtoMessage()

func (*SelectUserResponse) Reset 

func (m *SelectUserResponse) Reset()

func (*SelectUserResponse) String 

func (m *SelectUserResponse) String() string

func (*SelectUserResponse) XXX_DiscardUnknown 

func (m *SelectUserResponse) XXX_DiscardUnknown()

func (*SelectUserResponse) XXX_Marshal 

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

func (*SelectUserResponse) XXX_Merge 

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

func (*SelectUserResponse) XXX_Size 

func (m *SelectUserResponse) XXX_Size() int

func (*SelectUserResponse) XXX_Unmarshal 

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

type ShardReplica 

type ShardReplica struct {
	LeaderID      int64  `protobuf:"varint,1,opt,name=leaderID,proto3" json:"leaderID,omitempty"`
	LeaderAddr    string `protobuf:"bytes,2,opt,name=leader_addr,json=leaderAddr,proto3" json:"leader_addr,omitempty"`
	DmChannelName string `protobuf:"bytes,3,opt,name=dm_channel_name,json=dmChannelName,proto3" json:"dm_channel_name,omitempty"`
	// optional, DO NOT save it in meta, set it only for GetReplicas()
	// if with_shard_nodes is true
	NodeIds              []int64  `protobuf:"varint,4,rep,packed,name=node_ids,json=nodeIds,proto3" json:"node_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShardReplica) Descriptor 

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

func (*ShardReplica) GetDmChannelName 

func (m *ShardReplica) GetDmChannelName() string

func (*ShardReplica) GetLeaderAddr 

func (m *ShardReplica) GetLeaderAddr() string

func (*ShardReplica) GetLeaderID 

func (m *ShardReplica) GetLeaderID() int64

func (*ShardReplica) GetNodeIds 

func (m *ShardReplica) GetNodeIds() []int64

func (*ShardReplica) ProtoMessage 

func (*ShardReplica) ProtoMessage()

func (*ShardReplica) Reset 

func (m *ShardReplica) Reset()

func (*ShardReplica) String 

func (m *ShardReplica) String() string

func (*ShardReplica) XXX_DiscardUnknown 

func (m *ShardReplica) XXX_DiscardUnknown()

func (*ShardReplica) XXX_Marshal 

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

func (*ShardReplica) XXX_Merge 

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

func (*ShardReplica) XXX_Size 

func (m *ShardReplica) XXX_Size() int

func (*ShardReplica) XXX_Unmarshal 

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

type ShowCollectionsRequest 

type ShowCollectionsRequest struct {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// Not useful for now
	TimeStamp uint64 `protobuf:"varint,3,opt,name=time_stamp,json=timeStamp,proto3" json:"time_stamp,omitempty"`
	// Decide return Loaded collections or All collections(Optional)
	Type ShowType `protobuf:"varint,4,opt,name=type,proto3,enum=milvus.proto.milvus.ShowType" json:"type,omitempty"`
	// When type is InMemory, will return these collection's inMemory_percentages.(Optional)
	// Deprecated: use GetLoadingProgress rpc instead
	CollectionNames      []string `protobuf:"bytes,5,rep,name=collection_names,json=collectionNames,proto3" json:"collection_names,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

List collections

func (*ShowCollectionsRequest) Descriptor 

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

func (*ShowCollectionsRequest) GetBase 

func (m *ShowCollectionsRequest) GetBase() *commonpb.MsgBase

func (*ShowCollectionsRequest) GetCollectionNames 

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

func (*ShowCollectionsRequest) GetDbName 

func (m *ShowCollectionsRequest) GetDbName() string

func (*ShowCollectionsRequest) GetTimeStamp 

func (m *ShowCollectionsRequest) GetTimeStamp() uint64

func (*ShowCollectionsRequest) GetType 

func (m *ShowCollectionsRequest) GetType() ShowType

func (*ShowCollectionsRequest) ProtoMessage 

func (*ShowCollectionsRequest) ProtoMessage()

func (*ShowCollectionsRequest) Reset 

func (m *ShowCollectionsRequest) Reset()

func (*ShowCollectionsRequest) String 

func (m *ShowCollectionsRequest) String() string

func (*ShowCollectionsRequest) XXX_DiscardUnknown 

func (m *ShowCollectionsRequest) XXX_DiscardUnknown()

func (*ShowCollectionsRequest) XXX_Marshal 

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

func (*ShowCollectionsRequest) XXX_Merge 

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

func (*ShowCollectionsRequest) XXX_Size 

func (m *ShowCollectionsRequest) XXX_Size() int

func (*ShowCollectionsRequest) XXX_Unmarshal 

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

type ShowCollectionsResponse 

type ShowCollectionsResponse struct {
	// Contain error_code and reason
	Status *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Collection name array
	CollectionNames []string `protobuf:"bytes,2,rep,name=collection_names,json=collectionNames,proto3" json:"collection_names,omitempty"`
	// Collection Id array
	CollectionIds []int64 `protobuf:"varint,3,rep,packed,name=collection_ids,json=collectionIds,proto3" json:"collection_ids,omitempty"`
	// Hybrid timestamps in milvus
	CreatedTimestamps []uint64 `protobuf:"varint,4,rep,packed,name=created_timestamps,json=createdTimestamps,proto3" json:"created_timestamps,omitempty"`
	// The utc timestamp calculated by created_timestamp
	CreatedUtcTimestamps []uint64 `` /* 131-byte string literal not displayed */
	// Load percentage on querynode when type is InMemory
	// Deprecated: use GetLoadingProgress rpc instead
	InMemoryPercentages []int64 `` /* 126-byte string literal not displayed */
	// Indicate whether query service is available
	QueryServiceAvailable []bool   `` /* 134-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

Return basic collection infos.

func (*ShowCollectionsResponse) Descriptor 

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

func (*ShowCollectionsResponse) GetCollectionIds 

func (m *ShowCollectionsResponse) GetCollectionIds() []int64

func (*ShowCollectionsResponse) GetCollectionNames 

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

func (*ShowCollectionsResponse) GetCreatedTimestamps 

func (m *ShowCollectionsResponse) GetCreatedTimestamps() []uint64

func (*ShowCollectionsResponse) GetCreatedUtcTimestamps 

func (m *ShowCollectionsResponse) GetCreatedUtcTimestamps() []uint64

func (*ShowCollectionsResponse) GetInMemoryPercentages 

func (m *ShowCollectionsResponse) GetInMemoryPercentages() []int64

func (*ShowCollectionsResponse) GetQueryServiceAvailable 

func (m *ShowCollectionsResponse) GetQueryServiceAvailable() []bool

func (*ShowCollectionsResponse) GetStatus 

func (m *ShowCollectionsResponse) GetStatus() *commonpb.Status

func (*ShowCollectionsResponse) ProtoMessage 

func (*ShowCollectionsResponse) ProtoMessage()

func (*ShowCollectionsResponse) Reset 

func (m *ShowCollectionsResponse) Reset()

func (*ShowCollectionsResponse) String 

func (m *ShowCollectionsResponse) String() string

func (*ShowCollectionsResponse) XXX_DiscardUnknown 

func (m *ShowCollectionsResponse) XXX_DiscardUnknown()

func (*ShowCollectionsResponse) XXX_Marshal 

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

func (*ShowCollectionsResponse) XXX_Merge 

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

func (*ShowCollectionsResponse) XXX_Size 

func (m *ShowCollectionsResponse) XXX_Size() int

func (*ShowCollectionsResponse) XXX_Unmarshal 

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

type ShowPartitionsRequest 

type ShowPartitionsRequest struct {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// Not useful for now
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// The collection name you want to describe, you can pass collection_name or collectionID
	CollectionName string `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	// The collection id in milvus
	CollectionID int64 `protobuf:"varint,4,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	// When type is InMemory, will return these patitions's inMemory_percentages.(Optional)
	PartitionNames []string `protobuf:"bytes,5,rep,name=partition_names,json=partitionNames,proto3" json:"partition_names,omitempty"`
	// Decide return Loaded partitions or All partitions(Optional)
	// Deprecated: use GetLoadingProgress rpc instead
	Type                 ShowType `protobuf:"varint,6,opt,name=type,proto3,enum=milvus.proto.milvus.ShowType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

List all partitions for particular collection

func (*ShowPartitionsRequest) Descriptor 

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

func (*ShowPartitionsRequest) GetBase 

func (m *ShowPartitionsRequest) GetBase() *commonpb.MsgBase

func (*ShowPartitionsRequest) GetCollectionID 

func (m *ShowPartitionsRequest) GetCollectionID() int64

func (*ShowPartitionsRequest) GetCollectionName 

func (m *ShowPartitionsRequest) GetCollectionName() string

func (*ShowPartitionsRequest) GetDbName 

func (m *ShowPartitionsRequest) GetDbName() string

func (*ShowPartitionsRequest) GetPartitionNames 

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

func (*ShowPartitionsRequest) GetType 

func (m *ShowPartitionsRequest) GetType() ShowType

func (*ShowPartitionsRequest) ProtoMessage 

func (*ShowPartitionsRequest) ProtoMessage()

func (*ShowPartitionsRequest) Reset 

func (m *ShowPartitionsRequest) Reset()

func (*ShowPartitionsRequest) String 

func (m *ShowPartitionsRequest) String() string

func (*ShowPartitionsRequest) XXX_DiscardUnknown 

func (m *ShowPartitionsRequest) XXX_DiscardUnknown()

func (*ShowPartitionsRequest) XXX_Marshal 

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

func (*ShowPartitionsRequest) XXX_Merge 

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

func (*ShowPartitionsRequest) XXX_Size 

func (m *ShowPartitionsRequest) XXX_Size() int

func (*ShowPartitionsRequest) XXX_Unmarshal 

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

type ShowPartitionsResponse 

type ShowPartitionsResponse struct {
	// Contain error_code and reason
	Status *commonpb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// All partition names for this collection
	PartitionNames []string `protobuf:"bytes,2,rep,name=partition_names,json=partitionNames,proto3" json:"partition_names,omitempty"`
	// All partition ids for this collection
	PartitionIDs []int64 `protobuf:"varint,3,rep,packed,name=partitionIDs,proto3" json:"partitionIDs,omitempty"`
	// All hybrid timestamps
	CreatedTimestamps []uint64 `protobuf:"varint,4,rep,packed,name=created_timestamps,json=createdTimestamps,proto3" json:"created_timestamps,omitempty"`
	// All utc timestamps calculated by created_timestamps
	CreatedUtcTimestamps []uint64 `` /* 131-byte string literal not displayed */
	// Load percentage on querynode
	// Deprecated: use GetLoadingProgress rpc instead
	InMemoryPercentages  []int64  `` /* 126-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

List all partitions for particular collection response. The returned datas are all rows, we can format to columns by therir index.

func (*ShowPartitionsResponse) Descriptor 

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

func (*ShowPartitionsResponse) GetCreatedTimestamps 

func (m *ShowPartitionsResponse) GetCreatedTimestamps() []uint64

func (*ShowPartitionsResponse) GetCreatedUtcTimestamps 

func (m *ShowPartitionsResponse) GetCreatedUtcTimestamps() []uint64

func (*ShowPartitionsResponse) GetInMemoryPercentages 

func (m *ShowPartitionsResponse) GetInMemoryPercentages() []int64

func (*ShowPartitionsResponse) GetPartitionIDs 

func (m *ShowPartitionsResponse) GetPartitionIDs() []int64

func (*ShowPartitionsResponse) GetPartitionNames 

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

func (*ShowPartitionsResponse) GetStatus 

func (m *ShowPartitionsResponse) GetStatus() *commonpb.Status

func (*ShowPartitionsResponse) ProtoMessage 

func (*ShowPartitionsResponse) ProtoMessage()

func (*ShowPartitionsResponse) Reset 

func (m *ShowPartitionsResponse) Reset()

func (*ShowPartitionsResponse) String 

func (m *ShowPartitionsResponse) String() string

func (*ShowPartitionsResponse) XXX_DiscardUnknown 

func (m *ShowPartitionsResponse) XXX_DiscardUnknown()

func (*ShowPartitionsResponse) XXX_Marshal 

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

func (*ShowPartitionsResponse) XXX_Merge 

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

func (*ShowPartitionsResponse) XXX_Size 

func (m *ShowPartitionsResponse) XXX_Size() int

func (*ShowPartitionsResponse) XXX_Unmarshal 

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

type ShowSegmentsRequest 

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

func (*ShowSegmentsRequest) Descriptor 

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

func (*ShowSegmentsRequest) GetBase 

func (m *ShowSegmentsRequest) GetBase() *commonpb.MsgBase

func (*ShowSegmentsRequest) GetCollectionID 

func (m *ShowSegmentsRequest) GetCollectionID() int64

func (*ShowSegmentsRequest) GetPartitionID 

func (m *ShowSegmentsRequest) GetPartitionID() int64

func (*ShowSegmentsRequest) ProtoMessage 

func (*ShowSegmentsRequest) ProtoMessage()

func (*ShowSegmentsRequest) Reset 

func (m *ShowSegmentsRequest) Reset()

func (*ShowSegmentsRequest) String 

func (m *ShowSegmentsRequest) String() string

func (*ShowSegmentsRequest) XXX_DiscardUnknown 

func (m *ShowSegmentsRequest) XXX_DiscardUnknown()

func (*ShowSegmentsRequest) XXX_Marshal 

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

func (*ShowSegmentsRequest) XXX_Merge 

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

func (*ShowSegmentsRequest) XXX_Size 

func (m *ShowSegmentsRequest) XXX_Size() int

func (*ShowSegmentsRequest) XXX_Unmarshal 

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

type ShowSegmentsResponse 

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

func (*ShowSegmentsResponse) Descriptor 

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

func (*ShowSegmentsResponse) GetSegmentIDs 

func (m *ShowSegmentsResponse) GetSegmentIDs() []int64

func (*ShowSegmentsResponse) GetStatus 

func (m *ShowSegmentsResponse) GetStatus() *commonpb.Status

func (*ShowSegmentsResponse) ProtoMessage 

func (*ShowSegmentsResponse) ProtoMessage()

func (*ShowSegmentsResponse) Reset 

func (m *ShowSegmentsResponse) Reset()

func (*ShowSegmentsResponse) String 

func (m *ShowSegmentsResponse) String() string

func (*ShowSegmentsResponse) XXX_DiscardUnknown 

func (m *ShowSegmentsResponse) XXX_DiscardUnknown()

func (*ShowSegmentsResponse) XXX_Marshal 

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

func (*ShowSegmentsResponse) XXX_Merge 

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

func (*ShowSegmentsResponse) XXX_Size 

func (m *ShowSegmentsResponse) XXX_Size() int

func (*ShowSegmentsResponse) XXX_Unmarshal 

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

type ShowType deprecated 

type ShowType int32

Deprecated: use GetLoadingProgress rpc instead 

const (
	// Will return all collections
	ShowType_All ShowType = 0
	// Will return loaded collections with their inMemory_percentages
	ShowType_InMemory ShowType = 1
)

func (ShowType) EnumDescriptor 

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

func (ShowType) String 

func (x ShowType) String() string

type StringResponse 

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

func (*StringResponse) Descriptor 

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

func (*StringResponse) GetStatus 

func (m *StringResponse) GetStatus() *commonpb.Status

func (*StringResponse) GetValue 

func (m *StringResponse) GetValue() string

func (*StringResponse) ProtoMessage 

func (*StringResponse) ProtoMessage()

func (*StringResponse) Reset 

func (m *StringResponse) Reset()

func (*StringResponse) String 

func (m *StringResponse) String() string

func (*StringResponse) XXX_DiscardUnknown 

func (m *StringResponse) XXX_DiscardUnknown()

func (*StringResponse) XXX_Marshal 

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

func (*StringResponse) XXX_Merge 

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

func (*StringResponse) XXX_Size 

func (m *StringResponse) XXX_Size() int

func (*StringResponse) XXX_Unmarshal 

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

type UnimplementedMilvusServiceServer 

type UnimplementedMilvusServiceServer struct {
}

UnimplementedMilvusServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMilvusServiceServer) AlterAlias 

func (*UnimplementedMilvusServiceServer) AlterAlias(ctx context.Context, req *AlterAliasRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) AlterCollection 

func (*UnimplementedMilvusServiceServer) AlterCollection(ctx context.Context, req *AlterCollectionRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) CalcDistance 

func (*UnimplementedMilvusServiceServer) CalcDistance(ctx context.Context, req *CalcDistanceRequest) (*CalcDistanceResults, error)

func (*UnimplementedMilvusServiceServer) CreateAlias 

func (*UnimplementedMilvusServiceServer) CreateAlias(ctx context.Context, req *CreateAliasRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) CreateCollection 

func (*UnimplementedMilvusServiceServer) CreateCollection(ctx context.Context, req *CreateCollectionRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) CreateCredential 

func (*UnimplementedMilvusServiceServer) CreateCredential(ctx context.Context, req *CreateCredentialRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) CreateIndex 

func (*UnimplementedMilvusServiceServer) CreateIndex(ctx context.Context, req *CreateIndexRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) CreatePartition 

func (*UnimplementedMilvusServiceServer) CreatePartition(ctx context.Context, req *CreatePartitionRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) CreateRole 

func (*UnimplementedMilvusServiceServer) CreateRole(ctx context.Context, req *CreateRoleRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) Delete 

func (*UnimplementedMilvusServiceServer) Delete(ctx context.Context, req *DeleteRequest) (*MutationResult, error)

func (*UnimplementedMilvusServiceServer) DeleteCredential 

func (*UnimplementedMilvusServiceServer) DeleteCredential(ctx context.Context, req *DeleteCredentialRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) DescribeCollection 

func (*UnimplementedMilvusServiceServer) DescribeCollection(ctx context.Context, req *DescribeCollectionRequest) (*DescribeCollectionResponse, error)

func (*UnimplementedMilvusServiceServer) DescribeIndex 

func (*UnimplementedMilvusServiceServer) DescribeIndex(ctx context.Context, req *DescribeIndexRequest) (*DescribeIndexResponse, error)

func (*UnimplementedMilvusServiceServer) DropAlias 

func (*UnimplementedMilvusServiceServer) DropAlias(ctx context.Context, req *DropAliasRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) DropCollection 

func (*UnimplementedMilvusServiceServer) DropCollection(ctx context.Context, req *DropCollectionRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) DropIndex 

func (*UnimplementedMilvusServiceServer) DropIndex(ctx context.Context, req *DropIndexRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) DropPartition 

func (*UnimplementedMilvusServiceServer) DropPartition(ctx context.Context, req *DropPartitionRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) DropRole 

func (*UnimplementedMilvusServiceServer) DropRole(ctx context.Context, req *DropRoleRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) Dummy 

func (*UnimplementedMilvusServiceServer) Dummy(ctx context.Context, req *DummyRequest) (*DummyResponse, error)

func (*UnimplementedMilvusServiceServer) Flush 

func (*UnimplementedMilvusServiceServer) Flush(ctx context.Context, req *FlushRequest) (*FlushResponse, error)

func (*UnimplementedMilvusServiceServer) GetCollectionStatistics 

func (*UnimplementedMilvusServiceServer) GetCollectionStatistics(ctx context.Context, req *GetCollectionStatisticsRequest) (*GetCollectionStatisticsResponse, error)

func (*UnimplementedMilvusServiceServer) GetCompactionState 

func (*UnimplementedMilvusServiceServer) GetCompactionState(ctx context.Context, req *GetCompactionStateRequest) (*GetCompactionStateResponse, error)

func (*UnimplementedMilvusServiceServer) GetCompactionStateWithPlans 

func (*UnimplementedMilvusServiceServer) GetCompactionStateWithPlans(ctx context.Context, req *GetCompactionPlansRequest) (*GetCompactionPlansResponse, error)

func (*UnimplementedMilvusServiceServer) GetComponentStates 

func (*UnimplementedMilvusServiceServer) GetComponentStates(ctx context.Context, req *GetComponentStatesRequest) (*ComponentStates, error)

func (*UnimplementedMilvusServiceServer) GetFlushState 

func (*UnimplementedMilvusServiceServer) GetFlushState(ctx context.Context, req *GetFlushStateRequest) (*GetFlushStateResponse, error)

func (*UnimplementedMilvusServiceServer) GetImportState 

func (*UnimplementedMilvusServiceServer) GetImportState(ctx context.Context, req *GetImportStateRequest) (*GetImportStateResponse, error)

func (*UnimplementedMilvusServiceServer) GetIndexBuildProgress 

func (*UnimplementedMilvusServiceServer) GetIndexBuildProgress(ctx context.Context, req *GetIndexBuildProgressRequest) (*GetIndexBuildProgressResponse, error)

func (*UnimplementedMilvusServiceServer) GetIndexState 

func (*UnimplementedMilvusServiceServer) GetIndexState(ctx context.Context, req *GetIndexStateRequest) (*GetIndexStateResponse, error)

func (*UnimplementedMilvusServiceServer) GetLoadingProgress 

func (*UnimplementedMilvusServiceServer) GetLoadingProgress(ctx context.Context, req *GetLoadingProgressRequest) (*GetLoadingProgressResponse, error)

func (*UnimplementedMilvusServiceServer) GetMetrics 

func (*UnimplementedMilvusServiceServer) GetMetrics(ctx context.Context, req *GetMetricsRequest) (*GetMetricsResponse, error)

func (*UnimplementedMilvusServiceServer) GetPartitionStatistics 

func (*UnimplementedMilvusServiceServer) GetPartitionStatistics(ctx context.Context, req *GetPartitionStatisticsRequest) (*GetPartitionStatisticsResponse, error)

func (*UnimplementedMilvusServiceServer) GetPersistentSegmentInfo 

func (*UnimplementedMilvusServiceServer) GetPersistentSegmentInfo(ctx context.Context, req *GetPersistentSegmentInfoRequest) (*GetPersistentSegmentInfoResponse, error)

func (*UnimplementedMilvusServiceServer) GetQuerySegmentInfo 

func (*UnimplementedMilvusServiceServer) GetQuerySegmentInfo(ctx context.Context, req *GetQuerySegmentInfoRequest) (*GetQuerySegmentInfoResponse, error)

func (*UnimplementedMilvusServiceServer) GetReplicas 

func (*UnimplementedMilvusServiceServer) GetReplicas(ctx context.Context, req *GetReplicasRequest) (*GetReplicasResponse, error)

func (*UnimplementedMilvusServiceServer) GetVersion 

func (*UnimplementedMilvusServiceServer) GetVersion(ctx context.Context, req *GetVersionRequest) (*GetVersionResponse, error)

func (*UnimplementedMilvusServiceServer) HasCollection 

func (*UnimplementedMilvusServiceServer) HasCollection(ctx context.Context, req *HasCollectionRequest) (*BoolResponse, error)

func (*UnimplementedMilvusServiceServer) HasPartition 

func (*UnimplementedMilvusServiceServer) HasPartition(ctx context.Context, req *HasPartitionRequest) (*BoolResponse, error)

func (*UnimplementedMilvusServiceServer) Import 

func (*UnimplementedMilvusServiceServer) Import(ctx context.Context, req *ImportRequest) (*ImportResponse, error)

func (*UnimplementedMilvusServiceServer) Insert 

func (*UnimplementedMilvusServiceServer) Insert(ctx context.Context, req *InsertRequest) (*MutationResult, error)

func (*UnimplementedMilvusServiceServer) ListCredUsers 

func (*UnimplementedMilvusServiceServer) ListCredUsers(ctx context.Context, req *ListCredUsersRequest) (*ListCredUsersResponse, error)

func (*UnimplementedMilvusServiceServer) ListImportTasks 

func (*UnimplementedMilvusServiceServer) ListImportTasks(ctx context.Context, req *ListImportTasksRequest) (*ListImportTasksResponse, error)

func (*UnimplementedMilvusServiceServer) LoadBalance 

func (*UnimplementedMilvusServiceServer) LoadBalance(ctx context.Context, req *LoadBalanceRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) LoadCollection 

func (*UnimplementedMilvusServiceServer) LoadCollection(ctx context.Context, req *LoadCollectionRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) LoadPartitions 

func (*UnimplementedMilvusServiceServer) LoadPartitions(ctx context.Context, req *LoadPartitionsRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) ManualCompaction 

func (*UnimplementedMilvusServiceServer) ManualCompaction(ctx context.Context, req *ManualCompactionRequest) (*ManualCompactionResponse, error)

func (*UnimplementedMilvusServiceServer) OperatePrivilege 

func (*UnimplementedMilvusServiceServer) OperatePrivilege(ctx context.Context, req *OperatePrivilegeRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) OperateUserRole 

func (*UnimplementedMilvusServiceServer) OperateUserRole(ctx context.Context, req *OperateUserRoleRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) Query 

func (*UnimplementedMilvusServiceServer) Query(ctx context.Context, req *QueryRequest) (*QueryResults, error)
func (*UnimplementedMilvusServiceServer) RegisterLink(ctx context.Context, req *RegisterLinkRequest) (*RegisterLinkResponse, error)

func (*UnimplementedMilvusServiceServer) ReleaseCollection 

func (*UnimplementedMilvusServiceServer) ReleaseCollection(ctx context.Context, req *ReleaseCollectionRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) ReleasePartitions 

func (*UnimplementedMilvusServiceServer) ReleasePartitions(ctx context.Context, req *ReleasePartitionsRequest) (*commonpb.Status, error)

func (*UnimplementedMilvusServiceServer) Search 

func (*UnimplementedMilvusServiceServer) Search(ctx context.Context, req *SearchRequest) (*SearchResults, error)

func (*UnimplementedMilvusServiceServer) SelectGrant 

func (*UnimplementedMilvusServiceServer) SelectGrant(ctx context.Context, req *SelectGrantRequest) (*SelectGrantResponse, error)

func (*UnimplementedMilvusServiceServer) SelectRole 

func (*UnimplementedMilvusServiceServer) SelectRole(ctx context.Context, req *SelectRoleRequest) (*SelectRoleResponse, error)

func (*UnimplementedMilvusServiceServer) SelectUser 

func (*UnimplementedMilvusServiceServer) SelectUser(ctx context.Context, req *SelectUserRequest) (*SelectUserResponse, error)

func (*UnimplementedMilvusServiceServer) ShowCollections 

func (*UnimplementedMilvusServiceServer) ShowCollections(ctx context.Context, req *ShowCollectionsRequest) (*ShowCollectionsResponse, error)

func (*UnimplementedMilvusServiceServer) ShowPartitions 

func (*UnimplementedMilvusServiceServer) ShowPartitions(ctx context.Context, req *ShowPartitionsRequest) (*ShowPartitionsResponse, error)

func (*UnimplementedMilvusServiceServer) UpdateCredential 

func (*UnimplementedMilvusServiceServer) UpdateCredential(ctx context.Context, req *UpdateCredentialRequest) (*commonpb.Status, error)

type UnimplementedProxyServiceServer 

type UnimplementedProxyServiceServer struct {
}

UnimplementedProxyServiceServer can be embedded to have forward compatible implementations. 

func (*UnimplementedProxyServiceServer) RegisterLink(ctx context.Context, req *RegisterLinkRequest) (*RegisterLinkResponse, error)

type UpdateCredentialRequest 

type UpdateCredentialRequest struct {
	// Not useful for now
	Base *commonpb.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// username
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	// old password
	OldPassword string `protobuf:"bytes,3,opt,name=oldPassword,proto3" json:"oldPassword,omitempty"`
	// new password
	NewPassword string `protobuf:"bytes,4,opt,name=newPassword,proto3" json:"newPassword,omitempty"`
	// create time
	CreatedUtcTimestamps uint64 `protobuf:"varint,5,opt,name=created_utc_timestamps,json=createdUtcTimestamps,proto3" json:"created_utc_timestamps,omitempty"`
	// modify time
	ModifiedUtcTimestamps uint64   `` /* 127-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

func (*UpdateCredentialRequest) Descriptor 

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

func (*UpdateCredentialRequest) GetBase 

func (m *UpdateCredentialRequest) GetBase() *commonpb.MsgBase

func (*UpdateCredentialRequest) GetCreatedUtcTimestamps 

func (m *UpdateCredentialRequest) GetCreatedUtcTimestamps() uint64

func (*UpdateCredentialRequest) GetModifiedUtcTimestamps 

func (m *UpdateCredentialRequest) GetModifiedUtcTimestamps() uint64

func (*UpdateCredentialRequest) GetNewPassword 

func (m *UpdateCredentialRequest) GetNewPassword() string

func (*UpdateCredentialRequest) GetOldPassword 

func (m *UpdateCredentialRequest) GetOldPassword() string

func (*UpdateCredentialRequest) GetUsername 

func (m *UpdateCredentialRequest) GetUsername() string

func (*UpdateCredentialRequest) ProtoMessage 

func (*UpdateCredentialRequest) ProtoMessage()

func (*UpdateCredentialRequest) Reset 

func (m *UpdateCredentialRequest) Reset()

func (*UpdateCredentialRequest) String 

func (m *UpdateCredentialRequest) String() string

func (*UpdateCredentialRequest) XXX_DiscardUnknown 

func (m *UpdateCredentialRequest) XXX_DiscardUnknown()

func (*UpdateCredentialRequest) XXX_Marshal 

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

func (*UpdateCredentialRequest) XXX_Merge 

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

func (*UpdateCredentialRequest) XXX_Size 

func (m *UpdateCredentialRequest) XXX_Size() int

func (*UpdateCredentialRequest) XXX_Unmarshal 

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

type UserEntity 

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

func (*UserEntity) Descriptor 

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

func (*UserEntity) GetName 

func (m *UserEntity) GetName() string

func (*UserEntity) ProtoMessage 

func (*UserEntity) ProtoMessage()

func (*UserEntity) Reset 

func (m *UserEntity) Reset()

func (*UserEntity) String 

func (m *UserEntity) String() string

func (*UserEntity) XXX_DiscardUnknown 

func (m *UserEntity) XXX_DiscardUnknown()

func (*UserEntity) XXX_Marshal 

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

func (*UserEntity) XXX_Merge 

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

func (*UserEntity) XXX_Size 

func (m *UserEntity) XXX_Size() int

func (*UserEntity) XXX_Unmarshal 

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

type UserResult 

type UserResult struct {
	User                 *UserEntity   `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Roles                []*RoleEntity `protobuf:"bytes,2,rep,name=roles,proto3" json:"roles,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*UserResult) Descriptor 

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

func (*UserResult) GetRoles 

func (m *UserResult) GetRoles() []*RoleEntity

func (*UserResult) GetUser 

func (m *UserResult) GetUser() *UserEntity

func (*UserResult) ProtoMessage 

func (*UserResult) ProtoMessage()

func (*UserResult) Reset 

func (m *UserResult) Reset()

func (*UserResult) String 

func (m *UserResult) String() string

func (*UserResult) XXX_DiscardUnknown 

func (m *UserResult) XXX_DiscardUnknown()

func (*UserResult) XXX_Marshal 

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

func (*UserResult) XXX_Merge 

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

func (*UserResult) XXX_Size 

func (m *UserResult) XXX_Size() int

func (*UserResult) XXX_Unmarshal 

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

type VectorIDs 

type VectorIDs struct {
	CollectionName       string        `protobuf:"bytes,1,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	FieldName            string        `protobuf:"bytes,2,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	IdArray              *schemapb.IDs `protobuf:"bytes,3,opt,name=id_array,json=idArray,proto3" json:"id_array,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 (*VectorIDs) Descriptor 

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

func (*VectorIDs) GetCollectionName 

func (m *VectorIDs) GetCollectionName() string

func (*VectorIDs) GetFieldName 

func (m *VectorIDs) GetFieldName() string

func (*VectorIDs) GetIdArray 

func (m *VectorIDs) GetIdArray() *schemapb.IDs

func (*VectorIDs) GetPartitionNames 

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

func (*VectorIDs) ProtoMessage 

func (*VectorIDs) ProtoMessage()

func (*VectorIDs) Reset 

func (m *VectorIDs) Reset()

func (*VectorIDs) String 

func (m *VectorIDs) String() string

func (*VectorIDs) XXX_DiscardUnknown 

func (m *VectorIDs) XXX_DiscardUnknown()

func (*VectorIDs) XXX_Marshal 

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

func (*VectorIDs) XXX_Merge 

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

func (*VectorIDs) XXX_Size 

func (m *VectorIDs) XXX_Size() int

func (*VectorIDs) XXX_Unmarshal 

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

type VectorsArray 

type VectorsArray struct {
	// Types that are valid to be assigned to Array:
	//	*VectorsArray_IdArray
	//	*VectorsArray_DataArray
	Array                isVectorsArray_Array `protobuf_oneof:"array"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*VectorsArray) Descriptor 

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

func (*VectorsArray) GetArray 

func (m *VectorsArray) GetArray() isVectorsArray_Array

func (*VectorsArray) GetDataArray 

func (m *VectorsArray) GetDataArray() *schemapb.VectorField

func (*VectorsArray) GetIdArray 

func (m *VectorsArray) GetIdArray() *VectorIDs

func (*VectorsArray) ProtoMessage 

func (*VectorsArray) ProtoMessage()

func (*VectorsArray) Reset 

func (m *VectorsArray) Reset()

func (*VectorsArray) String 

func (m *VectorsArray) String() string

func (*VectorsArray) XXX_DiscardUnknown 

func (m *VectorsArray) XXX_DiscardUnknown()

func (*VectorsArray) XXX_Marshal 

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

func (*VectorsArray) XXX_Merge 

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

func (*VectorsArray) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*VectorsArray) XXX_Size 

func (m *VectorsArray) XXX_Size() int

func (*VectorsArray) XXX_Unmarshal 

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

type VectorsArray_DataArray 

type VectorsArray_DataArray struct {
	DataArray *schemapb.VectorField `protobuf:"bytes,2,opt,name=data_array,json=dataArray,proto3,oneof"`
}

type VectorsArray_IdArray 

type VectorsArray_IdArray struct {
	IdArray *VectorIDs `protobuf:"bytes,1,opt,name=id_array,json=idArray,proto3,oneof"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.