grpcdatacoord

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

Overview

Package grpcdatacoord implements grpc server for datacoord

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
}

Server is the grpc server of datacoord

func NewServer 

func NewServer(ctx context.Context, factory dependency.Factory, opts ...datacoord.Option) *Server

NewServer new data service grpc server

func (*Server) AllocSegment 

func (s *Server) AllocSegment(ctx context.Context, req *datapb.AllocSegmentRequest) (*datapb.AllocSegmentResponse, error)

AllocSegment alloc a new growing segment, add it into segment meta.

func (*Server) AlterIndex 

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

func (*Server) AssignSegmentID 

func (s *Server) AssignSegmentID(ctx context.Context, req *datapb.AssignSegmentIDRequest) (*datapb.AssignSegmentIDResponse, error)

AssignSegmentID requests to allocate segment space for insert

func (*Server) BroadcastAlteredCollection 

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

func (*Server) CheckHealth 

func (s *Server) CheckHealth(ctx context.Context, req *milvuspb.CheckHealthRequest) (*milvuspb.CheckHealthResponse, error)

func (*Server) CreateIndex 

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

CreateIndex sends the build index request to DataCoord.

func (*Server) DescribeIndex 

func (s *Server) DescribeIndex(ctx context.Context, req *indexpb.DescribeIndexRequest) (*indexpb.DescribeIndexResponse, error)

DescribeIndex gets all indexes of the collection.

func (*Server) DropIndex 

func (s *Server) DropIndex(ctx context.Context, request *indexpb.DropIndexRequest) (*commonpb.Status, error)

DropIndex sends the drop index request to DataCoord.

func (*Server) DropVirtualChannel 

func (s *Server) DropVirtualChannel(ctx context.Context, req *datapb.DropVirtualChannelRequest) (*datapb.DropVirtualChannelResponse, error)

DropVirtualChannel drop virtual channel in datacoord

func (*Server) Flush 

func (s *Server) Flush(ctx context.Context, req *datapb.FlushRequest) (*datapb.FlushResponse, error)

Flush flushes a collection's data

func (*Server) GcConfirm 

func (s *Server) GcConfirm(ctx context.Context, request *datapb.GcConfirmRequest) (*datapb.GcConfirmResponse, error)

func (*Server) GcControl 

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

func (*Server) GetChannelRecoveryInfo 

func (s *Server) GetChannelRecoveryInfo(ctx context.Context, req *datapb.GetChannelRecoveryInfoRequest) (*datapb.GetChannelRecoveryInfoResponse, error)

GetChannelRecoveryInfo gets the corresponding vchannel info.

func (*Server) GetCollectionStatistics 

func (s *Server) GetCollectionStatistics(ctx context.Context, req *datapb.GetCollectionStatisticsRequest) (*datapb.GetCollectionStatisticsResponse, error)

GetCollectionStatistics gets statistics of a collection

func (*Server) GetCompactionState 

func (s *Server) GetCompactionState(ctx context.Context, req *milvuspb.GetCompactionStateRequest) (*milvuspb.GetCompactionStateResponse, error)

GetCompactionState gets the state of a compaction

func (*Server) GetCompactionStateWithPlans 

func (s *Server) GetCompactionStateWithPlans(ctx context.Context, req *milvuspb.GetCompactionPlansRequest) (*milvuspb.GetCompactionPlansResponse, error)

GetCompactionStateWithPlans gets the state of a compaction by plan

func (*Server) GetComponentStates 

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

GetComponentStates gets states of datacoord and datanodes

func (*Server) GetFlushAllState 

func (s *Server) GetFlushAllState(ctx context.Context, req *milvuspb.GetFlushAllStateRequest) (*milvuspb.GetFlushAllStateResponse, error)

GetFlushAllState checks if all DML messages before `FlushAllTs` have been flushed.

func (*Server) GetFlushState 

func (s *Server) GetFlushState(ctx context.Context, req *datapb.GetFlushStateRequest) (*milvuspb.GetFlushStateResponse, error)

GetFlushState gets the flush state of the collection based on the provided flush ts and segment IDs.

func (*Server) GetFlushedSegments 

func (s *Server) GetFlushedSegments(ctx context.Context, req *datapb.GetFlushedSegmentsRequest) (*datapb.GetFlushedSegmentsResponse, error)

GetFlushedSegments get all flushed segments of a partition

func (*Server) GetImportProgress 

func (s *Server) GetImportProgress(ctx context.Context, in *internalpb.GetImportProgressRequest) (*internalpb.GetImportProgressResponse, error)

func (*Server) GetIndexBuildProgress deprecated 

func (s *Server) GetIndexBuildProgress(ctx context.Context, req *indexpb.GetIndexBuildProgressRequest) (*indexpb.GetIndexBuildProgressResponse, error)

Deprecated: use DescribeIndex instead

func (*Server) GetIndexInfos 

func (s *Server) GetIndexInfos(ctx context.Context, req *indexpb.GetIndexInfoRequest) (*indexpb.GetIndexInfoResponse, error)

GetIndexInfos gets the index file paths from DataCoord.

func (*Server) GetIndexState 

func (s *Server) GetIndexState(ctx context.Context, req *indexpb.GetIndexStateRequest) (*indexpb.GetIndexStateResponse, error)

GetIndexState gets the index states from DataCoord. Deprecated: use DescribeIndex instead

func (*Server) GetIndexStatistics 

func (s *Server) GetIndexStatistics(ctx context.Context, req *indexpb.GetIndexStatisticsRequest) (*indexpb.GetIndexStatisticsResponse, error)

GetIndexStatistics get the information of index..

func (*Server) GetInsertBinlogPaths 

func (s *Server) GetInsertBinlogPaths(ctx context.Context, req *datapb.GetInsertBinlogPathsRequest) (*datapb.GetInsertBinlogPathsResponse, error)

GetInsertBinlogPaths gets insert binlog paths of a segment

func (*Server) GetMetrics 

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

GetMetrics gets metrics of data coordinator and datanodes

func (*Server) GetPartitionStatistics 

func (s *Server) GetPartitionStatistics(ctx context.Context, req *datapb.GetPartitionStatisticsRequest) (*datapb.GetPartitionStatisticsResponse, error)

GetPartitionStatistics gets statistics of a partition

func (*Server) GetRecoveryInfo 

func (s *Server) GetRecoveryInfo(ctx context.Context, req *datapb.GetRecoveryInfoRequest) (*datapb.GetRecoveryInfoResponse, error)

GetRecoveryInfo gets information for recovering channels

func (*Server) GetRecoveryInfoV2 

func (s *Server) GetRecoveryInfoV2(ctx context.Context, req *datapb.GetRecoveryInfoRequestV2) (*datapb.GetRecoveryInfoResponseV2, error)

GetRecoveryInfoV2 gets information for recovering channels

func (*Server) GetSegmentIndexState 

func (s *Server) GetSegmentIndexState(ctx context.Context, req *indexpb.GetSegmentIndexStateRequest) (*indexpb.GetSegmentIndexStateResponse, error)

func (*Server) GetSegmentInfo 

func (s *Server) GetSegmentInfo(ctx context.Context, req *datapb.GetSegmentInfoRequest) (*datapb.GetSegmentInfoResponse, error)

GetSegmentInfo gets segment information according to segment id

func (*Server) GetSegmentInfoChannel 

func (s *Server) GetSegmentInfoChannel(ctx context.Context, req *datapb.GetSegmentInfoChannelRequest) (*milvuspb.StringResponse, error)

GetSegmentInfoChannel gets channel to which datacoord sends segment information

func (*Server) GetSegmentStates 

func (s *Server) GetSegmentStates(ctx context.Context, req *datapb.GetSegmentStatesRequest) (*datapb.GetSegmentStatesResponse, error)

GetSegmentStates gets states of segments

func (*Server) GetSegmentsByStates 

func (s *Server) GetSegmentsByStates(ctx context.Context, req *datapb.GetSegmentsByStatesRequest) (*datapb.GetSegmentsByStatesResponse, error)

GetSegmentsByStates get all segments of a partition by given states

func (*Server) GetStatisticsChannel 

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

GetStatisticsChannel gets statistics channel

func (*Server) GetTimeTickChannel 

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

GetTimeTickChannel gets timetick channel

func (*Server) ImportV2 

func (s *Server) ImportV2(ctx context.Context, in *internalpb.ImportRequestInternal) (*internalpb.ImportResponse, error)

func (*Server) ListImports 

func (s *Server) ListImports(ctx context.Context, in *internalpb.ListImportsRequestInternal) (*internalpb.ListImportsResponse, error)

func (*Server) ListIndexes 

func (s *Server) ListIndexes(ctx context.Context, in *indexpb.ListIndexesRequest) (*indexpb.ListIndexesResponse, error)

func (*Server) ManualCompaction 

func (s *Server) ManualCompaction(ctx context.Context, req *milvuspb.ManualCompactionRequest) (*milvuspb.ManualCompactionResponse, error)

ManualCompaction triggers a compaction for a collection

func (*Server) MarkSegmentsDropped 

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

MarkSegmentsDropped is the distributed caller of MarkSegmentsDropped.

func (*Server) ReportDataNodeTtMsgs 

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

func (*Server) Run 

func (s *Server) Run() error

Run starts the Server. Need to call inner init and start method.

func (*Server) SaveBinlogPaths 

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

SaveBinlogPaths implement DataCoordServer, saves segment, collection binlog according to datanode request

func (*Server) SetSegmentState 

func (s *Server) SetSegmentState(ctx context.Context, req *datapb.SetSegmentStateRequest) (*datapb.SetSegmentStateResponse, error)

SetSegmentState sets the state of a segment.

func (*Server) ShowConfigurations 

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

ShowConfigurations gets specified configurations para of DataCoord

func (*Server) Stop 

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

Stop stops the DataCoord server gracefully. Need to call the GracefulStop interface of grpc server and call the stop method of the inner DataCoord object.

func (*Server) UpdateChannelCheckpoint 

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

UpdateChannelCheckpoint updates channel checkpoint in dataCoord.

func (*Server) UpdateSegmentStatistics 

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

UpdateSegmentStatistics is the dataCoord service caller of UpdateSegmentStatistics.

func (*Server) WatchChannels 

func (s *Server) WatchChannels(ctx context.Context, req *datapb.WatchChannelsRequest) (*datapb.WatchChannelsResponse, error)

WatchChannels starts watch channels by give request

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.