diff --git a/internal/distributed/datacoord/service.go b/internal/distributed/datacoord/service.go index 9fb0d1a5ed..ce8305818a 100644 --- a/internal/distributed/datacoord/service.go +++ b/internal/distributed/datacoord/service.go @@ -264,14 +264,17 @@ func (s *Server) GetMetrics(ctx context.Context, req *milvuspb.GetMetricsRequest return s.dataCoord.GetMetrics(ctx, req) } +// CompleteCompaction completes a compaction with the result func (s *Server) CompleteCompaction(ctx context.Context, req *datapb.CompactionResult) (*commonpb.Status, error) { return s.dataCoord.CompleteCompaction(ctx, req) } +// ManualCompaction triggers a compaction for a collection func (s *Server) ManualCompaction(ctx context.Context, req *milvuspb.ManualCompactionRequest) (*milvuspb.ManualCompactionResponse, error) { return s.dataCoord.ManualCompaction(ctx, req) } +// GetCompactionState gets the state of a compaction func (s *Server) GetCompactionState(ctx context.Context, req *milvuspb.GetCompactionStateRequest) (*milvuspb.GetCompactionStateResponse, error) { return s.dataCoord.GetCompactionState(ctx, req) }