server

package
v2.1.2 Latest Latest
Warning

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

 Go to latest Published: Sep 8, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ShowType_name = map[int32]string{
		0: "All",
		1: "InMemory",
	}
	ShowType_value = map[string]int32{
		"All":      0,
		"InMemory": 1,
	}
)

Enum value maps for ShowType.

View Source 
var (
	OperateUserRoleType_name = map[int32]string{
		0: "AddUserToRole",
		1: "RemoveUserFromRole",
	}
	OperateUserRoleType_value = map[string]int32{
		"AddUserToRole":      0,
		"RemoveUserFromRole": 1,
	}
)

Enum value maps for OperateUserRoleType.

View Source 
var (
	OperatePrivilegeType_name = map[int32]string{
		0: "Grant",
		1: "Revoke",
	}
	OperatePrivilegeType_value = map[string]int32{
		"Grant":  0,
		"Revoke": 1,
	}
)

Enum value maps for OperatePrivilegeType.

View Source 
var (
	// optional milvus.proto.milvus.MilvusExt milvus_ext_obj = 1001;
	E_MilvusExtObj = &file_milvus_proto_extTypes[0]
)

Extension fields to descriptor.FileOptions.

View Source 
var File_milvus_proto protoreflect.FileDescriptor

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           *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName         string          `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName string          `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	Alias          string          `protobuf:"bytes,4,opt,name=alias,proto3" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

func (*AlterAliasRequest) Descriptor deprecated 

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

Deprecated: Use AlterAliasRequest.ProtoReflect.Descriptor instead.

func (*AlterAliasRequest) GetAlias 

func (x *AlterAliasRequest) GetAlias() string

func (*AlterAliasRequest) GetBase 

func (x *AlterAliasRequest) GetBase() *common.MsgBase

func (*AlterAliasRequest) GetCollectionName 

func (x *AlterAliasRequest) GetCollectionName() string

func (*AlterAliasRequest) GetDbName 

func (x *AlterAliasRequest) GetDbName() string

func (*AlterAliasRequest) ProtoMessage 

func (*AlterAliasRequest) ProtoMessage()

func (*AlterAliasRequest) ProtoReflect added in v2.1.0 

func (x *AlterAliasRequest) ProtoReflect() protoreflect.Message

func (*AlterAliasRequest) Reset 

func (x *AlterAliasRequest) Reset()

func (*AlterAliasRequest) String 

func (x *AlterAliasRequest) String() string

type BoolResponse 

type BoolResponse struct {
	Status *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Value  bool           `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*BoolResponse) Descriptor deprecated 

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

Deprecated: Use BoolResponse.ProtoReflect.Descriptor instead.

func (*BoolResponse) GetStatus 

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

func (*BoolResponse) GetValue 

func (x *BoolResponse) GetValue() bool

func (*BoolResponse) ProtoMessage 

func (*BoolResponse) ProtoMessage()

func (*BoolResponse) ProtoReflect added in v2.1.0 

func (x *BoolResponse) ProtoReflect() protoreflect.Message

func (*BoolResponse) Reset 

func (x *BoolResponse) Reset()

func (*BoolResponse) String 

func (x *BoolResponse) String() string

type CalcDistanceRequest 

type CalcDistanceRequest struct {
	Base    *common.MsgBase        `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	OpLeft  *VectorsArray          `protobuf:"bytes,2,opt,name=op_left,json=opLeft,proto3" json:"op_left,omitempty"`    // vectors on the left of operator
	OpRight *VectorsArray          `protobuf:"bytes,3,opt,name=op_right,json=opRight,proto3" json:"op_right,omitempty"` // vectors on the right of operator
	Params  []*common.KeyValuePair `protobuf:"bytes,4,rep,name=params,proto3" json:"params,omitempty"`                  // "metric":"L2"/"IP"/"HAMMIN"/"TANIMOTO"
	// contains filtered or unexported fields
}

func (*CalcDistanceRequest) Descriptor deprecated 

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

Deprecated: Use CalcDistanceRequest.ProtoReflect.Descriptor instead.

func (*CalcDistanceRequest) GetBase 

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

func (*CalcDistanceRequest) GetOpLeft 

func (x *CalcDistanceRequest) GetOpLeft() *VectorsArray

func (*CalcDistanceRequest) GetOpRight 

func (x *CalcDistanceRequest) GetOpRight() *VectorsArray

func (*CalcDistanceRequest) GetParams 

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

func (*CalcDistanceRequest) ProtoMessage 

func (*CalcDistanceRequest) ProtoMessage()

func (*CalcDistanceRequest) ProtoReflect added in v2.1.0 

func (x *CalcDistanceRequest) ProtoReflect() protoreflect.Message

func (*CalcDistanceRequest) Reset 

func (x *CalcDistanceRequest) Reset()

func (*CalcDistanceRequest) String 

func (x *CalcDistanceRequest) String() string

type CalcDistanceResults 

type CalcDistanceResults struct {
	Status *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// num(op_left)*num(op_right) distance values, "HAMMIN" return integer distance
	//
	// Types that are assignable to Array:
	//	*CalcDistanceResults_IntDist
	//	*CalcDistanceResults_FloatDist
	Array isCalcDistanceResults_Array `protobuf_oneof:"array"`
	// contains filtered or unexported fields
}

func (*CalcDistanceResults) Descriptor deprecated 

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

Deprecated: Use CalcDistanceResults.ProtoReflect.Descriptor instead.

func (*CalcDistanceResults) GetArray 

func (m *CalcDistanceResults) GetArray() isCalcDistanceResults_Array

func (*CalcDistanceResults) GetFloatDist 

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

func (*CalcDistanceResults) GetIntDist 

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

func (*CalcDistanceResults) GetStatus 

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

func (*CalcDistanceResults) ProtoMessage 

func (*CalcDistanceResults) ProtoMessage()

func (*CalcDistanceResults) ProtoReflect added in v2.1.0 

func (x *CalcDistanceResults) ProtoReflect() protoreflect.Message

func (*CalcDistanceResults) Reset 

func (x *CalcDistanceResults) Reset()

func (*CalcDistanceResults) String 

func (x *CalcDistanceResults) String() string

type CalcDistanceResults_FloatDist 

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

type CalcDistanceResults_IntDist 

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

type 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"`
	// contains filtered or unexported fields
}

func (*CompactionMergeInfo) Descriptor deprecated 

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

Deprecated: Use CompactionMergeInfo.ProtoReflect.Descriptor instead.

func (*CompactionMergeInfo) GetSources 

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

func (*CompactionMergeInfo) GetTarget 

func (x *CompactionMergeInfo) GetTarget() int64

func (*CompactionMergeInfo) ProtoMessage 

func (*CompactionMergeInfo) ProtoMessage()

func (*CompactionMergeInfo) ProtoReflect added in v2.1.0 

func (x *CompactionMergeInfo) ProtoReflect() protoreflect.Message

func (*CompactionMergeInfo) Reset 

func (x *CompactionMergeInfo) Reset()

func (*CompactionMergeInfo) String 

func (x *CompactionMergeInfo) String() string

type CreateAliasRequest 

type CreateAliasRequest struct {
	Base           *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName         string          `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName string          `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	Alias          string          `protobuf:"bytes,4,opt,name=alias,proto3" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateAliasRequest) Descriptor deprecated 

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

Deprecated: Use CreateAliasRequest.ProtoReflect.Descriptor instead.

func (*CreateAliasRequest) GetAlias 

func (x *CreateAliasRequest) GetAlias() string

func (*CreateAliasRequest) GetBase 

func (x *CreateAliasRequest) GetBase() *common.MsgBase

func (*CreateAliasRequest) GetCollectionName 

func (x *CreateAliasRequest) GetCollectionName() string

func (*CreateAliasRequest) GetDbName 

func (x *CreateAliasRequest) GetDbName() string

func (*CreateAliasRequest) ProtoMessage 

func (*CreateAliasRequest) ProtoMessage()

func (*CreateAliasRequest) ProtoReflect added in v2.1.0 

func (x *CreateAliasRequest) ProtoReflect() protoreflect.Message

func (*CreateAliasRequest) Reset 

func (x *CreateAliasRequest) Reset()

func (*CreateAliasRequest) String 

func (x *CreateAliasRequest) String() string

type CreateCollectionRequest 

type CreateCollectionRequest struct {

	// Not useful for now
	Base *common.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 common.ConsistencyLevel `` /* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

* Create collection in milvus

func (*CreateCollectionRequest) Descriptor deprecated 

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

Deprecated: Use CreateCollectionRequest.ProtoReflect.Descriptor instead.

func (*CreateCollectionRequest) GetBase 

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

func (*CreateCollectionRequest) GetCollectionName 

func (x *CreateCollectionRequest) GetCollectionName() string

func (*CreateCollectionRequest) GetConsistencyLevel 

func (x *CreateCollectionRequest) GetConsistencyLevel() common.ConsistencyLevel

func (*CreateCollectionRequest) GetDbName 

func (x *CreateCollectionRequest) GetDbName() string

func (*CreateCollectionRequest) GetSchema 

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

func (*CreateCollectionRequest) GetShardsNum 

func (x *CreateCollectionRequest) GetShardsNum() int32

func (*CreateCollectionRequest) ProtoMessage 

func (*CreateCollectionRequest) ProtoMessage()

func (*CreateCollectionRequest) ProtoReflect added in v2.1.0 

func (x *CreateCollectionRequest) ProtoReflect() protoreflect.Message

func (*CreateCollectionRequest) Reset 

func (x *CreateCollectionRequest) Reset()

func (*CreateCollectionRequest) String 

func (x *CreateCollectionRequest) String() string

type CreateCredentialRequest added in v2.1.0 

type CreateCredentialRequest struct {

	// Not useful for now
	Base *common.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 */
	// contains filtered or unexported fields
}

func (*CreateCredentialRequest) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use CreateCredentialRequest.ProtoReflect.Descriptor instead.

func (*CreateCredentialRequest) GetBase added in v2.1.0 

func (x *CreateCredentialRequest) GetBase() *common.MsgBase

func (*CreateCredentialRequest) GetCreatedUtcTimestamps added in v2.1.0 

func (x *CreateCredentialRequest) GetCreatedUtcTimestamps() uint64

func (*CreateCredentialRequest) GetModifiedUtcTimestamps added in v2.1.0 

func (x *CreateCredentialRequest) GetModifiedUtcTimestamps() uint64

func (*CreateCredentialRequest) GetPassword added in v2.1.0 

func (x *CreateCredentialRequest) GetPassword() string

func (*CreateCredentialRequest) GetUsername added in v2.1.0 

func (x *CreateCredentialRequest) GetUsername() string

func (*CreateCredentialRequest) ProtoMessage added in v2.1.0 

func (*CreateCredentialRequest) ProtoMessage()

func (*CreateCredentialRequest) ProtoReflect added in v2.1.0 

func (x *CreateCredentialRequest) ProtoReflect() protoreflect.Message

func (*CreateCredentialRequest) Reset added in v2.1.0 

func (x *CreateCredentialRequest) Reset()

func (*CreateCredentialRequest) String added in v2.1.0 

func (x *CreateCredentialRequest) String() string

type CreateIndexRequest 

type CreateIndexRequest struct {

	// Not useful for now
	Base *common.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 []*common.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"`
	// contains filtered or unexported fields
}

Create index for vector datas

func (*CreateIndexRequest) Descriptor deprecated 

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

Deprecated: Use CreateIndexRequest.ProtoReflect.Descriptor instead.

func (*CreateIndexRequest) GetBase 

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

func (*CreateIndexRequest) GetCollectionName 

func (x *CreateIndexRequest) GetCollectionName() string

func (*CreateIndexRequest) GetDbName 

func (x *CreateIndexRequest) GetDbName() string

func (*CreateIndexRequest) GetExtraParams 

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

func (*CreateIndexRequest) GetFieldName 

func (x *CreateIndexRequest) GetFieldName() string

func (*CreateIndexRequest) GetIndexName added in v2.1.0 

func (x *CreateIndexRequest) GetIndexName() string

func (*CreateIndexRequest) ProtoMessage 

func (*CreateIndexRequest) ProtoMessage()

func (*CreateIndexRequest) ProtoReflect added in v2.1.0 

func (x *CreateIndexRequest) ProtoReflect() protoreflect.Message

func (*CreateIndexRequest) Reset 

func (x *CreateIndexRequest) Reset()

func (*CreateIndexRequest) String 

func (x *CreateIndexRequest) String() string

type CreatePartitionRequest 

type CreatePartitionRequest struct {

	// Not useful for now
	Base *common.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"`
	// contains filtered or unexported fields
}

Create partition in created collection.

func (*CreatePartitionRequest) Descriptor deprecated 

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

Deprecated: Use CreatePartitionRequest.ProtoReflect.Descriptor instead.

func (*CreatePartitionRequest) GetBase 

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

func (*CreatePartitionRequest) GetCollectionName 

func (x *CreatePartitionRequest) GetCollectionName() string

func (*CreatePartitionRequest) GetDbName 

func (x *CreatePartitionRequest) GetDbName() string

func (*CreatePartitionRequest) GetPartitionName 

func (x *CreatePartitionRequest) GetPartitionName() string

func (*CreatePartitionRequest) ProtoMessage 

func (*CreatePartitionRequest) ProtoMessage()

func (*CreatePartitionRequest) ProtoReflect added in v2.1.0 

func (x *CreatePartitionRequest) ProtoReflect() protoreflect.Message

func (*CreatePartitionRequest) Reset 

func (x *CreatePartitionRequest) Reset()

func (*CreatePartitionRequest) String 

func (x *CreatePartitionRequest) String() string

type CreateRoleRequest added in v2.1.0 

type CreateRoleRequest struct {

	// Not useful for now
	Base *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// role
	Entity *RoleEntity `protobuf:"bytes,2,opt,name=entity,proto3" json:"entity,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRoleRequest) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use CreateRoleRequest.ProtoReflect.Descriptor instead.

func (*CreateRoleRequest) GetBase added in v2.1.0 

func (x *CreateRoleRequest) GetBase() *common.MsgBase

func (*CreateRoleRequest) GetEntity added in v2.1.0 

func (x *CreateRoleRequest) GetEntity() *RoleEntity

func (*CreateRoleRequest) ProtoMessage added in v2.1.0 

func (*CreateRoleRequest) ProtoMessage()

func (*CreateRoleRequest) ProtoReflect added in v2.1.0 

func (x *CreateRoleRequest) ProtoReflect() protoreflect.Message

func (*CreateRoleRequest) Reset added in v2.1.0 

func (x *CreateRoleRequest) Reset()

func (*CreateRoleRequest) String added in v2.1.0 

func (x *CreateRoleRequest) String() string

type DeleteCredentialRequest added in v2.1.0 

type DeleteCredentialRequest struct {

	// Not useful for now
	Base *common.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"`
	// contains filtered or unexported fields
}

func (*DeleteCredentialRequest) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use DeleteCredentialRequest.ProtoReflect.Descriptor instead.

func (*DeleteCredentialRequest) GetBase added in v2.1.0 

func (x *DeleteCredentialRequest) GetBase() *common.MsgBase

func (*DeleteCredentialRequest) GetUsername added in v2.1.0 

func (x *DeleteCredentialRequest) GetUsername() string

func (*DeleteCredentialRequest) ProtoMessage added in v2.1.0 

func (*DeleteCredentialRequest) ProtoMessage()

func (*DeleteCredentialRequest) ProtoReflect added in v2.1.0 

func (x *DeleteCredentialRequest) ProtoReflect() protoreflect.Message

func (*DeleteCredentialRequest) Reset added in v2.1.0 

func (x *DeleteCredentialRequest) Reset()

func (*DeleteCredentialRequest) String added in v2.1.0 

func (x *DeleteCredentialRequest) String() string

type DeleteRequest 

type DeleteRequest struct {
	Base           *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName         string          `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName string          `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	PartitionName  string          `protobuf:"bytes,4,opt,name=partition_name,json=partitionName,proto3" json:"partition_name,omitempty"`
	Expr           string          `protobuf:"bytes,5,opt,name=expr,proto3" json:"expr,omitempty"`
	HashKeys       []uint32        `protobuf:"varint,6,rep,packed,name=hash_keys,json=hashKeys,proto3" json:"hash_keys,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetBase 

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

func (*DeleteRequest) GetCollectionName 

func (x *DeleteRequest) GetCollectionName() string

func (*DeleteRequest) GetDbName 

func (x *DeleteRequest) GetDbName() string

func (*DeleteRequest) GetExpr 

func (x *DeleteRequest) GetExpr() string

func (*DeleteRequest) GetHashKeys 

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

func (*DeleteRequest) GetPartitionName 

func (x *DeleteRequest) GetPartitionName() string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect added in v2.1.0 

func (x *DeleteRequest) ProtoReflect() protoreflect.Message

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type DescribeCollectionRequest 

type DescribeCollectionRequest struct {

	// Not useful for now
	Base *common.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"`
	// contains filtered or unexported fields
}

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

func (*DescribeCollectionRequest) Descriptor deprecated 

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

Deprecated: Use DescribeCollectionRequest.ProtoReflect.Descriptor instead.

func (*DescribeCollectionRequest) GetBase 

func (x *DescribeCollectionRequest) GetBase() *common.MsgBase

func (*DescribeCollectionRequest) GetCollectionID 

func (x *DescribeCollectionRequest) GetCollectionID() int64

func (*DescribeCollectionRequest) GetCollectionName 

func (x *DescribeCollectionRequest) GetCollectionName() string

func (*DescribeCollectionRequest) GetDbName 

func (x *DescribeCollectionRequest) GetDbName() string

func (*DescribeCollectionRequest) GetTimeStamp 

func (x *DescribeCollectionRequest) GetTimeStamp() uint64

func (*DescribeCollectionRequest) ProtoMessage 

func (*DescribeCollectionRequest) ProtoMessage()

func (*DescribeCollectionRequest) ProtoReflect added in v2.1.0 

func (x *DescribeCollectionRequest) ProtoReflect() protoreflect.Message

func (*DescribeCollectionRequest) Reset 

func (x *DescribeCollectionRequest) Reset()

func (*DescribeCollectionRequest) String 

func (x *DescribeCollectionRequest) String() string

type DescribeCollectionResponse 

type DescribeCollectionResponse struct {

	// Contain error_code and reason
	Status *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// The schema param when you created collection.
	Schema *schema.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 []*common.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 common.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"`
	// contains filtered or unexported fields
}

* DescribeCollection Response

func (*DescribeCollectionResponse) Descriptor deprecated 

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

Deprecated: Use DescribeCollectionResponse.ProtoReflect.Descriptor instead.

func (*DescribeCollectionResponse) GetAliases 

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

func (*DescribeCollectionResponse) GetCollectionID 

func (x *DescribeCollectionResponse) GetCollectionID() int64

func (*DescribeCollectionResponse) GetCollectionName added in v2.1.0 

func (x *DescribeCollectionResponse) GetCollectionName() string

func (*DescribeCollectionResponse) GetConsistencyLevel 

func (x *DescribeCollectionResponse) GetConsistencyLevel() common.ConsistencyLevel

func (*DescribeCollectionResponse) GetCreatedTimestamp 

func (x *DescribeCollectionResponse) GetCreatedTimestamp() uint64

func (*DescribeCollectionResponse) GetCreatedUtcTimestamp 

func (x *DescribeCollectionResponse) GetCreatedUtcTimestamp() uint64

func (*DescribeCollectionResponse) GetPhysicalChannelNames 

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

func (*DescribeCollectionResponse) GetSchema 

func (x *DescribeCollectionResponse) GetSchema() *schema.CollectionSchema

func (*DescribeCollectionResponse) GetShardsNum 

func (x *DescribeCollectionResponse) GetShardsNum() int32

func (*DescribeCollectionResponse) GetStartPositions 

func (x *DescribeCollectionResponse) GetStartPositions() []*common.KeyDataPair

func (*DescribeCollectionResponse) GetStatus 

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

func (*DescribeCollectionResponse) GetVirtualChannelNames 

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

func (*DescribeCollectionResponse) ProtoMessage 

func (*DescribeCollectionResponse) ProtoMessage()

func (*DescribeCollectionResponse) ProtoReflect added in v2.1.0 

func (x *DescribeCollectionResponse) ProtoReflect() protoreflect.Message

func (*DescribeCollectionResponse) Reset 

func (x *DescribeCollectionResponse) Reset()

func (*DescribeCollectionResponse) String 

func (x *DescribeCollectionResponse) String() string

type DescribeIndexRequest 

type DescribeIndexRequest struct {

	// Not useful for now
	Base *common.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"`
	// contains filtered or unexported fields
}

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

func (*DescribeIndexRequest) Descriptor deprecated 

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

Deprecated: Use DescribeIndexRequest.ProtoReflect.Descriptor instead.

func (*DescribeIndexRequest) GetBase 

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

func (*DescribeIndexRequest) GetCollectionName 

func (x *DescribeIndexRequest) GetCollectionName() string

func (*DescribeIndexRequest) GetDbName 

func (x *DescribeIndexRequest) GetDbName() string

func (*DescribeIndexRequest) GetFieldName 

func (x *DescribeIndexRequest) GetFieldName() string

func (*DescribeIndexRequest) GetIndexName 

func (x *DescribeIndexRequest) GetIndexName() string

func (*DescribeIndexRequest) ProtoMessage 

func (*DescribeIndexRequest) ProtoMessage()

func (*DescribeIndexRequest) ProtoReflect added in v2.1.0 

func (x *DescribeIndexRequest) ProtoReflect() protoreflect.Message

func (*DescribeIndexRequest) Reset 

func (x *DescribeIndexRequest) Reset()

func (*DescribeIndexRequest) String 

func (x *DescribeIndexRequest) String() string

type DescribeIndexResponse 

type DescribeIndexResponse struct {

	// Response status
	Status *common.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"`
	// contains filtered or unexported fields
}

Describe index response

func (*DescribeIndexResponse) Descriptor deprecated 

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

Deprecated: Use DescribeIndexResponse.ProtoReflect.Descriptor instead.

func (*DescribeIndexResponse) GetIndexDescriptions 

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

func (*DescribeIndexResponse) GetStatus 

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

func (*DescribeIndexResponse) ProtoMessage 

func (*DescribeIndexResponse) ProtoMessage()

func (*DescribeIndexResponse) ProtoReflect added in v2.1.0 

func (x *DescribeIndexResponse) ProtoReflect() protoreflect.Message

func (*DescribeIndexResponse) Reset 

func (x *DescribeIndexResponse) Reset()

func (*DescribeIndexResponse) String 

func (x *DescribeIndexResponse) String() string

type DescribeSegmentRequest 

type DescribeSegmentRequest struct {
	Base         *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	CollectionID int64           `protobuf:"varint,2,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	SegmentID    int64           `protobuf:"varint,3,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeSegmentRequest) Descriptor deprecated 

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

Deprecated: Use DescribeSegmentRequest.ProtoReflect.Descriptor instead.

func (*DescribeSegmentRequest) GetBase 

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

func (*DescribeSegmentRequest) GetCollectionID 

func (x *DescribeSegmentRequest) GetCollectionID() int64

func (*DescribeSegmentRequest) GetSegmentID 

func (x *DescribeSegmentRequest) GetSegmentID() int64

func (*DescribeSegmentRequest) ProtoMessage 

func (*DescribeSegmentRequest) ProtoMessage()

func (*DescribeSegmentRequest) ProtoReflect added in v2.1.0 

func (x *DescribeSegmentRequest) ProtoReflect() protoreflect.Message

func (*DescribeSegmentRequest) Reset 

func (x *DescribeSegmentRequest) Reset()

func (*DescribeSegmentRequest) String 

func (x *DescribeSegmentRequest) String() string

type DescribeSegmentResponse 

type DescribeSegmentResponse struct {
	Status      *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	IndexID     int64          `protobuf:"varint,2,opt,name=indexID,proto3" json:"indexID,omitempty"`
	BuildID     int64          `protobuf:"varint,3,opt,name=buildID,proto3" json:"buildID,omitempty"`
	EnableIndex bool           `protobuf:"varint,4,opt,name=enable_index,json=enableIndex,proto3" json:"enable_index,omitempty"`
	FieldID     int64          `protobuf:"varint,5,opt,name=fieldID,proto3" json:"fieldID,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeSegmentResponse) Descriptor deprecated 

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

Deprecated: Use DescribeSegmentResponse.ProtoReflect.Descriptor instead.

func (*DescribeSegmentResponse) GetBuildID 

func (x *DescribeSegmentResponse) GetBuildID() int64

func (*DescribeSegmentResponse) GetEnableIndex 

func (x *DescribeSegmentResponse) GetEnableIndex() bool

func (*DescribeSegmentResponse) GetFieldID 

func (x *DescribeSegmentResponse) GetFieldID() int64

func (*DescribeSegmentResponse) GetIndexID 

func (x *DescribeSegmentResponse) GetIndexID() int64

func (*DescribeSegmentResponse) GetStatus 

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

func (*DescribeSegmentResponse) ProtoMessage 

func (*DescribeSegmentResponse) ProtoMessage()

func (*DescribeSegmentResponse) ProtoReflect added in v2.1.0 

func (x *DescribeSegmentResponse) ProtoReflect() protoreflect.Message

func (*DescribeSegmentResponse) Reset 

func (x *DescribeSegmentResponse) Reset()

func (*DescribeSegmentResponse) String 

func (x *DescribeSegmentResponse) String() string

type DropAliasRequest 

type DropAliasRequest struct {
	Base   *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName string          `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	Alias  string          `protobuf:"bytes,3,opt,name=alias,proto3" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

func (*DropAliasRequest) Descriptor deprecated 

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

Deprecated: Use DropAliasRequest.ProtoReflect.Descriptor instead.

func (*DropAliasRequest) GetAlias 

func (x *DropAliasRequest) GetAlias() string

func (*DropAliasRequest) GetBase 

func (x *DropAliasRequest) GetBase() *common.MsgBase

func (*DropAliasRequest) GetDbName 

func (x *DropAliasRequest) GetDbName() string

func (*DropAliasRequest) ProtoMessage 

func (*DropAliasRequest) ProtoMessage()

func (*DropAliasRequest) ProtoReflect added in v2.1.0 

func (x *DropAliasRequest) ProtoReflect() protoreflect.Message

func (*DropAliasRequest) Reset 

func (x *DropAliasRequest) Reset()

func (*DropAliasRequest) String 

func (x *DropAliasRequest) String() string

type DropCollectionRequest 

type DropCollectionRequest struct {

	// Not useful for now
	Base *common.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"`
	// contains filtered or unexported fields
}

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

func (*DropCollectionRequest) Descriptor deprecated 

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

Deprecated: Use DropCollectionRequest.ProtoReflect.Descriptor instead.

func (*DropCollectionRequest) GetBase 

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

func (*DropCollectionRequest) GetCollectionName 

func (x *DropCollectionRequest) GetCollectionName() string

func (*DropCollectionRequest) GetDbName 

func (x *DropCollectionRequest) GetDbName() string

func (*DropCollectionRequest) ProtoMessage 

func (*DropCollectionRequest) ProtoMessage()

func (*DropCollectionRequest) ProtoReflect added in v2.1.0 

func (x *DropCollectionRequest) ProtoReflect() protoreflect.Message

func (*DropCollectionRequest) Reset 

func (x *DropCollectionRequest) Reset()

func (*DropCollectionRequest) String 

func (x *DropCollectionRequest) String() string

type DropIndexRequest 

type DropIndexRequest struct {
	Base           *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"` // must
	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"` // must
	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"` // No need to set up for now @2021.06.30
	// contains filtered or unexported fields
}

func (*DropIndexRequest) Descriptor deprecated 

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

Deprecated: Use DropIndexRequest.ProtoReflect.Descriptor instead.

func (*DropIndexRequest) GetBase 

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

func (*DropIndexRequest) GetCollectionName 

func (x *DropIndexRequest) GetCollectionName() string

func (*DropIndexRequest) GetDbName 

func (x *DropIndexRequest) GetDbName() string

func (*DropIndexRequest) GetFieldName 

func (x *DropIndexRequest) GetFieldName() string

func (*DropIndexRequest) GetIndexName 

func (x *DropIndexRequest) GetIndexName() string

func (*DropIndexRequest) ProtoMessage 

func (*DropIndexRequest) ProtoMessage()

func (*DropIndexRequest) ProtoReflect added in v2.1.0 

func (x *DropIndexRequest) ProtoReflect() protoreflect.Message

func (*DropIndexRequest) Reset 

func (x *DropIndexRequest) Reset()

func (*DropIndexRequest) String 

func (x *DropIndexRequest) String() string

type DropPartitionRequest 

type DropPartitionRequest struct {

	// Not useful for now
	Base *common.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"`
	// contains filtered or unexported fields
}

Drop partition in created collection.

func (*DropPartitionRequest) Descriptor deprecated 

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

Deprecated: Use DropPartitionRequest.ProtoReflect.Descriptor instead.

func (*DropPartitionRequest) GetBase 

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

func (*DropPartitionRequest) GetCollectionName 

func (x *DropPartitionRequest) GetCollectionName() string

func (*DropPartitionRequest) GetDbName 

func (x *DropPartitionRequest) GetDbName() string

func (*DropPartitionRequest) GetPartitionName 

func (x *DropPartitionRequest) GetPartitionName() string

func (*DropPartitionRequest) ProtoMessage 

func (*DropPartitionRequest) ProtoMessage()

func (*DropPartitionRequest) ProtoReflect added in v2.1.0 

func (x *DropPartitionRequest) ProtoReflect() protoreflect.Message

func (*DropPartitionRequest) Reset 

func (x *DropPartitionRequest) Reset()

func (*DropPartitionRequest) String 

func (x *DropPartitionRequest) String() string

type DropRoleRequest added in v2.1.0 

type DropRoleRequest struct {

	// Not useful for now
	Base *common.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"`
	// contains filtered or unexported fields
}

func (*DropRoleRequest) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use DropRoleRequest.ProtoReflect.Descriptor instead.

func (*DropRoleRequest) GetBase added in v2.1.0 

func (x *DropRoleRequest) GetBase() *common.MsgBase

func (*DropRoleRequest) GetRoleName added in v2.1.0 

func (x *DropRoleRequest) GetRoleName() string

func (*DropRoleRequest) ProtoMessage added in v2.1.0 

func (*DropRoleRequest) ProtoMessage()

func (*DropRoleRequest) ProtoReflect added in v2.1.0 

func (x *DropRoleRequest) ProtoReflect() protoreflect.Message

func (*DropRoleRequest) Reset added in v2.1.0 

func (x *DropRoleRequest) Reset()

func (*DropRoleRequest) String added in v2.1.0 

func (x *DropRoleRequest) String() string

type DummyRequest 

type DummyRequest struct {
	RequestType string `protobuf:"bytes,1,opt,name=request_type,json=requestType,proto3" json:"request_type,omitempty"`
	// contains filtered or unexported fields
}

func (*DummyRequest) Descriptor deprecated 

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

Deprecated: Use DummyRequest.ProtoReflect.Descriptor instead.

func (*DummyRequest) GetRequestType 

func (x *DummyRequest) GetRequestType() string

func (*DummyRequest) ProtoMessage 

func (*DummyRequest) ProtoMessage()

func (*DummyRequest) ProtoReflect added in v2.1.0 

func (x *DummyRequest) ProtoReflect() protoreflect.Message

func (*DummyRequest) Reset 

func (x *DummyRequest) Reset()

func (*DummyRequest) String 

func (x *DummyRequest) String() string

type DummyResponse 

type DummyResponse struct {
	Response string `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*DummyResponse) Descriptor deprecated 

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

Deprecated: Use DummyResponse.ProtoReflect.Descriptor instead.

func (*DummyResponse) GetResponse 

func (x *DummyResponse) GetResponse() string

func (*DummyResponse) ProtoMessage 

func (*DummyResponse) ProtoMessage()

func (*DummyResponse) ProtoReflect added in v2.1.0 

func (x *DummyResponse) ProtoReflect() protoreflect.Message

func (*DummyResponse) Reset 

func (x *DummyResponse) Reset()

func (*DummyResponse) String 

func (x *DummyResponse) String() string

type FlushRequest 

type FlushRequest struct {
	Base            *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName          string          `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionNames []string        `protobuf:"bytes,3,rep,name=collection_names,json=collectionNames,proto3" json:"collection_names,omitempty"`
	// contains filtered or unexported fields
}

func (*FlushRequest) Descriptor deprecated 

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

Deprecated: Use FlushRequest.ProtoReflect.Descriptor instead.

func (*FlushRequest) GetBase 

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

func (*FlushRequest) GetCollectionNames 

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

func (*FlushRequest) GetDbName 

func (x *FlushRequest) GetDbName() string

func (*FlushRequest) ProtoMessage 

func (*FlushRequest) ProtoMessage()

func (*FlushRequest) ProtoReflect added in v2.1.0 

func (x *FlushRequest) ProtoReflect() protoreflect.Message

func (*FlushRequest) Reset 

func (x *FlushRequest) Reset()

func (*FlushRequest) String 

func (x *FlushRequest) String() string

type FlushResponse 

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

func (*FlushResponse) Descriptor deprecated 

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

Deprecated: Use FlushResponse.ProtoReflect.Descriptor instead.

func (*FlushResponse) GetCollSegIDs 

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

func (*FlushResponse) GetDbName 

func (x *FlushResponse) GetDbName() string

func (*FlushResponse) GetStatus 

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

func (*FlushResponse) ProtoMessage 

func (*FlushResponse) ProtoMessage()

func (*FlushResponse) ProtoReflect added in v2.1.0 

func (x *FlushResponse) ProtoReflect() protoreflect.Message

func (*FlushResponse) Reset 

func (x *FlushResponse) Reset()

func (*FlushResponse) String 

func (x *FlushResponse) String() string

type GetCollectionStatisticsRequest 

type GetCollectionStatisticsRequest struct {

	// Not useful for now
	Base *common.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"`
	// contains filtered or unexported fields
}

* Get collection statistics like row_count.

func (*GetCollectionStatisticsRequest) Descriptor deprecated 

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

Deprecated: Use GetCollectionStatisticsRequest.ProtoReflect.Descriptor instead.

func (*GetCollectionStatisticsRequest) GetBase 

func (x *GetCollectionStatisticsRequest) GetBase() *common.MsgBase

func (*GetCollectionStatisticsRequest) GetCollectionName 

func (x *GetCollectionStatisticsRequest) GetCollectionName() string

func (*GetCollectionStatisticsRequest) GetDbName 

func (x *GetCollectionStatisticsRequest) GetDbName() string

func (*GetCollectionStatisticsRequest) ProtoMessage 

func (*GetCollectionStatisticsRequest) ProtoMessage()

func (*GetCollectionStatisticsRequest) ProtoReflect added in v2.1.0 

func (x *GetCollectionStatisticsRequest) ProtoReflect() protoreflect.Message

func (*GetCollectionStatisticsRequest) Reset 

func (x *GetCollectionStatisticsRequest) Reset()

func (*GetCollectionStatisticsRequest) String 

func (x *GetCollectionStatisticsRequest) String() string

type GetCollectionStatisticsResponse 

type GetCollectionStatisticsResponse struct {

	// Contain error_code and reason
	Status *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Collection statistics data
	Stats []*common.KeyValuePair `protobuf:"bytes,2,rep,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

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

func (*GetCollectionStatisticsResponse) Descriptor deprecated 

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

Deprecated: Use GetCollectionStatisticsResponse.ProtoReflect.Descriptor instead.

func (*GetCollectionStatisticsResponse) GetStats 

func (x *GetCollectionStatisticsResponse) GetStats() []*common.KeyValuePair

func (*GetCollectionStatisticsResponse) GetStatus 

func (x *GetCollectionStatisticsResponse) GetStatus() *common.Status

func (*GetCollectionStatisticsResponse) ProtoMessage 

func (*GetCollectionStatisticsResponse) ProtoMessage()

func (*GetCollectionStatisticsResponse) ProtoReflect added in v2.1.0 

func (x *GetCollectionStatisticsResponse) ProtoReflect() protoreflect.Message

func (*GetCollectionStatisticsResponse) Reset 

func (x *GetCollectionStatisticsResponse) Reset()

func (*GetCollectionStatisticsResponse) String 

func (x *GetCollectionStatisticsResponse) String() string

type GetCompactionPlansRequest 

type GetCompactionPlansRequest struct {
	CompactionID int64 `protobuf:"varint,1,opt,name=compactionID,proto3" json:"compactionID,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCompactionPlansRequest) Descriptor deprecated 

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

Deprecated: Use GetCompactionPlansRequest.ProtoReflect.Descriptor instead.

func (*GetCompactionPlansRequest) GetCompactionID 

func (x *GetCompactionPlansRequest) GetCompactionID() int64

func (*GetCompactionPlansRequest) ProtoMessage 

func (*GetCompactionPlansRequest) ProtoMessage()

func (*GetCompactionPlansRequest) ProtoReflect added in v2.1.0 

func (x *GetCompactionPlansRequest) ProtoReflect() protoreflect.Message

func (*GetCompactionPlansRequest) Reset 

func (x *GetCompactionPlansRequest) Reset()

func (*GetCompactionPlansRequest) String 

func (x *GetCompactionPlansRequest) String() string

type GetCompactionPlansResponse 

type GetCompactionPlansResponse struct {
	Status     *common.Status         `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	State      common.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"`
	// contains filtered or unexported fields
}

func (*GetCompactionPlansResponse) Descriptor deprecated 

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

Deprecated: Use GetCompactionPlansResponse.ProtoReflect.Descriptor instead.

func (*GetCompactionPlansResponse) GetMergeInfos 

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

func (*GetCompactionPlansResponse) GetState 

func (x *GetCompactionPlansResponse) GetState() common.CompactionState

func (*GetCompactionPlansResponse) GetStatus 

func (x *GetCompactionPlansResponse) GetStatus() *common.Status

func (*GetCompactionPlansResponse) ProtoMessage 

func (*GetCompactionPlansResponse) ProtoMessage()

func (*GetCompactionPlansResponse) ProtoReflect added in v2.1.0 

func (x *GetCompactionPlansResponse) ProtoReflect() protoreflect.Message

func (*GetCompactionPlansResponse) Reset 

func (x *GetCompactionPlansResponse) Reset()

func (*GetCompactionPlansResponse) String 

func (x *GetCompactionPlansResponse) String() string

type GetCompactionStateRequest 

type GetCompactionStateRequest struct {
	CompactionID int64 `protobuf:"varint,1,opt,name=compactionID,proto3" json:"compactionID,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCompactionStateRequest) Descriptor deprecated 

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

Deprecated: Use GetCompactionStateRequest.ProtoReflect.Descriptor instead.

func (*GetCompactionStateRequest) GetCompactionID 

func (x *GetCompactionStateRequest) GetCompactionID() int64

func (*GetCompactionStateRequest) ProtoMessage 

func (*GetCompactionStateRequest) ProtoMessage()

func (*GetCompactionStateRequest) ProtoReflect added in v2.1.0 

func (x *GetCompactionStateRequest) ProtoReflect() protoreflect.Message

func (*GetCompactionStateRequest) Reset 

func (x *GetCompactionStateRequest) Reset()

func (*GetCompactionStateRequest) String 

func (x *GetCompactionStateRequest) String() string

type GetCompactionStateResponse 

type GetCompactionStateResponse struct {
	Status          *common.Status         `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	State           common.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"`
	// contains filtered or unexported fields
}

func (*GetCompactionStateResponse) Descriptor deprecated 

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

Deprecated: Use GetCompactionStateResponse.ProtoReflect.Descriptor instead.

func (*GetCompactionStateResponse) GetCompletedPlanNo 

func (x *GetCompactionStateResponse) GetCompletedPlanNo() int64

func (*GetCompactionStateResponse) GetExecutingPlanNo 

func (x *GetCompactionStateResponse) GetExecutingPlanNo() int64

func (*GetCompactionStateResponse) GetState 

func (x *GetCompactionStateResponse) GetState() common.CompactionState

func (*GetCompactionStateResponse) GetStatus 

func (x *GetCompactionStateResponse) GetStatus() *common.Status

func (*GetCompactionStateResponse) GetTimeoutPlanNo 

func (x *GetCompactionStateResponse) GetTimeoutPlanNo() int64

func (*GetCompactionStateResponse) ProtoMessage 

func (*GetCompactionStateResponse) ProtoMessage()

func (*GetCompactionStateResponse) ProtoReflect added in v2.1.0 

func (x *GetCompactionStateResponse) ProtoReflect() protoreflect.Message

func (*GetCompactionStateResponse) Reset 

func (x *GetCompactionStateResponse) Reset()

func (*GetCompactionStateResponse) String 

func (x *GetCompactionStateResponse) String() string

type GetFlushStateRequest 

type GetFlushStateRequest struct {
	SegmentIDs []int64 `protobuf:"varint,1,rep,packed,name=segmentIDs,proto3" json:"segmentIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFlushStateRequest) Descriptor deprecated 

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

Deprecated: Use GetFlushStateRequest.ProtoReflect.Descriptor instead.

func (*GetFlushStateRequest) GetSegmentIDs 

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

func (*GetFlushStateRequest) ProtoMessage 

func (*GetFlushStateRequest) ProtoMessage()

func (*GetFlushStateRequest) ProtoReflect added in v2.1.0 

func (x *GetFlushStateRequest) ProtoReflect() protoreflect.Message

func (*GetFlushStateRequest) Reset 

func (x *GetFlushStateRequest) Reset()

func (*GetFlushStateRequest) String 

func (x *GetFlushStateRequest) String() string

type GetFlushStateResponse 

type GetFlushStateResponse struct {
	Status  *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Flushed bool           `protobuf:"varint,2,opt,name=flushed,proto3" json:"flushed,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFlushStateResponse) Descriptor deprecated 

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

Deprecated: Use GetFlushStateResponse.ProtoReflect.Descriptor instead.

func (*GetFlushStateResponse) GetFlushed 

func (x *GetFlushStateResponse) GetFlushed() bool

func (*GetFlushStateResponse) GetStatus 

func (x *GetFlushStateResponse) GetStatus() *common.Status

func (*GetFlushStateResponse) ProtoMessage 

func (*GetFlushStateResponse) ProtoMessage()

func (*GetFlushStateResponse) ProtoReflect added in v2.1.0 

func (x *GetFlushStateResponse) ProtoReflect() protoreflect.Message

func (*GetFlushStateResponse) Reset 

func (x *GetFlushStateResponse) Reset()

func (*GetFlushStateResponse) String 

func (x *GetFlushStateResponse) String() string

type GetImportStateRequest added in v2.1.0 

type GetImportStateRequest struct {
	Task int64 `protobuf:"varint,1,opt,name=task,proto3" json:"task,omitempty"` // id of an import task
	// contains filtered or unexported fields
}

func (*GetImportStateRequest) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use GetImportStateRequest.ProtoReflect.Descriptor instead.

func (*GetImportStateRequest) GetTask added in v2.1.0 

func (x *GetImportStateRequest) GetTask() int64

func (*GetImportStateRequest) ProtoMessage added in v2.1.0 

func (*GetImportStateRequest) ProtoMessage()

func (*GetImportStateRequest) ProtoReflect added in v2.1.0 

func (x *GetImportStateRequest) ProtoReflect() protoreflect.Message

func (*GetImportStateRequest) Reset added in v2.1.0 

func (x *GetImportStateRequest) Reset()

func (*GetImportStateRequest) String added in v2.1.0 

func (x *GetImportStateRequest) String() string

type GetImportStateResponse added in v2.1.0 

type GetImportStateResponse struct {
	Status        *common.Status         `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	State         common.ImportState     `protobuf:"varint,2,opt,name=state,proto3,enum=milvus.proto.common.ImportState" json:"state,omitempty"` // is this import task finished or not
	RowCount      int64                  `protobuf:"varint,3,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`                // if the task is finished, this value is how many rows are imported. if the task is not finished, this value is how many rows are parsed. return 0 if failed.
	IdList        []int64                `protobuf:"varint,4,rep,packed,name=id_list,json=idList,proto3" json:"id_list,omitempty"`               // auto generated ids if the primary key is autoid
	Infos         []*common.KeyValuePair `protobuf:"bytes,5,rep,name=infos,proto3" json:"infos,omitempty"`                                       // more information about the task, progress percent, file path, failed reason, etc.
	Id            int64                  `protobuf:"varint,6,opt,name=id,proto3" json:"id,omitempty"`                                            // id of an import task
	DataQueryable bool                   `protobuf:"varint,7,opt,name=data_queryable,json=dataQueryable,proto3" json:"data_queryable,omitempty"` // A flag indicating whether import data are queryable (i.e. loaded in query nodes)
	DataIndexed   bool                   `protobuf:"varint,8,opt,name=data_indexed,json=dataIndexed,proto3" json:"data_indexed,omitempty"`       // A flag indicating whether import data are indexed.
	// contains filtered or unexported fields
}

func (*GetImportStateResponse) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use GetImportStateResponse.ProtoReflect.Descriptor instead.

func (*GetImportStateResponse) GetDataIndexed added in v2.1.0 

func (x *GetImportStateResponse) GetDataIndexed() bool

func (*GetImportStateResponse) GetDataQueryable added in v2.1.0 

func (x *GetImportStateResponse) GetDataQueryable() bool

func (*GetImportStateResponse) GetId added in v2.1.0 

func (x *GetImportStateResponse) GetId() int64

func (*GetImportStateResponse) GetIdList added in v2.1.0 

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

func (*GetImportStateResponse) GetInfos added in v2.1.0 

func (x *GetImportStateResponse) GetInfos() []*common.KeyValuePair

func (*GetImportStateResponse) GetRowCount added in v2.1.0 

func (x *GetImportStateResponse) GetRowCount() int64

func (*GetImportStateResponse) GetState added in v2.1.0 

func (x *GetImportStateResponse) GetState() common.ImportState

func (*GetImportStateResponse) GetStatus added in v2.1.0 

func (x *GetImportStateResponse) GetStatus() *common.Status

func (*GetImportStateResponse) ProtoMessage added in v2.1.0 

func (*GetImportStateResponse) ProtoMessage()

func (*GetImportStateResponse) ProtoReflect added in v2.1.0 

func (x *GetImportStateResponse) ProtoReflect() protoreflect.Message

func (*GetImportStateResponse) Reset added in v2.1.0 

func (x *GetImportStateResponse) Reset()

func (*GetImportStateResponse) String added in v2.1.0 

func (x *GetImportStateResponse) String() string

type GetIndexBuildProgressRequest 

type GetIndexBuildProgressRequest struct {

	// Not useful for now
	Base *common.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"`
	// contains filtered or unexported fields
}

Get index building progress

func (*GetIndexBuildProgressRequest) Descriptor deprecated 

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

Deprecated: Use GetIndexBuildProgressRequest.ProtoReflect.Descriptor instead.

func (*GetIndexBuildProgressRequest) GetBase 

func (x *GetIndexBuildProgressRequest) GetBase() *common.MsgBase

func (*GetIndexBuildProgressRequest) GetCollectionName 

func (x *GetIndexBuildProgressRequest) GetCollectionName() string

func (*GetIndexBuildProgressRequest) GetDbName 

func (x *GetIndexBuildProgressRequest) GetDbName() string

func (*GetIndexBuildProgressRequest) GetFieldName 

func (x *GetIndexBuildProgressRequest) GetFieldName() string

func (*GetIndexBuildProgressRequest) GetIndexName 

func (x *GetIndexBuildProgressRequest) GetIndexName() string

func (*GetIndexBuildProgressRequest) ProtoMessage 

func (*GetIndexBuildProgressRequest) ProtoMessage()

func (*GetIndexBuildProgressRequest) ProtoReflect added in v2.1.0 

func (x *GetIndexBuildProgressRequest) ProtoReflect() protoreflect.Message

func (*GetIndexBuildProgressRequest) Reset 

func (x *GetIndexBuildProgressRequest) Reset()

func (*GetIndexBuildProgressRequest) String 

func (x *GetIndexBuildProgressRequest) String() string

type GetIndexBuildProgressResponse 

type GetIndexBuildProgressResponse struct {
	Status      *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	IndexedRows int64          `protobuf:"varint,2,opt,name=indexed_rows,json=indexedRows,proto3" json:"indexed_rows,omitempty"`
	TotalRows   int64          `protobuf:"varint,3,opt,name=total_rows,json=totalRows,proto3" json:"total_rows,omitempty"`
	// contains filtered or unexported fields
}

func (*GetIndexBuildProgressResponse) Descriptor deprecated 

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

Deprecated: Use GetIndexBuildProgressResponse.ProtoReflect.Descriptor instead.

func (*GetIndexBuildProgressResponse) GetIndexedRows 

func (x *GetIndexBuildProgressResponse) GetIndexedRows() int64

func (*GetIndexBuildProgressResponse) GetStatus 

func (x *GetIndexBuildProgressResponse) GetStatus() *common.Status

func (*GetIndexBuildProgressResponse) GetTotalRows 

func (x *GetIndexBuildProgressResponse) GetTotalRows() int64

func (*GetIndexBuildProgressResponse) ProtoMessage 

func (*GetIndexBuildProgressResponse) ProtoMessage()

func (*GetIndexBuildProgressResponse) ProtoReflect added in v2.1.0 

func (x *GetIndexBuildProgressResponse) ProtoReflect() protoreflect.Message

func (*GetIndexBuildProgressResponse) Reset 

func (x *GetIndexBuildProgressResponse) Reset()

func (*GetIndexBuildProgressResponse) String 

func (x *GetIndexBuildProgressResponse) String() string

type GetIndexStateRequest 

type GetIndexStateRequest struct {
	Base           *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"` // must
	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"` // must
	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"` // No need to set up for now @2021.06.30
	// contains filtered or unexported fields
}

func (*GetIndexStateRequest) Descriptor deprecated 

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

Deprecated: Use GetIndexStateRequest.ProtoReflect.Descriptor instead.

func (*GetIndexStateRequest) GetBase 

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

func (*GetIndexStateRequest) GetCollectionName 

func (x *GetIndexStateRequest) GetCollectionName() string

func (*GetIndexStateRequest) GetDbName 

func (x *GetIndexStateRequest) GetDbName() string

func (*GetIndexStateRequest) GetFieldName 

func (x *GetIndexStateRequest) GetFieldName() string

func (*GetIndexStateRequest) GetIndexName 

func (x *GetIndexStateRequest) GetIndexName() string

func (*GetIndexStateRequest) ProtoMessage 

func (*GetIndexStateRequest) ProtoMessage()

func (*GetIndexStateRequest) ProtoReflect added in v2.1.0 

func (x *GetIndexStateRequest) ProtoReflect() protoreflect.Message

func (*GetIndexStateRequest) Reset 

func (x *GetIndexStateRequest) Reset()

func (*GetIndexStateRequest) String 

func (x *GetIndexStateRequest) String() string

type GetIndexStateResponse 

type GetIndexStateResponse struct {
	Status     *common.Status    `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	State      common.IndexState `protobuf:"varint,2,opt,name=state,proto3,enum=milvus.proto.common.IndexState" json:"state,omitempty"`
	FailReason string            `protobuf:"bytes,3,opt,name=fail_reason,json=failReason,proto3" json:"fail_reason,omitempty"`
	// contains filtered or unexported fields
}

func (*GetIndexStateResponse) Descriptor deprecated 

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

Deprecated: Use GetIndexStateResponse.ProtoReflect.Descriptor instead.

func (*GetIndexStateResponse) GetFailReason 

func (x *GetIndexStateResponse) GetFailReason() string

func (*GetIndexStateResponse) GetState 

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

func (*GetIndexStateResponse) GetStatus 

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

func (*GetIndexStateResponse) ProtoMessage 

func (*GetIndexStateResponse) ProtoMessage()

func (*GetIndexStateResponse) ProtoReflect added in v2.1.0 

func (x *GetIndexStateResponse) ProtoReflect() protoreflect.Message

func (*GetIndexStateResponse) Reset 

func (x *GetIndexStateResponse) Reset()

func (*GetIndexStateResponse) String 

func (x *GetIndexStateResponse) String() string

type GetMetricsRequest 

type GetMetricsRequest struct {
	Base    *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	Request string          `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"` // request is of jsonic format
	// contains filtered or unexported fields
}

func (*GetMetricsRequest) Descriptor deprecated 

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

Deprecated: Use GetMetricsRequest.ProtoReflect.Descriptor instead.

func (*GetMetricsRequest) GetBase 

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

func (*GetMetricsRequest) GetRequest 

func (x *GetMetricsRequest) GetRequest() string

func (*GetMetricsRequest) ProtoMessage 

func (*GetMetricsRequest) ProtoMessage()

func (*GetMetricsRequest) ProtoReflect added in v2.1.0 

func (x *GetMetricsRequest) ProtoReflect() protoreflect.Message

func (*GetMetricsRequest) Reset 

func (x *GetMetricsRequest) Reset()

func (*GetMetricsRequest) String 

func (x *GetMetricsRequest) String() string

type GetMetricsResponse 

type GetMetricsResponse struct {
	Status        *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Response      string         `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`                                // response is of jsonic format
	ComponentName string         `protobuf:"bytes,3,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"` // metrics from which component
	// contains filtered or unexported fields
}

func (*GetMetricsResponse) Descriptor deprecated 

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

Deprecated: Use GetMetricsResponse.ProtoReflect.Descriptor instead.

func (*GetMetricsResponse) GetComponentName 

func (x *GetMetricsResponse) GetComponentName() string

func (*GetMetricsResponse) GetResponse 

func (x *GetMetricsResponse) GetResponse() string

func (*GetMetricsResponse) GetStatus 

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

func (*GetMetricsResponse) ProtoMessage 

func (*GetMetricsResponse) ProtoMessage()

func (*GetMetricsResponse) ProtoReflect added in v2.1.0 

func (x *GetMetricsResponse) ProtoReflect() protoreflect.Message

func (*GetMetricsResponse) Reset 

func (x *GetMetricsResponse) Reset()

func (*GetMetricsResponse) String 

func (x *GetMetricsResponse) String() string

type GetPartitionStatisticsRequest 

type GetPartitionStatisticsRequest struct {

	// Not useful for now
	Base *common.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"`
	// contains filtered or unexported fields
}

Get partition statistics like row_count.

func (*GetPartitionStatisticsRequest) Descriptor deprecated 

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

Deprecated: Use GetPartitionStatisticsRequest.ProtoReflect.Descriptor instead.

func (*GetPartitionStatisticsRequest) GetBase 

func (x *GetPartitionStatisticsRequest) GetBase() *common.MsgBase

func (*GetPartitionStatisticsRequest) GetCollectionName 

func (x *GetPartitionStatisticsRequest) GetCollectionName() string

func (*GetPartitionStatisticsRequest) GetDbName 

func (x *GetPartitionStatisticsRequest) GetDbName() string

func (*GetPartitionStatisticsRequest) GetPartitionName 

func (x *GetPartitionStatisticsRequest) GetPartitionName() string

func (*GetPartitionStatisticsRequest) ProtoMessage 

func (*GetPartitionStatisticsRequest) ProtoMessage()

func (*GetPartitionStatisticsRequest) ProtoReflect added in v2.1.0 

func (x *GetPartitionStatisticsRequest) ProtoReflect() protoreflect.Message

func (*GetPartitionStatisticsRequest) Reset 

func (x *GetPartitionStatisticsRequest) Reset()

func (*GetPartitionStatisticsRequest) String 

func (x *GetPartitionStatisticsRequest) String() string

type GetPartitionStatisticsResponse 

type GetPartitionStatisticsResponse struct {
	Status *common.Status         `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Stats  []*common.KeyValuePair `protobuf:"bytes,2,rep,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPartitionStatisticsResponse) Descriptor deprecated 

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

Deprecated: Use GetPartitionStatisticsResponse.ProtoReflect.Descriptor instead.

func (*GetPartitionStatisticsResponse) GetStats 

func (x *GetPartitionStatisticsResponse) GetStats() []*common.KeyValuePair

func (*GetPartitionStatisticsResponse) GetStatus 

func (x *GetPartitionStatisticsResponse) GetStatus() *common.Status

func (*GetPartitionStatisticsResponse) ProtoMessage 

func (*GetPartitionStatisticsResponse) ProtoMessage()

func (*GetPartitionStatisticsResponse) ProtoReflect added in v2.1.0 

func (x *GetPartitionStatisticsResponse) ProtoReflect() protoreflect.Message

func (*GetPartitionStatisticsResponse) Reset 

func (x *GetPartitionStatisticsResponse) Reset()

func (*GetPartitionStatisticsResponse) String 

func (x *GetPartitionStatisticsResponse) String() string

type GetPersistentSegmentInfoRequest 

type GetPersistentSegmentInfoRequest struct {
	Base           *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"` // must
	DbName         string          `protobuf:"bytes,2,opt,name=dbName,proto3" json:"dbName,omitempty"`
	CollectionName string          `protobuf:"bytes,3,opt,name=collectionName,proto3" json:"collectionName,omitempty"` // must
	// contains filtered or unexported fields
}

func (*GetPersistentSegmentInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetPersistentSegmentInfoRequest.ProtoReflect.Descriptor instead.

func (*GetPersistentSegmentInfoRequest) GetBase 

func (x *GetPersistentSegmentInfoRequest) GetBase() *common.MsgBase

func (*GetPersistentSegmentInfoRequest) GetCollectionName 

func (x *GetPersistentSegmentInfoRequest) GetCollectionName() string

func (*GetPersistentSegmentInfoRequest) GetDbName 

func (x *GetPersistentSegmentInfoRequest) GetDbName() string

func (*GetPersistentSegmentInfoRequest) ProtoMessage 

func (*GetPersistentSegmentInfoRequest) ProtoMessage()

func (*GetPersistentSegmentInfoRequest) ProtoReflect added in v2.1.0 

func (x *GetPersistentSegmentInfoRequest) ProtoReflect() protoreflect.Message

func (*GetPersistentSegmentInfoRequest) Reset 

func (x *GetPersistentSegmentInfoRequest) Reset()

func (*GetPersistentSegmentInfoRequest) String 

func (x *GetPersistentSegmentInfoRequest) String() string

type GetPersistentSegmentInfoResponse 

type GetPersistentSegmentInfoResponse struct {
	Status *common.Status           `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Infos  []*PersistentSegmentInfo `protobuf:"bytes,2,rep,name=infos,proto3" json:"infos,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPersistentSegmentInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetPersistentSegmentInfoResponse.ProtoReflect.Descriptor instead.

func (*GetPersistentSegmentInfoResponse) GetInfos 

func (x *GetPersistentSegmentInfoResponse) GetInfos() []*PersistentSegmentInfo

func (*GetPersistentSegmentInfoResponse) GetStatus 

func (x *GetPersistentSegmentInfoResponse) GetStatus() *common.Status

func (*GetPersistentSegmentInfoResponse) ProtoMessage 

func (*GetPersistentSegmentInfoResponse) ProtoMessage()

func (*GetPersistentSegmentInfoResponse) ProtoReflect added in v2.1.0 

func (x *GetPersistentSegmentInfoResponse) ProtoReflect() protoreflect.Message

func (*GetPersistentSegmentInfoResponse) Reset 

func (x *GetPersistentSegmentInfoResponse) Reset()

func (*GetPersistentSegmentInfoResponse) String 

func (x *GetPersistentSegmentInfoResponse) String() string

type GetQuerySegmentInfoRequest 

type GetQuerySegmentInfoRequest struct {
	Base           *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"` // must
	DbName         string          `protobuf:"bytes,2,opt,name=dbName,proto3" json:"dbName,omitempty"`
	CollectionName string          `protobuf:"bytes,3,opt,name=collectionName,proto3" json:"collectionName,omitempty"` // must
	// contains filtered or unexported fields
}

func (*GetQuerySegmentInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetQuerySegmentInfoRequest.ProtoReflect.Descriptor instead.

func (*GetQuerySegmentInfoRequest) GetBase 

func (x *GetQuerySegmentInfoRequest) GetBase() *common.MsgBase

func (*GetQuerySegmentInfoRequest) GetCollectionName 

func (x *GetQuerySegmentInfoRequest) GetCollectionName() string

func (*GetQuerySegmentInfoRequest) GetDbName 

func (x *GetQuerySegmentInfoRequest) GetDbName() string

func (*GetQuerySegmentInfoRequest) ProtoMessage 

func (*GetQuerySegmentInfoRequest) ProtoMessage()

func (*GetQuerySegmentInfoRequest) ProtoReflect added in v2.1.0 

func (x *GetQuerySegmentInfoRequest) ProtoReflect() protoreflect.Message

func (*GetQuerySegmentInfoRequest) Reset 

func (x *GetQuerySegmentInfoRequest) Reset()

func (*GetQuerySegmentInfoRequest) String 

func (x *GetQuerySegmentInfoRequest) String() string

type GetQuerySegmentInfoResponse 

type GetQuerySegmentInfoResponse struct {
	Status *common.Status      `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Infos  []*QuerySegmentInfo `protobuf:"bytes,2,rep,name=infos,proto3" json:"infos,omitempty"`
	// contains filtered or unexported fields
}

func (*GetQuerySegmentInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetQuerySegmentInfoResponse.ProtoReflect.Descriptor instead.

func (*GetQuerySegmentInfoResponse) GetInfos 

func (x *GetQuerySegmentInfoResponse) GetInfos() []*QuerySegmentInfo

func (*GetQuerySegmentInfoResponse) GetStatus 

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

func (*GetQuerySegmentInfoResponse) ProtoMessage 

func (*GetQuerySegmentInfoResponse) ProtoMessage()

func (*GetQuerySegmentInfoResponse) ProtoReflect added in v2.1.0 

func (x *GetQuerySegmentInfoResponse) ProtoReflect() protoreflect.Message

func (*GetQuerySegmentInfoResponse) Reset 

func (x *GetQuerySegmentInfoResponse) Reset()

func (*GetQuerySegmentInfoResponse) String 

func (x *GetQuerySegmentInfoResponse) String() string

type GetReplicasRequest added in v2.1.0 

type GetReplicasRequest struct {
	Base           *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	CollectionID   int64           `protobuf:"varint,2,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	WithShardNodes bool            `protobuf:"varint,3,opt,name=with_shard_nodes,json=withShardNodes,proto3" json:"with_shard_nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*GetReplicasRequest) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use GetReplicasRequest.ProtoReflect.Descriptor instead.

func (*GetReplicasRequest) GetBase added in v2.1.0 

func (x *GetReplicasRequest) GetBase() *common.MsgBase

func (*GetReplicasRequest) GetCollectionID added in v2.1.0 

func (x *GetReplicasRequest) GetCollectionID() int64

func (*GetReplicasRequest) GetWithShardNodes added in v2.1.0 

func (x *GetReplicasRequest) GetWithShardNodes() bool

func (*GetReplicasRequest) ProtoMessage added in v2.1.0 

func (*GetReplicasRequest) ProtoMessage()

func (*GetReplicasRequest) ProtoReflect added in v2.1.0 

func (x *GetReplicasRequest) ProtoReflect() protoreflect.Message

func (*GetReplicasRequest) Reset added in v2.1.0 

func (x *GetReplicasRequest) Reset()

func (*GetReplicasRequest) String added in v2.1.0 

func (x *GetReplicasRequest) String() string

type GetReplicasResponse added in v2.1.0 

type GetReplicasResponse struct {
	Status   *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Replicas []*ReplicaInfo `protobuf:"bytes,2,rep,name=replicas,proto3" json:"replicas,omitempty"`
	// contains filtered or unexported fields
}

func (*GetReplicasResponse) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use GetReplicasResponse.ProtoReflect.Descriptor instead.

func (*GetReplicasResponse) GetReplicas added in v2.1.0 

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

func (*GetReplicasResponse) GetStatus added in v2.1.0 

func (x *GetReplicasResponse) GetStatus() *common.Status

func (*GetReplicasResponse) ProtoMessage added in v2.1.0 

func (*GetReplicasResponse) ProtoMessage()

func (*GetReplicasResponse) ProtoReflect added in v2.1.0 

func (x *GetReplicasResponse) ProtoReflect() protoreflect.Message

func (*GetReplicasResponse) Reset added in v2.1.0 

func (x *GetReplicasResponse) Reset()

func (*GetReplicasResponse) String added in v2.1.0 

func (x *GetReplicasResponse) String() string

type GrantEntity added in v2.1.0 

type GrantEntity struct {

	// principal
	Principal *PrincipalEntity `protobuf:"bytes,1,opt,name=principal,proto3" json:"principal,omitempty"`
	// resource
	Resource *ResourceEntity `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource,omitempty"`
	// resource name
	ResourceName string `protobuf:"bytes,3,opt,name=resource_name,json=resourceName,proto3" json:"resource_name,omitempty"`
	// privilege
	Grantor *GrantorEntity `protobuf:"bytes,4,opt,name=grantor,proto3" json:"grantor,omitempty"`
	// contains filtered or unexported fields
}

func (*GrantEntity) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use GrantEntity.ProtoReflect.Descriptor instead.

func (*GrantEntity) GetGrantor added in v2.1.0 

func (x *GrantEntity) GetGrantor() *GrantorEntity

func (*GrantEntity) GetPrincipal added in v2.1.0 

func (x *GrantEntity) GetPrincipal() *PrincipalEntity

func (*GrantEntity) GetResource added in v2.1.0 

func (x *GrantEntity) GetResource() *ResourceEntity

func (*GrantEntity) GetResourceName added in v2.1.0 

func (x *GrantEntity) GetResourceName() string

func (*GrantEntity) ProtoMessage added in v2.1.0 

func (*GrantEntity) ProtoMessage()

func (*GrantEntity) ProtoReflect added in v2.1.0 

func (x *GrantEntity) ProtoReflect() protoreflect.Message

func (*GrantEntity) Reset added in v2.1.0 

func (x *GrantEntity) Reset()

func (*GrantEntity) String added in v2.1.0 

func (x *GrantEntity) String() string

type GrantorEntity added in v2.1.0 

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"`
	// contains filtered or unexported fields
}

func (*GrantorEntity) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use GrantorEntity.ProtoReflect.Descriptor instead.

func (*GrantorEntity) GetPrivilege added in v2.1.0 

func (x *GrantorEntity) GetPrivilege() *PrivilegeEntity

func (*GrantorEntity) GetUser added in v2.1.0 

func (x *GrantorEntity) GetUser() *UserEntity

func (*GrantorEntity) ProtoMessage added in v2.1.0 

func (*GrantorEntity) ProtoMessage()

func (*GrantorEntity) ProtoReflect added in v2.1.0 

func (x *GrantorEntity) ProtoReflect() protoreflect.Message

func (*GrantorEntity) Reset added in v2.1.0 

func (x *GrantorEntity) Reset()

func (*GrantorEntity) String added in v2.1.0 

func (x *GrantorEntity) String() string

type HasCollectionRequest 

type HasCollectionRequest struct {

	// Not useful for now
	Base *common.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"`
	// contains filtered or unexported fields
}

* Check collection exist in milvus or not.

func (*HasCollectionRequest) Descriptor deprecated 

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

Deprecated: Use HasCollectionRequest.ProtoReflect.Descriptor instead.

func (*HasCollectionRequest) GetBase 

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

func (*HasCollectionRequest) GetCollectionName 

func (x *HasCollectionRequest) GetCollectionName() string

func (*HasCollectionRequest) GetDbName 

func (x *HasCollectionRequest) GetDbName() string

func (*HasCollectionRequest) GetTimeStamp 

func (x *HasCollectionRequest) GetTimeStamp() uint64

func (*HasCollectionRequest) ProtoMessage 

func (*HasCollectionRequest) ProtoMessage()

func (*HasCollectionRequest) ProtoReflect added in v2.1.0 

func (x *HasCollectionRequest) ProtoReflect() protoreflect.Message

func (*HasCollectionRequest) Reset 

func (x *HasCollectionRequest) Reset()

func (*HasCollectionRequest) String 

func (x *HasCollectionRequest) String() string

type HasPartitionRequest 

type HasPartitionRequest struct {

	// Not useful for now
	Base *common.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"`
	// contains filtered or unexported fields
}

Check if partition exist in collection or not.

func (*HasPartitionRequest) Descriptor deprecated 

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

Deprecated: Use HasPartitionRequest.ProtoReflect.Descriptor instead.

func (*HasPartitionRequest) GetBase 

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

func (*HasPartitionRequest) GetCollectionName 

func (x *HasPartitionRequest) GetCollectionName() string

func (*HasPartitionRequest) GetDbName 

func (x *HasPartitionRequest) GetDbName() string

func (*HasPartitionRequest) GetPartitionName 

func (x *HasPartitionRequest) GetPartitionName() string

func (*HasPartitionRequest) ProtoMessage 

func (*HasPartitionRequest) ProtoMessage()

func (*HasPartitionRequest) ProtoReflect added in v2.1.0 

func (x *HasPartitionRequest) ProtoReflect() protoreflect.Message

func (*HasPartitionRequest) Reset 

func (x *HasPartitionRequest) Reset()

func (*HasPartitionRequest) String 

func (x *HasPartitionRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*Hits) Descriptor deprecated 

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

Deprecated: Use Hits.ProtoReflect.Descriptor instead.

func (*Hits) GetIDs 

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

func (*Hits) GetRowData 

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

func (*Hits) GetScores 

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

func (*Hits) ProtoMessage 

func (*Hits) ProtoMessage()

func (*Hits) ProtoReflect added in v2.1.0 

func (x *Hits) ProtoReflect() protoreflect.Message

func (*Hits) Reset 

func (x *Hits) Reset()

func (*Hits) String 

func (x *Hits) String() string

type ImportRequest added in v2.1.0 

type ImportRequest struct {
	CollectionName string                 `protobuf:"bytes,1,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"` // target collection
	PartitionName  string                 `protobuf:"bytes,2,opt,name=partition_name,json=partitionName,proto3" json:"partition_name,omitempty"`    // target partition
	ChannelNames   []string               `protobuf:"bytes,3,rep,name=channel_names,json=channelNames,proto3" json:"channel_names,omitempty"`       // channel names for the collection
	RowBased       bool                   `protobuf:"varint,4,opt,name=row_based,json=rowBased,proto3" json:"row_based,omitempty"`                  // the file is row-based or column-based
	Files          []string               `protobuf:"bytes,5,rep,name=files,proto3" json:"files,omitempty"`                                         // file paths to be imported
	Options        []*common.KeyValuePair `protobuf:"bytes,6,rep,name=options,proto3" json:"options,omitempty"`                                     // import options, bucket, etc.
	// contains filtered or unexported fields
}

func (*ImportRequest) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use ImportRequest.ProtoReflect.Descriptor instead.

func (*ImportRequest) GetChannelNames added in v2.1.0 

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

func (*ImportRequest) GetCollectionName added in v2.1.0 

func (x *ImportRequest) GetCollectionName() string

func (*ImportRequest) GetFiles added in v2.1.0 

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

func (*ImportRequest) GetOptions added in v2.1.0 

func (x *ImportRequest) GetOptions() []*common.KeyValuePair

func (*ImportRequest) GetPartitionName added in v2.1.0 

func (x *ImportRequest) GetPartitionName() string

func (*ImportRequest) GetRowBased added in v2.1.0 

func (x *ImportRequest) GetRowBased() bool

func (*ImportRequest) ProtoMessage added in v2.1.0 

func (*ImportRequest) ProtoMessage()

func (*ImportRequest) ProtoReflect added in v2.1.0 

func (x *ImportRequest) ProtoReflect() protoreflect.Message

func (*ImportRequest) Reset added in v2.1.0 

func (x *ImportRequest) Reset()

func (*ImportRequest) String added in v2.1.0 

func (x *ImportRequest) String() string

type ImportResponse added in v2.1.0 

type ImportResponse struct {
	Status *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Tasks  []int64        `protobuf:"varint,2,rep,packed,name=tasks,proto3" json:"tasks,omitempty"` // id array of import tasks
	// contains filtered or unexported fields
}

func (*ImportResponse) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use ImportResponse.ProtoReflect.Descriptor instead.

func (*ImportResponse) GetStatus added in v2.1.0 

func (x *ImportResponse) GetStatus() *common.Status

func (*ImportResponse) GetTasks added in v2.1.0 

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

func (*ImportResponse) ProtoMessage added in v2.1.0 

func (*ImportResponse) ProtoMessage()

func (*ImportResponse) ProtoReflect added in v2.1.0 

func (x *ImportResponse) ProtoReflect() protoreflect.Message

func (*ImportResponse) Reset added in v2.1.0 

func (x *ImportResponse) Reset()

func (*ImportResponse) String added in v2.1.0 

func (x *ImportResponse) String() string

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 []*common.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"`
	// contains filtered or unexported fields
}

Index informations

func (*IndexDescription) Descriptor deprecated 

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

Deprecated: Use IndexDescription.ProtoReflect.Descriptor instead.

func (*IndexDescription) GetFieldName 

func (x *IndexDescription) GetFieldName() string

func (*IndexDescription) GetIndexID 

func (x *IndexDescription) GetIndexID() int64

func (*IndexDescription) GetIndexName 

func (x *IndexDescription) GetIndexName() string

func (*IndexDescription) GetParams 

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

func (*IndexDescription) ProtoMessage 

func (*IndexDescription) ProtoMessage()

func (*IndexDescription) ProtoReflect added in v2.1.0 

func (x *IndexDescription) ProtoReflect() protoreflect.Message

func (*IndexDescription) Reset 

func (x *IndexDescription) Reset()

func (*IndexDescription) String 

func (x *IndexDescription) String() string

type InsertRequest 

type InsertRequest struct {
	Base           *common.MsgBase     `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName         string              `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName string              `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	PartitionName  string              `protobuf:"bytes,4,opt,name=partition_name,json=partitionName,proto3" json:"partition_name,omitempty"`
	FieldsData     []*schema.FieldData `protobuf:"bytes,5,rep,name=fields_data,json=fieldsData,proto3" json:"fields_data,omitempty"`
	HashKeys       []uint32            `protobuf:"varint,6,rep,packed,name=hash_keys,json=hashKeys,proto3" json:"hash_keys,omitempty"`
	NumRows        uint32              `protobuf:"varint,7,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
	// contains filtered or unexported fields
}

func (*InsertRequest) Descriptor deprecated 

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

Deprecated: Use InsertRequest.ProtoReflect.Descriptor instead.

func (*InsertRequest) GetBase 

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

func (*InsertRequest) GetCollectionName 

func (x *InsertRequest) GetCollectionName() string

func (*InsertRequest) GetDbName 

func (x *InsertRequest) GetDbName() string

func (*InsertRequest) GetFieldsData 

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

func (*InsertRequest) GetHashKeys 

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

func (*InsertRequest) GetNumRows 

func (x *InsertRequest) GetNumRows() uint32

func (*InsertRequest) GetPartitionName 

func (x *InsertRequest) GetPartitionName() string

func (*InsertRequest) ProtoMessage 

func (*InsertRequest) ProtoMessage()

func (*InsertRequest) ProtoReflect added in v2.1.0 

func (x *InsertRequest) ProtoReflect() protoreflect.Message

func (*InsertRequest) Reset 

func (x *InsertRequest) Reset()

func (*InsertRequest) String 

func (x *InsertRequest) String() string

type ListCredUsersRequest added in v2.1.0 

type ListCredUsersRequest struct {

	// Not useful for now
	Base *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// contains filtered or unexported fields
}

func (*ListCredUsersRequest) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use ListCredUsersRequest.ProtoReflect.Descriptor instead.

func (*ListCredUsersRequest) GetBase added in v2.1.0 

func (x *ListCredUsersRequest) GetBase() *common.MsgBase

func (*ListCredUsersRequest) ProtoMessage added in v2.1.0 

func (*ListCredUsersRequest) ProtoMessage()

func (*ListCredUsersRequest) ProtoReflect added in v2.1.0 

func (x *ListCredUsersRequest) ProtoReflect() protoreflect.Message

func (*ListCredUsersRequest) Reset added in v2.1.0 

func (x *ListCredUsersRequest) Reset()

func (*ListCredUsersRequest) String added in v2.1.0 

func (x *ListCredUsersRequest) String() string

type ListCredUsersResponse added in v2.1.0 

type ListCredUsersResponse struct {

	// Contain error_code and reason
	Status *common.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"`
	// contains filtered or unexported fields
}

func (*ListCredUsersResponse) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use ListCredUsersResponse.ProtoReflect.Descriptor instead.

func (*ListCredUsersResponse) GetStatus added in v2.1.0 

func (x *ListCredUsersResponse) GetStatus() *common.Status

func (*ListCredUsersResponse) GetUsernames added in v2.1.0 

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

func (*ListCredUsersResponse) ProtoMessage added in v2.1.0 

func (*ListCredUsersResponse) ProtoMessage()

func (*ListCredUsersResponse) ProtoReflect added in v2.1.0 

func (x *ListCredUsersResponse) ProtoReflect() protoreflect.Message

func (*ListCredUsersResponse) Reset added in v2.1.0 

func (x *ListCredUsersResponse) Reset()

func (*ListCredUsersResponse) String added in v2.1.0 

func (x *ListCredUsersResponse) String() string

type ListImportTasksRequest added in v2.1.0 

type ListImportTasksRequest struct {
	// contains filtered or unexported fields
}

func (*ListImportTasksRequest) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use ListImportTasksRequest.ProtoReflect.Descriptor instead.

func (*ListImportTasksRequest) ProtoMessage added in v2.1.0 

func (*ListImportTasksRequest) ProtoMessage()

func (*ListImportTasksRequest) ProtoReflect added in v2.1.0 

func (x *ListImportTasksRequest) ProtoReflect() protoreflect.Message

func (*ListImportTasksRequest) Reset added in v2.1.0 

func (x *ListImportTasksRequest) Reset()

func (*ListImportTasksRequest) String added in v2.1.0 

func (x *ListImportTasksRequest) String() string

type ListImportTasksResponse added in v2.1.0 

type ListImportTasksResponse struct {
	Status *common.Status            `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Tasks  []*GetImportStateResponse `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty"` // list of all import tasks
	// contains filtered or unexported fields
}

func (*ListImportTasksResponse) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use ListImportTasksResponse.ProtoReflect.Descriptor instead.

func (*ListImportTasksResponse) GetStatus added in v2.1.0 

func (x *ListImportTasksResponse) GetStatus() *common.Status

func (*ListImportTasksResponse) GetTasks added in v2.1.0 

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

func (*ListImportTasksResponse) ProtoMessage added in v2.1.0 

func (*ListImportTasksResponse) ProtoMessage()

func (*ListImportTasksResponse) ProtoReflect added in v2.1.0 

func (x *ListImportTasksResponse) ProtoReflect() protoreflect.Message

func (*ListImportTasksResponse) Reset added in v2.1.0 

func (x *ListImportTasksResponse) Reset()

func (*ListImportTasksResponse) String added in v2.1.0 

func (x *ListImportTasksResponse) String() string

type LoadBalanceRequest 

type LoadBalanceRequest struct {
	Base             *common.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"`
	// contains filtered or unexported fields
}

Do load balancing operation from src_nodeID to dst_nodeID.

func (*LoadBalanceRequest) Descriptor deprecated 

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

Deprecated: Use LoadBalanceRequest.ProtoReflect.Descriptor instead.

func (*LoadBalanceRequest) GetBase 

func (x *LoadBalanceRequest) GetBase() *common.MsgBase

func (*LoadBalanceRequest) GetCollectionName added in v2.1.0 

func (x *LoadBalanceRequest) GetCollectionName() string

func (*LoadBalanceRequest) GetDstNodeIDs 

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

func (*LoadBalanceRequest) GetSealedSegmentIDs 

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

func (*LoadBalanceRequest) GetSrcNodeID 

func (x *LoadBalanceRequest) GetSrcNodeID() int64

func (*LoadBalanceRequest) ProtoMessage 

func (*LoadBalanceRequest) ProtoMessage()

func (*LoadBalanceRequest) ProtoReflect added in v2.1.0 

func (x *LoadBalanceRequest) ProtoReflect() protoreflect.Message

func (*LoadBalanceRequest) Reset 

func (x *LoadBalanceRequest) Reset()

func (*LoadBalanceRequest) String 

func (x *LoadBalanceRequest) String() string

type LoadCollectionRequest 

type LoadCollectionRequest struct {

	// Not useful for now
	Base *common.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"`
	// contains filtered or unexported fields
}

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

func (*LoadCollectionRequest) Descriptor deprecated 

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

Deprecated: Use LoadCollectionRequest.ProtoReflect.Descriptor instead.

func (*LoadCollectionRequest) GetBase 

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

func (*LoadCollectionRequest) GetCollectionName 

func (x *LoadCollectionRequest) GetCollectionName() string

func (*LoadCollectionRequest) GetDbName 

func (x *LoadCollectionRequest) GetDbName() string

func (*LoadCollectionRequest) GetReplicaNumber added in v2.1.0 

func (x *LoadCollectionRequest) GetReplicaNumber() int32

func (*LoadCollectionRequest) ProtoMessage 

func (*LoadCollectionRequest) ProtoMessage()

func (*LoadCollectionRequest) ProtoReflect added in v2.1.0 

func (x *LoadCollectionRequest) ProtoReflect() protoreflect.Message

func (*LoadCollectionRequest) Reset 

func (x *LoadCollectionRequest) Reset()

func (*LoadCollectionRequest) String 

func (x *LoadCollectionRequest) String() string

type LoadPartitionsRequest 

type LoadPartitionsRequest struct {

	// Not useful for now
	Base *common.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"`
	// contains filtered or unexported fields
}

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 deprecated 

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

Deprecated: Use LoadPartitionsRequest.ProtoReflect.Descriptor instead.

func (*LoadPartitionsRequest) GetBase 

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

func (*LoadPartitionsRequest) GetCollectionName 

func (x *LoadPartitionsRequest) GetCollectionName() string

func (*LoadPartitionsRequest) GetDbName 

func (x *LoadPartitionsRequest) GetDbName() string

func (*LoadPartitionsRequest) GetPartitionNames 

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

func (*LoadPartitionsRequest) GetReplicaNumber added in v2.1.0 

func (x *LoadPartitionsRequest) GetReplicaNumber() int32

func (*LoadPartitionsRequest) ProtoMessage 

func (*LoadPartitionsRequest) ProtoMessage()

func (*LoadPartitionsRequest) ProtoReflect added in v2.1.0 

func (x *LoadPartitionsRequest) ProtoReflect() protoreflect.Message

func (*LoadPartitionsRequest) Reset 

func (x *LoadPartitionsRequest) Reset()

func (*LoadPartitionsRequest) String 

func (x *LoadPartitionsRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*ManualCompactionRequest) Descriptor deprecated 

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

Deprecated: Use ManualCompactionRequest.ProtoReflect.Descriptor instead.

func (*ManualCompactionRequest) GetCollectionID 

func (x *ManualCompactionRequest) GetCollectionID() int64

func (*ManualCompactionRequest) GetTimetravel 

func (x *ManualCompactionRequest) GetTimetravel() uint64

func (*ManualCompactionRequest) ProtoMessage 

func (*ManualCompactionRequest) ProtoMessage()

func (*ManualCompactionRequest) ProtoReflect added in v2.1.0 

func (x *ManualCompactionRequest) ProtoReflect() protoreflect.Message

func (*ManualCompactionRequest) Reset 

func (x *ManualCompactionRequest) Reset()

func (*ManualCompactionRequest) String 

func (x *ManualCompactionRequest) String() string

type ManualCompactionResponse 

type ManualCompactionResponse struct {
	Status       *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	CompactionID int64          `protobuf:"varint,2,opt,name=compactionID,proto3" json:"compactionID,omitempty"`
	// contains filtered or unexported fields
}

func (*ManualCompactionResponse) Descriptor deprecated 

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

Deprecated: Use ManualCompactionResponse.ProtoReflect.Descriptor instead.

func (*ManualCompactionResponse) GetCompactionID 

func (x *ManualCompactionResponse) GetCompactionID() int64

func (*ManualCompactionResponse) GetStatus 

func (x *ManualCompactionResponse) GetStatus() *common.Status

func (*ManualCompactionResponse) ProtoMessage 

func (*ManualCompactionResponse) ProtoMessage()

func (*ManualCompactionResponse) ProtoReflect added in v2.1.0 

func (x *ManualCompactionResponse) ProtoReflect() protoreflect.Message

func (*ManualCompactionResponse) Reset 

func (x *ManualCompactionResponse) Reset()

func (*ManualCompactionResponse) String 

func (x *ManualCompactionResponse) String() string

type MilvusExt added in v2.1.0 

type MilvusExt struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*MilvusExt) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use MilvusExt.ProtoReflect.Descriptor instead.

func (*MilvusExt) GetVersion added in v2.1.0 

func (x *MilvusExt) GetVersion() string

func (*MilvusExt) ProtoMessage added in v2.1.0 

func (*MilvusExt) ProtoMessage()

func (*MilvusExt) ProtoReflect added in v2.1.0 

func (x *MilvusExt) ProtoReflect() protoreflect.Message

func (*MilvusExt) Reset added in v2.1.0 

func (x *MilvusExt) Reset()

func (*MilvusExt) String added in v2.1.0 

func (x *MilvusExt) String() string

type MilvusServiceClient 

type MilvusServiceClient interface {
	CreateCollection(ctx context.Context, in *CreateCollectionRequest, opts ...grpc.CallOption) (*common.Status, error)
	DropCollection(ctx context.Context, in *DropCollectionRequest, opts ...grpc.CallOption) (*common.Status, error)
	HasCollection(ctx context.Context, in *HasCollectionRequest, opts ...grpc.CallOption) (*BoolResponse, error)
	LoadCollection(ctx context.Context, in *LoadCollectionRequest, opts ...grpc.CallOption) (*common.Status, error)
	ReleaseCollection(ctx context.Context, in *ReleaseCollectionRequest, opts ...grpc.CallOption) (*common.Status, error)
	DescribeCollection(ctx context.Context, in *DescribeCollectionRequest, opts ...grpc.CallOption) (*DescribeCollectionResponse, error)
	GetCollectionStatistics(ctx context.Context, in *GetCollectionStatisticsRequest, opts ...grpc.CallOption) (*GetCollectionStatisticsResponse, error)
	ShowCollections(ctx context.Context, in *ShowCollectionsRequest, opts ...grpc.CallOption) (*ShowCollectionsResponse, error)
	CreatePartition(ctx context.Context, in *CreatePartitionRequest, opts ...grpc.CallOption) (*common.Status, error)
	DropPartition(ctx context.Context, in *DropPartitionRequest, opts ...grpc.CallOption) (*common.Status, error)
	HasPartition(ctx context.Context, in *HasPartitionRequest, opts ...grpc.CallOption) (*BoolResponse, error)
	LoadPartitions(ctx context.Context, in *LoadPartitionsRequest, opts ...grpc.CallOption) (*common.Status, error)
	ReleasePartitions(ctx context.Context, in *ReleasePartitionsRequest, opts ...grpc.CallOption) (*common.Status, error)
	GetPartitionStatistics(ctx context.Context, in *GetPartitionStatisticsRequest, opts ...grpc.CallOption) (*GetPartitionStatisticsResponse, error)
	ShowPartitions(ctx context.Context, in *ShowPartitionsRequest, opts ...grpc.CallOption) (*ShowPartitionsResponse, error)
	CreateAlias(ctx context.Context, in *CreateAliasRequest, opts ...grpc.CallOption) (*common.Status, error)
	DropAlias(ctx context.Context, in *DropAliasRequest, opts ...grpc.CallOption) (*common.Status, error)
	AlterAlias(ctx context.Context, in *AlterAliasRequest, opts ...grpc.CallOption) (*common.Status, error)
	CreateIndex(ctx context.Context, in *CreateIndexRequest, opts ...grpc.CallOption) (*common.Status, error)
	DescribeIndex(ctx context.Context, in *DescribeIndexRequest, opts ...grpc.CallOption) (*DescribeIndexResponse, error)
	GetIndexState(ctx context.Context, in *GetIndexStateRequest, opts ...grpc.CallOption) (*GetIndexStateResponse, error)
	GetIndexBuildProgress(ctx context.Context, in *GetIndexBuildProgressRequest, opts ...grpc.CallOption) (*GetIndexBuildProgressResponse, error)
	DropIndex(ctx context.Context, in *DropIndexRequest, opts ...grpc.CallOption) (*common.Status, error)
	Insert(ctx context.Context, in *InsertRequest, opts ...grpc.CallOption) (*MutationResult, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*MutationResult, error)
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResults, error)
	Flush(ctx context.Context, in *FlushRequest, opts ...grpc.CallOption) (*FlushResponse, error)
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResults, error)
	CalcDistance(ctx context.Context, in *CalcDistanceRequest, opts ...grpc.CallOption) (*CalcDistanceResults, error)
	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)
	LoadBalance(ctx context.Context, in *LoadBalanceRequest, opts ...grpc.CallOption) (*common.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) (*common.Status, error)
	UpdateCredential(ctx context.Context, in *UpdateCredentialRequest, opts ...grpc.CallOption) (*common.Status, error)
	DeleteCredential(ctx context.Context, in *DeleteCredentialRequest, opts ...grpc.CallOption) (*common.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) (*common.Status, error)
	DropRole(ctx context.Context, in *DropRoleRequest, opts ...grpc.CallOption) (*common.Status, error)
	OperateUserRole(ctx context.Context, in *OperateUserRoleRequest, opts ...grpc.CallOption) (*common.Status, error)
	SelectRole(ctx context.Context, in *SelectRoleRequest, opts ...grpc.CallOption) (*SelectRoleResponse, error)
	SelectUser(ctx context.Context, in *SelectUserRequest, opts ...grpc.CallOption) (*SelectUserResponse, error)
	SelectResource(ctx context.Context, in *SelectResourceRequest, opts ...grpc.CallOption) (*SelectResourceResponse, error)
	OperatePrivilege(ctx context.Context, in *OperatePrivilegeRequest, opts ...grpc.CallOption) (*common.Status, error)
	SelectGrant(ctx context.Context, in *SelectGrantRequest, opts ...grpc.CallOption) (*SelectGrantResponse, 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.ClientConnInterface) MilvusServiceClient

type MilvusServiceServer 

type MilvusServiceServer interface {
	CreateCollection(context.Context, *CreateCollectionRequest) (*common.Status, error)
	DropCollection(context.Context, *DropCollectionRequest) (*common.Status, error)
	HasCollection(context.Context, *HasCollectionRequest) (*BoolResponse, error)
	LoadCollection(context.Context, *LoadCollectionRequest) (*common.Status, error)
	ReleaseCollection(context.Context, *ReleaseCollectionRequest) (*common.Status, error)
	DescribeCollection(context.Context, *DescribeCollectionRequest) (*DescribeCollectionResponse, error)
	GetCollectionStatistics(context.Context, *GetCollectionStatisticsRequest) (*GetCollectionStatisticsResponse, error)
	ShowCollections(context.Context, *ShowCollectionsRequest) (*ShowCollectionsResponse, error)
	CreatePartition(context.Context, *CreatePartitionRequest) (*common.Status, error)
	DropPartition(context.Context, *DropPartitionRequest) (*common.Status, error)
	HasPartition(context.Context, *HasPartitionRequest) (*BoolResponse, error)
	LoadPartitions(context.Context, *LoadPartitionsRequest) (*common.Status, error)
	ReleasePartitions(context.Context, *ReleasePartitionsRequest) (*common.Status, error)
	GetPartitionStatistics(context.Context, *GetPartitionStatisticsRequest) (*GetPartitionStatisticsResponse, error)
	ShowPartitions(context.Context, *ShowPartitionsRequest) (*ShowPartitionsResponse, error)
	CreateAlias(context.Context, *CreateAliasRequest) (*common.Status, error)
	DropAlias(context.Context, *DropAliasRequest) (*common.Status, error)
	AlterAlias(context.Context, *AlterAliasRequest) (*common.Status, error)
	CreateIndex(context.Context, *CreateIndexRequest) (*common.Status, error)
	DescribeIndex(context.Context, *DescribeIndexRequest) (*DescribeIndexResponse, error)
	GetIndexState(context.Context, *GetIndexStateRequest) (*GetIndexStateResponse, error)
	GetIndexBuildProgress(context.Context, *GetIndexBuildProgressRequest) (*GetIndexBuildProgressResponse, error)
	DropIndex(context.Context, *DropIndexRequest) (*common.Status, error)
	Insert(context.Context, *InsertRequest) (*MutationResult, error)
	Delete(context.Context, *DeleteRequest) (*MutationResult, error)
	Search(context.Context, *SearchRequest) (*SearchResults, error)
	Flush(context.Context, *FlushRequest) (*FlushResponse, error)
	Query(context.Context, *QueryRequest) (*QueryResults, error)
	CalcDistance(context.Context, *CalcDistanceRequest) (*CalcDistanceResults, error)
	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)
	LoadBalance(context.Context, *LoadBalanceRequest) (*common.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) (*common.Status, error)
	UpdateCredential(context.Context, *UpdateCredentialRequest) (*common.Status, error)
	DeleteCredential(context.Context, *DeleteCredentialRequest) (*common.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) (*common.Status, error)
	DropRole(context.Context, *DropRoleRequest) (*common.Status, error)
	OperateUserRole(context.Context, *OperateUserRoleRequest) (*common.Status, error)
	SelectRole(context.Context, *SelectRoleRequest) (*SelectRoleResponse, error)
	SelectUser(context.Context, *SelectUserRequest) (*SelectUserResponse, error)
	SelectResource(context.Context, *SelectResourceRequest) (*SelectResourceResponse, error)
	OperatePrivilege(context.Context, *OperatePrivilegeRequest) (*common.Status, error)
	SelectGrant(context.Context, *SelectGrantRequest) (*SelectGrantResponse, error)
}

MilvusServiceServer is the server API for MilvusService service.

type MutationResult 

type MutationResult struct {
	Status       *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	IDs          *schema.IDs    `protobuf:"bytes,2,opt,name=IDs,proto3" json:"IDs,omitempty"`                                      // required for insert, delete
	SuccIndex    []uint32       `protobuf:"varint,3,rep,packed,name=succ_index,json=succIndex,proto3" json:"succ_index,omitempty"` // error indexes indicate
	ErrIndex     []uint32       `protobuf:"varint,4,rep,packed,name=err_index,json=errIndex,proto3" json:"err_index,omitempty"`    // error indexes indicate
	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"`
	// contains filtered or unexported fields
}

func (*MutationResult) Descriptor deprecated 

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

Deprecated: Use MutationResult.ProtoReflect.Descriptor instead.

func (*MutationResult) GetAcknowledged 

func (x *MutationResult) GetAcknowledged() bool

func (*MutationResult) GetDeleteCnt 

func (x *MutationResult) GetDeleteCnt() int64

func (*MutationResult) GetErrIndex 

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

func (*MutationResult) GetIDs 

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

func (*MutationResult) GetInsertCnt 

func (x *MutationResult) GetInsertCnt() int64

func (*MutationResult) GetStatus 

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

func (*MutationResult) GetSuccIndex 

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

func (*MutationResult) GetTimestamp 

func (x *MutationResult) GetTimestamp() uint64

func (*MutationResult) GetUpsertCnt 

func (x *MutationResult) GetUpsertCnt() int64

func (*MutationResult) ProtoMessage 

func (*MutationResult) ProtoMessage()

func (*MutationResult) ProtoReflect added in v2.1.0 

func (x *MutationResult) ProtoReflect() protoreflect.Message

func (*MutationResult) Reset 

func (x *MutationResult) Reset()

func (*MutationResult) String 

func (x *MutationResult) String() string

type OperatePrivilegeRequest added in v2.1.0 

type OperatePrivilegeRequest struct {

	// Not useful for now
	Base *common.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"`
	// contains filtered or unexported fields
}

func (*OperatePrivilegeRequest) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use OperatePrivilegeRequest.ProtoReflect.Descriptor instead.

func (*OperatePrivilegeRequest) GetBase added in v2.1.0 

func (x *OperatePrivilegeRequest) GetBase() *common.MsgBase

func (*OperatePrivilegeRequest) GetEntity added in v2.1.0 

func (x *OperatePrivilegeRequest) GetEntity() *GrantEntity

func (*OperatePrivilegeRequest) GetType added in v2.1.0 

func (x *OperatePrivilegeRequest) GetType() OperatePrivilegeType

func (*OperatePrivilegeRequest) ProtoMessage added in v2.1.0 

func (*OperatePrivilegeRequest) ProtoMessage()

func (*OperatePrivilegeRequest) ProtoReflect added in v2.1.0 

func (x *OperatePrivilegeRequest) ProtoReflect() protoreflect.Message

func (*OperatePrivilegeRequest) Reset added in v2.1.0 

func (x *OperatePrivilegeRequest) Reset()

func (*OperatePrivilegeRequest) String added in v2.1.0 

func (x *OperatePrivilegeRequest) String() string

type OperatePrivilegeType added in v2.1.0 

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

func (OperatePrivilegeType) Descriptor added in v2.1.0 

func (OperatePrivilegeType) Descriptor() protoreflect.EnumDescriptor

func (OperatePrivilegeType) Enum added in v2.1.0 

func (x OperatePrivilegeType) Enum() *OperatePrivilegeType

func (OperatePrivilegeType) EnumDescriptor deprecated added in v2.1.0 

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

Deprecated: Use OperatePrivilegeType.Descriptor instead.

func (OperatePrivilegeType) Number added in v2.1.0 

func (x OperatePrivilegeType) Number() protoreflect.EnumNumber

func (OperatePrivilegeType) String added in v2.1.0 

func (x OperatePrivilegeType) String() string

func (OperatePrivilegeType) Type added in v2.1.0 

func (OperatePrivilegeType) Type() protoreflect.EnumType

type OperateUserRoleRequest added in v2.1.0 

type OperateUserRoleRequest struct {

	// Not useful for now
	Base *common.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"`
	// contains filtered or unexported fields
}

func (*OperateUserRoleRequest) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use OperateUserRoleRequest.ProtoReflect.Descriptor instead.

func (*OperateUserRoleRequest) GetBase added in v2.1.0 

func (x *OperateUserRoleRequest) GetBase() *common.MsgBase

func (*OperateUserRoleRequest) GetRoleName added in v2.1.0 

func (x *OperateUserRoleRequest) GetRoleName() string

func (*OperateUserRoleRequest) GetType added in v2.1.0 

func (x *OperateUserRoleRequest) GetType() OperateUserRoleType

func (*OperateUserRoleRequest) GetUsername added in v2.1.0 

func (x *OperateUserRoleRequest) GetUsername() string

func (*OperateUserRoleRequest) ProtoMessage added in v2.1.0 

func (*OperateUserRoleRequest) ProtoMessage()

func (*OperateUserRoleRequest) ProtoReflect added in v2.1.0 

func (x *OperateUserRoleRequest) ProtoReflect() protoreflect.Message

func (*OperateUserRoleRequest) Reset added in v2.1.0 

func (x *OperateUserRoleRequest) Reset()

func (*OperateUserRoleRequest) String added in v2.1.0 

func (x *OperateUserRoleRequest) String() string

type OperateUserRoleType added in v2.1.0 

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

func (OperateUserRoleType) Descriptor added in v2.1.0 

func (OperateUserRoleType) Descriptor() protoreflect.EnumDescriptor

func (OperateUserRoleType) Enum added in v2.1.0 

func (x OperateUserRoleType) Enum() *OperateUserRoleType

func (OperateUserRoleType) EnumDescriptor deprecated added in v2.1.0 

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

Deprecated: Use OperateUserRoleType.Descriptor instead.

func (OperateUserRoleType) Number added in v2.1.0 

func (x OperateUserRoleType) Number() protoreflect.EnumNumber

func (OperateUserRoleType) String added in v2.1.0 

func (x OperateUserRoleType) String() string

func (OperateUserRoleType) Type added in v2.1.0 

func (OperateUserRoleType) Type() protoreflect.EnumType

type PersistentSegmentInfo 

type PersistentSegmentInfo struct {
	SegmentID    int64               `protobuf:"varint,1,opt,name=segmentID,proto3" json:"segmentID,omitempty"`
	CollectionID int64               `protobuf:"varint,2,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionID  int64               `protobuf:"varint,3,opt,name=partitionID,proto3" json:"partitionID,omitempty"`
	NumRows      int64               `protobuf:"varint,4,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
	State        common.SegmentState `protobuf:"varint,5,opt,name=state,proto3,enum=milvus.proto.common.SegmentState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*PersistentSegmentInfo) Descriptor deprecated 

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

Deprecated: Use PersistentSegmentInfo.ProtoReflect.Descriptor instead.

func (*PersistentSegmentInfo) GetCollectionID 

func (x *PersistentSegmentInfo) GetCollectionID() int64

func (*PersistentSegmentInfo) GetNumRows 

func (x *PersistentSegmentInfo) GetNumRows() int64

func (*PersistentSegmentInfo) GetPartitionID 

func (x *PersistentSegmentInfo) GetPartitionID() int64

func (*PersistentSegmentInfo) GetSegmentID 

func (x *PersistentSegmentInfo) GetSegmentID() int64

func (*PersistentSegmentInfo) GetState 

func (x *PersistentSegmentInfo) GetState() common.SegmentState

func (*PersistentSegmentInfo) ProtoMessage 

func (*PersistentSegmentInfo) ProtoMessage()

func (*PersistentSegmentInfo) ProtoReflect added in v2.1.0 

func (x *PersistentSegmentInfo) ProtoReflect() protoreflect.Message

func (*PersistentSegmentInfo) Reset 

func (x *PersistentSegmentInfo) Reset()

func (*PersistentSegmentInfo) String 

func (x *PersistentSegmentInfo) String() string

type PrincipalEntity added in v2.1.0 

type PrincipalEntity struct {

	// principal type, including user, role
	PrincipalType string `protobuf:"bytes,1,opt,name=principal_type,json=principalType,proto3" json:"principal_type,omitempty"`
	// principal, including user entity or role entity
	//
	// Types that are assignable to Principal:
	//	*PrincipalEntity_User
	//	*PrincipalEntity_Role
	Principal isPrincipalEntity_Principal `protobuf_oneof:"principal"`
	// contains filtered or unexported fields
}

func (*PrincipalEntity) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use PrincipalEntity.ProtoReflect.Descriptor instead.

func (*PrincipalEntity) GetPrincipal added in v2.1.0 

func (m *PrincipalEntity) GetPrincipal() isPrincipalEntity_Principal

func (*PrincipalEntity) GetPrincipalType added in v2.1.0 

func (x *PrincipalEntity) GetPrincipalType() string

func (*PrincipalEntity) GetRole added in v2.1.0 

func (x *PrincipalEntity) GetRole() *RoleEntity

func (*PrincipalEntity) GetUser added in v2.1.0 

func (x *PrincipalEntity) GetUser() *UserEntity

func (*PrincipalEntity) ProtoMessage added in v2.1.0 

func (*PrincipalEntity) ProtoMessage()

func (*PrincipalEntity) ProtoReflect added in v2.1.0 

func (x *PrincipalEntity) ProtoReflect() protoreflect.Message

func (*PrincipalEntity) Reset added in v2.1.0 

func (x *PrincipalEntity) Reset()

func (*PrincipalEntity) String added in v2.1.0 

func (x *PrincipalEntity) String() string

type PrincipalEntity_Role added in v2.1.0 

type PrincipalEntity_Role struct {
	Role *RoleEntity `protobuf:"bytes,3,opt,name=role,proto3,oneof"`
}

type PrincipalEntity_User added in v2.1.0 

type PrincipalEntity_User struct {
	User *UserEntity `protobuf:"bytes,2,opt,name=user,proto3,oneof"`
}

type PrivilegeEntity added in v2.1.0 

type PrivilegeEntity struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*PrivilegeEntity) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use PrivilegeEntity.ProtoReflect.Descriptor instead.

func (*PrivilegeEntity) GetName added in v2.1.0 

func (x *PrivilegeEntity) GetName() string

func (*PrivilegeEntity) ProtoMessage added in v2.1.0 

func (*PrivilegeEntity) ProtoMessage()

func (*PrivilegeEntity) ProtoReflect added in v2.1.0 

func (x *PrivilegeEntity) ProtoReflect() protoreflect.Message

func (*PrivilegeEntity) Reset added in v2.1.0 

func (x *PrivilegeEntity) Reset()

func (*PrivilegeEntity) String added in v2.1.0 

func (x *PrivilegeEntity) String() string

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.ClientConnInterface) ProxyServiceClient

type ProxyServiceServer 

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

ProxyServiceServer is the server API for ProxyService service.

type QueryRequest 

type QueryRequest struct {
	Base               *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	DbName             string          `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	CollectionName     string          `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	Expr               string          `protobuf:"bytes,4,opt,name=expr,proto3" json:"expr,omitempty"`
	OutputFields       []string        `protobuf:"bytes,5,rep,name=output_fields,json=outputFields,proto3" json:"output_fields,omitempty"`
	PartitionNames     []string        `protobuf:"bytes,6,rep,name=partition_names,json=partitionNames,proto3" json:"partition_names,omitempty"`
	TravelTimestamp    uint64          `protobuf:"varint,7,opt,name=travel_timestamp,json=travelTimestamp,proto3" json:"travel_timestamp,omitempty"`
	GuaranteeTimestamp uint64          `protobuf:"varint,8,opt,name=guarantee_timestamp,json=guaranteeTimestamp,proto3" json:"guarantee_timestamp,omitempty"` // guarantee_timestamp
	// contains filtered or unexported fields
}

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetBase 

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

func (*QueryRequest) GetCollectionName 

func (x *QueryRequest) GetCollectionName() string

func (*QueryRequest) GetDbName 

func (x *QueryRequest) GetDbName() string

func (*QueryRequest) GetExpr 

func (x *QueryRequest) GetExpr() string

func (*QueryRequest) GetGuaranteeTimestamp 

func (x *QueryRequest) GetGuaranteeTimestamp() uint64

func (*QueryRequest) GetOutputFields 

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

func (*QueryRequest) GetPartitionNames 

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

func (*QueryRequest) GetTravelTimestamp 

func (x *QueryRequest) GetTravelTimestamp() uint64

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect added in v2.1.0 

func (x *QueryRequest) ProtoReflect() protoreflect.Message

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type QueryResults 

type QueryResults struct {
	Status         *common.Status      `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	FieldsData     []*schema.FieldData `protobuf:"bytes,2,rep,name=fields_data,json=fieldsData,proto3" json:"fields_data,omitempty"`
	CollectionName string              `protobuf:"bytes,3,opt,name=collection_name,json=collectionName,proto3" json:"collection_name,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryResults) Descriptor deprecated 

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

Deprecated: Use QueryResults.ProtoReflect.Descriptor instead.

func (*QueryResults) GetCollectionName added in v2.1.0 

func (x *QueryResults) GetCollectionName() string

func (*QueryResults) GetFieldsData 

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

func (*QueryResults) GetStatus 

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

func (*QueryResults) ProtoMessage 

func (*QueryResults) ProtoMessage()

func (*QueryResults) ProtoReflect added in v2.1.0 

func (x *QueryResults) ProtoReflect() protoreflect.Message

func (*QueryResults) Reset 

func (x *QueryResults) Reset()

func (*QueryResults) String 

func (x *QueryResults) String() string

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   common.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"`
	// contains filtered or unexported fields
}

func (*QuerySegmentInfo) Descriptor deprecated 

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

Deprecated: Use QuerySegmentInfo.ProtoReflect.Descriptor instead.

func (*QuerySegmentInfo) GetCollectionID 

func (x *QuerySegmentInfo) GetCollectionID() int64

func (*QuerySegmentInfo) GetIndexID 

func (x *QuerySegmentInfo) GetIndexID() int64

func (*QuerySegmentInfo) GetIndexName 

func (x *QuerySegmentInfo) GetIndexName() string

func (*QuerySegmentInfo) GetMemSize 

func (x *QuerySegmentInfo) GetMemSize() int64

func (*QuerySegmentInfo) GetNodeID 

func (x *QuerySegmentInfo) GetNodeID() int64

func (*QuerySegmentInfo) GetNodeIds added in v2.1.0 

func (x *QuerySegmentInfo) GetNodeIds() []int64

func (*QuerySegmentInfo) GetNumRows 

func (x *QuerySegmentInfo) GetNumRows() int64

func (*QuerySegmentInfo) GetPartitionID 

func (x *QuerySegmentInfo) GetPartitionID() int64

func (*QuerySegmentInfo) GetSegmentID 

func (x *QuerySegmentInfo) GetSegmentID() int64

func (*QuerySegmentInfo) GetState 

func (x *QuerySegmentInfo) GetState() common.SegmentState

func (*QuerySegmentInfo) ProtoMessage 

func (*QuerySegmentInfo) ProtoMessage()

func (*QuerySegmentInfo) ProtoReflect added in v2.1.0 

func (x *QuerySegmentInfo) ProtoReflect() protoreflect.Message

func (*QuerySegmentInfo) Reset 

func (x *QuerySegmentInfo) Reset()

func (*QuerySegmentInfo) String 

func (x *QuerySegmentInfo) String() string

type RegisterLinkRequest 

type RegisterLinkRequest struct {
	// contains filtered or unexported fields
}

func (*RegisterLinkRequest) Descriptor deprecated 

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

Deprecated: Use RegisterLinkRequest.ProtoReflect.Descriptor instead.

func (*RegisterLinkRequest) ProtoMessage 

func (*RegisterLinkRequest) ProtoMessage()

func (*RegisterLinkRequest) ProtoReflect added in v2.1.0 

func (x *RegisterLinkRequest) ProtoReflect() protoreflect.Message

func (*RegisterLinkRequest) Reset 

func (x *RegisterLinkRequest) Reset()

func (*RegisterLinkRequest) String 

func (x *RegisterLinkRequest) String() string

type RegisterLinkResponse 

type RegisterLinkResponse struct {
	Address *common.Address `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Status  *common.Status  `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterLinkResponse) Descriptor deprecated 

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

Deprecated: Use RegisterLinkResponse.ProtoReflect.Descriptor instead.

func (*RegisterLinkResponse) GetAddress 

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

func (*RegisterLinkResponse) GetStatus 

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

func (*RegisterLinkResponse) ProtoMessage 

func (*RegisterLinkResponse) ProtoMessage()

func (*RegisterLinkResponse) ProtoReflect added in v2.1.0 

func (x *RegisterLinkResponse) ProtoReflect() protoreflect.Message

func (*RegisterLinkResponse) Reset 

func (x *RegisterLinkResponse) Reset()

func (*RegisterLinkResponse) String 

func (x *RegisterLinkResponse) String() string

type ReleaseCollectionRequest 

type ReleaseCollectionRequest struct {

	// Not useful for now
	Base *common.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"`
	// contains filtered or unexported fields
}

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

func (*ReleaseCollectionRequest) Descriptor deprecated 

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

Deprecated: Use ReleaseCollectionRequest.ProtoReflect.Descriptor instead.

func (*ReleaseCollectionRequest) GetBase 

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

func (*ReleaseCollectionRequest) GetCollectionName 

func (x *ReleaseCollectionRequest) GetCollectionName() string

func (*ReleaseCollectionRequest) GetDbName 

func (x *ReleaseCollectionRequest) GetDbName() string

func (*ReleaseCollectionRequest) ProtoMessage 

func (*ReleaseCollectionRequest) ProtoMessage()

func (*ReleaseCollectionRequest) ProtoReflect added in v2.1.0 

func (x *ReleaseCollectionRequest) ProtoReflect() protoreflect.Message

func (*ReleaseCollectionRequest) Reset 

func (x *ReleaseCollectionRequest) Reset()

func (*ReleaseCollectionRequest) String 

func (x *ReleaseCollectionRequest) String() string

type ReleasePartitionsRequest 

type ReleasePartitionsRequest struct {

	// Not useful for now
	Base *common.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"`
	// contains filtered or unexported fields
}

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 deprecated 

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

Deprecated: Use ReleasePartitionsRequest.ProtoReflect.Descriptor instead.

func (*ReleasePartitionsRequest) GetBase 

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

func (*ReleasePartitionsRequest) GetCollectionName 

func (x *ReleasePartitionsRequest) GetCollectionName() string

func (*ReleasePartitionsRequest) GetDbName 

func (x *ReleasePartitionsRequest) GetDbName() string

func (*ReleasePartitionsRequest) GetPartitionNames 

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

func (*ReleasePartitionsRequest) ProtoMessage 

func (*ReleasePartitionsRequest) ProtoMessage()

func (*ReleasePartitionsRequest) ProtoReflect added in v2.1.0 

func (x *ReleasePartitionsRequest) ProtoReflect() protoreflect.Message

func (*ReleasePartitionsRequest) Reset 

func (x *ReleasePartitionsRequest) Reset()

func (*ReleasePartitionsRequest) String 

func (x *ReleasePartitionsRequest) String() string

type ReplicaInfo added in v2.1.0 

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"` // empty indicates to load collection
	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"` // include leaders
	// contains filtered or unexported fields
}

func (*ReplicaInfo) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use ReplicaInfo.ProtoReflect.Descriptor instead.

func (*ReplicaInfo) GetCollectionID added in v2.1.0 

func (x *ReplicaInfo) GetCollectionID() int64

func (*ReplicaInfo) GetNodeIds added in v2.1.0 

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

func (*ReplicaInfo) GetPartitionIds added in v2.1.0 

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

func (*ReplicaInfo) GetReplicaID added in v2.1.0 

func (x *ReplicaInfo) GetReplicaID() int64

func (*ReplicaInfo) GetShardReplicas added in v2.1.0 

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

func (*ReplicaInfo) ProtoMessage added in v2.1.0 

func (*ReplicaInfo) ProtoMessage()

func (*ReplicaInfo) ProtoReflect added in v2.1.0 

func (x *ReplicaInfo) ProtoReflect() protoreflect.Message

func (*ReplicaInfo) Reset added in v2.1.0 

func (x *ReplicaInfo) Reset()

func (*ReplicaInfo) String added in v2.1.0 

func (x *ReplicaInfo) String() string

type ResourceEntity added in v2.1.0 

type ResourceEntity struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceEntity) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use ResourceEntity.ProtoReflect.Descriptor instead.

func (*ResourceEntity) GetType added in v2.1.0 

func (x *ResourceEntity) GetType() string

func (*ResourceEntity) ProtoMessage added in v2.1.0 

func (*ResourceEntity) ProtoMessage()

func (*ResourceEntity) ProtoReflect added in v2.1.0 

func (x *ResourceEntity) ProtoReflect() protoreflect.Message

func (*ResourceEntity) Reset added in v2.1.0 

func (x *ResourceEntity) Reset()

func (*ResourceEntity) String added in v2.1.0 

func (x *ResourceEntity) String() string

type ResourceResult added in v2.1.0 

type ResourceResult struct {
	Resource   *ResourceEntity    `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	Privileges []*PrivilegeEntity `protobuf:"bytes,2,rep,name=privileges,proto3" json:"privileges,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceResult) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use ResourceResult.ProtoReflect.Descriptor instead.

func (*ResourceResult) GetPrivileges added in v2.1.0 

func (x *ResourceResult) GetPrivileges() []*PrivilegeEntity

func (*ResourceResult) GetResource added in v2.1.0 

func (x *ResourceResult) GetResource() *ResourceEntity

func (*ResourceResult) ProtoMessage added in v2.1.0 

func (*ResourceResult) ProtoMessage()

func (*ResourceResult) ProtoReflect added in v2.1.0 

func (x *ResourceResult) ProtoReflect() protoreflect.Message

func (*ResourceResult) Reset added in v2.1.0 

func (x *ResourceResult) Reset()

func (*ResourceResult) String added in v2.1.0 

func (x *ResourceResult) String() string

type RoleEntity added in v2.1.0 

type RoleEntity struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

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

func (*RoleEntity) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use RoleEntity.ProtoReflect.Descriptor instead.

func (*RoleEntity) GetName added in v2.1.0 

func (x *RoleEntity) GetName() string

func (*RoleEntity) ProtoMessage added in v2.1.0 

func (*RoleEntity) ProtoMessage()

func (*RoleEntity) ProtoReflect added in v2.1.0 

func (x *RoleEntity) ProtoReflect() protoreflect.Message

func (*RoleEntity) Reset added in v2.1.0 

func (x *RoleEntity) Reset()

func (*RoleEntity) String added in v2.1.0 

func (x *RoleEntity) String() string

type RoleResult added in v2.1.0 

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"`
	// contains filtered or unexported fields
}

func (*RoleResult) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use RoleResult.ProtoReflect.Descriptor instead.

func (*RoleResult) GetRole added in v2.1.0 

func (x *RoleResult) GetRole() *RoleEntity

func (*RoleResult) GetUsers added in v2.1.0 

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

func (*RoleResult) ProtoMessage added in v2.1.0 

func (*RoleResult) ProtoMessage()

func (*RoleResult) ProtoReflect added in v2.1.0 

func (x *RoleResult) ProtoReflect() protoreflect.Message

func (*RoleResult) Reset added in v2.1.0 

func (x *RoleResult) Reset()

func (*RoleResult) String added in v2.1.0 

func (x *RoleResult) String() string

type SearchRequest 

type SearchRequest struct {
	Base           *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"` // must
	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"` // must
	PartitionNames []string        `protobuf:"bytes,4,rep,name=partition_names,json=partitionNames,proto3" json:"partition_names,omitempty"` // must
	Dsl            string          `protobuf:"bytes,5,opt,name=dsl,proto3" json:"dsl,omitempty"`                                             // must
	// serialized `PlaceholderGroup`
	PlaceholderGroup   []byte                 `protobuf:"bytes,6,opt,name=placeholder_group,json=placeholderGroup,proto3" json:"placeholder_group,omitempty"`        // must
	DslType            common.DslType         `protobuf:"varint,7,opt,name=dsl_type,json=dslType,proto3,enum=milvus.proto.common.DslType" json:"dsl_type,omitempty"` // must
	OutputFields       []string               `protobuf:"bytes,8,rep,name=output_fields,json=outputFields,proto3" json:"output_fields,omitempty"`
	SearchParams       []*common.KeyValuePair `protobuf:"bytes,9,rep,name=search_params,json=searchParams,proto3" json:"search_params,omitempty"` // must
	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"` // guarantee_timestamp
	Nq                 int64                  `protobuf:"varint,12,opt,name=nq,proto3" json:"nq,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchRequest) Descriptor deprecated 

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

Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.

func (*SearchRequest) GetBase 

func (x *SearchRequest) GetBase() *common.MsgBase

func (*SearchRequest) GetCollectionName 

func (x *SearchRequest) GetCollectionName() string

func (*SearchRequest) GetDbName 

func (x *SearchRequest) GetDbName() string

func (*SearchRequest) GetDsl 

func (x *SearchRequest) GetDsl() string

func (*SearchRequest) GetDslType 

func (x *SearchRequest) GetDslType() common.DslType

func (*SearchRequest) GetGuaranteeTimestamp 

func (x *SearchRequest) GetGuaranteeTimestamp() uint64

func (*SearchRequest) GetNq added in v2.1.0 

func (x *SearchRequest) GetNq() int64

func (*SearchRequest) GetOutputFields 

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

func (*SearchRequest) GetPartitionNames 

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

func (*SearchRequest) GetPlaceholderGroup 

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

func (*SearchRequest) GetSearchParams 

func (x *SearchRequest) GetSearchParams() []*common.KeyValuePair

func (*SearchRequest) GetTravelTimestamp 

func (x *SearchRequest) GetTravelTimestamp() uint64

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) ProtoReflect added in v2.1.0 

func (x *SearchRequest) ProtoReflect() protoreflect.Message

func (*SearchRequest) Reset 

func (x *SearchRequest) Reset()

func (*SearchRequest) String 

func (x *SearchRequest) String() string

type SearchResults 

type SearchResults struct {
	Status         *common.Status           `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Results        *schema.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"`
	// contains filtered or unexported fields
}

func (*SearchResults) Descriptor deprecated 

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

Deprecated: Use SearchResults.ProtoReflect.Descriptor instead.

func (*SearchResults) GetCollectionName added in v2.1.0 

func (x *SearchResults) GetCollectionName() string

func (*SearchResults) GetResults 

func (x *SearchResults) GetResults() *schema.SearchResultData

func (*SearchResults) GetStatus 

func (x *SearchResults) GetStatus() *common.Status

func (*SearchResults) ProtoMessage 

func (*SearchResults) ProtoMessage()

func (*SearchResults) ProtoReflect added in v2.1.0 

func (x *SearchResults) ProtoReflect() protoreflect.Message

func (*SearchResults) Reset 

func (x *SearchResults) Reset()

func (*SearchResults) String 

func (x *SearchResults) String() string

type SelectGrantRequest added in v2.1.0 

type SelectGrantRequest struct {

	// Not useful for now
	Base *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// grant
	Entity *GrantEntity `protobuf:"bytes,2,opt,name=entity,proto3" json:"entity,omitempty"`
	// contains filtered or unexported fields
}

func (*SelectGrantRequest) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use SelectGrantRequest.ProtoReflect.Descriptor instead.

func (*SelectGrantRequest) GetBase added in v2.1.0 

func (x *SelectGrantRequest) GetBase() *common.MsgBase

func (*SelectGrantRequest) GetEntity added in v2.1.0 

func (x *SelectGrantRequest) GetEntity() *GrantEntity

func (*SelectGrantRequest) ProtoMessage added in v2.1.0 

func (*SelectGrantRequest) ProtoMessage()

func (*SelectGrantRequest) ProtoReflect added in v2.1.0 

func (x *SelectGrantRequest) ProtoReflect() protoreflect.Message

func (*SelectGrantRequest) Reset added in v2.1.0 

func (x *SelectGrantRequest) Reset()

func (*SelectGrantRequest) String added in v2.1.0 

func (x *SelectGrantRequest) String() string

type SelectGrantResponse added in v2.1.0 

type SelectGrantResponse struct {

	// Not useful for now
	Status *common.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"`
	// contains filtered or unexported fields
}

func (*SelectGrantResponse) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use SelectGrantResponse.ProtoReflect.Descriptor instead.

func (*SelectGrantResponse) GetEntities added in v2.1.0 

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

func (*SelectGrantResponse) GetStatus added in v2.1.0 

func (x *SelectGrantResponse) GetStatus() *common.Status

func (*SelectGrantResponse) ProtoMessage added in v2.1.0 

func (*SelectGrantResponse) ProtoMessage()

func (*SelectGrantResponse) ProtoReflect added in v2.1.0 

func (x *SelectGrantResponse) ProtoReflect() protoreflect.Message

func (*SelectGrantResponse) Reset added in v2.1.0 

func (x *SelectGrantResponse) Reset()

func (*SelectGrantResponse) String added in v2.1.0 

func (x *SelectGrantResponse) String() string

type SelectResourceRequest added in v2.1.0 

type SelectResourceRequest struct {

	// Not useful for now
	Base *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// resource
	Entity *ResourceEntity `protobuf:"bytes,2,opt,name=entity,proto3" json:"entity,omitempty"`
	// include privilege info
	IncludePrivilegeInfo bool `protobuf:"varint,3,opt,name=include_privilege_info,json=includePrivilegeInfo,proto3" json:"include_privilege_info,omitempty"`
	// contains filtered or unexported fields
}

func (*SelectResourceRequest) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use SelectResourceRequest.ProtoReflect.Descriptor instead.

func (*SelectResourceRequest) GetBase added in v2.1.0 

func (x *SelectResourceRequest) GetBase() *common.MsgBase

func (*SelectResourceRequest) GetEntity added in v2.1.0 

func (x *SelectResourceRequest) GetEntity() *ResourceEntity

func (*SelectResourceRequest) GetIncludePrivilegeInfo added in v2.1.0 

func (x *SelectResourceRequest) GetIncludePrivilegeInfo() bool

func (*SelectResourceRequest) ProtoMessage added in v2.1.0 

func (*SelectResourceRequest) ProtoMessage()

func (*SelectResourceRequest) ProtoReflect added in v2.1.0 

func (x *SelectResourceRequest) ProtoReflect() protoreflect.Message

func (*SelectResourceRequest) Reset added in v2.1.0 

func (x *SelectResourceRequest) Reset()

func (*SelectResourceRequest) String added in v2.1.0 

func (x *SelectResourceRequest) String() string

type SelectResourceResponse added in v2.1.0 

type SelectResourceResponse struct {

	// Not useful for now
	Status *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// resource result array
	Results []*ResourceResult `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*SelectResourceResponse) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use SelectResourceResponse.ProtoReflect.Descriptor instead.

func (*SelectResourceResponse) GetResults added in v2.1.0 

func (x *SelectResourceResponse) GetResults() []*ResourceResult

func (*SelectResourceResponse) GetStatus added in v2.1.0 

func (x *SelectResourceResponse) GetStatus() *common.Status

func (*SelectResourceResponse) ProtoMessage added in v2.1.0 

func (*SelectResourceResponse) ProtoMessage()

func (*SelectResourceResponse) ProtoReflect added in v2.1.0 

func (x *SelectResourceResponse) ProtoReflect() protoreflect.Message

func (*SelectResourceResponse) Reset added in v2.1.0 

func (x *SelectResourceResponse) Reset()

func (*SelectResourceResponse) String added in v2.1.0 

func (x *SelectResourceResponse) String() string

type SelectRoleRequest added in v2.1.0 

type SelectRoleRequest struct {

	// Not useful for now
	Base *common.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"`
	// contains filtered or unexported fields
}

func (*SelectRoleRequest) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use SelectRoleRequest.ProtoReflect.Descriptor instead.

func (*SelectRoleRequest) GetBase added in v2.1.0 

func (x *SelectRoleRequest) GetBase() *common.MsgBase

func (*SelectRoleRequest) GetIncludeUserInfo added in v2.1.0 

func (x *SelectRoleRequest) GetIncludeUserInfo() bool

func (*SelectRoleRequest) GetRole added in v2.1.0 

func (x *SelectRoleRequest) GetRole() *RoleEntity

func (*SelectRoleRequest) ProtoMessage added in v2.1.0 

func (*SelectRoleRequest) ProtoMessage()

func (*SelectRoleRequest) ProtoReflect added in v2.1.0 

func (x *SelectRoleRequest) ProtoReflect() protoreflect.Message

func (*SelectRoleRequest) Reset added in v2.1.0 

func (x *SelectRoleRequest) Reset()

func (*SelectRoleRequest) String added in v2.1.0 

func (x *SelectRoleRequest) String() string

type SelectRoleResponse added in v2.1.0 

type SelectRoleResponse struct {

	// Not useful for now
	Status *common.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"`
	// contains filtered or unexported fields
}

func (*SelectRoleResponse) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use SelectRoleResponse.ProtoReflect.Descriptor instead.

func (*SelectRoleResponse) GetResults added in v2.1.0 

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

func (*SelectRoleResponse) GetStatus added in v2.1.0 

func (x *SelectRoleResponse) GetStatus() *common.Status

func (*SelectRoleResponse) ProtoMessage added in v2.1.0 

func (*SelectRoleResponse) ProtoMessage()

func (*SelectRoleResponse) ProtoReflect added in v2.1.0 

func (x *SelectRoleResponse) ProtoReflect() protoreflect.Message

func (*SelectRoleResponse) Reset added in v2.1.0 

func (x *SelectRoleResponse) Reset()

func (*SelectRoleResponse) String added in v2.1.0 

func (x *SelectRoleResponse) String() string

type SelectUserRequest added in v2.1.0 

type SelectUserRequest struct {

	// Not useful for now
	Base *common.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"`
	// contains filtered or unexported fields
}

func (*SelectUserRequest) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use SelectUserRequest.ProtoReflect.Descriptor instead.

func (*SelectUserRequest) GetBase added in v2.1.0 

func (x *SelectUserRequest) GetBase() *common.MsgBase

func (*SelectUserRequest) GetIncludeRoleInfo added in v2.1.0 

func (x *SelectUserRequest) GetIncludeRoleInfo() bool

func (*SelectUserRequest) GetUser added in v2.1.0 

func (x *SelectUserRequest) GetUser() *UserEntity

func (*SelectUserRequest) ProtoMessage added in v2.1.0 

func (*SelectUserRequest) ProtoMessage()

func (*SelectUserRequest) ProtoReflect added in v2.1.0 

func (x *SelectUserRequest) ProtoReflect() protoreflect.Message

func (*SelectUserRequest) Reset added in v2.1.0 

func (x *SelectUserRequest) Reset()

func (*SelectUserRequest) String added in v2.1.0 

func (x *SelectUserRequest) String() string

type SelectUserResponse added in v2.1.0 

type SelectUserResponse struct {

	// Not useful for now
	Status *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// user result array
	Result []*UserResult `protobuf:"bytes,2,rep,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*SelectUserResponse) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use SelectUserResponse.ProtoReflect.Descriptor instead.

func (*SelectUserResponse) GetResult added in v2.1.0 

func (x *SelectUserResponse) GetResult() []*UserResult

func (*SelectUserResponse) GetStatus added in v2.1.0 

func (x *SelectUserResponse) GetStatus() *common.Status

func (*SelectUserResponse) ProtoMessage added in v2.1.0 

func (*SelectUserResponse) ProtoMessage()

func (*SelectUserResponse) ProtoReflect added in v2.1.0 

func (x *SelectUserResponse) ProtoReflect() protoreflect.Message

func (*SelectUserResponse) Reset added in v2.1.0 

func (x *SelectUserResponse) Reset()

func (*SelectUserResponse) String added in v2.1.0 

func (x *SelectUserResponse) String() string

type ShardReplica added in v2.1.0 

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"` // IP:port
	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"`
	// contains filtered or unexported fields
}

func (*ShardReplica) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use ShardReplica.ProtoReflect.Descriptor instead.

func (*ShardReplica) GetDmChannelName added in v2.1.0 

func (x *ShardReplica) GetDmChannelName() string

func (*ShardReplica) GetLeaderAddr added in v2.1.0 

func (x *ShardReplica) GetLeaderAddr() string

func (*ShardReplica) GetLeaderID added in v2.1.0 

func (x *ShardReplica) GetLeaderID() int64

func (*ShardReplica) GetNodeIds added in v2.1.0 

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

func (*ShardReplica) ProtoMessage added in v2.1.0 

func (*ShardReplica) ProtoMessage()

func (*ShardReplica) ProtoReflect added in v2.1.0 

func (x *ShardReplica) ProtoReflect() protoreflect.Message

func (*ShardReplica) Reset added in v2.1.0 

func (x *ShardReplica) Reset()

func (*ShardReplica) String added in v2.1.0 

func (x *ShardReplica) String() string

type ShowCollectionsRequest 

type ShowCollectionsRequest struct {

	// Not useful for now
	Base *common.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)
	CollectionNames []string `protobuf:"bytes,5,rep,name=collection_names,json=collectionNames,proto3" json:"collection_names,omitempty"`
	// contains filtered or unexported fields
}

List collections

func (*ShowCollectionsRequest) Descriptor deprecated 

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

Deprecated: Use ShowCollectionsRequest.ProtoReflect.Descriptor instead.

func (*ShowCollectionsRequest) GetBase 

func (x *ShowCollectionsRequest) GetBase() *common.MsgBase

func (*ShowCollectionsRequest) GetCollectionNames 

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

func (*ShowCollectionsRequest) GetDbName 

func (x *ShowCollectionsRequest) GetDbName() string

func (*ShowCollectionsRequest) GetTimeStamp 

func (x *ShowCollectionsRequest) GetTimeStamp() uint64

func (*ShowCollectionsRequest) GetType 

func (x *ShowCollectionsRequest) GetType() ShowType

func (*ShowCollectionsRequest) ProtoMessage 

func (*ShowCollectionsRequest) ProtoMessage()

func (*ShowCollectionsRequest) ProtoReflect added in v2.1.0 

func (x *ShowCollectionsRequest) ProtoReflect() protoreflect.Message

func (*ShowCollectionsRequest) Reset 

func (x *ShowCollectionsRequest) Reset()

func (*ShowCollectionsRequest) String 

func (x *ShowCollectionsRequest) String() string

type ShowCollectionsResponse 

type ShowCollectionsResponse struct {

	// Contain error_code and reason
	Status *common.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
	InMemoryPercentages []int64 `` /* 126-byte string literal not displayed */
	// Indicate whether query service is available
	QueryServiceAvailable []bool `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

Return basic collection infos.

func (*ShowCollectionsResponse) Descriptor deprecated 

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

Deprecated: Use ShowCollectionsResponse.ProtoReflect.Descriptor instead.

func (*ShowCollectionsResponse) GetCollectionIds 

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

func (*ShowCollectionsResponse) GetCollectionNames 

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

func (*ShowCollectionsResponse) GetCreatedTimestamps 

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

func (*ShowCollectionsResponse) GetCreatedUtcTimestamps 

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

func (*ShowCollectionsResponse) GetInMemoryPercentages 

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

func (*ShowCollectionsResponse) GetQueryServiceAvailable added in v2.1.0 

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

func (*ShowCollectionsResponse) GetStatus 

func (x *ShowCollectionsResponse) GetStatus() *common.Status

func (*ShowCollectionsResponse) ProtoMessage 

func (*ShowCollectionsResponse) ProtoMessage()

func (*ShowCollectionsResponse) ProtoReflect added in v2.1.0 

func (x *ShowCollectionsResponse) ProtoReflect() protoreflect.Message

func (*ShowCollectionsResponse) Reset 

func (x *ShowCollectionsResponse) Reset()

func (*ShowCollectionsResponse) String 

func (x *ShowCollectionsResponse) String() string

type ShowPartitionsRequest 

type ShowPartitionsRequest struct {

	// Not useful for now
	Base *common.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)
	Type ShowType `protobuf:"varint,6,opt,name=type,proto3,enum=milvus.proto.milvus.ShowType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

List all partitions for particular collection

func (*ShowPartitionsRequest) Descriptor deprecated 

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

Deprecated: Use ShowPartitionsRequest.ProtoReflect.Descriptor instead.

func (*ShowPartitionsRequest) GetBase 

func (x *ShowPartitionsRequest) GetBase() *common.MsgBase

func (*ShowPartitionsRequest) GetCollectionID 

func (x *ShowPartitionsRequest) GetCollectionID() int64

func (*ShowPartitionsRequest) GetCollectionName 

func (x *ShowPartitionsRequest) GetCollectionName() string

func (*ShowPartitionsRequest) GetDbName 

func (x *ShowPartitionsRequest) GetDbName() string

func (*ShowPartitionsRequest) GetPartitionNames 

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

func (*ShowPartitionsRequest) GetType 

func (x *ShowPartitionsRequest) GetType() ShowType

func (*ShowPartitionsRequest) ProtoMessage 

func (*ShowPartitionsRequest) ProtoMessage()

func (*ShowPartitionsRequest) ProtoReflect added in v2.1.0 

func (x *ShowPartitionsRequest) ProtoReflect() protoreflect.Message

func (*ShowPartitionsRequest) Reset 

func (x *ShowPartitionsRequest) Reset()

func (*ShowPartitionsRequest) String 

func (x *ShowPartitionsRequest) String() string

type ShowPartitionsResponse 

type ShowPartitionsResponse struct {

	// Contain error_code and reason
	Status *common.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
	InMemoryPercentages []int64 `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

func (*ShowPartitionsResponse) Descriptor deprecated 

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

Deprecated: Use ShowPartitionsResponse.ProtoReflect.Descriptor instead.

func (*ShowPartitionsResponse) GetCreatedTimestamps 

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

func (*ShowPartitionsResponse) GetCreatedUtcTimestamps 

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

func (*ShowPartitionsResponse) GetInMemoryPercentages 

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

func (*ShowPartitionsResponse) GetPartitionIDs 

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

func (*ShowPartitionsResponse) GetPartitionNames 

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

func (*ShowPartitionsResponse) GetStatus 

func (x *ShowPartitionsResponse) GetStatus() *common.Status

func (*ShowPartitionsResponse) ProtoMessage 

func (*ShowPartitionsResponse) ProtoMessage()

func (*ShowPartitionsResponse) ProtoReflect added in v2.1.0 

func (x *ShowPartitionsResponse) ProtoReflect() protoreflect.Message

func (*ShowPartitionsResponse) Reset 

func (x *ShowPartitionsResponse) Reset()

func (*ShowPartitionsResponse) String 

func (x *ShowPartitionsResponse) String() string

type ShowSegmentsRequest 

type ShowSegmentsRequest struct {
	Base         *common.MsgBase `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	CollectionID int64           `protobuf:"varint,2,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	PartitionID  int64           `protobuf:"varint,3,opt,name=partitionID,proto3" json:"partitionID,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowSegmentsRequest) Descriptor deprecated 

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

Deprecated: Use ShowSegmentsRequest.ProtoReflect.Descriptor instead.

func (*ShowSegmentsRequest) GetBase 

func (x *ShowSegmentsRequest) GetBase() *common.MsgBase

func (*ShowSegmentsRequest) GetCollectionID 

func (x *ShowSegmentsRequest) GetCollectionID() int64

func (*ShowSegmentsRequest) GetPartitionID 

func (x *ShowSegmentsRequest) GetPartitionID() int64

func (*ShowSegmentsRequest) ProtoMessage 

func (*ShowSegmentsRequest) ProtoMessage()

func (*ShowSegmentsRequest) ProtoReflect added in v2.1.0 

func (x *ShowSegmentsRequest) ProtoReflect() protoreflect.Message

func (*ShowSegmentsRequest) Reset 

func (x *ShowSegmentsRequest) Reset()

func (*ShowSegmentsRequest) String 

func (x *ShowSegmentsRequest) String() string

type ShowSegmentsResponse 

type ShowSegmentsResponse struct {
	Status     *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	SegmentIDs []int64        `protobuf:"varint,2,rep,packed,name=segmentIDs,proto3" json:"segmentIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowSegmentsResponse) Descriptor deprecated 

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

Deprecated: Use ShowSegmentsResponse.ProtoReflect.Descriptor instead.

func (*ShowSegmentsResponse) GetSegmentIDs 

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

func (*ShowSegmentsResponse) GetStatus 

func (x *ShowSegmentsResponse) GetStatus() *common.Status

func (*ShowSegmentsResponse) ProtoMessage 

func (*ShowSegmentsResponse) ProtoMessage()

func (*ShowSegmentsResponse) ProtoReflect added in v2.1.0 

func (x *ShowSegmentsResponse) ProtoReflect() protoreflect.Message

func (*ShowSegmentsResponse) Reset 

func (x *ShowSegmentsResponse) Reset()

func (*ShowSegmentsResponse) String 

func (x *ShowSegmentsResponse) String() string

type ShowType 

type ShowType int32

This is for ShowCollectionsRequest type field. 

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

func (ShowType) Descriptor added in v2.1.0 

func (ShowType) Descriptor() protoreflect.EnumDescriptor

func (ShowType) Enum added in v2.1.0 

func (x ShowType) Enum() *ShowType

func (ShowType) EnumDescriptor deprecated 

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

Deprecated: Use ShowType.Descriptor instead.

func (ShowType) Number added in v2.1.0 

func (x ShowType) Number() protoreflect.EnumNumber

func (ShowType) String 

func (x ShowType) String() string

func (ShowType) Type added in v2.1.0 

func (ShowType) Type() protoreflect.EnumType

type StringResponse 

type StringResponse struct {
	Status *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Value  string         `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*StringResponse) Descriptor deprecated 

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

Deprecated: Use StringResponse.ProtoReflect.Descriptor instead.

func (*StringResponse) GetStatus 

func (x *StringResponse) GetStatus() *common.Status

func (*StringResponse) GetValue 

func (x *StringResponse) GetValue() string

func (*StringResponse) ProtoMessage 

func (*StringResponse) ProtoMessage()

func (*StringResponse) ProtoReflect added in v2.1.0 

func (x *StringResponse) ProtoReflect() protoreflect.Message

func (*StringResponse) Reset 

func (x *StringResponse) Reset()

func (*StringResponse) String 

func (x *StringResponse) String() string

type UnimplementedMilvusServiceServer 

type UnimplementedMilvusServiceServer struct {
}

UnimplementedMilvusServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMilvusServiceServer) AlterAlias 

func (*UnimplementedMilvusServiceServer) AlterAlias(context.Context, *AlterAliasRequest) (*common.Status, error)

func (*UnimplementedMilvusServiceServer) CalcDistance 

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

func (*UnimplementedMilvusServiceServer) CreateAlias 

func (*UnimplementedMilvusServiceServer) CreateAlias(context.Context, *CreateAliasRequest) (*common.Status, error)

func (*UnimplementedMilvusServiceServer) CreateCollection 

func (*UnimplementedMilvusServiceServer) CreateCollection(context.Context, *CreateCollectionRequest) (*common.Status, error)

func (*UnimplementedMilvusServiceServer) CreateCredential added in v2.1.0 

func (*UnimplementedMilvusServiceServer) CreateCredential(context.Context, *CreateCredentialRequest) (*common.Status, error)

func (*UnimplementedMilvusServiceServer) CreateIndex 

func (*UnimplementedMilvusServiceServer) CreateIndex(context.Context, *CreateIndexRequest) (*common.Status, error)

func (*UnimplementedMilvusServiceServer) CreatePartition 

func (*UnimplementedMilvusServiceServer) CreatePartition(context.Context, *CreatePartitionRequest) (*common.Status, error)

func (*UnimplementedMilvusServiceServer) CreateRole added in v2.1.0 

func (*UnimplementedMilvusServiceServer) CreateRole(context.Context, *CreateRoleRequest) (*common.Status, error)

func (*UnimplementedMilvusServiceServer) Delete 

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

func (*UnimplementedMilvusServiceServer) DeleteCredential added in v2.1.0 

func (*UnimplementedMilvusServiceServer) DeleteCredential(context.Context, *DeleteCredentialRequest) (*common.Status, error)

func (*UnimplementedMilvusServiceServer) DescribeCollection 

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

func (*UnimplementedMilvusServiceServer) DescribeIndex 

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

func (*UnimplementedMilvusServiceServer) DropAlias 

func (*UnimplementedMilvusServiceServer) DropAlias(context.Context, *DropAliasRequest) (*common.Status, error)

func (*UnimplementedMilvusServiceServer) DropCollection 

func (*UnimplementedMilvusServiceServer) DropCollection(context.Context, *DropCollectionRequest) (*common.Status, error)

func (*UnimplementedMilvusServiceServer) DropIndex 

func (*UnimplementedMilvusServiceServer) DropIndex(context.Context, *DropIndexRequest) (*common.Status, error)

func (*UnimplementedMilvusServiceServer) DropPartition 

func (*UnimplementedMilvusServiceServer) DropPartition(context.Context, *DropPartitionRequest) (*common.Status, error)

func (*UnimplementedMilvusServiceServer) DropRole added in v2.1.0 

func (*UnimplementedMilvusServiceServer) DropRole(context.Context, *DropRoleRequest) (*common.Status, error)

func (*UnimplementedMilvusServiceServer) Dummy 

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

func (*UnimplementedMilvusServiceServer) Flush 

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

func (*UnimplementedMilvusServiceServer) GetCollectionStatistics 

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

func (*UnimplementedMilvusServiceServer) GetCompactionState 

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

func (*UnimplementedMilvusServiceServer) GetCompactionStateWithPlans 

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

func (*UnimplementedMilvusServiceServer) GetFlushState 

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

func (*UnimplementedMilvusServiceServer) GetImportState added in v2.1.0 

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

func (*UnimplementedMilvusServiceServer) GetIndexBuildProgress 

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

func (*UnimplementedMilvusServiceServer) GetIndexState 

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

func (*UnimplementedMilvusServiceServer) GetMetrics 

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

func (*UnimplementedMilvusServiceServer) GetPartitionStatistics 

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

func (*UnimplementedMilvusServiceServer) GetPersistentSegmentInfo 

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

func (*UnimplementedMilvusServiceServer) GetQuerySegmentInfo 

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

func (*UnimplementedMilvusServiceServer) GetReplicas added in v2.1.0 

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

func (*UnimplementedMilvusServiceServer) HasCollection 

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

func (*UnimplementedMilvusServiceServer) HasPartition 

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

func (*UnimplementedMilvusServiceServer) Import added in v2.1.0 

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

func (*UnimplementedMilvusServiceServer) Insert 

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

func (*UnimplementedMilvusServiceServer) ListCredUsers added in v2.1.0 

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

func (*UnimplementedMilvusServiceServer) ListImportTasks added in v2.1.0 

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

func (*UnimplementedMilvusServiceServer) LoadBalance 

func (*UnimplementedMilvusServiceServer) LoadBalance(context.Context, *LoadBalanceRequest) (*common.Status, error)

func (*UnimplementedMilvusServiceServer) LoadCollection 

func (*UnimplementedMilvusServiceServer) LoadCollection(context.Context, *LoadCollectionRequest) (*common.Status, error)

func (*UnimplementedMilvusServiceServer) LoadPartitions 

func (*UnimplementedMilvusServiceServer) LoadPartitions(context.Context, *LoadPartitionsRequest) (*common.Status, error)

func (*UnimplementedMilvusServiceServer) ManualCompaction 

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

func (*UnimplementedMilvusServiceServer) OperatePrivilege added in v2.1.0 

func (*UnimplementedMilvusServiceServer) OperatePrivilege(context.Context, *OperatePrivilegeRequest) (*common.Status, error)

func (*UnimplementedMilvusServiceServer) OperateUserRole added in v2.1.0 

func (*UnimplementedMilvusServiceServer) OperateUserRole(context.Context, *OperateUserRoleRequest) (*common.Status, error)

func (*UnimplementedMilvusServiceServer) Query 

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

func (*UnimplementedMilvusServiceServer) ReleaseCollection 

func (*UnimplementedMilvusServiceServer) ReleaseCollection(context.Context, *ReleaseCollectionRequest) (*common.Status, error)

func (*UnimplementedMilvusServiceServer) ReleasePartitions 

func (*UnimplementedMilvusServiceServer) ReleasePartitions(context.Context, *ReleasePartitionsRequest) (*common.Status, error)

func (*UnimplementedMilvusServiceServer) Search 

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

func (*UnimplementedMilvusServiceServer) SelectGrant added in v2.1.0 

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

func (*UnimplementedMilvusServiceServer) SelectResource added in v2.1.0 

func (*UnimplementedMilvusServiceServer) SelectResource(context.Context, *SelectResourceRequest) (*SelectResourceResponse, error)

func (*UnimplementedMilvusServiceServer) SelectRole added in v2.1.0 

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

func (*UnimplementedMilvusServiceServer) SelectUser added in v2.1.0 

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

func (*UnimplementedMilvusServiceServer) ShowCollections 

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

func (*UnimplementedMilvusServiceServer) ShowPartitions 

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

func (*UnimplementedMilvusServiceServer) UpdateCredential added in v2.1.0 

func (*UnimplementedMilvusServiceServer) UpdateCredential(context.Context, *UpdateCredentialRequest) (*common.Status, error)

type UnimplementedProxyServiceServer 

type UnimplementedProxyServiceServer struct {
}

UnimplementedProxyServiceServer can be embedded to have forward compatible implementations. 

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

type UpdateCredentialRequest added in v2.1.0 

type UpdateCredentialRequest struct {

	// Not useful for now
	Base *common.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 */
	// contains filtered or unexported fields
}

func (*UpdateCredentialRequest) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use UpdateCredentialRequest.ProtoReflect.Descriptor instead.

func (*UpdateCredentialRequest) GetBase added in v2.1.0 

func (x *UpdateCredentialRequest) GetBase() *common.MsgBase

func (*UpdateCredentialRequest) GetCreatedUtcTimestamps added in v2.1.0 

func (x *UpdateCredentialRequest) GetCreatedUtcTimestamps() uint64

func (*UpdateCredentialRequest) GetModifiedUtcTimestamps added in v2.1.0 

func (x *UpdateCredentialRequest) GetModifiedUtcTimestamps() uint64

func (*UpdateCredentialRequest) GetNewPassword added in v2.1.0 

func (x *UpdateCredentialRequest) GetNewPassword() string

func (*UpdateCredentialRequest) GetOldPassword added in v2.1.0 

func (x *UpdateCredentialRequest) GetOldPassword() string

func (*UpdateCredentialRequest) GetUsername added in v2.1.0 

func (x *UpdateCredentialRequest) GetUsername() string

func (*UpdateCredentialRequest) ProtoMessage added in v2.1.0 

func (*UpdateCredentialRequest) ProtoMessage()

func (*UpdateCredentialRequest) ProtoReflect added in v2.1.0 

func (x *UpdateCredentialRequest) ProtoReflect() protoreflect.Message

func (*UpdateCredentialRequest) Reset added in v2.1.0 

func (x *UpdateCredentialRequest) Reset()

func (*UpdateCredentialRequest) String added in v2.1.0 

func (x *UpdateCredentialRequest) String() string

type UserEntity added in v2.1.0 

type UserEntity struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*UserEntity) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use UserEntity.ProtoReflect.Descriptor instead.

func (*UserEntity) GetName added in v2.1.0 

func (x *UserEntity) GetName() string

func (*UserEntity) ProtoMessage added in v2.1.0 

func (*UserEntity) ProtoMessage()

func (*UserEntity) ProtoReflect added in v2.1.0 

func (x *UserEntity) ProtoReflect() protoreflect.Message

func (*UserEntity) Reset added in v2.1.0 

func (x *UserEntity) Reset()

func (*UserEntity) String added in v2.1.0 

func (x *UserEntity) String() string

type UserResult added in v2.1.0 

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"`
	// contains filtered or unexported fields
}

func (*UserResult) Descriptor deprecated added in v2.1.0 

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

Deprecated: Use UserResult.ProtoReflect.Descriptor instead.

func (*UserResult) GetRoles added in v2.1.0 

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

func (*UserResult) GetUser added in v2.1.0 

func (x *UserResult) GetUser() *UserEntity

func (*UserResult) ProtoMessage added in v2.1.0 

func (*UserResult) ProtoMessage()

func (*UserResult) ProtoReflect added in v2.1.0 

func (x *UserResult) ProtoReflect() protoreflect.Message

func (*UserResult) Reset added in v2.1.0 

func (x *UserResult) Reset()

func (*UserResult) String added in v2.1.0 

func (x *UserResult) String() string

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        *schema.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"`
	// contains filtered or unexported fields
}

func (*VectorIDs) Descriptor deprecated 

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

Deprecated: Use VectorIDs.ProtoReflect.Descriptor instead.

func (*VectorIDs) GetCollectionName 

func (x *VectorIDs) GetCollectionName() string

func (*VectorIDs) GetFieldName 

func (x *VectorIDs) GetFieldName() string

func (*VectorIDs) GetIdArray 

func (x *VectorIDs) GetIdArray() *schema.IDs

func (*VectorIDs) GetPartitionNames 

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

func (*VectorIDs) ProtoMessage 

func (*VectorIDs) ProtoMessage()

func (*VectorIDs) ProtoReflect added in v2.1.0 

func (x *VectorIDs) ProtoReflect() protoreflect.Message

func (*VectorIDs) Reset 

func (x *VectorIDs) Reset()

func (*VectorIDs) String 

func (x *VectorIDs) String() string

type VectorsArray 

type VectorsArray struct {

	// Types that are assignable to Array:
	//	*VectorsArray_IdArray
	//	*VectorsArray_DataArray
	Array isVectorsArray_Array `protobuf_oneof:"array"`
	// contains filtered or unexported fields
}

func (*VectorsArray) Descriptor deprecated 

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

Deprecated: Use VectorsArray.ProtoReflect.Descriptor instead.

func (*VectorsArray) GetArray 

func (m *VectorsArray) GetArray() isVectorsArray_Array

func (*VectorsArray) GetDataArray 

func (x *VectorsArray) GetDataArray() *schema.VectorField

func (*VectorsArray) GetIdArray 

func (x *VectorsArray) GetIdArray() *VectorIDs

func (*VectorsArray) ProtoMessage 

func (*VectorsArray) ProtoMessage()

func (*VectorsArray) ProtoReflect added in v2.1.0 

func (x *VectorsArray) ProtoReflect() protoreflect.Message

func (*VectorsArray) Reset 

func (x *VectorsArray) Reset()

func (*VectorsArray) String 

func (x *VectorsArray) String() string

type VectorsArray_DataArray 

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

type VectorsArray_IdArray 

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

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.