grpcquerycoord

func (*Server) ActivateChecker ¶

func (s *Server) ActivateChecker(ctx context.Context, req *querypb.ActivateCheckerRequest) (*commonpb.Status, error)

func (*Server) CheckHealth ¶

func (s *Server) CheckHealth(ctx context.Context, req *milvuspb.CheckHealthRequest) (*milvuspb.CheckHealthResponse, error)

func (*Server) CheckQueryNodeDistribution ¶

func (s *Server) CheckQueryNodeDistribution(ctx context.Context, req *querypb.CheckQueryNodeDistributionRequest) (*commonpb.Status, error)

func (*Server) CreateResourceGroup ¶

func (s *Server) CreateResourceGroup(ctx context.Context, req *milvuspb.CreateResourceGroupRequest) (*commonpb.Status, error)

func (*Server) DeactivateChecker ¶

func (s *Server) DeactivateChecker(ctx context.Context, req *querypb.DeactivateCheckerRequest) (*commonpb.Status, error)

func (*Server) DescribeResourceGroup ¶

func (s *Server) DescribeResourceGroup(ctx context.Context, req *querypb.DescribeResourceGroupRequest) (*querypb.DescribeResourceGroupResponse, error)

func (*Server) DropResourceGroup ¶

func (s *Server) DropResourceGroup(ctx context.Context, req *milvuspb.DropResourceGroupRequest) (*commonpb.Status, error)

func (*Server) GetComponentStates ¶

func (s *Server) GetComponentStates(ctx context.Context, req *milvuspb.GetComponentStatesRequest) (*milvuspb.ComponentStates, error)

GetComponentStates gets the component states of QueryCoord.

func (*Server) GetMetrics ¶

func (s *Server) GetMetrics(ctx context.Context, req *milvuspb.GetMetricsRequest) (*milvuspb.GetMetricsResponse, error)

GetMetrics gets the metrics information of QueryCoord.

func (*Server) GetPartitionStates ¶

func (s *Server) GetPartitionStates(ctx context.Context, req *querypb.GetPartitionStatesRequest) (*querypb.GetPartitionStatesResponse, error)

GetPartitionStates gets the states of the specified partition.

func (*Server) GetQueryCoord ¶

func (s *Server) GetQueryCoord() types.QueryCoordComponent

func (*Server) GetQueryNodeDistribution ¶

func (s *Server) GetQueryNodeDistribution(ctx context.Context, req *querypb.GetQueryNodeDistributionRequest) (*querypb.GetQueryNodeDistributionResponse, error)

func (*Server) GetReplicas ¶

func (s *Server) GetReplicas(ctx context.Context, req *milvuspb.GetReplicasRequest) (*milvuspb.GetReplicasResponse, error)

GetReplicas returns the shard leaders of a certain collection.

func (*Server) GetSegmentInfo ¶

func (s *Server) GetSegmentInfo(ctx context.Context, req *querypb.GetSegmentInfoRequest) (*querypb.GetSegmentInfoResponse, error)

GetSegmentInfo gets the information of the specified segment from QueryCoord.

func (*Server) GetShardLeaders ¶

func (s *Server) GetShardLeaders(ctx context.Context, req *querypb.GetShardLeadersRequest) (*querypb.GetShardLeadersResponse, error)

GetShardLeaders returns the shard leaders of a certain collection.

func (*Server) GetStatisticsChannel ¶

func (s *Server) GetStatisticsChannel(ctx context.Context, req *internalpb.GetStatisticsChannelRequest) (*milvuspb.StringResponse, error)

GetStatisticsChannel gets the statistics channel of QueryCoord.

func (*Server) GetTimeTickChannel ¶

func (s *Server) GetTimeTickChannel(ctx context.Context, req *internalpb.GetTimeTickChannelRequest) (*milvuspb.StringResponse, error)

GetTimeTickChannel gets the time tick channel of QueryCoord.

func (*Server) ListCheckers ¶

func (s *Server) ListCheckers(ctx context.Context, req *querypb.ListCheckersRequest) (*querypb.ListCheckersResponse, error)

func (*Server) ListQueryNode ¶

func (s *Server) ListQueryNode(ctx context.Context, req *querypb.ListQueryNodeRequest) (*querypb.ListQueryNodeResponse, error)

func (*Server) ListResourceGroups ¶

func (s *Server) ListResourceGroups(ctx context.Context, req *milvuspb.ListResourceGroupsRequest) (*milvuspb.ListResourceGroupsResponse, error)

func (*Server) LoadBalance ¶

func (s *Server) LoadBalance(ctx context.Context, req *querypb.LoadBalanceRequest) (*commonpb.Status, error)

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

func (*Server) LoadCollection ¶

func (s *Server) LoadCollection(ctx context.Context, req *querypb.LoadCollectionRequest) (*commonpb.Status, error)

LoadCollection loads the data of the specified collection in QueryCoord.

func (*Server) LoadPartitions ¶

func (s *Server) LoadPartitions(ctx context.Context, req *querypb.LoadPartitionsRequest) (*commonpb.Status, error)

LoadPartitions loads the data of the specified partition in QueryCoord.

func (*Server) ReleaseCollection ¶

func (s *Server) ReleaseCollection(ctx context.Context, req *querypb.ReleaseCollectionRequest) (*commonpb.Status, error)

ReleaseCollection releases the data of the specified collection in QueryCoord.

func (*Server) ReleasePartitions ¶

func (s *Server) ReleasePartitions(ctx context.Context, req *querypb.ReleasePartitionsRequest) (*commonpb.Status, error)

ReleasePartitions releases the data of the specified partition in QueryCoord.

func (*Server) ResumeBalance ¶

func (s *Server) ResumeBalance(ctx context.Context, req *querypb.ResumeBalanceRequest) (*commonpb.Status, error)

func (*Server) ResumeNode ¶

func (s *Server) ResumeNode(ctx context.Context, req *querypb.ResumeNodeRequest) (*commonpb.Status, error)

func (*Server) Run ¶

func (s *Server) Run() error

Run initializes and starts QueryCoord's grpc service.

func (*Server) SetDataCoord ¶

func (s *Server) SetDataCoord(d types.DataCoordClient) error

SetDataCoord sets the DataCoord's client for QueryCoord component.

func (*Server) SetEtcdClient ¶

func (s *Server) SetEtcdClient(etcdClient *clientv3.Client)

SetRootCoord sets root coordinator's client

func (*Server) SetRootCoord ¶

func (s *Server) SetRootCoord(m types.RootCoordClient) error

SetRootCoord sets the RootCoord's client for QueryCoord component.

func (*Server) SetTiKVClient ¶

func (s *Server) SetTiKVClient(client *txnkv.Client)

func (*Server) ShowCollections ¶

func (s *Server) ShowCollections(ctx context.Context, req *querypb.ShowCollectionsRequest) (*querypb.ShowCollectionsResponse, error)

ShowCollections shows the collections in the QueryCoord.

func (*Server) ShowConfigurations ¶

func (s *Server) ShowConfigurations(ctx context.Context, req *internalpb.ShowConfigurationsRequest) (*internalpb.ShowConfigurationsResponse, error)

ShowConfigurations gets specified configurations para of QueryCoord

func (*Server) ShowPartitions ¶

func (s *Server) ShowPartitions(ctx context.Context, req *querypb.ShowPartitionsRequest) (*querypb.ShowPartitionsResponse, error)

ShowPartitions shows the partitions in the QueryCoord.

func (*Server) Stop ¶

func (s *Server) Stop() (err error)

Stop stops QueryCoord's grpc service.

func (*Server) SuspendBalance ¶

func (s *Server) SuspendBalance(ctx context.Context, req *querypb.SuspendBalanceRequest) (*commonpb.Status, error)

func (*Server) SuspendNode ¶

func (s *Server) SuspendNode(ctx context.Context, req *querypb.SuspendNodeRequest) (*commonpb.Status, error)

func (*Server) SyncNewCreatedPartition ¶

func (s *Server) SyncNewCreatedPartition(ctx context.Context, req *querypb.SyncNewCreatedPartitionRequest) (*commonpb.Status, error)

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

func (*Server) TransferChannel ¶

func (s *Server) TransferChannel(ctx context.Context, req *querypb.TransferChannelRequest) (*commonpb.Status, error)

func (*Server) TransferNode ¶

func (s *Server) TransferNode(ctx context.Context, req *milvuspb.TransferNodeRequest) (*commonpb.Status, error)

func (*Server) TransferReplica ¶

func (s *Server) TransferReplica(ctx context.Context, req *querypb.TransferReplicaRequest) (*commonpb.Status, error)

func (*Server) TransferSegment ¶

func (s *Server) TransferSegment(ctx context.Context, req *querypb.TransferSegmentRequest) (*commonpb.Status, error)

func (*Server) UpdateResourceGroups ¶

func (s *Server) UpdateResourceGroups(ctx context.Context, req *querypb.UpdateResourceGroupsRequest) (*commonpb.Status, error)