client

package

Go to main page

Versions in this module

v2

v2.3.6

Feb 20, 2024

v2.3.5

Jan 17, 2024

v2.3.4

Dec 29, 2023

Changes in this version

type ReleasePartitionsOption

+ func WithReleasePartitionsMsgBase(msgBase *commonpb.MsgBase) ReleasePartitionsOption

v2.3.3

Nov 10, 2023

Changes in this version

type Client

+ ReplicateMessage func(ctx context.Context, channelName string, beginTs, endTs uint64, ...) (*entity.MessageInfo, error)

type CreateCollectionOption

+ func WithCreateCollectionMsgBase(msgBase *commonpb.MsgBase) CreateCollectionOption

+ type CreateDatabaseOption func(*milvuspb.CreateDatabaseRequest)

+ func WithCreateDatabaseMsgBase(msgBase *commonpb.MsgBase) CreateDatabaseOption

+ type CreatePartitionOption func(*milvuspb.CreatePartitionRequest)

+ func WithCreatePartitionMsgBase(msgBase *commonpb.MsgBase) CreatePartitionOption

+ type DropCollectionOption func(*milvuspb.DropCollectionRequest)

+ func WithDropCollectionMsgBase(msgBase *commonpb.MsgBase) DropCollectionOption

+ type DropDatabaseOption func(*milvuspb.DropDatabaseRequest)

+ func WithDropDatabaseMsgBase(msgBase *commonpb.MsgBase) DropDatabaseOption

+ type DropPartitionOption func(*milvuspb.DropPartitionRequest)

+ func WithDropPartitionMsgBase(msgBase *commonpb.MsgBase) DropPartitionOption

+ type FlushOption func(*milvuspb.FlushRequest)

+ func WithFlushMsgBase(msgBase *commonpb.MsgBase) FlushOption

type GrpcClient

+ func (c *GrpcClient) ReplicateMessage(ctx context.Context, channelName string, beginTs, endTs uint64, ...) (*entity.MessageInfo, error)

type IndexOption

+ func WithIndexMsgBase(msgBase *commonpb.MsgBase) IndexOption

type LoadCollectionOption

+ func WithLoadCollectionMsgBase(msgBase *commonpb.MsgBase) LoadCollectionOption

+ type LoadPartitionsOption func(*milvuspb.LoadPartitionsRequest)

+ func WithLoadPartitionsMsgBase(msgBase *commonpb.MsgBase) LoadPartitionsOption

+ type ReleaseCollectionOption func(*milvuspb.ReleaseCollectionRequest)

+ func WithReleaseCollectionMsgBase(msgBase *commonpb.MsgBase) ReleaseCollectionOption

+ type ReleasePartitionsOption func(*milvuspb.ReleasePartitionsRequest)

+ func WithReleasePartitionMsgBase(msgBase *commonpb.MsgBase) ReleasePartitionsOption

+ type ReplicateMessageOption func(*milvuspb.ReplicateMessageRequest)

+ func WithReplicateMessageMsgBase(msgBase *commonpb.MsgBase) ReplicateMessageOption

v2.3.2

Oct 26, 2023

Changes in this version

type Client

+ CheckHealth func(ctx context.Context) (*entity.MilvusState, error)

type GrpcClient

+ func (c *GrpcClient) CheckHealth(ctx context.Context) (*entity.MilvusState, error)

v2.3.1

Sep 22, 2023

Changes in this version

type Client

+ Delete func(ctx context.Context, collName string, partitionName string, expr string) error

type GrpcClient

+ func (c *GrpcClient) Delete(ctx context.Context, collName string, partitionName string, expr string) error

v2.3.0

Aug 23, 2023

Changes in this version

type Client

+ RenameCollection func(ctx context.Context, collName, newName string) error

+ Upsert func(ctx context.Context, collName string, partitionName string, ...) (entity.Column, error)

type GrpcClient

+ func (c *GrpcClient) RenameCollection(ctx context.Context, collName, newName string) error

+ func (c *GrpcClient) Upsert(ctx context.Context, collName string, partitionName string, ...) (entity.Column, error)

type SearchQueryOption

+ ForTuning bool

type SearchQueryOptionFunc

+ func WithForTuning() SearchQueryOptionFunc

v2.3.0-beta

Aug 14, 2023

v2.2.8

Aug 23, 2023

v2.2.7

Aug 9, 2023

Changes in this version

type Config

+ RetryRateLimit *RetryRateLimitOption

+ type RetryRateLimitOption struct

+ MaxBackoff time.Duration

+ MaxRetry uint

v2.2.6

Jul 4, 2023

Changes in this version

type CreateCollectionOption

+ func WithCollectionProperty(key, value string) CreateCollectionOption

v2.2.5

Jun 29, 2023

Changes in this version

type Client

+ Get func(ctx context.Context, collectionName string, ids entity.Column, ...) (ResultSet, error)

+ NewCollection func(ctx context.Context, collName string, dimension int64, ...) error

type CreateCollectionOption

+ func WithAutoID(autoID bool) CreateCollectionOption

+ func WithEnableDynamicSchema(enable bool) CreateCollectionOption

+ func WithMetricsType(mt entity.MetricType) CreateCollectionOption

+ func WithPKFieldName(name string) CreateCollectionOption

+ func WithPKFieldType(tp entity.FieldType) CreateCollectionOption

+ func WithPKMaxLength(maxLength int64) CreateCollectionOption

+ func WithVectorFieldName(name string) CreateCollectionOption

+ type GetOption func(o *getOption)

+ func GetWithOutputFields(outputFields ...string) GetOption

+ func GetWithPartitions(partionNames ...string) GetOption

type GrpcClient

+ func (c *GrpcClient) Get(ctx context.Context, collectionName string, ids entity.Column, ...) (ResultSet, error)

+ func (c *GrpcClient) NewCollection(ctx context.Context, collName string, dimension int64, ...) error

v2.2.4

Jun 14, 2023

Changes in this version

+ var ErrFeatureNotSupported = errors.New("feature not supported")

type Config

+ ServerVersion string

v2.2.3

Jun 2, 2023

Changes in this version

type BulkInsertOption

+ func IsBackup() BulkInsertOption

type Client

+ func NewClient(ctx context.Context, config Config) (Client, error)

+ CreateDatabase func(ctx context.Context, dbName string) error

+ DropDatabase func(ctx context.Context, dbName string) error

+ FlushV2 func(ctx context.Context, collName string, async bool) ([]int64, []int64, int64, error)

+ InsertRows func(ctx context.Context, collName string, partitionName string, rows []interface{}) (entity.Column, error)

+ ListDatabases func(ctx context.Context) ([]entity.Database, error)

+ UsingDatabase func(ctx context.Context, dbName string) error

+ type Config struct

+ APIKey string

+ Address string

+ DBName string

+ DialOptions []grpc.DialOption

+ DisableConn bool

+ EnableTLSAuth bool

+ Identifier string

+ Password string

+ Username string

+ func (c *Config) Copy() Config

type CreateCollectionOption

+ func WithPartitionNum(partitionNums int64) CreateCollectionOption

type GrpcClient

+ func (c *GrpcClient) CreateDatabase(ctx context.Context, dbName string) error

+ func (c *GrpcClient) DropDatabase(ctx context.Context, dbName string) error

+ func (c *GrpcClient) FlushV2(ctx context.Context, collName string, async bool) ([]int64, []int64, int64, error)

+ func (c *GrpcClient) InsertRows(ctx context.Context, collName string, partitionName string, rows []interface{}) (entity.Column, error)

+ func (c *GrpcClient) ListDatabases(ctx context.Context) ([]entity.Database, error)

+ func (c *GrpcClient) UsingDatabase(ctx context.Context, dbName string) error

+ type ResultSet []entity.Column

+ func (rs ResultSet) GetColumn(fieldName string) entity.Column

v2.2.2

Apr 26, 2023

Changes in this version

type Client

+ AlterCollection func(ctx context.Context, collName string, attrs ...entity.CollectionAttribute) error

type GrpcClient

+ func (c *GrpcClient) AlterCollection(ctx context.Context, collName string, attrs ...entity.CollectionAttribute) error

type LoadCollectionOption

+ func WithResourceGroups(rgs []string) LoadCollectionOption

type SearchQueryOption

+ IgnoreGrowing bool

type SearchQueryOptionFunc

+ func WithIgnoreGrowing() SearchQueryOptionFunc

v2.2.1

Mar 7, 2023

Changes in this version

type Client

+ CreateResourceGroup func(ctx context.Context, rgName string) error

+ DescribeResourceGroup func(ctx context.Context, rgName string) (*entity.ResourceGroup, error)

+ DropResourceGroup func(ctx context.Context, rgName string) error

+ GetLoadState func(ctx context.Context, collectionName string, partitionNames []string) (entity.LoadState, error)

+ GetLoadingProgress func(ctx context.Context, collectionName string, partitionNames []string) (int64, error)

+ GetVersion func(ctx context.Context) (string, error)

+ ListResourceGroups func(ctx context.Context) ([]string, error)

+ TransferNode func(ctx context.Context, sourceRg, targetRg string, nodesNum int32) error

+ TransferReplica func(ctx context.Context, sourceRg, targetRg string, collectionName string, ...) error

type GrpcClient

+ func (c *GrpcClient) CreateResourceGroup(ctx context.Context, rgName string) error

+ func (c *GrpcClient) DescribeResourceGroup(ctx context.Context, rgName string) (*entity.ResourceGroup, error)

+ func (c *GrpcClient) DropResourceGroup(ctx context.Context, rgName string) error

+ func (c *GrpcClient) GetLoadState(ctx context.Context, collName string, partitionNames []string) (entity.LoadState, error)

+ func (c *GrpcClient) GetLoadingProgress(ctx context.Context, collName string, partitionNames []string) (int64, error)

+ func (c *GrpcClient) GetVersion(ctx context.Context) (string, error)

+ func (c *GrpcClient) ListResourceGroups(ctx context.Context) ([]string, error)

+ func (c *GrpcClient) TransferNode(ctx context.Context, sourceRg, targetRg string, nodesNum int32) error

+ func (c *GrpcClient) TransferReplica(ctx context.Context, sourceRg, targetRg string, collectionName string, ...) error

v2.2.0

Nov 23, 2022

Changes in this version

+ const RetryOnRateLimit

+ var MaxBackOff = 60 * time.Second

+ func BadRequestStatus() (*common.Status, error)

+ func BadStatus() (*common.Status, error)

+ func RetryOnRateLimitInterceptor(maxRetry uint, backoffFunc grpc_retry.BackoffFuncContext) grpc.UnaryClientInterceptor

+ func SuccessStatus() (*common.Status, error)

+ type BulkInsertOption func(request *server.ImportRequest)

+ func WithEndTs(endTs int64) BulkInsertOption

+ func WithStartTs(startTs int64) BulkInsertOption

type Client

+ func NewDefaultGrpcClientWithURI(ctx context.Context, uri, username, password string) (Client, error)

+ AddUserRole func(ctx context.Context, username string, role string) error

+ BulkInsert func(ctx context.Context, collName string, partitionName string, files []string, ...) (int64, error)

+ CreateRole func(ctx context.Context, name string) error

+ DropRole func(ctx context.Context, name string) error

+ GetBulkInsertState func(ctx context.Context, taskID int64) (*entity.BulkInsertTaskState, error)

+ GetPersistentSegmentInfo func(ctx context.Context, collName string) ([]*entity.Segment, error)

+ Grant func(ctx context.Context, role string, objectType entity.PriviledgeObjectType, ...) error

+ ListBulkInsertTasks func(ctx context.Context, collName string, limit int64) ([]*entity.BulkInsertTaskState, error)

+ ListRoles func(ctx context.Context) ([]entity.Role, error)

+ ListUsers func(ctx context.Context) ([]entity.User, error)

+ Query func(ctx context.Context, collectionName string, partitionNames []string, ...) ([]entity.Column, error)

+ RemoveUserRole func(ctx context.Context, username string, role string) error

+ Revoke func(ctx context.Context, role string, objectType entity.PriviledgeObjectType, ...) error

+ type GrpcClient struct

+ Conn *grpc.ClientConn

+ Service server.MilvusServiceClient

+ func (c *GrpcClient) AddUserRole(ctx context.Context, username string, role string) error

+ func (c *GrpcClient) AlterAlias(ctx context.Context, collName string, alias string) error

+ func (c *GrpcClient) BulkInsert(ctx context.Context, collName string, partitionName string, files []string, ...) (int64, error)

+ func (c *GrpcClient) CalcDistance(ctx context.Context, collName string, partitions []string, ...) (entity.Column, error)

+ func (c *GrpcClient) Close() error

+ func (c *GrpcClient) CreateAlias(ctx context.Context, collName string, alias string) error

+ func (c *GrpcClient) CreateCollection(ctx context.Context, collSchema *entity.Schema, shardNum int32, ...) error

+ func (c *GrpcClient) CreateCollectionByRow(ctx context.Context, row entity.Row, shardNum int32) error

+ func (c *GrpcClient) CreateCredential(ctx context.Context, username string, password string) error

+ func (c *GrpcClient) CreateIndex(ctx context.Context, collName string, fieldName string, idx entity.Index, ...) error

+ func (c *GrpcClient) CreatePartition(ctx context.Context, collName string, partitionName string) error

+ func (c *GrpcClient) CreateRole(ctx context.Context, name string) error

+ func (c *GrpcClient) DeleteByPks(ctx context.Context, collName string, partitionName string, ids entity.Column) error

+ func (c *GrpcClient) DeleteCredential(ctx context.Context, username string) error

+ func (c *GrpcClient) DescribeCollection(ctx context.Context, collName string) (*entity.Collection, error)

+ func (c *GrpcClient) DescribeIndex(ctx context.Context, collName string, fieldName string, opts ...IndexOption) ([]entity.Index, error)

+ func (c *GrpcClient) DropAlias(ctx context.Context, alias string) error

+ func (c *GrpcClient) DropCollection(ctx context.Context, collName string) error

+ func (c *GrpcClient) DropIndex(ctx context.Context, collName string, fieldName string, opts ...IndexOption) error

+ func (c *GrpcClient) DropPartition(ctx context.Context, collName string, partitionName string) error

+ func (c *GrpcClient) DropRole(ctx context.Context, name string) error

+ func (c *GrpcClient) Flush(ctx context.Context, collName string, async bool) error

+ func (c *GrpcClient) GetBulkInsertState(ctx context.Context, taskID int64) (*entity.BulkInsertTaskState, error)

+ func (c *GrpcClient) GetCollectionStatistics(ctx context.Context, collName string) (map[string]string, error)

+ func (c *GrpcClient) GetCompactionState(ctx context.Context, id int64) (entity.CompactionState, error)

+ func (c *GrpcClient) GetCompactionStateWithPlans(ctx context.Context, id int64) (entity.CompactionState, []entity.CompactionPlan, error)

+ func (c *GrpcClient) GetIndexBuildProgress(ctx context.Context, collName string, fieldName string, opts ...IndexOption) (total, indexed int64, err error)

+ func (c *GrpcClient) GetIndexState(ctx context.Context, collName string, fieldName string, opts ...IndexOption) (entity.IndexState, error)

+ func (c *GrpcClient) GetPersistentSegmentInfo(ctx context.Context, collName string) ([]*entity.Segment, error)

+ func (c *GrpcClient) GetQuerySegmentInfo(ctx context.Context, collName string) ([]*entity.Segment, error)

+ func (c *GrpcClient) GetReplicas(ctx context.Context, collName string) ([]*entity.ReplicaGroup, error)

+ func (c *GrpcClient) Grant(ctx context.Context, role string, objectType entity.PriviledgeObjectType, ...) error

+ func (c *GrpcClient) HasCollection(ctx context.Context, collName string) (bool, error)

+ func (c *GrpcClient) HasPartition(ctx context.Context, collName string, partitionName string) (bool, error)

+ func (c *GrpcClient) Insert(ctx context.Context, collName string, partitionName string, ...) (entity.Column, error)

+ func (c *GrpcClient) InsertByRows(ctx context.Context, collName string, partitionName string, rows []entity.Row) (entity.Column, error)

+ func (c *GrpcClient) ListBulkInsertTasks(ctx context.Context, collName string, limit int64) ([]*entity.BulkInsertTaskState, error)

+ func (c *GrpcClient) ListCollections(ctx context.Context) ([]*entity.Collection, error)

+ func (c *GrpcClient) ListCredUsers(ctx context.Context) ([]string, error)

+ func (c *GrpcClient) ListRoles(ctx context.Context) ([]entity.Role, error)

+ func (c *GrpcClient) ListUsers(ctx context.Context) ([]entity.User, error)

+ func (c *GrpcClient) LoadCollection(ctx context.Context, collName string, async bool, opts ...LoadCollectionOption) error

+ func (c *GrpcClient) LoadPartitions(ctx context.Context, collName string, partitionNames []string, async bool) error

+ func (c *GrpcClient) ManualCompaction(ctx context.Context, collName string, toleranceDuration time.Duration) (int64, error)

+ func (c *GrpcClient) Query(ctx context.Context, collectionName string, partitionNames []string, ...) ([]entity.Column, error)

+ func (c *GrpcClient) QueryByPks(ctx context.Context, collectionName string, partitionNames []string, ...) ([]entity.Column, error)

+ func (c *GrpcClient) ReleaseCollection(ctx context.Context, collName string) error

+ func (c *GrpcClient) ReleasePartitions(ctx context.Context, collName string, partitionNames []string) error

+ func (c *GrpcClient) RemoveUserRole(ctx context.Context, username string, role string) error

+ func (c *GrpcClient) Revoke(ctx context.Context, role string, objectType entity.PriviledgeObjectType, ...) error

+ func (c *GrpcClient) Search(ctx context.Context, collName string, partitions []string, expr string, ...) ([]SearchResult, error)

+ func (c *GrpcClient) ShowCollection(ctx context.Context, collName string) (*entity.Collection, error)

+ func (c *GrpcClient) ShowPartitions(ctx context.Context, collName string) ([]*entity.Partition, error)

+ func (c *GrpcClient) UpdateCredential(ctx context.Context, username string, oldPassword string, newPassword string) error

+ type IndexOption func(*indexDef)

+ func WithIndexName(name string) IndexOption

+ type MockServer struct

+ Injections map[ServiceMethod]TestInjection

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

+ func (m *MockServer) AlterCollection(ctx context.Context, req *server.AlterCollectionRequest) (*common.Status, error)

+ func (m *MockServer) CalcDistance(ctx context.Context, req *server.CalcDistanceRequest) (*server.CalcDistanceResults, error)

+ func (m *MockServer) CheckHealth(ctx context.Context, req *server.CheckHealthRequest) (*server.CheckHealthResponse, error)

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

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

+ func (m *MockServer) CreateCredential(ctx context.Context, req *server.CreateCredentialRequest) (*common.Status, error)

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

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

+ func (m *MockServer) CreateRole(_ context.Context, _ *server.CreateRoleRequest) (*common.Status, error)

+ func (m *MockServer) DelInjection(n ServiceMethod)

+ func (m *MockServer) Delete(ctx context.Context, req *server.DeleteRequest) (*server.MutationResult, error)

+ func (m *MockServer) DeleteCredential(ctx context.Context, req *server.DeleteCredentialRequest) (*common.Status, error)

+ func (m *MockServer) DescribeCollection(ctx context.Context, req *server.DescribeCollectionRequest) (*server.DescribeCollectionResponse, error)

+ func (m *MockServer) DescribeIndex(ctx context.Context, req *server.DescribeIndexRequest) (*server.DescribeIndexResponse, error)

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

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

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

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

+ func (m *MockServer) DropRole(_ context.Context, _ *server.DropRoleRequest) (*common.Status, error)

+ func (m *MockServer) Dummy(_ context.Context, _ *server.DummyRequest) (*server.DummyResponse, error)

+ func (m *MockServer) Flush(ctx context.Context, req *server.FlushRequest) (*server.FlushResponse, error)

+ func (m *MockServer) GetCollectionStatistics(ctx context.Context, req *server.GetCollectionStatisticsRequest) (*server.GetCollectionStatisticsResponse, error)

+ func (m *MockServer) GetCompactionState(ctx context.Context, req *server.GetCompactionStateRequest) (*server.GetCompactionStateResponse, error)

+ func (m *MockServer) GetCompactionStateWithPlans(ctx context.Context, req *server.GetCompactionPlansRequest) (*server.GetCompactionPlansResponse, error)

+ func (m *MockServer) GetComponentStates(ctx context.Context, req *server.GetComponentStatesRequest) (*server.ComponentStates, error)

+ func (m *MockServer) GetFlushState(ctx context.Context, req *server.GetFlushStateRequest) (*server.GetFlushStateResponse, error)

+ func (m *MockServer) GetImportState(_ context.Context, _ *server.GetImportStateRequest) (*server.GetImportStateResponse, error)

+ func (m *MockServer) GetIndexBuildProgress(ctx context.Context, req *server.GetIndexBuildProgressRequest) (*server.GetIndexBuildProgressResponse, error)

+ func (m *MockServer) GetIndexState(ctx context.Context, req *server.GetIndexStateRequest) (*server.GetIndexStateResponse, error)

+ func (m *MockServer) GetInjection(n ServiceMethod) TestInjection

+ func (m *MockServer) GetLoadingProgress(ctx context.Context, req *server.GetLoadingProgressRequest) (*server.GetLoadingProgressResponse, error)

+ func (m *MockServer) GetMetrics(_ context.Context, _ *server.GetMetricsRequest) (*server.GetMetricsResponse, error)

+ func (m *MockServer) GetPartitionStatistics(_ context.Context, _ *server.GetPartitionStatisticsRequest) (*server.GetPartitionStatisticsResponse, error)

+ func (m *MockServer) GetPersistentSegmentInfo(ctx context.Context, req *server.GetPersistentSegmentInfoRequest) (*server.GetPersistentSegmentInfoResponse, error)

+ func (m *MockServer) GetQuerySegmentInfo(ctx context.Context, req *server.GetQuerySegmentInfoRequest) (*server.GetQuerySegmentInfoResponse, error)

+ func (m *MockServer) GetReplicas(ctx context.Context, req *server.GetReplicasRequest) (*server.GetReplicasResponse, error)

+ func (m *MockServer) GetVersion(ctx context.Context, req *server.GetVersionRequest) (*server.GetVersionResponse, error)

+ func (m *MockServer) HasCollection(ctx context.Context, req *server.HasCollectionRequest) (*server.BoolResponse, error)

+ func (m *MockServer) HasPartition(ctx context.Context, req *server.HasPartitionRequest) (*server.BoolResponse, error)

+ func (m *MockServer) Import(_ context.Context, _ *server.ImportRequest) (*server.ImportResponse, error)

+ func (m *MockServer) Insert(ctx context.Context, req *server.InsertRequest) (*server.MutationResult, error)

+ func (m *MockServer) ListCredUsers(ctx context.Context, req *server.ListCredUsersRequest) (*server.ListCredUsersResponse, error)

+ func (m *MockServer) ListImportTasks(_ context.Context, _ *server.ListImportTasksRequest) (*server.ListImportTasksResponse, error)

+ func (m *MockServer) LoadBalance(_ context.Context, _ *server.LoadBalanceRequest) (*common.Status, error)

+ func (m *MockServer) LoadCollection(ctx context.Context, req *server.LoadCollectionRequest) (*common.Status, error)

+ func (m *MockServer) LoadPartitions(ctx context.Context, req *server.LoadPartitionsRequest) (*common.Status, error)

+ func (m *MockServer) ManualCompaction(ctx context.Context, req *server.ManualCompactionRequest) (*server.ManualCompactionResponse, error)

+ func (m *MockServer) OperatePrivilege(_ context.Context, _ *server.OperatePrivilegeRequest) (*common.Status, error)

+ func (m *MockServer) OperateUserRole(_ context.Context, _ *server.OperateUserRoleRequest) (*common.Status, error)

+ func (m *MockServer) Query(ctx context.Context, req *server.QueryRequest) (*server.QueryResults, error)

+ func (m *MockServer) RegisterLink(_ context.Context, _ *server.RegisterLinkRequest) (*server.RegisterLinkResponse, error)

+ func (m *MockServer) ReleaseCollection(ctx context.Context, req *server.ReleaseCollectionRequest) (*common.Status, error)

+ func (m *MockServer) ReleasePartitions(ctx context.Context, req *server.ReleasePartitionsRequest) (*common.Status, error)

+ func (m *MockServer) Search(ctx context.Context, req *server.SearchRequest) (*server.SearchResults, error)

+ func (m *MockServer) SelectGrant(_ context.Context, _ *server.SelectGrantRequest) (*server.SelectGrantResponse, error)

+ func (m *MockServer) SelectRole(_ context.Context, _ *server.SelectRoleRequest) (*server.SelectRoleResponse, error)

+ func (m *MockServer) SelectUser(_ context.Context, _ *server.SelectUserRequest) (*server.SelectUserResponse, error)

+ func (m *MockServer) SetInjection(n ServiceMethod, f TestInjection)

+ func (m *MockServer) ShowCollections(ctx context.Context, req *server.ShowCollectionsRequest) (*server.ShowCollectionsResponse, error)

+ func (m *MockServer) ShowPartitions(ctx context.Context, req *server.ShowPartitionsRequest) (*server.ShowPartitionsResponse, error)

+ func (m *MockServer) UpdateCredential(ctx context.Context, req *server.UpdateCredentialRequest) (*common.Status, error)

type SearchQueryOption

+ Limit int64

+ Offset int64

type SearchQueryOptionFunc

+ func WithLimit(limit int64) SearchQueryOptionFunc

+ func WithOffset(offset int64) SearchQueryOptionFunc

+ type ServiceMethod int

+ const MAlterAlias

+ const MAlterCollection

+ const MCalcDistance

+ const MCheckHealth

+ const MCreateAlias

+ const MCreateCollection

+ const MCreateCredential

+ const MCreateIndex

+ const MCreatePartition

+ const MDelete

+ const MDeleteCredential

+ const MDescribeCollection

+ const MDescribeIndex

+ const MDropAlias

+ const MDropCollection

+ const MDropIndex

+ const MDropPartition

+ const MFlush

+ const MGetCollectionStatistics

+ const MGetCompactionState

+ const MGetCompactionStateWithPlans

+ const MGetComponentStates

+ const MGetFlushState

+ const MGetIndexBuildProgress

+ const MGetIndexState

+ const MGetLoadingProgress

+ const MGetPersistentSegmentInfo

+ const MGetQuerySegmentInfo

+ const MGetReplicas

+ const MGetVersion

+ const MHasCollection

+ const MHasPartition

+ const MInsert

+ const MListCollection

+ const MListCredUsers

+ const MLoadCollection

+ const MLoadPartitions

+ const MManualCompaction

+ const MQuery

+ const MReleaseCollection

+ const MReleasePartitions

+ const MSearch

+ const MShowCollections

+ const MShowPartitions

+ const MUpdateCredential

+ type TestInjection func(context.Context, proto.Message) (proto.Message, error)

v2.1.2

Sep 8, 2022

Changes in this version

+ var DefaultGrpcOpts = []grpc.DialOption

+ func PKs2Expr(ids entity.Column) string

+ func WithClientRequestID(ctx context.Context, reqID string) context.Context

+ func WithDebugLogLevel(ctx context.Context) context.Context

+ func WithErrorLogLevel(ctx context.Context) context.Context

+ func WithInfoLogLevel(ctx context.Context) context.Context

+ func WithWarnLogLevel(ctx context.Context) context.Context

type Client

+ func NewDefaultGrpcClient(ctx context.Context, addr string) (Client, error)

+ func NewDefaultGrpcClientWithAuth(ctx context.Context, addr, username, password string) (Client, error)

+ func NewDefaultGrpcClientWithTLSAuth(ctx context.Context, addr, username, password string) (Client, error)

v2.1.1

Aug 12, 2022

Changes in this version

+ var MetaCache = metaCache

v2.1.0

Jul 22, 2022

Changes in this version

+ const BoundedTimestamp

+ const EventuallyTimestamp

+ const StrongTimestamp

+ func AuthenticationInterceptor(ctx context.Context, username, password string) context.Context

+ func CreateAuthenticationStreamInterceptor(username, password string) grpc.StreamClientInterceptor

+ func CreateAuthenticationUnaryInterceptor(username, password string) grpc.UnaryClientInterceptor

type Client

+ CreateCredential func(ctx context.Context, username string, password string) error

+ DeleteCredential func(ctx context.Context, username string) error

+ GetReplicas func(ctx context.Context, collName string) ([]*entity.ReplicaGroup, error)

+ ListCredUsers func(ctx context.Context) ([]string, error)

+ UpdateCredential func(ctx context.Context, username string, oldPassword string, newPassword string) error

+ type CreateCollectionOption func(*server.CreateCollectionRequest)

+ func WithConsistencyLevel(cl entity.ConsistencyLevel) CreateCollectionOption

+ type LoadCollectionOption func(*server.LoadCollectionRequest)

+ func WithReplicaNumber(rn int32) LoadCollectionOption

+ type SearchQueryOption struct

+ ConsistencyLevel entity.ConsistencyLevel

+ GuaranteeTimestamp uint64

+ TravelTimestamp uint64

+ func MakeSearchQueryOption(c *entity.Collection, opts ...SearchQueryOptionFunc) (*SearchQueryOption, error)

+ type SearchQueryOptionFunc func(option *SearchQueryOption)

+ func WithGuaranteeTimestamp(gt uint64) SearchQueryOptionFunc

+ func WithSearchQueryConsistencyLevel(cl entity.ConsistencyLevel) SearchQueryOptionFunc

+ func WithTravelTimestamp(tt uint64) SearchQueryOptionFunc

v2.0.0

Jan 26, 2022

Changes in this version

+ var ErrClientNotReady = errors.New("client not ready")

+ var ErrFieldTypeNotMatch = errors.New("field type not matched")

+ var ErrStatusNil = errors.New("response status is nil")

+ func SetFieldValue(field *entity.Field, f reflect.Value, fieldData *schema.FieldData, idx int) error

+ type Client interface

+ AlterAlias func(ctx context.Context, collName string, alias string) error

+ CalcDistance func(ctx context.Context, collName string, partitions []string, ...) (entity.Column, error)

+ Close func() error

+ CreateAlias func(ctx context.Context, collName string, alias string) error

+ CreateCollection func(ctx context.Context, schema *entity.Schema, shardsNum int32) error

+ CreateCollectionByRow func(ctx context.Context, row entity.Row, shardNum int32) error

+ CreateIndex func(ctx context.Context, collName string, fieldName string, idx entity.Index, ...) error

+ CreatePartition func(ctx context.Context, collName string, partitionName string) error

+ DeleteByPks func(ctx context.Context, collName string, partitionName string, ids entity.Column) error

+ DescribeCollection func(ctx context.Context, collName string) (*entity.Collection, error)

+ DescribeIndex func(ctx context.Context, collName string, fieldName string) ([]entity.Index, error)

+ DropAlias func(ctx context.Context, alias string) error

+ DropCollection func(ctx context.Context, collName string) error

+ DropIndex func(ctx context.Context, collName string, fieldName string) error

+ DropPartition func(ctx context.Context, collName string, partitionName string) error

+ Flush func(ctx context.Context, collName string, async bool) error

+ GetCollectionStatistics func(ctx context.Context, collName string) (map[string]string, error)

+ GetCompactionState func(ctx context.Context, id int64) (entity.CompactionState, error)

+ GetCompactionStateWithPlans func(ctx context.Context, id int64) (entity.CompactionState, []entity.CompactionPlan, error)

+ GetIndexState func(ctx context.Context, collName string, fieldName string) (entity.IndexState, error)

+ HasCollection func(ctx context.Context, collName string) (bool, error)

+ HasPartition func(ctx context.Context, collName string, partitionName string) (bool, error)

+ Insert func(ctx context.Context, collName string, partitionName string, ...) (entity.Column, error)

+ InsertByRows func(ctx context.Context, collName string, paritionName string, rows []entity.Row) (entity.Column, error)

+ ListCollections func(ctx context.Context) ([]*entity.Collection, error)

+ LoadCollection func(ctx context.Context, collName string, async bool) error

+ LoadPartitions func(ctx context.Context, collName string, partitionNames []string, async bool) error

+ ManualCompaction func(ctx context.Context, collName string, toleranceDuration time.Duration) (int64, error)

+ QueryByPks func(ctx context.Context, collectionName string, partitionNames []string, ...) ([]entity.Column, error)

+ ReleaseCollection func(ctx context.Context, collName string) error

+ ReleasePartitions func(ctx context.Context, collName string, partitionNames []string) error

+ Search func(ctx context.Context, collName string, partitions []string, expr string, ...) ([]SearchResult, error)

+ ShowPartitions func(ctx context.Context, collName string) ([]*entity.Partition, error)

+ func NewGrpcClient(ctx context.Context, addr string, dialOptions ...grpc.DialOption) (Client, error)

+ type ErrCollectionNotExists struct

+ func (e ErrCollectionNotExists) Error() string

+ type ErrPartitionNotExists struct

+ func (e ErrPartitionNotExists) Error() string

+ type ErrServiceFailed error

+ type SearchResult struct

+ Err error

+ Fields []entity.Column

+ IDs entity.Column

+ ResultCount int

+ Scores []float32

+ type SearchResultByRows struct

+ Err error

+ ResultCount int

+ Rows []entity.Row

+ Scores []float32

+ func SearchResultToRows(sch *entity.Schema, results *schema.SearchResultData, t reflect.Type, ...) ([]SearchResultByRows, error)

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