grpcproxyclient

Documentation

Index

• Variables
• func NewClient(ctx context.Context, addr string, nodeID int64) (types.ProxyClient, error)
• type Client
  • func (c *Client) Close() error
  • func (c *Client) GetComponentStates(ctx context.Context, req *milvuspb.GetComponentStatesRequest, ...) (*milvuspb.ComponentStates, error)
  • func (c *Client) GetDdChannel(ctx context.Context, req *internalpb.GetDdChannelRequest, ...) (*milvuspb.StringResponse, error)
  • func (c *Client) GetImportProgress(ctx context.Context, req *internalpb.GetImportProgressRequest, ...) (*internalpb.GetImportProgressResponse, error)
  • func (c *Client) GetProxyMetrics(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 *internalpb.ImportRequest, opts ...grpc.CallOption) (*internalpb.ImportResponse, error)
  • func (c *Client) InvalidateCollectionMetaCache(ctx context.Context, req *proxypb.InvalidateCollMetaCacheRequest, ...) (*commonpb.Status, error)
  • func (c *Client) InvalidateCredentialCache(ctx context.Context, req *proxypb.InvalidateCredCacheRequest, ...) (*commonpb.Status, error)
  • func (c *Client) InvalidateShardLeaderCache(ctx context.Context, req *proxypb.InvalidateShardLeaderCacheRequest, ...) (*commonpb.Status, error)
  • func (c *Client) ListClientInfos(ctx context.Context, req *proxypb.ListClientInfosRequest, ...) (*proxypb.ListClientInfosResponse, error)
  • func (c *Client) ListImports(ctx context.Context, req *internalpb.ListImportsRequest, ...) (*internalpb.ListImportsResponse, error)
  • func (c *Client) RefreshPolicyInfoCache(ctx context.Context, req *proxypb.RefreshPolicyInfoCacheRequest, ...) (*commonpb.Status, error)
  • func (c *Client) SetRates(ctx context.Context, req *proxypb.SetRatesRequest, opts ...grpc.CallOption) (*commonpb.Status, error)
  • func (c *Client) UpdateCredentialCache(ctx context.Context, req *proxypb.UpdateCredCacheRequest, ...) (*commonpb.Status, error)

Variables

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

Functions

func NewClient

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

NewClient creates a new client instance

Types

type Client

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

Client is the grpc client for Proxy

func (*Client) Close

func (c *Client) Close() error

Close stops the client, closes the connection

func (*Client) GetComponentStates

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

GetComponentStates get the component state.

func (*Client) GetDdChannel

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

func (*Client) GetImportProgress

func (c *Client) GetImportProgress(ctx context.Context, req *internalpb.GetImportProgressRequest, opts ...grpc.CallOption) (*internalpb.GetImportProgressResponse, error)

func (*Client) GetProxyMetrics

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

GetProxyMetrics gets the metrics of proxy, it's an internal interface which is different from GetMetrics interface, because it only obtains the metrics of Proxy, not including the topological metrics of Query cluster and Data cluster.

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

func (*Client) ImportV2

func (c *Client) ImportV2(ctx context.Context, req *internalpb.ImportRequest, opts ...grpc.CallOption) (*internalpb.ImportResponse, error)

func (*Client) InvalidateCollectionMetaCache

func (c *Client) InvalidateCollectionMetaCache(ctx context.Context, req *proxypb.InvalidateCollMetaCacheRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

InvalidateCollectionMetaCache invalidate collection meta cache

func (*Client) InvalidateCredentialCache

func (c *Client) InvalidateCredentialCache(ctx context.Context, req *proxypb.InvalidateCredCacheRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) InvalidateShardLeaderCache

func (c *Client) InvalidateShardLeaderCache(ctx context.Context, req *proxypb.InvalidateShardLeaderCacheRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) ListClientInfos

func (c *Client) ListClientInfos(ctx context.Context, req *proxypb.ListClientInfosRequest, opts ...grpc.CallOption) (*proxypb.ListClientInfosResponse, error)

func (*Client) ListImports

func (c *Client) ListImports(ctx context.Context, req *internalpb.ListImportsRequest, opts ...grpc.CallOption) (*internalpb.ListImportsResponse, error)

func (*Client) RefreshPolicyInfoCache

func (c *Client) RefreshPolicyInfoCache(ctx context.Context, req *proxypb.RefreshPolicyInfoCacheRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

func (*Client) SetRates

func (c *Client) SetRates(ctx context.Context, req *proxypb.SetRatesRequest, opts ...grpc.CallOption) (*commonpb.Status, error)

SetRates notifies Proxy to limit rates of requests.

func (*Client) UpdateCredentialCache

func (c *Client) UpdateCredentialCache(ctx context.Context, req *proxypb.UpdateCredCacheRequest, opts ...grpc.CallOption) (*commonpb.Status, error)