grpcindexnodeclient

Documentation

Index

• Variables
• func NewClient(ctx context.Context, addr string, nodeID int64, encryption bool) (types.IndexNodeClient, error)
• type Client
  • func (c *Client) Close() error
  • func (c *Client) CreateJob(ctx context.Context, req *workerpb.CreateJobRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
  • func (c *Client) CreateJobV2(ctx context.Context, req *workerpb.CreateJobV2Request, opts ...grpc.CallOption) (*commonpb.Status, error)
  • func (c *Client) DropJobs(ctx context.Context, req *workerpb.DropJobsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
  • func (c *Client) DropJobsV2(ctx context.Context, req *workerpb.DropJobsV2Request, opt ...grpc.CallOption) (*commonpb.Status, error)
  • func (c *Client) GetComponentStates(ctx context.Context, req *milvuspb.GetComponentStatesRequest, ...) (*milvuspb.ComponentStates, error)
  • func (c *Client) GetJobStats(ctx context.Context, req *workerpb.GetJobStatsRequest, opts ...grpc.CallOption) (*workerpb.GetJobStatsResponse, 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) QueryJobs(ctx context.Context, req *workerpb.QueryJobsRequest, opts ...grpc.CallOption) (*workerpb.QueryJobsResponse, error)
  • func (c *Client) QueryJobsV2(ctx context.Context, req *workerpb.QueryJobsV2Request, opts ...grpc.CallOption) (*workerpb.QueryJobsV2Response, error)
  • func (c *Client) ShowConfigurations(ctx context.Context, req *internalpb.ShowConfigurationsRequest, ...) (*internalpb.ShowConfigurationsResponse, error)

Variables

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

Functions

func NewClient

func NewClient(ctx context.Context, addr string, nodeID int64, encryption bool) (types.IndexNodeClient, error)

NewClient creates a new IndexNode client.

Types

type Client

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

Client is the grpc client of IndexNode.

func (*Client) Close

func (c *Client) Close() error

Close stops IndexNode's grpc client.

func (*Client) CreateJob

func (c *Client) CreateJob(ctx context.Context, req *workerpb.CreateJobRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

CreateJob sends the build index request to IndexNode.

func (*Client) CreateJobV2

func (c *Client) CreateJobV2(ctx context.Context, req *workerpb.CreateJobV2Request, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) DropJobs

func (c *Client) DropJobs(ctx context.Context, req *workerpb.DropJobsRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

DropJobs query the task info of the index task.

func (*Client) DropJobsV2

func (c *Client) DropJobsV2(ctx context.Context, req *workerpb.DropJobsV2Request, opt ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) GetComponentStates

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

GetComponentStates gets the component states of IndexNode.

func (*Client) GetJobStats

func (c *Client) GetJobStats(ctx context.Context, req *workerpb.GetJobStatsRequest, opts ...grpc.CallOption) (*workerpb.GetJobStatsResponse, error)

GetJobStats query the task info of the index task.

func (*Client) GetMetrics

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

GetMetrics gets the metrics info of IndexNode.

func (*Client) GetStatisticsChannel

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

func (*Client) QueryJobs

func (c *Client) QueryJobs(ctx context.Context, req *workerpb.QueryJobsRequest, opts ...grpc.CallOption) (*workerpb.QueryJobsResponse, error)

QueryJobs query the task info of the index task.

func (*Client) QueryJobsV2

func (c *Client) QueryJobsV2(ctx context.Context, req *workerpb.QueryJobsV2Request, opts ...grpc.CallOption) (*workerpb.QueryJobsV2Response, 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 IndexNode