grpcquerynodeclient

Documentation

Index

• Variables
• func NewClient(ctx context.Context, addr string, nodeID int64) (types.QueryNodeClient, error)
• type Client
  • func (c *Client) Close() error
  • func (c *Client) Delete(ctx context.Context, req *querypb.DeleteRequest, _ ...grpc.CallOption) (*commonpb.Status, error)
  • func (c *Client) DeleteBatch(ctx context.Context, req *querypb.DeleteBatchRequest, _ ...grpc.CallOption) (*querypb.DeleteBatchResponse, error)
  • func (c *Client) GetComponentStates(ctx context.Context, _ *milvuspb.GetComponentStatesRequest, ...) (*milvuspb.ComponentStates, error)
  • func (c *Client) GetDataDistribution(ctx context.Context, req *querypb.GetDataDistributionRequest, ...) (*querypb.GetDataDistributionResponse, error)
  • func (c *Client) GetMetrics(ctx context.Context, req *milvuspb.GetMetricsRequest, _ ...grpc.CallOption) (*milvuspb.GetMetricsResponse, error)
  • func (c *Client) GetSegmentInfo(ctx context.Context, req *querypb.GetSegmentInfoRequest, _ ...grpc.CallOption) (*querypb.GetSegmentInfoResponse, error)
  • func (c *Client) GetStatistics(ctx context.Context, request *querypb.GetStatisticsRequest, ...) (*internalpb.GetStatisticsResponse, error)
  • func (c *Client) GetStatisticsChannel(ctx context.Context, req *internalpb.GetStatisticsChannelRequest, ...) (*milvuspb.StringResponse, error)
  • func (c *Client) GetTimeTickChannel(ctx context.Context, req *internalpb.GetTimeTickChannelRequest, ...) (*milvuspb.StringResponse, error)
  • func (c *Client) LoadPartitions(ctx context.Context, req *querypb.LoadPartitionsRequest, _ ...grpc.CallOption) (*commonpb.Status, error)
  • func (c *Client) LoadSegments(ctx context.Context, req *querypb.LoadSegmentsRequest, _ ...grpc.CallOption) (*commonpb.Status, error)
  • func (c *Client) Query(ctx context.Context, req *querypb.QueryRequest, _ ...grpc.CallOption) (*internalpb.RetrieveResults, error)
  • func (c *Client) QuerySegments(ctx context.Context, req *querypb.QueryRequest, _ ...grpc.CallOption) (*internalpb.RetrieveResults, error)
  • func (c *Client) QueryStream(ctx context.Context, req *querypb.QueryRequest, _ ...grpc.CallOption) (querypb.QueryNode_QueryStreamClient, error)
  • func (c *Client) QueryStreamSegments(ctx context.Context, req *querypb.QueryRequest, _ ...grpc.CallOption) (querypb.QueryNode_QueryStreamSegmentsClient, error)
  • func (c *Client) ReleaseCollection(ctx context.Context, req *querypb.ReleaseCollectionRequest, ...) (*commonpb.Status, error)
  • func (c *Client) ReleasePartitions(ctx context.Context, req *querypb.ReleasePartitionsRequest, ...) (*commonpb.Status, error)
  • func (c *Client) ReleaseSegments(ctx context.Context, req *querypb.ReleaseSegmentsRequest, _ ...grpc.CallOption) (*commonpb.Status, error)
  • func (c *Client) Search(ctx context.Context, req *querypb.SearchRequest, _ ...grpc.CallOption) (*internalpb.SearchResults, error)
  • func (c *Client) SearchSegments(ctx context.Context, req *querypb.SearchRequest, _ ...grpc.CallOption) (*internalpb.SearchResults, error)
  • func (c *Client) ShowConfigurations(ctx context.Context, req *internalpb.ShowConfigurationsRequest, ...) (*internalpb.ShowConfigurationsResponse, error)
  • func (c *Client) SyncDistribution(ctx context.Context, req *querypb.SyncDistributionRequest, ...) (*commonpb.Status, error)
  • func (c *Client) SyncReplicaSegments(ctx context.Context, req *querypb.SyncReplicaSegmentsRequest, ...) (*commonpb.Status, error)
  • func (c *Client) UnsubDmChannel(ctx context.Context, req *querypb.UnsubDmChannelRequest, _ ...grpc.CallOption) (*commonpb.Status, error)
  • func (c *Client) WatchDmChannels(ctx context.Context, req *querypb.WatchDmChannelsRequest, _ ...grpc.CallOption) (*commonpb.Status, error)

Variables

var Params *paramtable.ComponentParam = paramtable.Get()

Functions

func NewClient

func NewClient(ctx context.Context, addr string, nodeID int64) (types.QueryNodeClient, error)

NewClient creates a new QueryNode client.

Types

type Client

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

Client is the grpc client of QueryNode.

func (*Client) Close

func (c *Client) Close() error

Close close QueryNode's grpc client

func (*Client) Delete

func (c *Client) Delete(ctx context.Context, req *querypb.DeleteRequest, _ ...grpc.CallOption) (*commonpb.Status, error)

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

func (*Client) DeleteBatch

func (c *Client) DeleteBatch(ctx context.Context, req *querypb.DeleteBatchRequest, _ ...grpc.CallOption) (*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 (*Client) GetComponentStates

func (c *Client) GetComponentStates(ctx context.Context, _ *milvuspb.GetComponentStatesRequest, _ ...grpc.CallOption) (*milvuspb.ComponentStates, error)

GetComponentStates gets the component states of QueryNode.

func (*Client) GetDataDistribution

func (c *Client) GetDataDistribution(ctx context.Context, req *querypb.GetDataDistributionRequest, _ ...grpc.CallOption) (*querypb.GetDataDistributionResponse, error)

func (*Client) GetMetrics

func (c *Client) GetMetrics(ctx context.Context, req *milvuspb.GetMetricsRequest, _ ...grpc.CallOption) (*milvuspb.GetMetricsResponse, error)

GetMetrics gets the metrics information of QueryNode.

func (*Client) GetSegmentInfo

func (c *Client) GetSegmentInfo(ctx context.Context, req *querypb.GetSegmentInfoRequest, _ ...grpc.CallOption) (*querypb.GetSegmentInfoResponse, error)

GetSegmentInfo gets the information of the specified segments in QueryNode.

func (*Client) GetStatistics

func (c *Client) GetStatistics(ctx context.Context, request *querypb.GetStatisticsRequest, _ ...grpc.CallOption) (*internalpb.GetStatisticsResponse, error)

func (*Client) GetStatisticsChannel

func (c *Client) GetStatisticsChannel(ctx context.Context, req *internalpb.GetStatisticsChannelRequest, _ ...grpc.CallOption) (*milvuspb.StringResponse, error)

GetStatisticsChannel gets the statistics channel of QueryNode.

func (*Client) GetTimeTickChannel

func (c *Client) GetTimeTickChannel(ctx context.Context, req *internalpb.GetTimeTickChannelRequest, _ ...grpc.CallOption) (*milvuspb.StringResponse, error)

GetTimeTickChannel gets the time tick channel of QueryNode.

func (*Client) LoadPartitions

func (c *Client) LoadPartitions(ctx context.Context, req *querypb.LoadPartitionsRequest, _ ...grpc.CallOption) (*commonpb.Status, error)

LoadPartitions updates partitions meta info in QueryNode.

func (*Client) LoadSegments

func (c *Client) LoadSegments(ctx context.Context, req *querypb.LoadSegmentsRequest, _ ...grpc.CallOption) (*commonpb.Status, error)

LoadSegments loads the segments to search.

func (*Client) Query

func (c *Client) Query(ctx context.Context, req *querypb.QueryRequest, _ ...grpc.CallOption) (*internalpb.RetrieveResults, error)

Query performs replica query tasks in QueryNode.

func (*Client) QuerySegments

func (c *Client) QuerySegments(ctx context.Context, req *querypb.QueryRequest, _ ...grpc.CallOption) (*internalpb.RetrieveResults, error)

func (*Client) QueryStream

func (c *Client) QueryStream(ctx context.Context, req *querypb.QueryRequest, _ ...grpc.CallOption) (querypb.QueryNode_QueryStreamClient, error)

func (*Client) QueryStreamSegments

func (c *Client) QueryStreamSegments(ctx context.Context, req *querypb.QueryRequest, _ ...grpc.CallOption) (querypb.QueryNode_QueryStreamSegmentsClient, error)

func (*Client) ReleaseCollection

func (c *Client) ReleaseCollection(ctx context.Context, req *querypb.ReleaseCollectionRequest, _ ...grpc.CallOption) (*commonpb.Status, error)

ReleaseCollection releases the data of the specified collection in QueryNode.

func (*Client) ReleasePartitions

func (c *Client) ReleasePartitions(ctx context.Context, req *querypb.ReleasePartitionsRequest, _ ...grpc.CallOption) (*commonpb.Status, error)

ReleasePartitions releases the data of the specified partitions in QueryNode.

func (*Client) ReleaseSegments

func (c *Client) ReleaseSegments(ctx context.Context, req *querypb.ReleaseSegmentsRequest, _ ...grpc.CallOption) (*commonpb.Status, error)

ReleaseSegments releases the data of the specified segments in QueryNode.

func (*Client) Search

func (c *Client) Search(ctx context.Context, req *querypb.SearchRequest, _ ...grpc.CallOption) (*internalpb.SearchResults, error)

Search performs replica search tasks in QueryNode.

func (*Client) SearchSegments

func (c *Client) SearchSegments(ctx context.Context, req *querypb.SearchRequest, _ ...grpc.CallOption) (*internalpb.SearchResults, error)

func (*Client) ShowConfigurations

func (c *Client) ShowConfigurations(ctx context.Context, req *internalpb.ShowConfigurationsRequest, _ ...grpc.CallOption) (*internalpb.ShowConfigurationsResponse, error)

ShowConfigurations gets specified configurations para of QueryNode

func (*Client) SyncDistribution

func (c *Client) SyncDistribution(ctx context.Context, req *querypb.SyncDistributionRequest, _ ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) SyncReplicaSegments

func (c *Client) SyncReplicaSegments(ctx context.Context, req *querypb.SyncReplicaSegmentsRequest, _ ...grpc.CallOption) (*commonpb.Status, error)

SyncReplicaSegments syncs replica node segments information to shard leaders.

func (*Client) UnsubDmChannel

func (c *Client) UnsubDmChannel(ctx context.Context, req *querypb.UnsubDmChannelRequest, _ ...grpc.CallOption) (*commonpb.Status, error)

UnsubDmChannel unsubscribes the channels about data manipulation.

func (*Client) WatchDmChannels

func (c *Client) WatchDmChannels(ctx context.Context, req *querypb.WatchDmChannelsRequest, _ ...grpc.CallOption) (*commonpb.Status, error)

WatchDmChannels watches the channels about data manipulation.