grpcdatanode

package
v0.0.0-...-34e0b2d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 9, 2024 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Server

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

func NewServer

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

NewServer new DataNode grpc server

func (*Server) CheckChannelOperationProgress

func (s *Server) CheckChannelOperationProgress(ctx context.Context, req *datapb.ChannelWatchInfo) (*datapb.ChannelOperationProgressResponse, error)

func (*Server) CompactionV2

func (s *Server) CompactionV2(ctx context.Context, request *datapb.CompactionPlan) (*commonpb.Status, error)

func (*Server) DropCompactionPlan

func (s *Server) DropCompactionPlan(ctx context.Context, req *datapb.DropCompactionPlanRequest) (*commonpb.Status, error)

func (*Server) DropImport

func (s *Server) DropImport(ctx context.Context, req *datapb.DropImportRequest) (*commonpb.Status, error)

func (*Server) FlushChannels

func (s *Server) FlushChannels(ctx context.Context, req *datapb.FlushChannelsRequest) (*commonpb.Status, error)

func (*Server) FlushSegments

func (s *Server) FlushSegments(ctx context.Context, req *datapb.FlushSegmentsRequest) (*commonpb.Status, error)

func (*Server) GetCompactionState

func (s *Server) GetCompactionState(ctx context.Context, request *datapb.CompactionStateRequest) (*datapb.CompactionStateResponse, error)

GetCompactionState gets the Compaction tasks state of DataNode

func (*Server) GetComponentStates

GetComponentStates gets the component states of Datanode

func (*Server) GetMetrics

GetMetrics gets the metrics info of Datanode.

func (*Server) GetStatisticsChannel

GetStatisticsChannel gets the statistics channel of Datanode.

func (*Server) ImportV2

func (s *Server) ImportV2(ctx context.Context, req *datapb.ImportRequest) (*commonpb.Status, error)

func (*Server) NotifyChannelOperation

func (s *Server) NotifyChannelOperation(ctx context.Context, req *datapb.ChannelOperationsRequest) (*commonpb.Status, error)

func (*Server) PreImport

func (s *Server) PreImport(ctx context.Context, req *datapb.PreImportRequest) (*commonpb.Status, error)

func (*Server) QueryImport

func (*Server) QueryPreImport

func (*Server) QuerySlot

func (*Server) ResendSegmentStats

func (*Server) Run

func (s *Server) Run() error

Run initializes and starts Datanode's grpc service.

func (*Server) SetDataCoordInterface

func (s *Server) SetDataCoordInterface(ds types.DataCoordClient) error

func (*Server) SetEtcdClient

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

func (*Server) SetRootCoordInterface

func (s *Server) SetRootCoordInterface(ms types.RootCoordClient) error

func (*Server) ShowConfigurations

ShowConfigurations gets specified configurations para of DataNode

func (*Server) Stop

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

Stop stops Datanode's grpc service.

func (*Server) SyncSegments

func (s *Server) SyncSegments(ctx context.Context, request *datapb.SyncSegmentsRequest) (*commonpb.Status, error)

func (*Server) WatchDmChannels

func (s *Server) WatchDmChannels(ctx context.Context, req *datapb.WatchDmChannelsRequest) (*commonpb.Status, error)

Deprecated

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL