grpcquerynode

Documentation

Index

• type Server
  • func NewServer(ctx context.Context, factory dependency.Factory) (*Server, error)
  • func (s *Server) Delete(ctx context.Context, req *querypb.DeleteRequest) (*commonpb.Status, error)
  • func (s *Server) DeleteBatch(ctx context.Context, req *querypb.DeleteBatchRequest) (*querypb.DeleteBatchResponse, error)
  • func (s *Server) GetComponentStates(ctx context.Context, req *milvuspb.GetComponentStatesRequest) (*milvuspb.ComponentStates, error)
  • func (s *Server) GetDataDistribution(ctx context.Context, req *querypb.GetDataDistributionRequest) (*querypb.GetDataDistributionResponse, error)
  • func (s *Server) GetMetrics(ctx context.Context, req *milvuspb.GetMetricsRequest) (*milvuspb.GetMetricsResponse, error)
  • func (s *Server) GetQueryNode() types.QueryNodeComponent
  • func (s *Server) GetSegmentInfo(ctx context.Context, req *querypb.GetSegmentInfoRequest) (*querypb.GetSegmentInfoResponse, error)
  • func (s *Server) GetStatistics(ctx context.Context, request *querypb.GetStatisticsRequest) (*internalpb.GetStatisticsResponse, error)
  • func (s *Server) GetStatisticsChannel(ctx context.Context, req *internalpb.GetStatisticsChannelRequest) (*milvuspb.StringResponse, error)
  • func (s *Server) GetTimeTickChannel(ctx context.Context, req *internalpb.GetTimeTickChannelRequest) (*milvuspb.StringResponse, error)
  • func (s *Server) LoadPartitions(ctx context.Context, req *querypb.LoadPartitionsRequest) (*commonpb.Status, error)
  • func (s *Server) LoadSegments(ctx context.Context, req *querypb.LoadSegmentsRequest) (*commonpb.Status, error)
  • func (s *Server) Prepare() error
  • func (s *Server) Query(ctx context.Context, req *querypb.QueryRequest) (*internalpb.RetrieveResults, error)
  • func (s *Server) QuerySegments(ctx context.Context, req *querypb.QueryRequest) (*internalpb.RetrieveResults, error)
  • func (s *Server) QueryStream(req *querypb.QueryRequest, srv querypb.QueryNode_QueryStreamServer) error
  • func (s *Server) QueryStreamSegments(req *querypb.QueryRequest, srv querypb.QueryNode_QueryStreamSegmentsServer) error
  • func (s *Server) ReleaseCollection(ctx context.Context, req *querypb.ReleaseCollectionRequest) (*commonpb.Status, error)
  • func (s *Server) ReleasePartitions(ctx context.Context, req *querypb.ReleasePartitionsRequest) (*commonpb.Status, error)
  • func (s *Server) ReleaseSegments(ctx context.Context, req *querypb.ReleaseSegmentsRequest) (*commonpb.Status, error)
  • func (s *Server) Run() error
  • func (s *Server) Search(ctx context.Context, req *querypb.SearchRequest) (*internalpb.SearchResults, error)
  • func (s *Server) SearchSegments(ctx context.Context, req *querypb.SearchRequest) (*internalpb.SearchResults, error)
  • func (s *Server) SetEtcdClient(etcdCli *clientv3.Client)
  • func (s *Server) ShowConfigurations(ctx context.Context, req *internalpb.ShowConfigurationsRequest) (*internalpb.ShowConfigurationsResponse, error)
  • func (s *Server) Stop() (err error)
  • func (s *Server) SyncDistribution(ctx context.Context, req *querypb.SyncDistributionRequest) (*commonpb.Status, error)
  • func (s *Server) SyncReplicaSegments(ctx context.Context, req *querypb.SyncReplicaSegmentsRequest) (*commonpb.Status, error)
  • func (s *Server) UnsubDmChannel(ctx context.Context, req *querypb.UnsubDmChannelRequest) (*commonpb.Status, error)
  • func (s *Server) WatchDmChannels(ctx context.Context, req *querypb.WatchDmChannelsRequest) (*commonpb.Status, error)
• type UniqueID

Types

type Server

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

Server is the grpc server of QueryNode.

func NewServer

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

NewServer create a new QueryNode grpc server.

func (*Server) Delete

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

Delete is used to forward delete message between delegator and workers.

func (*Server) DeleteBatch

func (s *Server) DeleteBatch(ctx context.Context, req *querypb.DeleteBatchRequest) (*querypb.DeleteBatchResponse, error)

DeleteBatch is the API to apply same delete data into multiple segments. it's basically same as `Delete` but cost less memory pressure.

func (*Server) GetComponentStates

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

GetComponentStates gets the component states of QueryNode.

func (*Server) GetDataDistribution

func (s *Server) GetDataDistribution(ctx context.Context, req *querypb.GetDataDistributionRequest) (*querypb.GetDataDistributionResponse, error)

GetDataDistribution gets the distribution information of QueryNode.

func (*Server) GetMetrics

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

GetMetrics gets the metrics information of QueryNode.

func (*Server) GetQueryNode

func (s *Server) GetQueryNode() types.QueryNodeComponent

func (*Server) GetSegmentInfo

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

GetSegmentInfo gets the information of the specified segments in QueryNode.

func (*Server) GetStatistics

func (s *Server) GetStatistics(ctx context.Context, request *querypb.GetStatisticsRequest) (*internalpb.GetStatisticsResponse, error)

func (*Server) GetStatisticsChannel

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

GetStatisticsChannel gets the statistics channel of QueryNode.

func (*Server) GetTimeTickChannel

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

GetTimeTickChannel gets the time tick channel of QueryNode.

func (*Server) LoadPartitions

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

LoadPartitions updates partitions meta info in QueryNode.

func (*Server) LoadSegments

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

LoadSegments loads the segments to search.

func (*Server) Prepare

func (s *Server) Prepare() error

func (*Server) Query

func (s *Server) Query(ctx context.Context, req *querypb.QueryRequest) (*internalpb.RetrieveResults, error)

Query performs query of streaming/historical replica on QueryNode.

func (*Server) QuerySegments

func (s *Server) QuerySegments(ctx context.Context, req *querypb.QueryRequest) (*internalpb.RetrieveResults, error)

func (*Server) QueryStream

func (s *Server) QueryStream(req *querypb.QueryRequest, srv querypb.QueryNode_QueryStreamServer) error

func (*Server) QueryStreamSegments

func (s *Server) QueryStreamSegments(req *querypb.QueryRequest, srv querypb.QueryNode_QueryStreamSegmentsServer) 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 QueryNode.

func (*Server) ReleasePartitions

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

ReleasePartitions releases the data of the specified partitions in QueryNode.

func (*Server) ReleaseSegments

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

ReleaseSegments releases the data of the specified segments in QueryNode.

func (*Server) Run

func (s *Server) Run() error

Run initializes and starts QueryNode's grpc service.

func (*Server) Search

func (s *Server) Search(ctx context.Context, req *querypb.SearchRequest) (*internalpb.SearchResults, error)

Search performs search of streaming/historical replica on QueryNode.

func (*Server) SearchSegments

func (s *Server) SearchSegments(ctx context.Context, req *querypb.SearchRequest) (*internalpb.SearchResults, error)

func (*Server) SetEtcdClient

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

SetEtcdClient sets the etcd client for QueryNode component.

func (*Server) ShowConfigurations

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

ShowConfigurations gets specified configurations para of QueryNode

func (*Server) Stop

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

Stop stops QueryNode's grpc service.

func (*Server) SyncDistribution

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

func (*Server) SyncReplicaSegments

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

SyncReplicaSegments syncs replica segment information to shard leader

func (*Server) UnsubDmChannel

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

func (*Server) WatchDmChannels

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

WatchDmChannels watches the channels about data manipulation.

type UniqueID

type UniqueID = typeutil.UniqueID

UniqueID is an alias for type typeutil.UniqueID, used as a unique identifier for the request.