grpcdatanodeclient

Documentation

Index

• Variables
• func NewClient(ctx context.Context, addr string, serverID int64) (types.DataNodeClient, error)
• type Client
  • func (c *Client) CheckChannelOperationProgress(ctx context.Context, req *datapb.ChannelWatchInfo, opts ...grpc.CallOption) (*datapb.ChannelOperationProgressResponse, error)
  • func (c *Client) Close() error
  • func (c *Client) CompactionV2(ctx context.Context, req *datapb.CompactionPlan, opts ...grpc.CallOption) (*commonpb.Status, error)
  • func (c *Client) DropCompactionPlan(ctx context.Context, req *datapb.DropCompactionPlanRequest, ...) (*commonpb.Status, error)
  • func (c *Client) DropImport(ctx context.Context, req *datapb.DropImportRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
  • func (c *Client) FlushChannels(ctx context.Context, req *datapb.FlushChannelsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
  • func (c *Client) FlushSegments(ctx context.Context, req *datapb.FlushSegmentsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
  • func (c *Client) GetCompactionState(ctx context.Context, req *datapb.CompactionStateRequest, ...) (*datapb.CompactionStateResponse, error)
  • func (c *Client) GetComponentStates(ctx context.Context, req *milvuspb.GetComponentStatesRequest, ...) (*milvuspb.ComponentStates, error)
  • func (c *Client) GetMetrics(ctx context.Context, req *milvuspb.GetMetricsRequest, opts ...grpc.CallOption) (*milvuspb.GetMetricsResponse, error)
  • func (c *Client) GetStatisticsChannel(ctx context.Context, req *internalpb.GetStatisticsChannelRequest, ...) (*milvuspb.StringResponse, error)
  • func (c *Client) ImportV2(ctx context.Context, req *datapb.ImportRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
  • func (c *Client) NotifyChannelOperation(ctx context.Context, req *datapb.ChannelOperationsRequest, ...) (*commonpb.Status, error)
  • func (c *Client) PreImport(ctx context.Context, req *datapb.PreImportRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
  • func (c *Client) QueryImport(ctx context.Context, req *datapb.QueryImportRequest, opts ...grpc.CallOption) (*datapb.QueryImportResponse, error)
  • func (c *Client) QueryPreImport(ctx context.Context, req *datapb.QueryPreImportRequest, ...) (*datapb.QueryPreImportResponse, error)
  • func (c *Client) QuerySlot(ctx context.Context, req *datapb.QuerySlotRequest, opts ...grpc.CallOption) (*datapb.QuerySlotResponse, error)
  • func (c *Client) ResendSegmentStats(ctx context.Context, req *datapb.ResendSegmentStatsRequest, ...) (*datapb.ResendSegmentStatsResponse, error)
  • func (c *Client) ShowConfigurations(ctx context.Context, req *internalpb.ShowConfigurationsRequest, ...) (*internalpb.ShowConfigurationsResponse, error)
  • func (c *Client) SyncSegments(ctx context.Context, req *datapb.SyncSegmentsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
  • func (c *Client) WatchDmChannels(ctx context.Context, req *datapb.WatchDmChannelsRequest, ...) (*commonpb.Status, error)

Variables

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

Functions

func NewClient

func NewClient(ctx context.Context, addr string, serverID int64) (types.DataNodeClient, error)

NewClient creates a client for DataNode.

Types

type Client

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

Client is the grpc client for DataNode

func (*Client) CheckChannelOperationProgress

func (c *Client) CheckChannelOperationProgress(ctx context.Context, req *datapb.ChannelWatchInfo, opts ...grpc.CallOption) (*datapb.ChannelOperationProgressResponse, error)

func (*Client) Close

func (c *Client) Close() error

Close stops the client. Currently, it closes the grpc connection with the DataNode.

func (*Client) CompactionV2

func (c *Client) CompactionV2(ctx context.Context, req *datapb.CompactionPlan, opts ...grpc.CallOption) (*commonpb.Status, error)

CompactionV2 return compaction by given plan

func (*Client) DropCompactionPlan

func (c *Client) DropCompactionPlan(ctx context.Context, req *datapb.DropCompactionPlanRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) DropImport

func (c *Client) DropImport(ctx context.Context, req *datapb.DropImportRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) FlushChannels

func (c *Client) FlushChannels(ctx context.Context, req *datapb.FlushChannelsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

FlushChannels notifies DataNode to sync all the segments belongs to the target channels.

func (*Client) FlushSegments

func (c *Client) FlushSegments(ctx context.Context, req *datapb.FlushSegmentsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

FlushSegments notifies DataNode to flush the segments req provids. The flush tasks are async to this

rpc, DataNode will flush the segments in the background.

Return UnexpectedError code in status:

If DataNode isn't in HEALTHY: states not HEALTHY or dynamic checks not HEALTHY
If DataNode doesn't find the correspounding segmentID in its memeory replica

Return Success code in status and trigers background flush:

Log an info log if a segment is under flushing

func (*Client) GetCompactionState

func (c *Client) GetCompactionState(ctx context.Context, req *datapb.CompactionStateRequest, opts ...grpc.CallOption) (*datapb.CompactionStateResponse, error)

func (*Client) GetComponentStates

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

GetComponentStates returns ComponentStates

func (*Client) GetMetrics

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

GetMetrics returns metrics

func (*Client) GetStatisticsChannel

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

GetStatisticsChannel return the statistics channel in string Statistics channel contains statistics infos of query nodes, such as segment infos, memory infos

func (*Client) ImportV2

func (c *Client) ImportV2(ctx context.Context, req *datapb.ImportRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) NotifyChannelOperation

func (c *Client) NotifyChannelOperation(ctx context.Context, req *datapb.ChannelOperationsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) PreImport

func (c *Client) PreImport(ctx context.Context, req *datapb.PreImportRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) QueryImport

func (c *Client) QueryImport(ctx context.Context, req *datapb.QueryImportRequest, opts ...grpc.CallOption) (*datapb.QueryImportResponse, error)

func (*Client) QueryPreImport

func (c *Client) QueryPreImport(ctx context.Context, req *datapb.QueryPreImportRequest, opts ...grpc.CallOption) (*datapb.QueryPreImportResponse, error)

func (*Client) QuerySlot

func (c *Client) QuerySlot(ctx context.Context, req *datapb.QuerySlotRequest, opts ...grpc.CallOption) (*datapb.QuerySlotResponse, error)

func (*Client) ResendSegmentStats

func (c *Client) ResendSegmentStats(ctx context.Context, req *datapb.ResendSegmentStatsRequest, opts ...grpc.CallOption) (*datapb.ResendSegmentStatsResponse, error)

func (*Client) ShowConfigurations

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

ShowConfigurations gets specified configurations para of DataNode

func (*Client) SyncSegments

func (c *Client) SyncSegments(ctx context.Context, req *datapb.SyncSegmentsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

SyncSegments is the DataNode client side code for SyncSegments call.

func (*Client) WatchDmChannels

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

Deprecated WatchDmChannels create consumers on dmChannels to reveive Incremental data