Versions in this module Expand all Collapse all v1 v1.1.1 May 21, 2021 Changes in this version + type CollectionParam struct + CollectionName string + Dimension int64 + IndexFileSize int64 + MetricType int32 + type ConnectParam struct + IPAddress string + Port string + type Entity struct + BinaryData []byte + FloatData []float32 + type ErrorCode int64 + const NotConnected + const NotSupported + const OK + const RPCFailed + const ServerFailed + const UnKnownError + type IndexParam struct + CollectionName string + ExtraParams string + IndexType IndexType + type IndexType int64 + const ANNOY + const FLAT + const HNSW + const INVALID + const IVFFLAT + const IVFPQ + const IVFSQ8 + const IVFSQ8H + const RNSG + const SPTAGBKT + const SPTAGKDT + type InsertParam struct + CollectionName string + IDArray []int64 + PartitionTag string + RecordArray []Entity + type ListIDInSegmentParam struct + CollectionName string + SegmentName string + type LoadCollectionParam struct + CollectionName string + PartitionTagList []string + type MetricType int64 + const HAMMING + const IP + const JACCARD + const L2 + const SUBSTRUCTURE + const SUPERSTRUCTURE + const TANIMOTO + type MilvusClient interface + Compact func(ctx context.Context, collectionName string) (Status, error) + Connect func(ctx context.Context, connectParam ConnectParam) error + CountEntities func(ctx context.Context, collectionName string) (int64, Status, error) + CreateCollection func(ctx context.Context, collectionParam CollectionParam) (Status, error) + CreateIndex func(ctx context.Context, indexParam *IndexParam) (Status, error) + CreatePartition func(ctx context.Context, partitionParam PartitionParam) (Status, error) + DeleteEntityByID func(ctx context.Context, collectionName string, partitionTag string, ...) (Status, error) + Disconnect func(ctx context.Context) error + DropCollection func(ctx context.Context, collectionName string) (Status, error) + DropIndex func(ctx context.Context, collectionName string) (Status, error) + DropPartition func(ctx context.Context, partitionParam PartitionParam) (Status, error) + Flush func(ctx context.Context, collectionNameArray []string) (Status, error) + GetClientVersion func(ctx context.Context) string + GetCollectionInfo func(ctx context.Context, collectionName string) (CollectionParam, Status, error) + GetCollectionStats func(ctx context.Context, collectionName string) (string, Status, error) + GetConfig func(ctx context.Context, nodeName string) (string, Status, error) + GetEntityByID func(ctx context.Context, collectionName string, partitionTag string, ...) ([]Entity, Status, error) + GetIndexInfo func(ctx context.Context, collectionName string) (IndexParam, Status, error) + HasCollection func(ctx context.Context, collectionName string) (bool, Status, error) + Insert func(ctx context.Context, insertParam *InsertParam) ([]int64, Status, error) + IsConnected func(ctx context.Context) bool + ListCollections func(ctx context.Context) ([]string, Status, error) + ListIDInSegment func(ctx context.Context, listIDInSegmentParam ListIDInSegmentParam) ([]int64, Status, error) + ListPartitions func(ctx context.Context, collectionName string) ([]PartitionParam, Status, error) + LoadCollection func(ctx context.Context, param LoadCollectionParam) (Status, error) + ReleaseCollection func(ctx context.Context, param LoadCollectionParam) (Status, error) + Search func(sctx context.Context, earchParam SearchParam) (TopkQueryResult, Status, error) + ServerStatus func(ctx context.Context) (string, Status, error) + ServerVersion func(ctx context.Context) (string, Status, error) + SetConfig func(ctx context.Context, nodeName string, value string) (Status, error) + func NewMilvusClient(ctx context.Context, connectParam ConnectParam) (MilvusClient, error) + type MilvusGrpcClient interface + Cmd func(ctx context.Context, command pb.Command) (pb.StringReply, error) + Compact func(ctx context.Context, name pb.CollectionName) (pb.Status, error) + CountCollection func(ctx context.Context, collectionName pb.CollectionName) (pb.CollectionRowCount, error) + CreateCollection func(ctx context.Context, collectionSchema pb.CollectionSchema) (pb.Status, error) + CreateIndex func(ctx context.Context, indexParam pb.IndexParam) (pb.Status, error) + CreatePartition func(ctx context.Context, partitionParam pb.PartitionParam) (pb.Status, error) + DeleteByID func(ctx context.Context, param pb.DeleteByIDParam) (pb.Status, error) + DescribeCollection func(ctx context.Context, collectionName pb.CollectionName) (pb.CollectionSchema, error) + DescribeIndex func(ctx context.Context, collectionName pb.CollectionName) (pb.IndexParam, error) + DropCollection func(ctx context.Context, collectionName pb.CollectionName) (pb.Status, error) + DropIndex func(ctx context.Context, collectionName pb.CollectionName) (pb.Status, error) + DropPartition func(ctx context.Context, partitionParam pb.PartitionParam) (pb.Status, error) + Flush func(ctx context.Context, param pb.FlushParam) (pb.Status, error) + GetVectorIDs func(ctx context.Context, param pb.GetVectorIDsParam) (pb.VectorIds, error) + GetVectorsByID func(ctx context.Context, identity pb.VectorsIdentity) (pb.VectorsData, error) + HasCollection func(ctx context.Context, collectionName pb.CollectionName) (pb.BoolReply, error) + Insert func(ctx context.Context, insertParam pb.InsertParam) (pb.VectorIds, error) + PreloadCollection func(ctx context.Context, preloadCollectionParam pb.PreloadCollectionParam) (pb.Status, error) + ReleaseCollection func(ctx context.Context, preloadCollectionParam pb.PreloadCollectionParam) (pb.Status, error) + Search func(ctx context.Context, searchParam pb.SearchParam) (*pb.TopKQueryResult, error) + SearchInFiles func(ctx context.Context, searchInFilesParam pb.SearchInFilesParam) (*pb.TopKQueryResult, error) + ShowCollectionInfo func(ctx context.Context, collectionName pb.CollectionName) (pb.CollectionInfo, error) + ShowCollections func(ctx context.Context) (pb.CollectionNameList, error) + ShowPartitions func(ctx context.Context, collectionName pb.CollectionName) (pb.PartitionList, error) + func NewMilvusGrpcClient(client pb.MilvusServiceClient) MilvusGrpcClient + type Milvusclient struct + Instance MilvusGrpcClient + func (client *Milvusclient) Compact(ctx context.Context, collectionName string) (Status, error) + func (client *Milvusclient) Connect(ctx context.Context, connectParam ConnectParam) error + func (client *Milvusclient) CountEntities(ctx context.Context, collectionName string) (int64, Status, error) + func (client *Milvusclient) CreateCollection(ctx context.Context, collectionParam CollectionParam) (Status, error) + func (client *Milvusclient) CreateIndex(ctx context.Context, indexParam *IndexParam) (Status, error) + func (client *Milvusclient) CreatePartition(ctx context.Context, partitionParam PartitionParam) (Status, error) + func (client *Milvusclient) DeleteEntityByID(ctx context.Context, collectionName string, partitionTag string, ...) (Status, error) + func (client *Milvusclient) Disconnect(ctx context.Context) error + func (client *Milvusclient) DropCollection(ctx context.Context, collectionName string) (Status, error) + func (client *Milvusclient) DropIndex(ctx context.Context, collectionName string) (Status, error) + func (client *Milvusclient) DropPartition(ctx context.Context, partitionParam PartitionParam) (Status, error) + func (client *Milvusclient) Flush(ctx context.Context, collectionNameArray []string) (Status, error) + func (client *Milvusclient) GetClientVersion(ctx context.Context) string + func (client *Milvusclient) GetCollectionInfo(ctx context.Context, collectionName string) (CollectionParam, Status, error) + func (client *Milvusclient) GetCollectionStats(ctx context.Context, collectionName string) (string, Status, error) + func (client *Milvusclient) GetConfig(ctx context.Context, nodeName string) (string, Status, error) + func (client *Milvusclient) GetEntityByID(ctx context.Context, collectionName string, partitionTag string, ...) ([]Entity, Status, error) + func (client *Milvusclient) GetIndexInfo(ctx context.Context, collectionName string) (IndexParam, Status, error) + func (client *Milvusclient) HasCollection(ctx context.Context, collectionName string) (bool, Status, error) + func (client *Milvusclient) Insert(ctx context.Context, insertParam *InsertParam) ([]int64, Status, error) + func (client *Milvusclient) IsConnected(ctx context.Context) bool + func (client *Milvusclient) ListCollections(ctx context.Context) ([]string, Status, error) + func (client *Milvusclient) ListIDInSegment(ctx context.Context, listIDInSegmentParam ListIDInSegmentParam) ([]int64, Status, error) + func (client *Milvusclient) ListPartitions(ctx context.Context, collectionName string) ([]PartitionParam, Status, error) + func (client *Milvusclient) LoadCollection(ctx context.Context, param LoadCollectionParam) (Status, error) + func (client *Milvusclient) ReleaseCollection(ctx context.Context, param LoadCollectionParam) (Status, error) + func (client *Milvusclient) Search(ctx context.Context, searchParam SearchParam) (TopkQueryResult, Status, error) + func (client *Milvusclient) ServerStatus(ctx context.Context) (string, Status, error) + func (client *Milvusclient) ServerVersion(ctx context.Context) (string, Status, error) + func (client *Milvusclient) SetConfig(ctx context.Context, nodeName string, value string) (Status, error) + type PartitionParam struct + CollectionName string + PartitionTag string + type PartitionStat struct + RowCount int64 + SegmentsStat []SegmentStat + Tag string + type QueryResult struct + Distances []float32 + Ids []int64 + type Range struct + EndValue string + StartValue string + type SearchParam struct + CollectionName string + ExtraParams string + PartitionTag []string + QueryEntities []Entity + Topk int64 + type SegmentStat struct + DataSize int64 + IndexName string + RowCount int64 + SegmentName string + type Status interface + GetMessage func() string + GetStatus func() status + Ok func() bool + func NewStatus(_status status) Status + func NewStatus1(errorCode ErrorCode, state string) Status + type TopkQueryResult struct + QueryResultList []QueryResult