grpcmixcoordclient

func (*Client) ActivateChecker ¶

func (c *Client) ActivateChecker(ctx context.Context, req *querypb.ActivateCheckerRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) AddCollectionField ¶

func (c *Client) AddCollectionField(ctx context.Context, in *milvuspb.AddCollectionFieldRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

CreatePartition create partition

func (*Client) AddFileResource ¶

func (c *Client) AddFileResource(ctx context.Context, req *milvuspb.AddFileResourceRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) AllocID ¶

func (c *Client) AllocID(ctx context.Context, in *rootcoordpb.AllocIDRequest, opts ...grpc.CallOption) (*rootcoordpb.AllocIDResponse, error)

AllocID global ID allocator

func (*Client) AllocSegment ¶

func (c *Client) AllocSegment(ctx context.Context, in *datapb.AllocSegmentRequest, opts ...grpc.CallOption) (*datapb.AllocSegmentResponse, error)

func (*Client) AllocTimestamp ¶

func (c *Client) AllocTimestamp(ctx context.Context, in *rootcoordpb.AllocTimestampRequest, opts ...grpc.CallOption) (*rootcoordpb.AllocTimestampResponse, error)

AllocTimestamp global timestamp allocator

func (*Client) AlterAlias ¶

func (c *Client) AlterAlias(ctx context.Context, req *milvuspb.AlterAliasRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

AlterAlias alter collection alias

func (*Client) AlterCollection ¶

func (c *Client) AlterCollection(ctx context.Context, request *milvuspb.AlterCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) AlterCollectionField ¶

func (c *Client) AlterCollectionField(ctx context.Context, request *milvuspb.AlterCollectionFieldRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) AlterDatabase ¶

func (c *Client) AlterDatabase(ctx context.Context, request *rootcoordpb.AlterDatabaseRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) AlterIndex ¶

func (c *Client) AlterIndex(ctx context.Context, req *indexpb.AlterIndexRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

AlterIndex sends the alter index request to IndexCoord.

func (*Client) AssignSegmentID ¶

func (c *Client) AssignSegmentID(ctx context.Context, req *datapb.AssignSegmentIDRequest, opts ...grpc.CallOption) (*datapb.AssignSegmentIDResponse, error)

AssignSegmentID applies allocations for specified Coolection/Partition and related Channel Name(Virtial Channel)

ctx is the context to control request deadline and cancellation req contains the requester's info(id and role) and the list of Assignment Request, which contains the specified collection, partitaion id, the related VChannel Name and row count it needs

response struct `AssignSegmentIDResponse` contains the assignment result for each request error is returned only when some communication issue occurs if some error occurs in the process of `AssignSegmentID`, it will be recorded and returned in `Status` field of response

`AssignSegmentID` will applies current configured allocation policies for each request if the VChannel is newly used, `WatchDmlChannels` will be invoked to notify a `DataNode`(selected by policy) to watch it if there is anything make the allocation impossible, the response will not contain the corresponding result

func (*Client) BackupRBAC ¶

func (c *Client) BackupRBAC(ctx context.Context, in *milvuspb.BackupRBACMetaRequest, opts ...grpc.CallOption) (*milvuspb.BackupRBACMetaResponse, error)

func (*Client) BroadcastAlteredCollection ¶

func (c *Client) BroadcastAlteredCollection(ctx context.Context, req *datapb.AlterCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

BroadcastAlteredCollection is the DataCoord client side code for BroadcastAlteredCollection call.

func (*Client) CheckBalanceStatus ¶

func (c *Client) CheckBalanceStatus(ctx context.Context, req *querypb.CheckBalanceStatusRequest, opts ...grpc.CallOption) (*querypb.CheckBalanceStatusResponse, error)

func (*Client) CheckHealth ¶

func (c *Client) CheckHealth(ctx context.Context, req *milvuspb.CheckHealthRequest, opts ...grpc.CallOption) (*milvuspb.CheckHealthResponse, error)

func (*Client) CheckQueryNodeDistribution ¶

func (c *Client) CheckQueryNodeDistribution(ctx context.Context, req *querypb.CheckQueryNodeDistributionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) Close ¶

func (c *Client) Close() error

Close terminate grpc connection

func (*Client) CreateAlias ¶

func (c *Client) CreateAlias(ctx context.Context, req *milvuspb.CreateAliasRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

CreateAlias create collection alias

func (*Client) CreateCollection ¶

func (c *Client) CreateCollection(ctx context.Context, in *milvuspb.CreateCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

CreateCollection create collection

func (*Client) CreateCredential ¶

func (c *Client) CreateCredential(ctx context.Context, req *internalpb.CredentialInfo, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) CreateDatabase ¶

func (c *Client) CreateDatabase(ctx context.Context, in *milvuspb.CreateDatabaseRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) CreateIndex ¶

func (c *Client) CreateIndex(ctx context.Context, req *indexpb.CreateIndexRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

CreateIndex sends the build index request to IndexCoord.

func (*Client) CreatePartition ¶

func (c *Client) CreatePartition(ctx context.Context, in *milvuspb.CreatePartitionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

CreatePartition create partition

func (*Client) CreatePrivilegeGroup ¶

func (c *Client) CreatePrivilegeGroup(ctx context.Context, in *milvuspb.CreatePrivilegeGroupRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) CreateResourceGroup ¶

func (c *Client) CreateResourceGroup(ctx context.Context, req *milvuspb.CreateResourceGroupRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) CreateRole ¶

func (c *Client) CreateRole(ctx context.Context, req *milvuspb.CreateRoleRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) DeactivateChecker ¶

func (c *Client) DeactivateChecker(ctx context.Context, req *querypb.DeactivateCheckerRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) DeleteCredential ¶

func (c *Client) DeleteCredential(ctx context.Context, req *milvuspb.DeleteCredentialRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) DescribeAlias ¶

func (c *Client) DescribeAlias(ctx context.Context, req *milvuspb.DescribeAliasRequest, opts ...grpc.CallOption) (*milvuspb.DescribeAliasResponse, error)

DescribeAlias describe alias

func (*Client) DescribeCollection ¶

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

DescribeCollection return collection info

func (*Client) DescribeCollectionInternal ¶

func (c *Client) DescribeCollectionInternal(ctx context.Context, in *milvuspb.DescribeCollectionRequest, opts ...grpc.CallOption) (*milvuspb.DescribeCollectionResponse, error)

func (*Client) DescribeDatabase ¶

func (c *Client) DescribeDatabase(ctx context.Context, req *rootcoordpb.DescribeDatabaseRequest, opts ...grpc.CallOption) (*rootcoordpb.DescribeDatabaseResponse, error)

func (*Client) DescribeIndex ¶

func (c *Client) DescribeIndex(ctx context.Context, req *indexpb.DescribeIndexRequest, opts ...grpc.CallOption) (*indexpb.DescribeIndexResponse, error)

DescribeIndex describe the index info of the collection.

func (*Client) DescribeResourceGroup ¶

func (c *Client) DescribeResourceGroup(ctx context.Context, req *querypb.DescribeResourceGroupRequest, opts ...grpc.CallOption) (*querypb.DescribeResourceGroupResponse, error)

func (*Client) DropAlias ¶

func (c *Client) DropAlias(ctx context.Context, req *milvuspb.DropAliasRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

DropAlias drop collection alias

func (*Client) DropCollection ¶

func (c *Client) DropCollection(ctx context.Context, in *milvuspb.DropCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

DropCollection drop collection

func (*Client) DropDatabase ¶

func (c *Client) DropDatabase(ctx context.Context, in *milvuspb.DropDatabaseRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) DropIndex ¶

func (c *Client) DropIndex(ctx context.Context, req *indexpb.DropIndexRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

DropIndex sends the drop index request to IndexCoord.

func (*Client) DropPartition ¶

func (c *Client) DropPartition(ctx context.Context, in *milvuspb.DropPartitionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

DropPartition drop partition

func (*Client) DropPrivilegeGroup ¶

func (c *Client) DropPrivilegeGroup(ctx context.Context, in *milvuspb.DropPrivilegeGroupRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) DropResourceGroup ¶

func (c *Client) DropResourceGroup(ctx context.Context, req *milvuspb.DropResourceGroupRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) DropRole ¶

func (c *Client) DropRole(ctx context.Context, req *milvuspb.DropRoleRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) DropVirtualChannel ¶

func (c *Client) DropVirtualChannel(ctx context.Context, req *datapb.DropVirtualChannelRequest, opts ...grpc.CallOption) (*datapb.DropVirtualChannelResponse, error)

DropVirtualChannel drops virtual channel in datacoord.

func (*Client) Flush ¶

func (c *Client) Flush(ctx context.Context, req *datapb.FlushRequest, opts ...grpc.CallOption) (*datapb.FlushResponse, error)

Flush flushes a collection's data

func (*Client) FlushAll ¶

func (c *Client) FlushAll(ctx context.Context, req *datapb.FlushAllRequest, opts ...grpc.CallOption) (*datapb.FlushAllResponse, error)

func (*Client) GcConfirm ¶

func (c *Client) GcConfirm(ctx context.Context, req *datapb.GcConfirmRequest, opts ...grpc.CallOption) (*datapb.GcConfirmResponse, error)

func (*Client) GcControl ¶

func (c *Client) GcControl(ctx context.Context, req *datapb.GcControlRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) GetChannelRecoveryInfo ¶

func (c *Client) GetChannelRecoveryInfo(ctx context.Context, req *datapb.GetChannelRecoveryInfoRequest, opts ...grpc.CallOption) (*datapb.GetChannelRecoveryInfoResponse, error)

GetChannelRecoveryInfo returns the corresponding vchannel info.

func (*Client) GetCollectionStatistics ¶

func (c *Client) GetCollectionStatistics(ctx context.Context, req *datapb.GetCollectionStatisticsRequest, opts ...grpc.CallOption) (*datapb.GetCollectionStatisticsResponse, error)

GetCollectionStatistics requests collection statistics

ctx is the context to control request deadline and cancellation req contains the collection id to query

response struct `GetCollectionStatisticsResponse` contains the key-value list fields returning related data

only row count for now

error is returned only when some communication issue occurs

func (*Client) GetCompactionState ¶

func (c *Client) GetCompactionState(ctx context.Context, req *milvuspb.GetCompactionStateRequest, opts ...grpc.CallOption) (*milvuspb.GetCompactionStateResponse, error)

GetCompactionState gets the state of a compaction

func (*Client) GetCompactionStateWithPlans ¶

func (c *Client) GetCompactionStateWithPlans(ctx context.Context, req *milvuspb.GetCompactionPlansRequest, opts ...grpc.CallOption) (*milvuspb.GetCompactionPlansResponse, error)

GetCompactionStateWithPlans gets the state of a compaction by plan

func (*Client) GetComponentStates ¶

func (c *Client) GetComponentStates(ctx context.Context, req *milvuspb.GetComponentStatesRequest, opts ...grpc.CallOption) (*milvuspb.ComponentStates, error)

GetComponentStates TODO: timeout need to be propagated through ctx

func (*Client) GetCredential ¶

func (c *Client) GetCredential(ctx context.Context, req *rootcoordpb.GetCredentialRequest, opts ...grpc.CallOption) (*rootcoordpb.GetCredentialResponse, error)

func (*Client) GetFlushAllState ¶

func (c *Client) GetFlushAllState(ctx context.Context, req *milvuspb.GetFlushAllStateRequest, opts ...grpc.CallOption) (*milvuspb.GetFlushAllStateResponse, error)

GetFlushAllState checks if all DML messages before `FlushAllTs` have been flushed.

func (*Client) GetFlushState ¶

func (c *Client) GetFlushState(ctx context.Context, req *datapb.GetFlushStateRequest, opts ...grpc.CallOption) (*milvuspb.GetFlushStateResponse, error)

GetFlushState gets the flush state of the collection based on the provided flush ts and segment IDs.

func (*Client) GetFlushedSegments ¶

func (c *Client) GetFlushedSegments(ctx context.Context, req *datapb.GetFlushedSegmentsRequest, opts ...grpc.CallOption) (*datapb.GetFlushedSegmentsResponse, error)

GetFlushedSegments returns flushed segment list of requested collection/parition

ctx is the context to control request deadline and cancellation req contains the collection/partition id to query

when partition is lesser or equal to 0, all flushed segments of collection will be returned

response struct `GetFlushedSegmentsResponse` contains flushed segment id list error is returned only when some communication issue occurs

func (*Client) GetImportProgress ¶

func (c *Client) GetImportProgress(ctx context.Context, in *internalpb.GetImportProgressRequest, opts ...grpc.CallOption) (*internalpb.GetImportProgressResponse, error)

func (*Client) GetIndexBuildProgress ¶

func (c *Client) GetIndexBuildProgress(ctx context.Context, req *indexpb.GetIndexBuildProgressRequest, opts ...grpc.CallOption) (*indexpb.GetIndexBuildProgressResponse, error)

GetIndexBuildProgress describe the progress of the index.

func (*Client) GetIndexInfos ¶

func (c *Client) GetIndexInfos(ctx context.Context, req *indexpb.GetIndexInfoRequest, opts ...grpc.CallOption) (*indexpb.GetIndexInfoResponse, error)

GetIndexInfos gets the index file paths from IndexCoord.

func (*Client) GetIndexState ¶

func (c *Client) GetIndexState(ctx context.Context, req *indexpb.GetIndexStateRequest, opts ...grpc.CallOption) (*indexpb.GetIndexStateResponse, error)

GetIndexState gets the index states from IndexCoord.

func (*Client) GetIndexStatistics ¶

func (c *Client) GetIndexStatistics(ctx context.Context, req *indexpb.GetIndexStatisticsRequest, opts ...grpc.CallOption) (*indexpb.GetIndexStatisticsResponse, error)

GetIndexStatistics get the statistics of the index.

func (*Client) GetInsertBinlogPaths ¶

func (c *Client) GetInsertBinlogPaths(ctx context.Context, req *datapb.GetInsertBinlogPathsRequest, opts ...grpc.CallOption) (*datapb.GetInsertBinlogPathsResponse, error)

GetInsertBinlogPaths requests binlog paths for specified segment

ctx is the context to control request deadline and cancellation req contains the segment id to query

response struct `GetInsertBinlogPathsResponse` contains the fields list

and corresponding binlog path list

error is returned only when some communication issue occurs

func (*Client) GetLoadSegmentInfo ¶

func (c *Client) GetLoadSegmentInfo(ctx context.Context, req *querypb.GetSegmentInfoRequest, opts ...grpc.CallOption) (*querypb.GetSegmentInfoResponse, error)

GetSegmentInfo gets the information of the specified segment from QueryCoord.

func (*Client) GetMetrics ¶

func (c *Client) GetMetrics(ctx context.Context, req *milvuspb.GetMetricsRequest, opts ...grpc.CallOption) (*milvuspb.GetMetricsResponse, error)

func (*Client) GetPChannelInfo ¶

func (c *Client) GetPChannelInfo(ctx context.Context, in *rootcoordpb.GetPChannelInfoRequest, opts ...grpc.CallOption) (*rootcoordpb.GetPChannelInfoResponse, error)

GetVChannels returns all vchannels belonging to the pchannel.

func (*Client) GetPartitionStates ¶

func (c *Client) GetPartitionStates(ctx context.Context, req *querypb.GetPartitionStatesRequest, opts ...grpc.CallOption) (*querypb.GetPartitionStatesResponse, error)

GetPartitionStates gets the states of the specified partition.

func (*Client) GetPartitionStatistics ¶

func (c *Client) GetPartitionStatistics(ctx context.Context, req *datapb.GetPartitionStatisticsRequest, opts ...grpc.CallOption) (*datapb.GetPartitionStatisticsResponse, error)

GetPartitionStatistics requests partition statistics

ctx is the context to control request deadline and cancellation req contains the collection and partition id to query

response struct `GetPartitionStatisticsResponse` contains the key-value list fields returning related data

only row count for now

error is returned only when some communication issue occurs

func (*Client) GetQueryNodeDistribution ¶

func (c *Client) GetQueryNodeDistribution(ctx context.Context, req *querypb.GetQueryNodeDistributionRequest, opts ...grpc.CallOption) (*querypb.GetQueryNodeDistributionResponse, error)

func (*Client) GetQuotaMetrics ¶

func (c *Client) GetQuotaMetrics(ctx context.Context, req *internalpb.GetQuotaMetricsRequest, opts ...grpc.CallOption) (*internalpb.GetQuotaMetricsResponse, error)

func (*Client) GetRecoveryInfo ¶

func (c *Client) GetRecoveryInfo(ctx context.Context, req *datapb.GetRecoveryInfoRequest, opts ...grpc.CallOption) (*datapb.GetRecoveryInfoResponse, error)

GetRecoveryInfo request segment recovery info of collection/partition

ctx is the context to control request deadline and cancellation req contains the collection/partition id to query

response struct `GetRecoveryInfoResponse` contains the list of segments info and corresponding vchannel info error is returned only when some communication issue occurs

func (*Client) GetRecoveryInfoV2 ¶

func (c *Client) GetRecoveryInfoV2(ctx context.Context, req *datapb.GetRecoveryInfoRequestV2, opts ...grpc.CallOption) (*datapb.GetRecoveryInfoResponseV2, error)

GetRecoveryInfoV2 request segment recovery info of collection/partitions

ctx is the context to control request deadline and cancellation req contains the collection/partitions id to query

response struct `GetRecoveryInfoResponseV2` contains the list of segments info and corresponding vchannel info error is returned only when some communication issue occurs

func (*Client) GetReplicas ¶

func (c *Client) GetReplicas(ctx context.Context, req *milvuspb.GetReplicasRequest, opts ...grpc.CallOption) (*milvuspb.GetReplicasResponse, error)

GetReplicas gets the replicas of a certain collection.

func (*Client) GetSegmentIndexState ¶

func (c *Client) GetSegmentIndexState(ctx context.Context, req *indexpb.GetSegmentIndexStateRequest, opts ...grpc.CallOption) (*indexpb.GetSegmentIndexStateResponse, error)

GetSegmentIndexState gets the index states from IndexCoord.

func (*Client) GetSegmentInfo ¶

func (c *Client) GetSegmentInfo(ctx context.Context, req *datapb.GetSegmentInfoRequest, opts ...grpc.CallOption) (*datapb.GetSegmentInfoResponse, error)

GetSegmentInfo requests segment info

ctx is the context to control request deadline and cancellation req contains the list of segment ids to query

response struct `GetSegmentInfoResponse` contains the list of segment info error is returned only when some communication issue occurs

func (*Client) GetSegmentInfoChannel ¶

func (c *Client) GetSegmentInfoChannel(ctx context.Context, _ *datapb.GetSegmentInfoChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error)

GetSegmentInfoChannel DEPRECATED legacy api to get SegmentInfo Channel name

func (*Client) GetSegmentStates ¶

func (c *Client) GetSegmentStates(ctx context.Context, req *datapb.GetSegmentStatesRequest, opts ...grpc.CallOption) (*datapb.GetSegmentStatesResponse, error)

GetSegmentStates requests segment state information

ctx is the context to control request deadline and cancellation req contains the list of segment id to query

response struct `GetSegmentStatesResponse` contains the list of each state query result

when the segment is not found, the state entry will has the field `Status`  to identify failure
otherwise the Segment State and Start position information will be returned

error is returned only when some communication issue occurs

func (*Client) GetSegmentsByStates ¶

func (c *Client) GetSegmentsByStates(ctx context.Context, req *datapb.GetSegmentsByStatesRequest, opts ...grpc.CallOption) (*datapb.GetSegmentsByStatesResponse, error)

GetSegmentsByStates returns segment list of requested collection/partition and segment states

ctx is the context to control request deadline and cancellation req contains the collection/partition id and segment states to query when partition is lesser or equal to 0, all segments of collection will be returned

response struct `GetSegmentsByStatesResponse` contains segment id list error is returned only when some communication issue occurs

func (*Client) GetShardLeaders ¶

func (c *Client) GetShardLeaders(ctx context.Context, req *querypb.GetShardLeadersRequest, opts ...grpc.CallOption) (*querypb.GetShardLeadersResponse, error)

GetShardLeaders gets the shard leaders of a certain collection.

func (*Client) GetStatisticsChannel ¶

func (c *Client) GetStatisticsChannel(ctx context.Context, req *internalpb.GetStatisticsChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error)

GetStatisticsChannel just define a channel, not used currently

func (*Client) GetTimeTickChannel ¶

func (c *Client) GetTimeTickChannel(ctx context.Context, req *internalpb.GetTimeTickChannelRequest, opts ...grpc.CallOption) (*milvuspb.StringResponse, error)

GetTimeTickChannel get timetick channel name

func (*Client) HasCollection ¶

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

HasCollection check collection existence

func (*Client) HasPartition ¶

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

HasPartition check partition existence

func (*Client) ImportV2 ¶

func (c *Client) ImportV2(ctx context.Context, in *internalpb.ImportRequestInternal, opts ...grpc.CallOption) (*internalpb.ImportResponse, error)

func (*Client) InvalidateCollectionMetaCache ¶

func (c *Client) InvalidateCollectionMetaCache(ctx context.Context, in *proxypb.InvalidateCollMetaCacheRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

InvalidateCollectionMetaCache notifies RootCoord to release the collection cache in Proxies.

func (*Client) ListAliases ¶

func (c *Client) ListAliases(ctx context.Context, req *milvuspb.ListAliasesRequest, opts ...grpc.CallOption) (*milvuspb.ListAliasesResponse, error)

ListAliases list all aliases of db or collection

func (*Client) ListCheckers ¶

func (c *Client) ListCheckers(ctx context.Context, req *querypb.ListCheckersRequest, opts ...grpc.CallOption) (*querypb.ListCheckersResponse, error)

func (*Client) ListCredUsers ¶

func (c *Client) ListCredUsers(ctx context.Context, req *milvuspb.ListCredUsersRequest, opts ...grpc.CallOption) (*milvuspb.ListCredUsersResponse, error)

func (*Client) ListDatabases ¶

func (c *Client) ListDatabases(ctx context.Context, in *milvuspb.ListDatabasesRequest, opts ...grpc.CallOption) (*milvuspb.ListDatabasesResponse, error)

func (*Client) ListFileResources ¶

func (c *Client) ListFileResources(ctx context.Context, req *milvuspb.ListFileResourcesRequest, opts ...grpc.CallOption) (*milvuspb.ListFileResourcesResponse, error)

func (*Client) ListImports ¶

func (c *Client) ListImports(ctx context.Context, in *internalpb.ListImportsRequestInternal, opts ...grpc.CallOption) (*internalpb.ListImportsResponse, error)

func (*Client) ListIndexes ¶

func (c *Client) ListIndexes(ctx context.Context, in *indexpb.ListIndexesRequest, opts ...grpc.CallOption) (*indexpb.ListIndexesResponse, error)

func (*Client) ListLoadedSegments ¶

func (c *Client) ListLoadedSegments(ctx context.Context, req *querypb.ListLoadedSegmentsRequest, opts ...grpc.CallOption) (*querypb.ListLoadedSegmentsResponse, error)

func (*Client) ListPolicy ¶

func (c *Client) ListPolicy(ctx context.Context, req *internalpb.ListPolicyRequest, opts ...grpc.CallOption) (*internalpb.ListPolicyResponse, error)

func (*Client) ListPrivilegeGroups ¶

func (c *Client) ListPrivilegeGroups(ctx context.Context, in *milvuspb.ListPrivilegeGroupsRequest, opts ...grpc.CallOption) (*milvuspb.ListPrivilegeGroupsResponse, error)

func (*Client) ListQueryNode ¶

func (c *Client) ListQueryNode(ctx context.Context, req *querypb.ListQueryNodeRequest, opts ...grpc.CallOption) (*querypb.ListQueryNodeResponse, error)

func (*Client) ListResourceGroups ¶

func (c *Client) ListResourceGroups(ctx context.Context, req *milvuspb.ListResourceGroupsRequest, opts ...grpc.CallOption) (*milvuspb.ListResourceGroupsResponse, error)

func (*Client) LoadBalance ¶

func (c *Client) LoadBalance(ctx context.Context, req *querypb.LoadBalanceRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

LoadBalance migrate the sealed segments on the source node to the dst nodes.

func (*Client) LoadCollection ¶

func (c *Client) LoadCollection(ctx context.Context, req *querypb.LoadCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

LoadCollection loads the data of the specified collections in the QueryCoord.

func (*Client) LoadPartitions ¶

func (c *Client) LoadPartitions(ctx context.Context, req *querypb.LoadPartitionsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

LoadPartitions loads the data of the specified partitions in the QueryCoord.

func (*Client) ManualCompaction ¶

func (c *Client) ManualCompaction(ctx context.Context, req *milvuspb.ManualCompactionRequest, opts ...grpc.CallOption) (*milvuspb.ManualCompactionResponse, error)

ManualCompaction triggers a compaction for a collection

func (*Client) MarkSegmentsDropped ¶

func (c *Client) MarkSegmentsDropped(ctx context.Context, req *datapb.MarkSegmentsDroppedRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) OperatePrivilege ¶

func (c *Client) OperatePrivilege(ctx context.Context, req *milvuspb.OperatePrivilegeRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) OperatePrivilegeGroup ¶

func (c *Client) OperatePrivilegeGroup(ctx context.Context, in *milvuspb.OperatePrivilegeGroupRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) OperateUserRole ¶

func (c *Client) OperateUserRole(ctx context.Context, req *milvuspb.OperateUserRoleRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) ReleaseCollection ¶

func (c *Client) ReleaseCollection(ctx context.Context, req *querypb.ReleaseCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

ReleaseCollection release the data of the specified collections in the QueryCoord.

func (*Client) ReleasePartitions ¶

func (c *Client) ReleasePartitions(ctx context.Context, req *querypb.ReleasePartitionsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

ReleasePartitions release the data of the specified partitions in the QueryCoord.

func (*Client) RemoveFileResource ¶

func (c *Client) RemoveFileResource(ctx context.Context, req *milvuspb.RemoveFileResourceRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) RenameCollection ¶

func (c *Client) RenameCollection(ctx context.Context, req *milvuspb.RenameCollectionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) ReportDataNodeTtMsgs ¶

func (c *Client) ReportDataNodeTtMsgs(ctx context.Context, req *datapb.ReportDataNodeTtMsgsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) RestoreRBAC ¶

func (c *Client) RestoreRBAC(ctx context.Context, in *milvuspb.RestoreRBACMetaRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) ResumeBalance ¶

func (c *Client) ResumeBalance(ctx context.Context, req *querypb.ResumeBalanceRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) ResumeNode ¶

func (c *Client) ResumeNode(ctx context.Context, req *querypb.ResumeNodeRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) RunAnalyzer ¶

func (c *Client) RunAnalyzer(ctx context.Context, req *querypb.RunAnalyzerRequest, opts ...grpc.CallOption) (*milvuspb.RunAnalyzerResponse, error)

func (*Client) SaveBinlogPaths ¶

func (c *Client) SaveBinlogPaths(ctx context.Context, req *datapb.SaveBinlogPathsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

SaveBinlogPaths updates segments binlogs(including insert binlogs, stats logs and delta logs)

and related message stream positions

ctx is the context to control request deadline and cancellation req contains the collection/partition id to query

response status contains the status/error code and failing reason if any error is returned only when some communication issue occurs

there is a constraint that the `SaveBinlogPaths` requests of same segment shall be passed in sequence

	the root reason is each `SaveBinlogPaths` will overwrite the checkpoint position
 if the constraint is broken, the checkpoint position will not be monotonically increasing and the integrity will be compromised

func (*Client) SelectGrant ¶

func (c *Client) SelectGrant(ctx context.Context, req *milvuspb.SelectGrantRequest, opts ...grpc.CallOption) (*milvuspb.SelectGrantResponse, error)

func (*Client) SelectRole ¶

func (c *Client) SelectRole(ctx context.Context, req *milvuspb.SelectRoleRequest, opts ...grpc.CallOption) (*milvuspb.SelectRoleResponse, error)

func (*Client) SelectUser ¶

func (c *Client) SelectUser(ctx context.Context, req *milvuspb.SelectUserRequest, opts ...grpc.CallOption) (*milvuspb.SelectUserResponse, error)

func (*Client) SetSegmentState ¶

func (c *Client) SetSegmentState(ctx context.Context, req *datapb.SetSegmentStateRequest, opts ...grpc.CallOption) (*datapb.SetSegmentStateResponse, error)

SetSegmentState sets the state of a given segment.

func (*Client) ShowCollectionIDs ¶

func (c *Client) ShowCollectionIDs(ctx context.Context, in *rootcoordpb.ShowCollectionIDsRequest, opts ...grpc.CallOption) (*rootcoordpb.ShowCollectionIDsResponse, error)

ShowCollectionIDs returns all collection IDs.

func (*Client) ShowCollections ¶

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

ShowCollections list all collection names

func (*Client) ShowConfigurations ¶

func (c *Client) ShowConfigurations(ctx context.Context, req *internalpb.ShowConfigurationsRequest, opts ...grpc.CallOption) (*internalpb.ShowConfigurationsResponse, error)

ShowConfigurations gets specified configurations para of RootCoord

func (*Client) ShowLoadCollections ¶

func (c *Client) ShowLoadCollections(ctx context.Context, req *querypb.ShowCollectionsRequest, opts ...grpc.CallOption) (*querypb.ShowCollectionsResponse, error)

func (*Client) ShowLoadPartitions ¶

func (c *Client) ShowLoadPartitions(ctx context.Context, req *querypb.ShowPartitionsRequest, opts ...grpc.CallOption) (*querypb.ShowPartitionsResponse, error)

ShowPartitions shows the partitions in the QueryCoord.

func (*Client) ShowPartitions ¶

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

ShowPartitions list all partitions in collection

func (*Client) ShowPartitionsInternal ¶

func (c *Client) ShowPartitionsInternal(ctx context.Context, in *milvuspb.ShowPartitionsRequest, opts ...grpc.CallOption) (*milvuspb.ShowPartitionsResponse, error)

func (*Client) ShowSegments ¶

func (c *Client) ShowSegments(ctx context.Context, in *milvuspb.ShowSegmentsRequest, opts ...grpc.CallOption) (*milvuspb.ShowSegmentsResponse, error)

ShowSegments list all segments

func (*Client) SuspendBalance ¶

func (c *Client) SuspendBalance(ctx context.Context, req *querypb.SuspendBalanceRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) SuspendNode ¶

func (c *Client) SuspendNode(ctx context.Context, req *querypb.SuspendNodeRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) SyncNewCreatedPartition ¶

func (c *Client) SyncNewCreatedPartition(ctx context.Context, req *querypb.SyncNewCreatedPartitionRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

SyncNewCreatedPartition notifies QueryCoord to sync new created partition if collection is loaded.

func (*Client) TransferChannel ¶

func (c *Client) TransferChannel(ctx context.Context, req *querypb.TransferChannelRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) TransferNode ¶

func (c *Client) TransferNode(ctx context.Context, req *milvuspb.TransferNodeRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) TransferReplica ¶

func (c *Client) TransferReplica(ctx context.Context, req *querypb.TransferReplicaRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) TransferSegment ¶

func (c *Client) TransferSegment(ctx context.Context, req *querypb.TransferSegmentRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) UpdateChannelCheckpoint ¶

func (c *Client) UpdateChannelCheckpoint(ctx context.Context, req *datapb.UpdateChannelCheckpointRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

UpdateChannelCheckpoint updates channel checkpoint in dataCoord.

func (*Client) UpdateChannelTimeTick ¶

func (c *Client) UpdateChannelTimeTick(ctx context.Context, in *internalpb.ChannelTimeTickMsg, opts ...grpc.CallOption) (*commonpb.Status, error)

UpdateChannelTimeTick used to handle ChannelTimeTickMsg

func (*Client) UpdateCredential ¶

func (c *Client) UpdateCredential(ctx context.Context, req *internalpb.CredentialInfo, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) UpdateLoadConfig ¶

func (c *Client) UpdateLoadConfig(ctx context.Context, req *querypb.UpdateLoadConfigRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) UpdateResourceGroups ¶

func (c *Client) UpdateResourceGroups(ctx context.Context, req *querypb.UpdateResourceGroupsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) UpdateSegmentStatistics ¶

func (c *Client) UpdateSegmentStatistics(ctx context.Context, req *datapb.UpdateSegmentStatisticsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

UpdateSegmentStatistics is the client side caller of UpdateSegmentStatistics.

func (*Client) ValidateAnalyzer ¶

func (c *Client) ValidateAnalyzer(ctx context.Context, req *querypb.ValidateAnalyzerRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) WatchChannels ¶

func (c *Client) WatchChannels(ctx context.Context, req *datapb.WatchChannelsRequest, opts ...grpc.CallOption) (*datapb.WatchChannelsResponse, error)

WatchChannels notifies DataCoord to watch vchannels of a collection