querycoordv2

package
v0.10.3-0...-f06509b Latest Latest
Warning

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

 Go to latest Published: Apr 25, 2024 License: Apache-2.0 Imports: 50 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Params = params.Params

Only for re-export

Functions

This section is empty.

Types

type Server 

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

func NewQueryCoord 

func NewQueryCoord(ctx context.Context) (*Server, error)

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)

func (*Server) GetMetrics 

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

func (*Server) GetPartitionStates 

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

func (*Server) GetQueryNodeDistribution 

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

return query node's data distribution, for given nodeID, return it's (channel_name_list, sealed_segment_list)

func (*Server) GetReplicas 

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

func (*Server) GetSegmentInfo 

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

func (*Server) GetShardLeaders 

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

func (*Server) GetStatisticsChannel 

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

func (*Server) GetTimeTickChannel 

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

func (*Server) Init 

func (s *Server) Init() error

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)

return all available node list, for each node, return it's (nodeID, ip_address)

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)

func (*Server) LoadCollection 

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

func (*Server) LoadPartitions 

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

func (*Server) Register 

func (s *Server) Register() error

func (*Server) ReleaseCollection 

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

func (*Server) ReleasePartitions 

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

func (*Server) ResumeBalance 

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

resume background balance for all query node, include stopping balance and auto balance

func (*Server) ResumeNode 

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

resume node from resource operation, for given node, resume load_segment/sub_channel operations

func (*Server) SetAddress 

func (s *Server) SetAddress(address string)

func (*Server) SetDataCoordClient 

func (s *Server) SetDataCoordClient(dataCoord types.DataCoordClient) error

SetDataCoord sets data coordinator's client

func (*Server) SetEtcdClient 

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

SetEtcdClient sets etcd's client

func (*Server) SetQueryNodeCreator 

func (s *Server) SetQueryNodeCreator(f func(ctx context.Context, addr string, nodeID int64) (types.QueryNodeClient, error))

func (*Server) SetRootCoordClient 

func (s *Server) SetRootCoordClient(rootCoord types.RootCoordClient) error

SetRootCoord sets root coordinator's client

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)

func (*Server) ShowConfigurations 

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

func (*Server) ShowPartitions 

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

func (*Server) Start 

func (s *Server) Start() error

func (*Server) State 

func (s *Server) State() commonpb.StateCode

func (*Server) Stop 

func (s *Server) Stop() error

func (*Server) SuspendBalance 

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

suspend background balance for all query node, include stopping balance and auto balance

func (*Server) SuspendNode 

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

suspend node from resource operation, for given node, suspend load_segment/sub_channel operations

func (*Server) SyncNewCreatedPartition 

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

func (*Server) TransferChannel 

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

transfer channel from source to target, if no channel_name specified, default to transfer all channel on the source node. if no target_nodeId specified, default to move channel to all other nodes

func (*Server) TransferNode 

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

go:deprecated TransferNode transfer nodes between resource groups.

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)

transfer segment from source to target, if no segment_id specified, default to transfer all segment on the source node. if no target_nodeId specified, default to move segment to all other nodes

func (*Server) UpdateResourceGroups 

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

func (*Server) UpdateStateCode 

func (s *Server) UpdateStateCode(code commonpb.StateCode)

UpdateStateCode updates the status of the coord, including healthy, unhealthy

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.