grpcquerycoord

package
v0.10.3-0...-00edec2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 16, 2024 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Server 

type Server struct {
	// contains filtered or unexported fields
}

Server is the grpc server of QueryCoord.

func NewServer 

func NewServer(ctx context.Context, factory dependency.Factory) (*Server, error)

NewServer create a new QueryCoord grpc server.

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) Prepare 

func (s *Server) Prepare() error

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) UpdateLoadConfig 

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

func (*Server) UpdateResourceGroups 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.