milvus

package

Go to main page

Versions in this module

v1

v1.1.1

Apr 19, 2022

Changes in this version

type ConnectParam

+ Opts []grpc.DialOption

v1.1.0

Apr 29, 2021

Changes in this version

type MilvusClient

+ ReleaseCollection func(ctx context.Context, param LoadCollectionParam) (Status, error)

type MilvusGrpcClient

+ ReleaseCollection func(ctx context.Context, preloadCollectionParam pb.PreloadCollectionParam) (pb.Status, error)

type Milvusclient

+ func (client *Milvusclient) ReleaseCollection(ctx context.Context, param LoadCollectionParam) (Status, error)

v1.0.1

Apr 1, 2021

v1.0.0

Mar 8, 2021

v0

v0.5.0

Dec 7, 2020

Changes in this version

+ func ParseDsl(dslString *string, vectorParam *string, vectorRecord *pb.VectorRecord) (string, error)

+ type CompactParam struct

+ CollectionName string

+ type DataType int

+ const BOOL

+ const DOUBLE

+ const FLOAT

+ const INT32

+ const INT64

+ const VECTORBINARY

+ const VECTORFLOAT

type Entity

+ Entity map[string]interface{}

+ EntityId int64

+ type Field struct

+ ExtraParams *Params

+ IndexParams *Params

+ Name string

+ Type DataType

+ type FieldValue struct

+ Name string

+ RawData interface{}

type IndexParam

+ FieldName string

+ IndexParams map[string]interface{}

type IndexType

+ const BINFLAT

+ const BINIVFFLAT

+ const RHNSWFLAT

+ const RHNSWPQ

+ const RHNSWSQ8

+ const SORTED

type InsertParam

+ Fields []FieldValue

type ListIDInSegmentParam

+ SegmentId int64

+ type Mapping struct

+ CollectionName string

+ ExtraParams *Params

+ Fields []Field

type MilvusClient

+ HasPartition func(ctx context.Context, param PartitionParam) (bool, Status, error)

type MilvusGrpcClient

+ GetEntityByID func(ctx context.Context, identity pb.EntityIdentity) (pb.Entities, error)

+ GetEntityIDs func(ctx context.Context, param pb.GetEntityIDsParam) (pb.EntityIds, error)

+ HasPartition func(ctx context.Context, param pb.PartitionParam) (pb.BoolReply, error)

type Milvusclient

+ func (client *Milvusclient) HasPartition(ctx context.Context, param PartitionParam) (bool, Status, error)

+ type Params struct

+ func NewParams(params string) *Params

+ func (p *Params) Get(key string) gjson.Result

+ func (p *Params) Set(key string, value interface{}) *Params

+ func (p *Params) String() string

type QueryResult

+ Entities []Entity

type SearchParam

+ Dsl map[string]interface{}

+ type VectorRecord struct

+ VectorRecord []VectorRowRecord

+ type VectorRowRecord struct

+ BinaryData []byte

+ FloatData []float32

v0.4.6

Feb 25, 2021

v0.4.5

Dec 22, 2020

Changes in this version

+ type LoadCollectionParam struct

+ CollectionName string

+ PartitionTagList []string

v0.4.4

Aug 15, 2020

v0.4.3

Jul 20, 2020

v0.4.2

Jun 13, 2020

v0.4.1

May 29, 2020

v0.4.0

May 14, 2020

Changes in this version

+ type ListIDInSegmentParam struct

+ CollectionName string

+ SegmentName string

type MilvusClient

+ CountEntities func(collectionName string) (int64, Status, error)

+ DeleteEntityByID func(collectionName string, id_array []int64) (Status, error)

+ GetCollectionInfo func(collectionName string) (CollectionParam, Status, error)

+ GetCollectionStats func(collectionName string) (string, Status, error)

+ GetIndexInfo func(collectionName string) (IndexParam, Status, error)

+ ListCollections func() ([]string, Status, error)

+ ListIDInSegment func(listIDInSegmentParam ListIDInSegmentParam) ([]int64, Status, error)

+ ListPartitions func(collectionName string) ([]PartitionParam, Status, error)

+ LoadCollection func(collectionName string) (Status, error)

type MilvusGrpcClient

+ GetVectorsByID func(identity pb.VectorsIdentity) (pb.VectorsData, error)

+ ShowCollectionInfo func(collectionName pb.CollectionName) (pb.CollectionInfo, error)

type Milvusclient

+ func (client *Milvusclient) CountEntities(collectionName string) (int64, Status, error)

+ func (client *Milvusclient) DeleteEntityByID(collectionName string, id_array []int64) (Status, error)

+ func (client *Milvusclient) GetCollectionInfo(collectionName string) (CollectionParam, Status, error)

+ func (client *Milvusclient) GetCollectionStats(collectionName string) (string, Status, error)

+ func (client *Milvusclient) GetIndexInfo(collectionName string) (IndexParam, Status, error)

+ func (client *Milvusclient) ListCollections() ([]string, Status, error)

+ func (client *Milvusclient) ListIDInSegment(listIDInSegmentParam ListIDInSegmentParam) ([]int64, Status, error)

+ func (client *Milvusclient) ListPartitions(collectionName string) ([]PartitionParam, Status, error)

+ func (client *Milvusclient) LoadCollection(collectionName string) (Status, error)

v0.3.0

Apr 15, 2020

Changes in this version

type MilvusGrpcClient

+ CountCollection func(collectionName pb.CollectionName) (pb.CollectionRowCount, error)

+ CreateCollection func(collectionSchema pb.CollectionSchema) (pb.Status, error)

+ DescribeCollection func(collectionName pb.CollectionName) (pb.CollectionSchema, error)

+ DropCollection func(collectionName pb.CollectionName) (pb.Status, error)

+ HasCollection func(collectionName pb.CollectionName) (pb.BoolReply, error)

+ PreloadCollection func(collectionName pb.CollectionName) (pb.Status, error)

+ ShowCollectionInfos func(collectionName pb.CollectionName) (pb.CollectionInfo, error)

+ ShowCollections func() (pb.CollectionNameList, error)

v0.2.0

Apr 2, 2020

Changes in this version

type IndexType

+ const ANNOY

type MetricType

+ const SUBSTRUCTURE

+ const SUPERSTRUCTURE

v0.1.0

Mar 10, 2020

Changes in this version

+ type CollectionInfo struct

+ PartitionsStat []PartitionStat

+ TotalRowCount int64

+ type CollectionParam struct

+ CollectionName string

+ Dimension int64

+ IndexFileSize int64

+ MetricType int64

+ 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 GetEntityIDsParam struct

+ CollectionName string

+ SegmentName string

+ type IndexParam struct

+ CollectionName string

+ ExtraParams string

+ IndexType IndexType

+ type IndexType int64

+ 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 MetricType int64

+ const HAMMING

+ const IP

+ const JACCARD

+ const L2

+ const TANIMOTO

+ type MilvusClient interface

+ Compact func(collectionName string) (Status, error)

+ Connect func(connectParam ConnectParam) error

+ CountCollection func(collectionName string) (int64, Status, error)

+ CreateCollection func(collectionParam CollectionParam) (Status, error)

+ CreateIndex func(indexParam *IndexParam) (Status, error)

+ CreatePartition func(partitionParam PartitionParam) (Status, error)

+ DeleteByID func(collectionName string, id_array []int64) (Status, error)

+ DescribeCollection func(collectionName string) (CollectionParam, Status, error)

+ DescribeIndex func(collectionName string) (IndexParam, Status, error)

+ Disconnect func() error

+ DropCollection func(collectionName string) (Status, error)

+ DropIndex func(collectionName string) (Status, error)

+ DropPartition func(partitionParam PartitionParam) (Status, error)

+ Flush func(collectionNameArray []string) (Status, error)

+ GetClientVersion func() string

+ GetConfig func(nodeName string) (string, Status, error)

+ GetEntityByID func(collectionName string, entity_id int64) (Entity, Status, error)

+ GetEntityIDs func(getEntityIDsParam GetEntityIDsParam) ([]int64, Status, error)

+ HasCollection func(collectionName string) (bool, Status, error)

+ Insert func(insertParam *InsertParam) (Status, error)

+ IsConnected func() bool

+ PreloadCollection func(collectionName string) (Status, error)

+ Search func(searchParam SearchParam) (TopkQueryResult, Status, error)

+ ServerStatus func() (string, Status, error)

+ ServerVersion func() (string, Status, error)

+ SetConfig func(nodeName string, value string) (Status, error)

+ ShowCollectionInfo func(collectionName string) (CollectionInfo, Status, error)

+ ShowCollections func() ([]string, Status, error)

+ ShowPartitions func(collectionName string) ([]PartitionParam, Status, error)

+ func NewMilvusClient(client MilvusGrpcClient) MilvusClient

+ type MilvusGrpcClient interface

+ Cmd func(command pb.Command) (pb.StringReply, error)

+ Compact func(name pb.TableName) (pb.Status, error)

+ CountTable func(tableName pb.TableName) (pb.TableRowCount, error)

+ CreateIndex func(indexParam pb.IndexParam) (pb.Status, error)

+ CreatePartition func(partitionParam pb.PartitionParam) (pb.Status, error)

+ CreateTable func(tableSchema pb.TableSchema) (pb.Status, error)

+ DeleteByID func(param pb.DeleteByIDParam) (pb.Status, error)

+ DescribeIndex func(tableName pb.TableName) (pb.IndexParam, error)

+ DescribeTable func(tableName pb.TableName) (pb.TableSchema, error)

+ DropIndex func(tableName pb.TableName) (pb.Status, error)

+ DropPartition func(partitionParam pb.PartitionParam) (pb.Status, error)

+ DropTable func(tableName pb.TableName) (pb.Status, error)

+ Flush func(param pb.FlushParam) (pb.Status, error)

+ GetVectorByID func(identity pb.VectorIdentity) (pb.VectorData, error)

+ GetVectorIDs func(param pb.GetVectorIDsParam) (pb.VectorIds, error)

+ HasTable func(tableName pb.TableName) (pb.BoolReply, error)

+ Insert func(insertParam pb.InsertParam) (pb.VectorIds, error)

+ PreloadTable func(tableName pb.TableName) (pb.Status, error)

+ Search func(searchParam pb.SearchParam) (*pb.TopKQueryResult, error)

+ SearchInFiles func(searchInFilesParam pb.SearchInFilesParam) (*pb.TopKQueryResult, error)

+ ShowPartitions func(tableName pb.TableName) (pb.PartitionList, error)

+ ShowTableInfos func(tableName pb.TableName) (pb.TableInfo, error)

+ ShowTables func() (pb.TableNameList, error)

+ func NewMilvusGrpcClient(client pb.MilvusServiceClient) MilvusGrpcClient

+ type Milvusclient struct

+ Instance MilvusGrpcClient

+ func (client *Milvusclient) Compact(collectionName string) (Status, error)

+ func (client *Milvusclient) Connect(connectParam ConnectParam) error

+ func (client *Milvusclient) CountCollection(collectionName string) (int64, Status, error)

+ func (client *Milvusclient) CreateCollection(collectionParam CollectionParam) (Status, error)

+ func (client *Milvusclient) CreateIndex(indexParam *IndexParam) (Status, error)

+ func (client *Milvusclient) CreatePartition(partitionParam PartitionParam) (Status, error)

+ func (client *Milvusclient) DeleteByID(collectionName string, id_array []int64) (Status, error)

+ func (client *Milvusclient) DescribeCollection(collectionName string) (CollectionParam, Status, error)

+ func (client *Milvusclient) DescribeIndex(collectionName string) (IndexParam, Status, error)

+ func (client *Milvusclient) Disconnect() error

+ func (client *Milvusclient) DropCollection(collectionName string) (Status, error)

+ func (client *Milvusclient) DropIndex(collectionName string) (Status, error)

+ func (client *Milvusclient) DropPartition(partitionParam PartitionParam) (Status, error)

+ func (client *Milvusclient) Flush(collectionNameArray []string) (Status, error)

+ func (client *Milvusclient) GetClientVersion() string

+ func (client *Milvusclient) GetConfig(nodeName string) (string, Status, error)

+ func (client *Milvusclient) GetEntityByID(collectionName string, vector_id int64) (Entity, Status, error)

+ func (client *Milvusclient) GetEntityIDs(getEntityIDsParam GetEntityIDsParam) ([]int64, Status, error)

+ func (client *Milvusclient) HasCollection(collectionName string) (bool, Status, error)

+ func (client *Milvusclient) Insert(insertParam *InsertParam) (Status, error)

+ func (client *Milvusclient) IsConnected() bool

+ func (client *Milvusclient) PreloadCollection(collectionName string) (Status, error)

+ func (client *Milvusclient) Search(searchParam SearchParam) (TopkQueryResult, Status, error)

+ func (client *Milvusclient) ServerStatus() (string, Status, error)

+ func (client *Milvusclient) ServerVersion() (string, Status, error)

+ func (client *Milvusclient) SetConfig(nodeName string, value string) (Status, error)

+ func (client *Milvusclient) ShowCollectionInfo(collectionName string) (CollectionInfo, Status, error)

+ func (client *Milvusclient) ShowCollections() ([]string, Status, error)

+ func (client *Milvusclient) ShowPartitions(collectionName string) ([]PartitionParam, 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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL