server

package

Go to main page

Versions in this module

v2

v2.1.2

Sep 8, 2022

v2.1.1

Aug 12, 2022

v2.1.0

Jul 22, 2022

Changes in this version

+ var E_MilvusExtObj = &file_milvus_proto_extTypes[0]

+ var File_milvus_proto protoreflect.FileDescriptor

+ var OperatePrivilegeType_name = map[int32]string

+ var OperatePrivilegeType_value = map[string]int32

+ var OperateUserRoleType_name = map[int32]string

+ var OperateUserRoleType_value = map[string]int32

type AlterAliasRequest

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

type BoolResponse

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

type CalcDistanceRequest

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

type CalcDistanceResults

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

type CompactionMergeInfo

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

type CreateAliasRequest

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

type CreateCollectionRequest

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

+ type CreateCredentialRequest struct

+ Base *common.MsgBase

+ CreatedUtcTimestamps uint64

+ ModifiedUtcTimestamps uint64

+ Password string

+ Username string

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

+ func (*CreateCredentialRequest) ProtoMessage()

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

+ func (x *CreateCredentialRequest) GetCreatedUtcTimestamps() uint64

+ func (x *CreateCredentialRequest) GetModifiedUtcTimestamps() uint64

+ func (x *CreateCredentialRequest) GetPassword() string

+ func (x *CreateCredentialRequest) GetUsername() string

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

+ func (x *CreateCredentialRequest) Reset()

+ func (x *CreateCredentialRequest) String() string

type CreateIndexRequest

+ IndexName string

+ func (x *CreateIndexRequest) GetIndexName() string

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

type CreatePartitionRequest

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

+ type CreateRoleRequest struct

+ Base *common.MsgBase

+ Entity *RoleEntity

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

+ func (*CreateRoleRequest) ProtoMessage()

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

+ func (x *CreateRoleRequest) GetEntity() *RoleEntity

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

+ func (x *CreateRoleRequest) Reset()

+ func (x *CreateRoleRequest) String() string

+ type DeleteCredentialRequest struct

+ Base *common.MsgBase

+ Username string

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

+ func (*DeleteCredentialRequest) ProtoMessage()

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

+ func (x *DeleteCredentialRequest) GetUsername() string

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

+ func (x *DeleteCredentialRequest) Reset()

+ func (x *DeleteCredentialRequest) String() string

type DeleteRequest

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

type DescribeCollectionRequest

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

type DescribeCollectionResponse

+ CollectionName string

+ func (x *DescribeCollectionResponse) GetCollectionName() string

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

type DescribeIndexRequest

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

type DescribeIndexResponse

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

type DescribeSegmentRequest

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

type DescribeSegmentResponse

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

type DropAliasRequest

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

type DropCollectionRequest

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

type DropIndexRequest

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

type DropPartitionRequest

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

+ type DropRoleRequest struct

+ Base *common.MsgBase

+ RoleName string

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

+ func (*DropRoleRequest) ProtoMessage()

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

+ func (x *DropRoleRequest) GetRoleName() string

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

+ func (x *DropRoleRequest) Reset()

+ func (x *DropRoleRequest) String() string

type DummyRequest

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

type DummyResponse

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

type FlushRequest

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

type FlushResponse

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

type GetCollectionStatisticsRequest

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

type GetCollectionStatisticsResponse

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

type GetCompactionPlansRequest

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

type GetCompactionPlansResponse

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

type GetCompactionStateRequest

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

type GetCompactionStateResponse

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

type GetFlushStateRequest

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

type GetFlushStateResponse

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

+ type GetImportStateRequest struct

+ Task int64

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

+ func (*GetImportStateRequest) ProtoMessage()

+ func (x *GetImportStateRequest) GetTask() int64

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

+ func (x *GetImportStateRequest) Reset()

+ func (x *GetImportStateRequest) String() string

+ type GetImportStateResponse struct

+ DataIndexed bool

+ DataQueryable bool

+ Id int64

+ IdList []int64

+ Infos []*common.KeyValuePair

+ RowCount int64

+ State common.ImportState

+ Status *common.Status

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

+ func (*GetImportStateResponse) ProtoMessage()

+ func (x *GetImportStateResponse) GetDataIndexed() bool

+ func (x *GetImportStateResponse) GetDataQueryable() bool

+ func (x *GetImportStateResponse) GetId() int64

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

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

+ func (x *GetImportStateResponse) GetRowCount() int64

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

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

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

+ func (x *GetImportStateResponse) Reset()

+ func (x *GetImportStateResponse) String() string

type GetIndexBuildProgressRequest

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

type GetIndexBuildProgressResponse

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

type GetIndexStateRequest

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

type GetIndexStateResponse

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

type GetMetricsRequest

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

type GetMetricsResponse

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

type GetPartitionStatisticsRequest

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

type GetPartitionStatisticsResponse

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

type GetPersistentSegmentInfoRequest

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

type GetPersistentSegmentInfoResponse

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

type GetQuerySegmentInfoRequest

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

type GetQuerySegmentInfoResponse

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

+ type GetReplicasRequest struct

+ Base *common.MsgBase

+ CollectionID int64

+ WithShardNodes bool

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

+ func (*GetReplicasRequest) ProtoMessage()

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

+ func (x *GetReplicasRequest) GetCollectionID() int64

+ func (x *GetReplicasRequest) GetWithShardNodes() bool

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

+ func (x *GetReplicasRequest) Reset()

+ func (x *GetReplicasRequest) String() string

+ type GetReplicasResponse struct

+ Replicas []*ReplicaInfo

+ Status *common.Status

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

+ func (*GetReplicasResponse) ProtoMessage()

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

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

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

+ func (x *GetReplicasResponse) Reset()

+ func (x *GetReplicasResponse) String() string

+ type GrantEntity struct

+ Grantor *GrantorEntity

+ Principal *PrincipalEntity

+ Resource *ResourceEntity

+ ResourceName string

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

+ func (*GrantEntity) ProtoMessage()

+ func (x *GrantEntity) GetGrantor() *GrantorEntity

+ func (x *GrantEntity) GetPrincipal() *PrincipalEntity

+ func (x *GrantEntity) GetResource() *ResourceEntity

+ func (x *GrantEntity) GetResourceName() string

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

+ func (x *GrantEntity) Reset()

+ func (x *GrantEntity) String() string

+ type GrantorEntity struct

+ Privilege *PrivilegeEntity

+ User *UserEntity

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

+ func (*GrantorEntity) ProtoMessage()

+ func (x *GrantorEntity) GetPrivilege() *PrivilegeEntity

+ func (x *GrantorEntity) GetUser() *UserEntity

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

+ func (x *GrantorEntity) Reset()

+ func (x *GrantorEntity) String() string

type HasCollectionRequest

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

type HasPartitionRequest

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

type Hits

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

+ type ImportRequest struct

+ ChannelNames []string

+ CollectionName string

+ Files []string

+ Options []*common.KeyValuePair

+ PartitionName string

+ RowBased bool

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

+ func (*ImportRequest) ProtoMessage()

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

+ func (x *ImportRequest) GetCollectionName() string

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

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

+ func (x *ImportRequest) GetPartitionName() string

+ func (x *ImportRequest) GetRowBased() bool

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

+ func (x *ImportRequest) Reset()

+ func (x *ImportRequest) String() string

+ type ImportResponse struct

+ Status *common.Status

+ Tasks []int64

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

+ func (*ImportResponse) ProtoMessage()

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

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

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

+ func (x *ImportResponse) Reset()

+ func (x *ImportResponse) String() string

type IndexDescription

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

type InsertRequest

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

+ type ListCredUsersRequest struct

+ Base *common.MsgBase

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

+ func (*ListCredUsersRequest) ProtoMessage()

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

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

+ func (x *ListCredUsersRequest) Reset()

+ func (x *ListCredUsersRequest) String() string

+ type ListCredUsersResponse struct

+ Status *common.Status

+ Usernames []string

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

+ func (*ListCredUsersResponse) ProtoMessage()

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

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

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

+ func (x *ListCredUsersResponse) Reset()

+ func (x *ListCredUsersResponse) String() string

+ type ListImportTasksRequest struct

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

+ func (*ListImportTasksRequest) ProtoMessage()

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

+ func (x *ListImportTasksRequest) Reset()

+ func (x *ListImportTasksRequest) String() string

+ type ListImportTasksResponse struct

+ Status *common.Status

+ Tasks []*GetImportStateResponse

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

+ func (*ListImportTasksResponse) ProtoMessage()

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

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

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

+ func (x *ListImportTasksResponse) Reset()

+ func (x *ListImportTasksResponse) String() string

type LoadBalanceRequest

+ CollectionName string

+ func (x *LoadBalanceRequest) GetCollectionName() string

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

type LoadCollectionRequest

+ ReplicaNumber int32

+ func (x *LoadCollectionRequest) GetReplicaNumber() int32

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

type LoadPartitionsRequest

+ ReplicaNumber int32

+ func (x *LoadPartitionsRequest) GetReplicaNumber() int32

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

type ManualCompactionRequest

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

type ManualCompactionResponse

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

+ type MilvusExt struct

+ Version string

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

+ func (*MilvusExt) ProtoMessage()

+ func (x *MilvusExt) GetVersion() string

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

+ func (x *MilvusExt) Reset()

+ func (x *MilvusExt) String() string

type MilvusServiceClient

+ CreateCredential func(ctx context.Context, in *CreateCredentialRequest, opts ...grpc.CallOption) (*common.Status, error)

+ CreateRole func(ctx context.Context, in *CreateRoleRequest, opts ...grpc.CallOption) (*common.Status, error)

+ DeleteCredential func(ctx context.Context, in *DeleteCredentialRequest, opts ...grpc.CallOption) (*common.Status, error)

+ DropRole func(ctx context.Context, in *DropRoleRequest, opts ...grpc.CallOption) (*common.Status, error)

+ GetImportState func(ctx context.Context, in *GetImportStateRequest, opts ...grpc.CallOption) (*GetImportStateResponse, error)

+ GetReplicas func(ctx context.Context, in *GetReplicasRequest, opts ...grpc.CallOption) (*GetReplicasResponse, error)

+ Import func(ctx context.Context, in *ImportRequest, opts ...grpc.CallOption) (*ImportResponse, error)

+ ListCredUsers func(ctx context.Context, in *ListCredUsersRequest, opts ...grpc.CallOption) (*ListCredUsersResponse, error)

+ ListImportTasks func(ctx context.Context, in *ListImportTasksRequest, opts ...grpc.CallOption) (*ListImportTasksResponse, error)

+ OperatePrivilege func(ctx context.Context, in *OperatePrivilegeRequest, opts ...grpc.CallOption) (*common.Status, error)

+ OperateUserRole func(ctx context.Context, in *OperateUserRoleRequest, opts ...grpc.CallOption) (*common.Status, error)

+ SelectGrant func(ctx context.Context, in *SelectGrantRequest, opts ...grpc.CallOption) (*SelectGrantResponse, error)

+ SelectResource func(ctx context.Context, in *SelectResourceRequest, opts ...grpc.CallOption) (*SelectResourceResponse, error)

+ SelectRole func(ctx context.Context, in *SelectRoleRequest, opts ...grpc.CallOption) (*SelectRoleResponse, error)

+ SelectUser func(ctx context.Context, in *SelectUserRequest, opts ...grpc.CallOption) (*SelectUserResponse, error)

+ UpdateCredential func(ctx context.Context, in *UpdateCredentialRequest, opts ...grpc.CallOption) (*common.Status, error)

type MilvusServiceServer

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

type MutationResult

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

+ type OperatePrivilegeRequest struct

+ Base *common.MsgBase

+ Entity *GrantEntity

+ Type OperatePrivilegeType

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

+ func (*OperatePrivilegeRequest) ProtoMessage()

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

+ func (x *OperatePrivilegeRequest) GetEntity() *GrantEntity

+ func (x *OperatePrivilegeRequest) GetType() OperatePrivilegeType

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

+ func (x *OperatePrivilegeRequest) Reset()

+ func (x *OperatePrivilegeRequest) String() string

+ type OperatePrivilegeType int32

+ const OperatePrivilegeType_Grant

+ const OperatePrivilegeType_Revoke

+ func (OperatePrivilegeType) Descriptor() protoreflect.EnumDescriptor

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

+ func (OperatePrivilegeType) Type() protoreflect.EnumType

+ func (x OperatePrivilegeType) Enum() *OperatePrivilegeType

+ func (x OperatePrivilegeType) Number() protoreflect.EnumNumber

+ func (x OperatePrivilegeType) String() string

+ type OperateUserRoleRequest struct

+ Base *common.MsgBase

+ RoleName string

+ Type OperateUserRoleType

+ Username string

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

+ func (*OperateUserRoleRequest) ProtoMessage()

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

+ func (x *OperateUserRoleRequest) GetRoleName() string

+ func (x *OperateUserRoleRequest) GetType() OperateUserRoleType

+ func (x *OperateUserRoleRequest) GetUsername() string

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

+ func (x *OperateUserRoleRequest) Reset()

+ func (x *OperateUserRoleRequest) String() string

+ type OperateUserRoleType int32

+ const OperateUserRoleType_AddUserToRole

+ const OperateUserRoleType_RemoveUserFromRole

+ func (OperateUserRoleType) Descriptor() protoreflect.EnumDescriptor

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

+ func (OperateUserRoleType) Type() protoreflect.EnumType

+ func (x OperateUserRoleType) Enum() *OperateUserRoleType

+ func (x OperateUserRoleType) Number() protoreflect.EnumNumber

+ func (x OperateUserRoleType) String() string

type PersistentSegmentInfo

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

+ type PrincipalEntity struct

+ Principal isPrincipalEntity_Principal

+ PrincipalType string

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

+ func (*PrincipalEntity) ProtoMessage()

+ func (m *PrincipalEntity) GetPrincipal() isPrincipalEntity_Principal

+ func (x *PrincipalEntity) GetPrincipalType() string

+ func (x *PrincipalEntity) GetRole() *RoleEntity

+ func (x *PrincipalEntity) GetUser() *UserEntity

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

+ func (x *PrincipalEntity) Reset()

+ func (x *PrincipalEntity) String() string

+ type PrincipalEntity_Role struct

+ Role *RoleEntity

+ type PrincipalEntity_User struct

+ User *UserEntity

+ type PrivilegeEntity struct

+ Name string

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

+ func (*PrivilegeEntity) ProtoMessage()

+ func (x *PrivilegeEntity) GetName() string

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

+ func (x *PrivilegeEntity) Reset()

+ func (x *PrivilegeEntity) String() string

type QueryRequest

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

type QueryResults

+ CollectionName string

+ func (x *QueryResults) GetCollectionName() string

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

type QuerySegmentInfo

+ NodeIds []int64

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

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

type RegisterLinkRequest

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

type RegisterLinkResponse

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

type ReleaseCollectionRequest

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

type ReleasePartitionsRequest

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

+ type ReplicaInfo struct

+ CollectionID int64

+ NodeIds []int64

+ PartitionIds []int64

+ ReplicaID int64

+ ShardReplicas []*ShardReplica

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

+ func (*ReplicaInfo) ProtoMessage()

+ func (x *ReplicaInfo) GetCollectionID() int64

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

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

+ func (x *ReplicaInfo) GetReplicaID() int64

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

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

+ func (x *ReplicaInfo) Reset()

+ func (x *ReplicaInfo) String() string

+ type ResourceEntity struct

+ Type string

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

+ func (*ResourceEntity) ProtoMessage()

+ func (x *ResourceEntity) GetType() string

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

+ func (x *ResourceEntity) Reset()

+ func (x *ResourceEntity) String() string

+ type ResourceResult struct

+ Privileges []*PrivilegeEntity

+ Resource *ResourceEntity

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

+ func (*ResourceResult) ProtoMessage()

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

+ func (x *ResourceResult) GetResource() *ResourceEntity

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

+ func (x *ResourceResult) Reset()

+ func (x *ResourceResult) String() string

+ type RoleEntity struct

+ Name string

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

+ func (*RoleEntity) ProtoMessage()

+ func (x *RoleEntity) GetName() string

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

+ func (x *RoleEntity) Reset()

+ func (x *RoleEntity) String() string

+ type RoleResult struct

+ Role *RoleEntity

+ Users []*UserEntity

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

+ func (*RoleResult) ProtoMessage()

+ func (x *RoleResult) GetRole() *RoleEntity

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

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

+ func (x *RoleResult) Reset()

+ func (x *RoleResult) String() string

type SearchRequest

+ Nq int64

+ func (x *SearchRequest) GetNq() int64

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

type SearchResults

+ CollectionName string

+ func (x *SearchResults) GetCollectionName() string

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

+ type SelectGrantRequest struct

+ Base *common.MsgBase

+ Entity *GrantEntity

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

+ func (*SelectGrantRequest) ProtoMessage()

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

+ func (x *SelectGrantRequest) GetEntity() *GrantEntity

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

+ func (x *SelectGrantRequest) Reset()

+ func (x *SelectGrantRequest) String() string

+ type SelectGrantResponse struct

+ Entities []*GrantEntity

+ Status *common.Status

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

+ func (*SelectGrantResponse) ProtoMessage()

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

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

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

+ func (x *SelectGrantResponse) Reset()

+ func (x *SelectGrantResponse) String() string

+ type SelectResourceRequest struct

+ Base *common.MsgBase

+ Entity *ResourceEntity

+ IncludePrivilegeInfo bool

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

+ func (*SelectResourceRequest) ProtoMessage()

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

+ func (x *SelectResourceRequest) GetEntity() *ResourceEntity

+ func (x *SelectResourceRequest) GetIncludePrivilegeInfo() bool

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

+ func (x *SelectResourceRequest) Reset()

+ func (x *SelectResourceRequest) String() string

+ type SelectResourceResponse struct

+ Results []*ResourceResult

+ Status *common.Status

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

+ func (*SelectResourceResponse) ProtoMessage()

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

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

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

+ func (x *SelectResourceResponse) Reset()

+ func (x *SelectResourceResponse) String() string

+ type SelectRoleRequest struct

+ Base *common.MsgBase

+ IncludeUserInfo bool

+ Role *RoleEntity

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

+ func (*SelectRoleRequest) ProtoMessage()

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

+ func (x *SelectRoleRequest) GetIncludeUserInfo() bool

+ func (x *SelectRoleRequest) GetRole() *RoleEntity

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

+ func (x *SelectRoleRequest) Reset()

+ func (x *SelectRoleRequest) String() string

+ type SelectRoleResponse struct

+ Results []*RoleResult

+ Status *common.Status

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

+ func (*SelectRoleResponse) ProtoMessage()

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

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

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

+ func (x *SelectRoleResponse) Reset()

+ func (x *SelectRoleResponse) String() string

+ type SelectUserRequest struct

+ Base *common.MsgBase

+ IncludeRoleInfo bool

+ User *UserEntity

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

+ func (*SelectUserRequest) ProtoMessage()

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

+ func (x *SelectUserRequest) GetIncludeRoleInfo() bool

+ func (x *SelectUserRequest) GetUser() *UserEntity

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

+ func (x *SelectUserRequest) Reset()

+ func (x *SelectUserRequest) String() string

+ type SelectUserResponse struct

+ Result []*UserResult

+ Status *common.Status

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

+ func (*SelectUserResponse) ProtoMessage()

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

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

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

+ func (x *SelectUserResponse) Reset()

+ func (x *SelectUserResponse) String() string

+ type ShardReplica struct

+ DmChannelName string

+ LeaderAddr string

+ LeaderID int64

+ NodeIds []int64

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

+ func (*ShardReplica) ProtoMessage()

+ func (x *ShardReplica) GetDmChannelName() string

+ func (x *ShardReplica) GetLeaderAddr() string

+ func (x *ShardReplica) GetLeaderID() int64

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

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

+ func (x *ShardReplica) Reset()

+ func (x *ShardReplica) String() string

type ShowCollectionsRequest

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

type ShowCollectionsResponse

+ QueryServiceAvailable []bool

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

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

type ShowPartitionsRequest

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

type ShowPartitionsResponse

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

type ShowSegmentsRequest

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

type ShowSegmentsResponse

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

type ShowType

+ func (ShowType) Descriptor() protoreflect.EnumDescriptor

+ func (ShowType) Type() protoreflect.EnumType

+ func (x ShowType) Enum() *ShowType

+ func (x ShowType) Number() protoreflect.EnumNumber

type StringResponse

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

type UnimplementedMilvusServiceServer

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type UpdateCredentialRequest struct

+ Base *common.MsgBase

+ CreatedUtcTimestamps uint64

+ ModifiedUtcTimestamps uint64

+ NewPassword string

+ OldPassword string

+ Username string

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

+ func (*UpdateCredentialRequest) ProtoMessage()

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

+ func (x *UpdateCredentialRequest) GetCreatedUtcTimestamps() uint64

+ func (x *UpdateCredentialRequest) GetModifiedUtcTimestamps() uint64

+ func (x *UpdateCredentialRequest) GetNewPassword() string

+ func (x *UpdateCredentialRequest) GetOldPassword() string

+ func (x *UpdateCredentialRequest) GetUsername() string

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

+ func (x *UpdateCredentialRequest) Reset()

+ func (x *UpdateCredentialRequest) String() string

+ type UserEntity struct

+ Name string

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

+ func (*UserEntity) ProtoMessage()

+ func (x *UserEntity) GetName() string

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

+ func (x *UserEntity) Reset()

+ func (x *UserEntity) String() string

+ type UserResult struct

+ Roles []*RoleEntity

+ User *UserEntity

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

+ func (*UserResult) ProtoMessage()

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

+ func (x *UserResult) GetUser() *UserEntity

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

+ func (x *UserResult) Reset()

+ func (x *UserResult) String() string

type VectorIDs

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

type VectorsArray

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

v2.0.0

Jan 26, 2022

Changes in this version

+ var PlaceholderType_name = map[int32]string

+ var PlaceholderType_value = map[string]int32

+ var ShowType_name = map[int32]string

+ var ShowType_value = map[string]int32

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

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

+ type AlterAliasRequest struct

+ Alias string

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AlterAliasRequest) ProtoMessage()

+ func (m *AlterAliasRequest) GetAlias() string

+ func (m *AlterAliasRequest) GetBase() *common.MsgBase

+ func (m *AlterAliasRequest) GetCollectionName() string

+ func (m *AlterAliasRequest) GetDbName() string

+ func (m *AlterAliasRequest) Reset()

+ func (m *AlterAliasRequest) String() string

+ func (m *AlterAliasRequest) XXX_DiscardUnknown()

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

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

+ func (m *AlterAliasRequest) XXX_Size() int

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

+ type BoolResponse struct

+ Status *common.Status

+ Value bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BoolResponse) ProtoMessage()

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

+ func (m *BoolResponse) GetValue() bool

+ func (m *BoolResponse) Reset()

+ func (m *BoolResponse) String() string

+ func (m *BoolResponse) XXX_DiscardUnknown()

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

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

+ func (m *BoolResponse) XXX_Size() int

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

+ type CalcDistanceRequest struct

+ Base *common.MsgBase

+ OpLeft *VectorsArray

+ OpRight *VectorsArray

+ Params []*common.KeyValuePair

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CalcDistanceRequest) ProtoMessage()

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

+ func (m *CalcDistanceRequest) GetOpLeft() *VectorsArray

+ func (m *CalcDistanceRequest) GetOpRight() *VectorsArray

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

+ func (m *CalcDistanceRequest) Reset()

+ func (m *CalcDistanceRequest) String() string

+ func (m *CalcDistanceRequest) XXX_DiscardUnknown()

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

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

+ func (m *CalcDistanceRequest) XXX_Size() int

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

+ type CalcDistanceResults struct

+ Array isCalcDistanceResults_Array

+ Status *common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CalcDistanceResults) ProtoMessage()

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

+ func (m *CalcDistanceResults) GetArray() isCalcDistanceResults_Array

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

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

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

+ func (m *CalcDistanceResults) Reset()

+ func (m *CalcDistanceResults) String() string

+ func (m *CalcDistanceResults) XXX_DiscardUnknown()

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

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

+ func (m *CalcDistanceResults) XXX_Size() int

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

+ type CalcDistanceResults_FloatDist struct

+ FloatDist *schema.FloatArray

+ type CalcDistanceResults_IntDist struct

+ IntDist *schema.IntArray

+ type CompactionMergeInfo struct

+ Sources []int64

+ Target int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CompactionMergeInfo) ProtoMessage()

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

+ func (m *CompactionMergeInfo) GetTarget() int64

+ func (m *CompactionMergeInfo) Reset()

+ func (m *CompactionMergeInfo) String() string

+ func (m *CompactionMergeInfo) XXX_DiscardUnknown()

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

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

+ func (m *CompactionMergeInfo) XXX_Size() int

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

+ type CreateAliasRequest struct

+ Alias string

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateAliasRequest) ProtoMessage()

+ func (m *CreateAliasRequest) GetAlias() string

+ func (m *CreateAliasRequest) GetBase() *common.MsgBase

+ func (m *CreateAliasRequest) GetCollectionName() string

+ func (m *CreateAliasRequest) GetDbName() string

+ func (m *CreateAliasRequest) Reset()

+ func (m *CreateAliasRequest) String() string

+ func (m *CreateAliasRequest) XXX_DiscardUnknown()

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

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

+ func (m *CreateAliasRequest) XXX_Size() int

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

+ type CreateCollectionRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ ConsistencyLevel common.ConsistencyLevel

+ DbName string

+ Schema []byte

+ ShardsNum int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateCollectionRequest) ProtoMessage()

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

+ func (m *CreateCollectionRequest) GetCollectionName() string

+ func (m *CreateCollectionRequest) GetConsistencyLevel() common.ConsistencyLevel

+ func (m *CreateCollectionRequest) GetDbName() string

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

+ func (m *CreateCollectionRequest) GetShardsNum() int32

+ func (m *CreateCollectionRequest) Reset()

+ func (m *CreateCollectionRequest) String() string

+ func (m *CreateCollectionRequest) XXX_DiscardUnknown()

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

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

+ func (m *CreateCollectionRequest) XXX_Size() int

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

+ type CreateIndexRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ ExtraParams []*common.KeyValuePair

+ FieldName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateIndexRequest) ProtoMessage()

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

+ func (m *CreateIndexRequest) GetCollectionName() string

+ func (m *CreateIndexRequest) GetDbName() string

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

+ func (m *CreateIndexRequest) GetFieldName() string

+ func (m *CreateIndexRequest) Reset()

+ func (m *CreateIndexRequest) String() string

+ func (m *CreateIndexRequest) XXX_DiscardUnknown()

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

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

+ func (m *CreateIndexRequest) XXX_Size() int

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

+ type CreatePartitionRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ PartitionName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreatePartitionRequest) ProtoMessage()

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

+ func (m *CreatePartitionRequest) GetCollectionName() string

+ func (m *CreatePartitionRequest) GetDbName() string

+ func (m *CreatePartitionRequest) GetPartitionName() string

+ func (m *CreatePartitionRequest) Reset()

+ func (m *CreatePartitionRequest) String() string

+ func (m *CreatePartitionRequest) XXX_DiscardUnknown()

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

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

+ func (m *CreatePartitionRequest) XXX_Size() int

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

+ type DeleteRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ Expr string

+ HashKeys []uint32

+ PartitionName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteRequest) ProtoMessage()

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

+ func (m *DeleteRequest) GetCollectionName() string

+ func (m *DeleteRequest) GetDbName() string

+ func (m *DeleteRequest) GetExpr() string

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

+ func (m *DeleteRequest) GetPartitionName() string

+ func (m *DeleteRequest) Reset()

+ func (m *DeleteRequest) String() string

+ func (m *DeleteRequest) XXX_DiscardUnknown()

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

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

+ func (m *DeleteRequest) XXX_Size() int

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

+ type DescribeCollectionRequest struct

+ Base *common.MsgBase

+ CollectionID int64

+ CollectionName string

+ DbName string

+ TimeStamp uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DescribeCollectionRequest) ProtoMessage()

+ func (m *DescribeCollectionRequest) GetBase() *common.MsgBase

+ func (m *DescribeCollectionRequest) GetCollectionID() int64

+ func (m *DescribeCollectionRequest) GetCollectionName() string

+ func (m *DescribeCollectionRequest) GetDbName() string

+ func (m *DescribeCollectionRequest) GetTimeStamp() uint64

+ func (m *DescribeCollectionRequest) Reset()

+ func (m *DescribeCollectionRequest) String() string

+ func (m *DescribeCollectionRequest) XXX_DiscardUnknown()

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

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

+ func (m *DescribeCollectionRequest) XXX_Size() int

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

+ type DescribeCollectionResponse struct

+ Aliases []string

+ CollectionID int64

+ ConsistencyLevel common.ConsistencyLevel

+ CreatedTimestamp uint64

+ CreatedUtcTimestamp uint64

+ PhysicalChannelNames []string

+ Schema *schema.CollectionSchema

+ ShardsNum int32

+ StartPositions []*common.KeyDataPair

+ Status *common.Status

+ VirtualChannelNames []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DescribeCollectionResponse) ProtoMessage()

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

+ func (m *DescribeCollectionResponse) GetCollectionID() int64

+ func (m *DescribeCollectionResponse) GetConsistencyLevel() common.ConsistencyLevel

+ func (m *DescribeCollectionResponse) GetCreatedTimestamp() uint64

+ func (m *DescribeCollectionResponse) GetCreatedUtcTimestamp() uint64

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

+ func (m *DescribeCollectionResponse) GetSchema() *schema.CollectionSchema

+ func (m *DescribeCollectionResponse) GetShardsNum() int32

+ func (m *DescribeCollectionResponse) GetStartPositions() []*common.KeyDataPair

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

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

+ func (m *DescribeCollectionResponse) Reset()

+ func (m *DescribeCollectionResponse) String() string

+ func (m *DescribeCollectionResponse) XXX_DiscardUnknown()

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

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

+ func (m *DescribeCollectionResponse) XXX_Size() int

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

+ type DescribeIndexRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ FieldName string

+ IndexName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DescribeIndexRequest) ProtoMessage()

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

+ func (m *DescribeIndexRequest) GetCollectionName() string

+ func (m *DescribeIndexRequest) GetDbName() string

+ func (m *DescribeIndexRequest) GetFieldName() string

+ func (m *DescribeIndexRequest) GetIndexName() string

+ func (m *DescribeIndexRequest) Reset()

+ func (m *DescribeIndexRequest) String() string

+ func (m *DescribeIndexRequest) XXX_DiscardUnknown()

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

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

+ func (m *DescribeIndexRequest) XXX_Size() int

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

+ type DescribeIndexResponse struct

+ IndexDescriptions []*IndexDescription

+ Status *common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DescribeIndexResponse) ProtoMessage()

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

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

+ func (m *DescribeIndexResponse) Reset()

+ func (m *DescribeIndexResponse) String() string

+ func (m *DescribeIndexResponse) XXX_DiscardUnknown()

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

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

+ func (m *DescribeIndexResponse) XXX_Size() int

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

+ type DescribeSegmentRequest struct

+ Base *common.MsgBase

+ CollectionID int64

+ SegmentID int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DescribeSegmentRequest) ProtoMessage()

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

+ func (m *DescribeSegmentRequest) GetCollectionID() int64

+ func (m *DescribeSegmentRequest) GetSegmentID() int64

+ func (m *DescribeSegmentRequest) Reset()

+ func (m *DescribeSegmentRequest) String() string

+ func (m *DescribeSegmentRequest) XXX_DiscardUnknown()

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

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

+ func (m *DescribeSegmentRequest) XXX_Size() int

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

+ type DescribeSegmentResponse struct

+ BuildID int64

+ EnableIndex bool

+ FieldID int64

+ IndexID int64

+ Status *common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DescribeSegmentResponse) ProtoMessage()

+ func (m *DescribeSegmentResponse) GetBuildID() int64

+ func (m *DescribeSegmentResponse) GetEnableIndex() bool

+ func (m *DescribeSegmentResponse) GetFieldID() int64

+ func (m *DescribeSegmentResponse) GetIndexID() int64

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

+ func (m *DescribeSegmentResponse) Reset()

+ func (m *DescribeSegmentResponse) String() string

+ func (m *DescribeSegmentResponse) XXX_DiscardUnknown()

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

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

+ func (m *DescribeSegmentResponse) XXX_Size() int

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

+ type DropAliasRequest struct

+ Alias string

+ Base *common.MsgBase

+ DbName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DropAliasRequest) ProtoMessage()

+ func (m *DropAliasRequest) GetAlias() string

+ func (m *DropAliasRequest) GetBase() *common.MsgBase

+ func (m *DropAliasRequest) GetDbName() string

+ func (m *DropAliasRequest) Reset()

+ func (m *DropAliasRequest) String() string

+ func (m *DropAliasRequest) XXX_DiscardUnknown()

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

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

+ func (m *DropAliasRequest) XXX_Size() int

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

+ type DropCollectionRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DropCollectionRequest) ProtoMessage()

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

+ func (m *DropCollectionRequest) GetCollectionName() string

+ func (m *DropCollectionRequest) GetDbName() string

+ func (m *DropCollectionRequest) Reset()

+ func (m *DropCollectionRequest) String() string

+ func (m *DropCollectionRequest) XXX_DiscardUnknown()

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

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

+ func (m *DropCollectionRequest) XXX_Size() int

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

+ type DropIndexRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ FieldName string

+ IndexName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DropIndexRequest) ProtoMessage()

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

+ func (m *DropIndexRequest) GetCollectionName() string

+ func (m *DropIndexRequest) GetDbName() string

+ func (m *DropIndexRequest) GetFieldName() string

+ func (m *DropIndexRequest) GetIndexName() string

+ func (m *DropIndexRequest) Reset()

+ func (m *DropIndexRequest) String() string

+ func (m *DropIndexRequest) XXX_DiscardUnknown()

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

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

+ func (m *DropIndexRequest) XXX_Size() int

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

+ type DropPartitionRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ PartitionName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DropPartitionRequest) ProtoMessage()

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

+ func (m *DropPartitionRequest) GetCollectionName() string

+ func (m *DropPartitionRequest) GetDbName() string

+ func (m *DropPartitionRequest) GetPartitionName() string

+ func (m *DropPartitionRequest) Reset()

+ func (m *DropPartitionRequest) String() string

+ func (m *DropPartitionRequest) XXX_DiscardUnknown()

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

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

+ func (m *DropPartitionRequest) XXX_Size() int

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

+ type DummyRequest struct

+ RequestType string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DummyRequest) ProtoMessage()

+ func (m *DummyRequest) GetRequestType() string

+ func (m *DummyRequest) Reset()

+ func (m *DummyRequest) String() string

+ func (m *DummyRequest) XXX_DiscardUnknown()

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

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

+ func (m *DummyRequest) XXX_Size() int

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

+ type DummyResponse struct

+ Response string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DummyResponse) ProtoMessage()

+ func (m *DummyResponse) GetResponse() string

+ func (m *DummyResponse) Reset()

+ func (m *DummyResponse) String() string

+ func (m *DummyResponse) XXX_DiscardUnknown()

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

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

+ func (m *DummyResponse) XXX_Size() int

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

+ type FlushRequest struct

+ Base *common.MsgBase

+ CollectionNames []string

+ DbName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*FlushRequest) ProtoMessage()

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

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

+ func (m *FlushRequest) GetDbName() string

+ func (m *FlushRequest) Reset()

+ func (m *FlushRequest) String() string

+ func (m *FlushRequest) XXX_DiscardUnknown()

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

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

+ func (m *FlushRequest) XXX_Size() int

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

+ type FlushResponse struct

+ CollSegIDs map[string]*schema.LongArray

+ DbName string

+ Status *common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*FlushResponse) ProtoMessage()

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

+ func (m *FlushResponse) GetDbName() string

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

+ func (m *FlushResponse) Reset()

+ func (m *FlushResponse) String() string

+ func (m *FlushResponse) XXX_DiscardUnknown()

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

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

+ func (m *FlushResponse) XXX_Size() int

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

+ type GetCollectionStatisticsRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetCollectionStatisticsRequest) ProtoMessage()

+ func (m *GetCollectionStatisticsRequest) GetBase() *common.MsgBase

+ func (m *GetCollectionStatisticsRequest) GetCollectionName() string

+ func (m *GetCollectionStatisticsRequest) GetDbName() string

+ func (m *GetCollectionStatisticsRequest) Reset()

+ func (m *GetCollectionStatisticsRequest) String() string

+ func (m *GetCollectionStatisticsRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetCollectionStatisticsRequest) XXX_Size() int

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

+ type GetCollectionStatisticsResponse struct

+ Stats []*common.KeyValuePair

+ Status *common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetCollectionStatisticsResponse) ProtoMessage()

+ func (m *GetCollectionStatisticsResponse) GetStats() []*common.KeyValuePair

+ func (m *GetCollectionStatisticsResponse) GetStatus() *common.Status

+ func (m *GetCollectionStatisticsResponse) Reset()

+ func (m *GetCollectionStatisticsResponse) String() string

+ func (m *GetCollectionStatisticsResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetCollectionStatisticsResponse) XXX_Size() int

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

+ type GetCompactionPlansRequest struct

+ CompactionID int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetCompactionPlansRequest) ProtoMessage()

+ func (m *GetCompactionPlansRequest) GetCompactionID() int64

+ func (m *GetCompactionPlansRequest) Reset()

+ func (m *GetCompactionPlansRequest) String() string

+ func (m *GetCompactionPlansRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetCompactionPlansRequest) XXX_Size() int

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

+ type GetCompactionPlansResponse struct

+ MergeInfos []*CompactionMergeInfo

+ State common.CompactionState

+ Status *common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetCompactionPlansResponse) ProtoMessage()

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

+ func (m *GetCompactionPlansResponse) GetState() common.CompactionState

+ func (m *GetCompactionPlansResponse) GetStatus() *common.Status

+ func (m *GetCompactionPlansResponse) Reset()

+ func (m *GetCompactionPlansResponse) String() string

+ func (m *GetCompactionPlansResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetCompactionPlansResponse) XXX_Size() int

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

+ type GetCompactionStateRequest struct

+ CompactionID int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetCompactionStateRequest) ProtoMessage()

+ func (m *GetCompactionStateRequest) GetCompactionID() int64

+ func (m *GetCompactionStateRequest) Reset()

+ func (m *GetCompactionStateRequest) String() string

+ func (m *GetCompactionStateRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetCompactionStateRequest) XXX_Size() int

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

+ type GetCompactionStateResponse struct

+ CompletedPlanNo int64

+ ExecutingPlanNo int64

+ State common.CompactionState

+ Status *common.Status

+ TimeoutPlanNo int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetCompactionStateResponse) ProtoMessage()

+ func (m *GetCompactionStateResponse) GetCompletedPlanNo() int64

+ func (m *GetCompactionStateResponse) GetExecutingPlanNo() int64

+ func (m *GetCompactionStateResponse) GetState() common.CompactionState

+ func (m *GetCompactionStateResponse) GetStatus() *common.Status

+ func (m *GetCompactionStateResponse) GetTimeoutPlanNo() int64

+ func (m *GetCompactionStateResponse) Reset()

+ func (m *GetCompactionStateResponse) String() string

+ func (m *GetCompactionStateResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetCompactionStateResponse) XXX_Size() int

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

+ type GetFlushStateRequest struct

+ SegmentIDs []int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetFlushStateRequest) ProtoMessage()

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

+ func (m *GetFlushStateRequest) Reset()

+ func (m *GetFlushStateRequest) String() string

+ func (m *GetFlushStateRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetFlushStateRequest) XXX_Size() int

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

+ type GetFlushStateResponse struct

+ Flushed bool

+ Status *common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetFlushStateResponse) ProtoMessage()

+ func (m *GetFlushStateResponse) GetFlushed() bool

+ func (m *GetFlushStateResponse) GetStatus() *common.Status

+ func (m *GetFlushStateResponse) Reset()

+ func (m *GetFlushStateResponse) String() string

+ func (m *GetFlushStateResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetFlushStateResponse) XXX_Size() int

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

+ type GetIndexBuildProgressRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ FieldName string

+ IndexName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetIndexBuildProgressRequest) ProtoMessage()

+ func (m *GetIndexBuildProgressRequest) GetBase() *common.MsgBase

+ func (m *GetIndexBuildProgressRequest) GetCollectionName() string

+ func (m *GetIndexBuildProgressRequest) GetDbName() string

+ func (m *GetIndexBuildProgressRequest) GetFieldName() string

+ func (m *GetIndexBuildProgressRequest) GetIndexName() string

+ func (m *GetIndexBuildProgressRequest) Reset()

+ func (m *GetIndexBuildProgressRequest) String() string

+ func (m *GetIndexBuildProgressRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetIndexBuildProgressRequest) XXX_Size() int

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

+ type GetIndexBuildProgressResponse struct

+ IndexedRows int64

+ Status *common.Status

+ TotalRows int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetIndexBuildProgressResponse) ProtoMessage()

+ func (m *GetIndexBuildProgressResponse) GetIndexedRows() int64

+ func (m *GetIndexBuildProgressResponse) GetStatus() *common.Status

+ func (m *GetIndexBuildProgressResponse) GetTotalRows() int64

+ func (m *GetIndexBuildProgressResponse) Reset()

+ func (m *GetIndexBuildProgressResponse) String() string

+ func (m *GetIndexBuildProgressResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetIndexBuildProgressResponse) XXX_Size() int

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

+ type GetIndexStateRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ FieldName string

+ IndexName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetIndexStateRequest) ProtoMessage()

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

+ func (m *GetIndexStateRequest) GetCollectionName() string

+ func (m *GetIndexStateRequest) GetDbName() string

+ func (m *GetIndexStateRequest) GetFieldName() string

+ func (m *GetIndexStateRequest) GetIndexName() string

+ func (m *GetIndexStateRequest) Reset()

+ func (m *GetIndexStateRequest) String() string

+ func (m *GetIndexStateRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetIndexStateRequest) XXX_Size() int

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

+ type GetIndexStateResponse struct

+ FailReason string

+ State common.IndexState

+ Status *common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetIndexStateResponse) ProtoMessage()

+ func (m *GetIndexStateResponse) GetFailReason() string

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

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

+ func (m *GetIndexStateResponse) Reset()

+ func (m *GetIndexStateResponse) String() string

+ func (m *GetIndexStateResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetIndexStateResponse) XXX_Size() int

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

+ type GetMetricsRequest struct

+ Base *common.MsgBase

+ Request string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetMetricsRequest) ProtoMessage()

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

+ func (m *GetMetricsRequest) GetRequest() string

+ func (m *GetMetricsRequest) Reset()

+ func (m *GetMetricsRequest) String() string

+ func (m *GetMetricsRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetMetricsRequest) XXX_Size() int

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

+ type GetMetricsResponse struct

+ ComponentName string

+ Response string

+ Status *common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetMetricsResponse) ProtoMessage()

+ func (m *GetMetricsResponse) GetComponentName() string

+ func (m *GetMetricsResponse) GetResponse() string

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

+ func (m *GetMetricsResponse) Reset()

+ func (m *GetMetricsResponse) String() string

+ func (m *GetMetricsResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetMetricsResponse) XXX_Size() int

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

+ type GetPartitionStatisticsRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ PartitionName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetPartitionStatisticsRequest) ProtoMessage()

+ func (m *GetPartitionStatisticsRequest) GetBase() *common.MsgBase

+ func (m *GetPartitionStatisticsRequest) GetCollectionName() string

+ func (m *GetPartitionStatisticsRequest) GetDbName() string

+ func (m *GetPartitionStatisticsRequest) GetPartitionName() string

+ func (m *GetPartitionStatisticsRequest) Reset()

+ func (m *GetPartitionStatisticsRequest) String() string

+ func (m *GetPartitionStatisticsRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetPartitionStatisticsRequest) XXX_Size() int

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

+ type GetPartitionStatisticsResponse struct

+ Stats []*common.KeyValuePair

+ Status *common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetPartitionStatisticsResponse) ProtoMessage()

+ func (m *GetPartitionStatisticsResponse) GetStats() []*common.KeyValuePair

+ func (m *GetPartitionStatisticsResponse) GetStatus() *common.Status

+ func (m *GetPartitionStatisticsResponse) Reset()

+ func (m *GetPartitionStatisticsResponse) String() string

+ func (m *GetPartitionStatisticsResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetPartitionStatisticsResponse) XXX_Size() int

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

+ type GetPersistentSegmentInfoRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetPersistentSegmentInfoRequest) ProtoMessage()

+ func (m *GetPersistentSegmentInfoRequest) GetBase() *common.MsgBase

+ func (m *GetPersistentSegmentInfoRequest) GetCollectionName() string

+ func (m *GetPersistentSegmentInfoRequest) GetDbName() string

+ func (m *GetPersistentSegmentInfoRequest) Reset()

+ func (m *GetPersistentSegmentInfoRequest) String() string

+ func (m *GetPersistentSegmentInfoRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetPersistentSegmentInfoRequest) XXX_Size() int

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

+ type GetPersistentSegmentInfoResponse struct

+ Infos []*PersistentSegmentInfo

+ Status *common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetPersistentSegmentInfoResponse) ProtoMessage()

+ func (m *GetPersistentSegmentInfoResponse) GetInfos() []*PersistentSegmentInfo

+ func (m *GetPersistentSegmentInfoResponse) GetStatus() *common.Status

+ func (m *GetPersistentSegmentInfoResponse) Reset()

+ func (m *GetPersistentSegmentInfoResponse) String() string

+ func (m *GetPersistentSegmentInfoResponse) XXX_DiscardUnknown()

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

+ func (m *GetPersistentSegmentInfoResponse) XXX_Merge(src proto.Message)

+ func (m *GetPersistentSegmentInfoResponse) XXX_Size() int

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

+ type GetQuerySegmentInfoRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetQuerySegmentInfoRequest) ProtoMessage()

+ func (m *GetQuerySegmentInfoRequest) GetBase() *common.MsgBase

+ func (m *GetQuerySegmentInfoRequest) GetCollectionName() string

+ func (m *GetQuerySegmentInfoRequest) GetDbName() string

+ func (m *GetQuerySegmentInfoRequest) Reset()

+ func (m *GetQuerySegmentInfoRequest) String() string

+ func (m *GetQuerySegmentInfoRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetQuerySegmentInfoRequest) XXX_Size() int

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

+ type GetQuerySegmentInfoResponse struct

+ Infos []*QuerySegmentInfo

+ Status *common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetQuerySegmentInfoResponse) ProtoMessage()

+ func (m *GetQuerySegmentInfoResponse) GetInfos() []*QuerySegmentInfo

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

+ func (m *GetQuerySegmentInfoResponse) Reset()

+ func (m *GetQuerySegmentInfoResponse) String() string

+ func (m *GetQuerySegmentInfoResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetQuerySegmentInfoResponse) XXX_Size() int

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

+ type HasCollectionRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ TimeStamp uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*HasCollectionRequest) ProtoMessage()

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

+ func (m *HasCollectionRequest) GetCollectionName() string

+ func (m *HasCollectionRequest) GetDbName() string

+ func (m *HasCollectionRequest) GetTimeStamp() uint64

+ func (m *HasCollectionRequest) Reset()

+ func (m *HasCollectionRequest) String() string

+ func (m *HasCollectionRequest) XXX_DiscardUnknown()

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

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

+ func (m *HasCollectionRequest) XXX_Size() int

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

+ type HasPartitionRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ PartitionName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*HasPartitionRequest) ProtoMessage()

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

+ func (m *HasPartitionRequest) GetCollectionName() string

+ func (m *HasPartitionRequest) GetDbName() string

+ func (m *HasPartitionRequest) GetPartitionName() string

+ func (m *HasPartitionRequest) Reset()

+ func (m *HasPartitionRequest) String() string

+ func (m *HasPartitionRequest) XXX_DiscardUnknown()

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

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

+ func (m *HasPartitionRequest) XXX_Size() int

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

+ type Hits struct

+ IDs []int64

+ RowData [][]byte

+ Scores []float32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Hits) ProtoMessage()

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

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

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

+ func (m *Hits) Reset()

+ func (m *Hits) String() string

+ func (m *Hits) XXX_DiscardUnknown()

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

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

+ func (m *Hits) XXX_Size() int

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

+ type IndexDescription struct

+ FieldName string

+ IndexID int64

+ IndexName string

+ Params []*common.KeyValuePair

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*IndexDescription) ProtoMessage()

+ func (m *IndexDescription) GetFieldName() string

+ func (m *IndexDescription) GetIndexID() int64

+ func (m *IndexDescription) GetIndexName() string

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

+ func (m *IndexDescription) Reset()

+ func (m *IndexDescription) String() string

+ func (m *IndexDescription) XXX_DiscardUnknown()

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

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

+ func (m *IndexDescription) XXX_Size() int

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

+ type InsertRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ FieldsData []*schema.FieldData

+ HashKeys []uint32

+ NumRows uint32

+ PartitionName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*InsertRequest) ProtoMessage()

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

+ func (m *InsertRequest) GetCollectionName() string

+ func (m *InsertRequest) GetDbName() string

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

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

+ func (m *InsertRequest) GetNumRows() uint32

+ func (m *InsertRequest) GetPartitionName() string

+ func (m *InsertRequest) Reset()

+ func (m *InsertRequest) String() string

+ func (m *InsertRequest) XXX_DiscardUnknown()

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

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

+ func (m *InsertRequest) XXX_Size() int

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

+ type LoadBalanceRequest struct

+ Base *common.MsgBase

+ DstNodeIDs []int64

+ SealedSegmentIDs []int64

+ SrcNodeID int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LoadBalanceRequest) ProtoMessage()

+ func (m *LoadBalanceRequest) GetBase() *common.MsgBase

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

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

+ func (m *LoadBalanceRequest) GetSrcNodeID() int64

+ func (m *LoadBalanceRequest) Reset()

+ func (m *LoadBalanceRequest) String() string

+ func (m *LoadBalanceRequest) XXX_DiscardUnknown()

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

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

+ func (m *LoadBalanceRequest) XXX_Size() int

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

+ type LoadCollectionRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LoadCollectionRequest) ProtoMessage()

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

+ func (m *LoadCollectionRequest) GetCollectionName() string

+ func (m *LoadCollectionRequest) GetDbName() string

+ func (m *LoadCollectionRequest) Reset()

+ func (m *LoadCollectionRequest) String() string

+ func (m *LoadCollectionRequest) XXX_DiscardUnknown()

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

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

+ func (m *LoadCollectionRequest) XXX_Size() int

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

+ type LoadPartitionsRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ PartitionNames []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LoadPartitionsRequest) ProtoMessage()

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

+ func (m *LoadPartitionsRequest) GetCollectionName() string

+ func (m *LoadPartitionsRequest) GetDbName() string

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

+ func (m *LoadPartitionsRequest) Reset()

+ func (m *LoadPartitionsRequest) String() string

+ func (m *LoadPartitionsRequest) XXX_DiscardUnknown()

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

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

+ func (m *LoadPartitionsRequest) XXX_Size() int

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

+ type ManualCompactionRequest struct

+ CollectionID int64

+ Timetravel uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ManualCompactionRequest) ProtoMessage()

+ func (m *ManualCompactionRequest) GetCollectionID() int64

+ func (m *ManualCompactionRequest) GetTimetravel() uint64

+ func (m *ManualCompactionRequest) Reset()

+ func (m *ManualCompactionRequest) String() string

+ func (m *ManualCompactionRequest) XXX_DiscardUnknown()

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

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

+ func (m *ManualCompactionRequest) XXX_Size() int

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

+ type ManualCompactionResponse struct

+ CompactionID int64

+ Status *common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ManualCompactionResponse) ProtoMessage()

+ func (m *ManualCompactionResponse) GetCompactionID() int64

+ func (m *ManualCompactionResponse) GetStatus() *common.Status

+ func (m *ManualCompactionResponse) Reset()

+ func (m *ManualCompactionResponse) String() string

+ func (m *ManualCompactionResponse) XXX_DiscardUnknown()

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

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

+ func (m *ManualCompactionResponse) XXX_Size() int

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

+ type MilvusServiceClient interface

+ AlterAlias func(ctx context.Context, in *AlterAliasRequest, opts ...grpc.CallOption) (*common.Status, error)

+ CalcDistance func(ctx context.Context, in *CalcDistanceRequest, opts ...grpc.CallOption) (*CalcDistanceResults, error)

+ CreateAlias func(ctx context.Context, in *CreateAliasRequest, opts ...grpc.CallOption) (*common.Status, error)

+ CreateCollection func(ctx context.Context, in *CreateCollectionRequest, opts ...grpc.CallOption) (*common.Status, error)

+ CreateIndex func(ctx context.Context, in *CreateIndexRequest, opts ...grpc.CallOption) (*common.Status, error)

+ CreatePartition func(ctx context.Context, in *CreatePartitionRequest, opts ...grpc.CallOption) (*common.Status, error)

+ Delete func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*MutationResult, error)

+ DescribeCollection func(ctx context.Context, in *DescribeCollectionRequest, opts ...grpc.CallOption) (*DescribeCollectionResponse, error)

+ DescribeIndex func(ctx context.Context, in *DescribeIndexRequest, opts ...grpc.CallOption) (*DescribeIndexResponse, error)

+ DropAlias func(ctx context.Context, in *DropAliasRequest, opts ...grpc.CallOption) (*common.Status, error)

+ DropCollection func(ctx context.Context, in *DropCollectionRequest, opts ...grpc.CallOption) (*common.Status, error)

+ DropIndex func(ctx context.Context, in *DropIndexRequest, opts ...grpc.CallOption) (*common.Status, error)

+ DropPartition func(ctx context.Context, in *DropPartitionRequest, opts ...grpc.CallOption) (*common.Status, error)

+ Dummy func(ctx context.Context, in *DummyRequest, opts ...grpc.CallOption) (*DummyResponse, error)

+ Flush func(ctx context.Context, in *FlushRequest, opts ...grpc.CallOption) (*FlushResponse, error)

+ GetCollectionStatistics func(ctx context.Context, in *GetCollectionStatisticsRequest, ...) (*GetCollectionStatisticsResponse, error)

+ GetCompactionState func(ctx context.Context, in *GetCompactionStateRequest, opts ...grpc.CallOption) (*GetCompactionStateResponse, error)

+ GetCompactionStateWithPlans func(ctx context.Context, in *GetCompactionPlansRequest, opts ...grpc.CallOption) (*GetCompactionPlansResponse, error)

+ GetFlushState func(ctx context.Context, in *GetFlushStateRequest, opts ...grpc.CallOption) (*GetFlushStateResponse, error)

+ GetIndexBuildProgress func(ctx context.Context, in *GetIndexBuildProgressRequest, opts ...grpc.CallOption) (*GetIndexBuildProgressResponse, error)

+ GetIndexState func(ctx context.Context, in *GetIndexStateRequest, opts ...grpc.CallOption) (*GetIndexStateResponse, error)

+ GetMetrics func(ctx context.Context, in *GetMetricsRequest, opts ...grpc.CallOption) (*GetMetricsResponse, error)

+ GetPartitionStatistics func(ctx context.Context, in *GetPartitionStatisticsRequest, ...) (*GetPartitionStatisticsResponse, error)

+ GetPersistentSegmentInfo func(ctx context.Context, in *GetPersistentSegmentInfoRequest, ...) (*GetPersistentSegmentInfoResponse, error)

+ GetQuerySegmentInfo func(ctx context.Context, in *GetQuerySegmentInfoRequest, opts ...grpc.CallOption) (*GetQuerySegmentInfoResponse, error)

+ HasCollection func(ctx context.Context, in *HasCollectionRequest, opts ...grpc.CallOption) (*BoolResponse, error)

+ HasPartition func(ctx context.Context, in *HasPartitionRequest, opts ...grpc.CallOption) (*BoolResponse, error)

+ Insert func(ctx context.Context, in *InsertRequest, opts ...grpc.CallOption) (*MutationResult, error)

+ LoadBalance func(ctx context.Context, in *LoadBalanceRequest, opts ...grpc.CallOption) (*common.Status, error)

+ LoadCollection func(ctx context.Context, in *LoadCollectionRequest, opts ...grpc.CallOption) (*common.Status, error)

+ LoadPartitions func(ctx context.Context, in *LoadPartitionsRequest, opts ...grpc.CallOption) (*common.Status, error)

+ ManualCompaction func(ctx context.Context, in *ManualCompactionRequest, opts ...grpc.CallOption) (*ManualCompactionResponse, error)

+ Query func(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResults, error)

+ RegisterLink func(ctx context.Context, in *RegisterLinkRequest, opts ...grpc.CallOption) (*RegisterLinkResponse, error)

+ ReleaseCollection func(ctx context.Context, in *ReleaseCollectionRequest, opts ...grpc.CallOption) (*common.Status, error)

+ ReleasePartitions func(ctx context.Context, in *ReleasePartitionsRequest, opts ...grpc.CallOption) (*common.Status, error)

+ Search func(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResults, error)

+ ShowCollections func(ctx context.Context, in *ShowCollectionsRequest, opts ...grpc.CallOption) (*ShowCollectionsResponse, error)

+ ShowPartitions func(ctx context.Context, in *ShowPartitionsRequest, opts ...grpc.CallOption) (*ShowPartitionsResponse, error)

+ func NewMilvusServiceClient(cc *grpc.ClientConn) MilvusServiceClient

+ type MilvusServiceServer interface

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ Query func(context.Context, *QueryRequest) (*QueryResults, error)

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

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

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

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

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

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

+ type MutationResult struct

+ Acknowledged bool

+ DeleteCnt int64

+ ErrIndex []uint32

+ IDs *schema.IDs

+ InsertCnt int64

+ Status *common.Status

+ SuccIndex []uint32

+ Timestamp uint64

+ UpsertCnt int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MutationResult) ProtoMessage()

+ func (m *MutationResult) GetAcknowledged() bool

+ func (m *MutationResult) GetDeleteCnt() int64

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

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

+ func (m *MutationResult) GetInsertCnt() int64

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

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

+ func (m *MutationResult) GetTimestamp() uint64

+ func (m *MutationResult) GetUpsertCnt() int64

+ func (m *MutationResult) Reset()

+ func (m *MutationResult) String() string

+ func (m *MutationResult) XXX_DiscardUnknown()

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

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

+ func (m *MutationResult) XXX_Size() int

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

+ type PersistentSegmentInfo struct

+ CollectionID int64

+ NumRows int64

+ PartitionID int64

+ SegmentID int64

+ State common.SegmentState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PersistentSegmentInfo) ProtoMessage()

+ func (m *PersistentSegmentInfo) GetCollectionID() int64

+ func (m *PersistentSegmentInfo) GetNumRows() int64

+ func (m *PersistentSegmentInfo) GetPartitionID() int64

+ func (m *PersistentSegmentInfo) GetSegmentID() int64

+ func (m *PersistentSegmentInfo) GetState() common.SegmentState

+ func (m *PersistentSegmentInfo) Reset()

+ func (m *PersistentSegmentInfo) String() string

+ func (m *PersistentSegmentInfo) XXX_DiscardUnknown()

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

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

+ func (m *PersistentSegmentInfo) XXX_Size() int

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

+ type PlaceholderGroup struct

+ Placeholders []*PlaceholderValue

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PlaceholderGroup) ProtoMessage()

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

+ func (m *PlaceholderGroup) Reset()

+ func (m *PlaceholderGroup) String() string

+ func (m *PlaceholderGroup) XXX_DiscardUnknown()

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

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

+ func (m *PlaceholderGroup) XXX_Size() int

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

+ type PlaceholderType int32

+ const PlaceholderType_BinaryVector

+ const PlaceholderType_FloatVector

+ const PlaceholderType_None

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

+ func (x PlaceholderType) String() string

+ type PlaceholderValue struct

+ Tag string

+ Type PlaceholderType

+ Values [][]byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PlaceholderValue) ProtoMessage()

+ func (m *PlaceholderValue) GetTag() string

+ func (m *PlaceholderValue) GetType() PlaceholderType

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

+ func (m *PlaceholderValue) Reset()

+ func (m *PlaceholderValue) String() string

+ func (m *PlaceholderValue) XXX_DiscardUnknown()

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

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

+ func (m *PlaceholderValue) XXX_Size() int

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

+ type ProxyServiceClient interface

+ RegisterLink func(ctx context.Context, in *RegisterLinkRequest, opts ...grpc.CallOption) (*RegisterLinkResponse, error)

+ func NewProxyServiceClient(cc *grpc.ClientConn) ProxyServiceClient

+ type ProxyServiceServer interface

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

+ type QueryRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ Expr string

+ GuaranteeTimestamp uint64

+ OutputFields []string

+ PartitionNames []string

+ TravelTimestamp uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*QueryRequest) ProtoMessage()

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

+ func (m *QueryRequest) GetCollectionName() string

+ func (m *QueryRequest) GetDbName() string

+ func (m *QueryRequest) GetExpr() string

+ func (m *QueryRequest) GetGuaranteeTimestamp() uint64

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

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

+ func (m *QueryRequest) GetTravelTimestamp() uint64

+ func (m *QueryRequest) Reset()

+ func (m *QueryRequest) String() string

+ func (m *QueryRequest) XXX_DiscardUnknown()

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

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

+ func (m *QueryRequest) XXX_Size() int

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

+ type QueryResults struct

+ FieldsData []*schema.FieldData

+ Status *common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*QueryResults) ProtoMessage()

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

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

+ func (m *QueryResults) Reset()

+ func (m *QueryResults) String() string

+ func (m *QueryResults) XXX_DiscardUnknown()

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

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

+ func (m *QueryResults) XXX_Size() int

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

+ type QuerySegmentInfo struct

+ CollectionID int64

+ IndexID int64

+ IndexName string

+ MemSize int64

+ NodeID int64

+ NumRows int64

+ PartitionID int64

+ SegmentID int64

+ State common.SegmentState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*QuerySegmentInfo) ProtoMessage()

+ func (m *QuerySegmentInfo) GetCollectionID() int64

+ func (m *QuerySegmentInfo) GetIndexID() int64

+ func (m *QuerySegmentInfo) GetIndexName() string

+ func (m *QuerySegmentInfo) GetMemSize() int64

+ func (m *QuerySegmentInfo) GetNodeID() int64

+ func (m *QuerySegmentInfo) GetNumRows() int64

+ func (m *QuerySegmentInfo) GetPartitionID() int64

+ func (m *QuerySegmentInfo) GetSegmentID() int64

+ func (m *QuerySegmentInfo) GetState() common.SegmentState

+ func (m *QuerySegmentInfo) Reset()

+ func (m *QuerySegmentInfo) String() string

+ func (m *QuerySegmentInfo) XXX_DiscardUnknown()

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

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

+ func (m *QuerySegmentInfo) XXX_Size() int

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

+ type RegisterLinkRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RegisterLinkRequest) ProtoMessage()

+ func (m *RegisterLinkRequest) Reset()

+ func (m *RegisterLinkRequest) String() string

+ func (m *RegisterLinkRequest) XXX_DiscardUnknown()

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

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

+ func (m *RegisterLinkRequest) XXX_Size() int

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

+ type RegisterLinkResponse struct

+ Address *common.Address

+ Status *common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RegisterLinkResponse) ProtoMessage()

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

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

+ func (m *RegisterLinkResponse) Reset()

+ func (m *RegisterLinkResponse) String() string

+ func (m *RegisterLinkResponse) XXX_DiscardUnknown()

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

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

+ func (m *RegisterLinkResponse) XXX_Size() int

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

+ type ReleaseCollectionRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReleaseCollectionRequest) ProtoMessage()

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

+ func (m *ReleaseCollectionRequest) GetCollectionName() string

+ func (m *ReleaseCollectionRequest) GetDbName() string

+ func (m *ReleaseCollectionRequest) Reset()

+ func (m *ReleaseCollectionRequest) String() string

+ func (m *ReleaseCollectionRequest) XXX_DiscardUnknown()

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

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

+ func (m *ReleaseCollectionRequest) XXX_Size() int

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

+ type ReleasePartitionsRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ PartitionNames []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReleasePartitionsRequest) ProtoMessage()

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

+ func (m *ReleasePartitionsRequest) GetCollectionName() string

+ func (m *ReleasePartitionsRequest) GetDbName() string

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

+ func (m *ReleasePartitionsRequest) Reset()

+ func (m *ReleasePartitionsRequest) String() string

+ func (m *ReleasePartitionsRequest) XXX_DiscardUnknown()

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

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

+ func (m *ReleasePartitionsRequest) XXX_Size() int

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

+ type SearchRequest struct

+ Base *common.MsgBase

+ CollectionName string

+ DbName string

+ Dsl string

+ DslType common.DslType

+ GuaranteeTimestamp uint64

+ OutputFields []string

+ PartitionNames []string

+ PlaceholderGroup []byte

+ SearchParams []*common.KeyValuePair

+ TravelTimestamp uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SearchRequest) ProtoMessage()

+ func (m *SearchRequest) GetBase() *common.MsgBase

+ func (m *SearchRequest) GetCollectionName() string

+ func (m *SearchRequest) GetDbName() string

+ func (m *SearchRequest) GetDsl() string

+ func (m *SearchRequest) GetDslType() common.DslType

+ func (m *SearchRequest) GetGuaranteeTimestamp() uint64

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

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

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

+ func (m *SearchRequest) GetSearchParams() []*common.KeyValuePair

+ func (m *SearchRequest) GetTravelTimestamp() uint64

+ func (m *SearchRequest) Reset()

+ func (m *SearchRequest) String() string

+ func (m *SearchRequest) XXX_DiscardUnknown()

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

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

+ func (m *SearchRequest) XXX_Size() int

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

+ type SearchResults struct

+ Results *schema.SearchResultData

+ Status *common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SearchResults) ProtoMessage()

+ func (m *SearchResults) GetResults() *schema.SearchResultData

+ func (m *SearchResults) GetStatus() *common.Status

+ func (m *SearchResults) Reset()

+ func (m *SearchResults) String() string

+ func (m *SearchResults) XXX_DiscardUnknown()

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

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

+ func (m *SearchResults) XXX_Size() int

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

+ type ShowCollectionsRequest struct

+ Base *common.MsgBase

+ CollectionNames []string

+ DbName string

+ TimeStamp uint64

+ Type ShowType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ShowCollectionsRequest) ProtoMessage()

+ func (m *ShowCollectionsRequest) GetBase() *common.MsgBase

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

+ func (m *ShowCollectionsRequest) GetDbName() string

+ func (m *ShowCollectionsRequest) GetTimeStamp() uint64

+ func (m *ShowCollectionsRequest) GetType() ShowType

+ func (m *ShowCollectionsRequest) Reset()

+ func (m *ShowCollectionsRequest) String() string

+ func (m *ShowCollectionsRequest) XXX_DiscardUnknown()

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

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

+ func (m *ShowCollectionsRequest) XXX_Size() int

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

+ type ShowCollectionsResponse struct

+ CollectionIds []int64

+ CollectionNames []string

+ CreatedTimestamps []uint64

+ CreatedUtcTimestamps []uint64

+ InMemoryPercentages []int64

+ Status *common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ShowCollectionsResponse) ProtoMessage()

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

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

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

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

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

+ func (m *ShowCollectionsResponse) GetStatus() *common.Status

+ func (m *ShowCollectionsResponse) Reset()

+ func (m *ShowCollectionsResponse) String() string

+ func (m *ShowCollectionsResponse) XXX_DiscardUnknown()

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

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

+ func (m *ShowCollectionsResponse) XXX_Size() int

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

+ type ShowPartitionsRequest struct

+ Base *common.MsgBase

+ CollectionID int64

+ CollectionName string

+ DbName string

+ PartitionNames []string

+ Type ShowType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ShowPartitionsRequest) ProtoMessage()

+ func (m *ShowPartitionsRequest) GetBase() *common.MsgBase

+ func (m *ShowPartitionsRequest) GetCollectionID() int64

+ func (m *ShowPartitionsRequest) GetCollectionName() string

+ func (m *ShowPartitionsRequest) GetDbName() string

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

+ func (m *ShowPartitionsRequest) GetType() ShowType

+ func (m *ShowPartitionsRequest) Reset()

+ func (m *ShowPartitionsRequest) String() string

+ func (m *ShowPartitionsRequest) XXX_DiscardUnknown()

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

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

+ func (m *ShowPartitionsRequest) XXX_Size() int

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

+ type ShowPartitionsResponse struct

+ CreatedTimestamps []uint64

+ CreatedUtcTimestamps []uint64

+ InMemoryPercentages []int64

+ PartitionIDs []int64

+ PartitionNames []string

+ Status *common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ShowPartitionsResponse) ProtoMessage()

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

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

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

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

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

+ func (m *ShowPartitionsResponse) GetStatus() *common.Status

+ func (m *ShowPartitionsResponse) Reset()

+ func (m *ShowPartitionsResponse) String() string

+ func (m *ShowPartitionsResponse) XXX_DiscardUnknown()

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

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

+ func (m *ShowPartitionsResponse) XXX_Size() int

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

+ type ShowSegmentsRequest struct

+ Base *common.MsgBase

+ CollectionID int64

+ PartitionID int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ShowSegmentsRequest) ProtoMessage()

+ func (m *ShowSegmentsRequest) GetBase() *common.MsgBase

+ func (m *ShowSegmentsRequest) GetCollectionID() int64

+ func (m *ShowSegmentsRequest) GetPartitionID() int64

+ func (m *ShowSegmentsRequest) Reset()

+ func (m *ShowSegmentsRequest) String() string

+ func (m *ShowSegmentsRequest) XXX_DiscardUnknown()

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

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

+ func (m *ShowSegmentsRequest) XXX_Size() int

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

+ type ShowSegmentsResponse struct

+ SegmentIDs []int64

+ Status *common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ShowSegmentsResponse) ProtoMessage()

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

+ func (m *ShowSegmentsResponse) GetStatus() *common.Status

+ func (m *ShowSegmentsResponse) Reset()

+ func (m *ShowSegmentsResponse) String() string

+ func (m *ShowSegmentsResponse) XXX_DiscardUnknown()

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

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

+ func (m *ShowSegmentsResponse) XXX_Size() int

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

+ type ShowType int32

+ const ShowType_All

+ const ShowType_InMemory

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

+ func (x ShowType) String() string

+ type StringResponse struct

+ Status *common.Status

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StringResponse) ProtoMessage()

+ func (m *StringResponse) GetStatus() *common.Status

+ func (m *StringResponse) GetValue() string

+ func (m *StringResponse) Reset()

+ func (m *StringResponse) String() string

+ func (m *StringResponse) XXX_DiscardUnknown()

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

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

+ func (m *StringResponse) XXX_Size() int

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

+ type UnimplementedMilvusServiceServer struct

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (*UnimplementedMilvusServiceServer) Query(ctx context.Context, req *QueryRequest) (*QueryResults, error)

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

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

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

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

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

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

+ type UnimplementedProxyServiceServer struct

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

+ type VectorIDs struct

+ CollectionName string

+ FieldName string

+ IdArray *schema.IDs

+ PartitionNames []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*VectorIDs) ProtoMessage()

+ func (m *VectorIDs) GetCollectionName() string

+ func (m *VectorIDs) GetFieldName() string

+ func (m *VectorIDs) GetIdArray() *schema.IDs

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

+ func (m *VectorIDs) Reset()

+ func (m *VectorIDs) String() string

+ func (m *VectorIDs) XXX_DiscardUnknown()

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

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

+ func (m *VectorIDs) XXX_Size() int

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

+ type VectorsArray struct

+ Array isVectorsArray_Array

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*VectorsArray) ProtoMessage()

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

+ func (m *VectorsArray) GetArray() isVectorsArray_Array

+ func (m *VectorsArray) GetDataArray() *schema.VectorField

+ func (m *VectorsArray) GetIdArray() *VectorIDs

+ func (m *VectorsArray) Reset()

+ func (m *VectorsArray) String() string

+ func (m *VectorsArray) XXX_DiscardUnknown()

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

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

+ func (m *VectorsArray) XXX_Size() int

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

+ type VectorsArray_DataArray struct

+ DataArray *schema.VectorField

+ type VectorsArray_IdArray struct

+ IdArray *VectorIDs

v2.0.0-alpha.3

Oct 14, 2021

v2.0.0-alpha.2

Jul 20, 2021

v2.0.0-alpha.1

Jul 15, 2021

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL