grpcindexnode

package

v0.10.3-0...-f06509b Latest Latest Go to latest Published: Apr 25, 2024 License: Apache-2.0 Imports: 29 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

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

Server is the grpc wrapper of IndexNode.

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

NewServer create a new IndexNode grpc server.

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

CreateJob sends the create index request to IndexNode.

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

DropJobs drops index build jobs

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

GetComponentStates gets the component states of IndexNode.

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

GetJobNum gets indexnode's job statisctics

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

GetMetrics gets the metrics info of IndexNode.

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

GetStatisticsChannel gets the statistics channel of IndexNode.

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

QueryJobs querys index jobs statues

func (s *Server) Run() error

Run initializes and starts IndexNode's grpc service.

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

SetEtcdClient sets the etcd client for QueryNode component.

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

ShowConfigurations gets specified configurations para of IndexNode

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

Stop stops IndexNode's grpc service.

Path	Synopsis
client