grpcquerynode

package
v0.10.3-0...-930112e Latest Latest
Warning

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

Go to latest
Published: Nov 23, 2024 License: Apache-2.0 Imports: 28 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 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

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

GetComponentStates gets the component states of QueryNode.

func (*Server) GetDataDistribution

GetDataDistribution gets the distribution information of QueryNode.

func (*Server) GetMetrics

GetMetrics gets the metrics information of QueryNode.

func (*Server) GetQueryNode

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

func (*Server) GetSegmentInfo

GetSegmentInfo gets the information of the specified segments in QueryNode.

func (*Server) GetStatistics

func (*Server) GetStatisticsChannel

GetStatisticsChannel gets the statistics channel of QueryNode.

func (*Server) GetTimeTickChannel

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

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 (*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

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

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.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL