grpcindexnode

Documentation

Index

• type Server
  • func NewServer(ctx context.Context, factory dependency.Factory) (*Server, error)
  • func (s *Server) CreateJob(ctx context.Context, req *workerpb.CreateJobRequest) (*commonpb.Status, error)
  • func (s *Server) CreateJobV2(ctx context.Context, request *workerpb.CreateJobV2Request) (*commonpb.Status, error)
  • func (s *Server) DropJobs(ctx context.Context, req *workerpb.DropJobsRequest) (*commonpb.Status, error)
  • func (s *Server) DropJobsV2(ctx context.Context, request *workerpb.DropJobsV2Request) (*commonpb.Status, error)
  • func (s *Server) GetComponentStates(ctx context.Context, req *milvuspb.GetComponentStatesRequest) (*milvuspb.ComponentStates, error)
  • func (s *Server) GetJobStats(ctx context.Context, req *workerpb.GetJobStatsRequest) (*workerpb.GetJobStatsResponse, error)
  • func (s *Server) GetMetrics(ctx context.Context, request *milvuspb.GetMetricsRequest) (*milvuspb.GetMetricsResponse, error)
  • func (s *Server) GetStatisticsChannel(ctx context.Context, req *internalpb.GetStatisticsChannelRequest) (*milvuspb.StringResponse, error)
  • func (s *Server) Prepare() error
  • func (s *Server) QueryJobs(ctx context.Context, req *workerpb.QueryJobsRequest) (*workerpb.QueryJobsResponse, error)
  • func (s *Server) QueryJobsV2(ctx context.Context, request *workerpb.QueryJobsV2Request) (*workerpb.QueryJobsV2Response, error)
  • func (s *Server) Run() error
  • func (s *Server) SetEtcdClient(etcdCli *clientv3.Client)
  • func (s *Server) ShowConfigurations(ctx context.Context, req *internalpb.ShowConfigurationsRequest) (*internalpb.ShowConfigurationsResponse, error)
  • func (s *Server) Stop() (err error)

Types

type Server

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

Server is the grpc wrapper of IndexNode.

func NewServer

func NewServer(ctx context.Context, factory dependency.Factory) (*Server, error)

NewServer create a new IndexNode grpc server.

func (*Server) CreateJob

func (s *Server) CreateJob(ctx context.Context, req *workerpb.CreateJobRequest) (*commonpb.Status, error)

CreateJob sends the create index request to IndexNode.

func (*Server) CreateJobV2

func (s *Server) CreateJobV2(ctx context.Context, request *workerpb.CreateJobV2Request) (*commonpb.Status, error)

func (*Server) DropJobs

func (s *Server) DropJobs(ctx context.Context, req *workerpb.DropJobsRequest) (*commonpb.Status, error)

DropJobs drops index build jobs

func (*Server) DropJobsV2

func (s *Server) DropJobsV2(ctx context.Context, request *workerpb.DropJobsV2Request) (*commonpb.Status, error)

func (*Server) GetComponentStates

func (s *Server) GetComponentStates(ctx context.Context, req *milvuspb.GetComponentStatesRequest) (*milvuspb.ComponentStates, error)

GetComponentStates gets the component states of IndexNode.

func (*Server) GetJobStats

func (s *Server) GetJobStats(ctx context.Context, req *workerpb.GetJobStatsRequest) (*workerpb.GetJobStatsResponse, error)

GetJobNum gets indexnode's job statisctics

func (*Server) GetMetrics

func (s *Server) GetMetrics(ctx context.Context, request *milvuspb.GetMetricsRequest) (*milvuspb.GetMetricsResponse, error)

GetMetrics gets the metrics info of IndexNode.

func (*Server) GetStatisticsChannel

func (s *Server) GetStatisticsChannel(ctx context.Context, req *internalpb.GetStatisticsChannelRequest) (*milvuspb.StringResponse, error)

GetStatisticsChannel gets the statistics channel of IndexNode.

func (*Server) Prepare

func (s *Server) Prepare() error

func (*Server) QueryJobs

func (s *Server) QueryJobs(ctx context.Context, req *workerpb.QueryJobsRequest) (*workerpb.QueryJobsResponse, error)

QueryJobs querys index jobs statues

func (*Server) QueryJobsV2

func (s *Server) QueryJobsV2(ctx context.Context, request *workerpb.QueryJobsV2Request) (*workerpb.QueryJobsV2Response, error)

func (*Server) Run

func (s *Server) Run() error

Run initializes and starts IndexNode's grpc service.

func (*Server) SetEtcdClient

func (s *Server) SetEtcdClient(etcdCli *clientv3.Client)

SetEtcdClient sets the etcd client for QueryNode component.

func (*Server) ShowConfigurations

func (s *Server) ShowConfigurations(ctx context.Context, req *internalpb.ShowConfigurationsRequest) (*internalpb.ShowConfigurationsResponse, error)

ShowConfigurations gets specified configurations para of IndexNode

func (*Server) Stop

func (s *Server) Stop() (err error)

Stop stops IndexNode's grpc service.