From 2a0d646196709e03498ea573e69dde3c72602387 Mon Sep 17 00:00:00 2001 From: shaoyue Date: Tue, 30 Nov 2021 14:28:20 +0800 Subject: [PATCH] [skip ci] Add comment for datacoord methods (#12367) Signed-off-by: shaoyue.chen --- internal/distributed/datacoord/service.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/internal/distributed/datacoord/service.go b/internal/distributed/datacoord/service.go index 046e56bf44..4f7210cb88 100644 --- a/internal/distributed/datacoord/service.go +++ b/internal/distributed/datacoord/service.go @@ -294,10 +294,12 @@ func (s *Server) GetCompactionState(ctx context.Context, req *milvuspb.GetCompac return s.dataCoord.GetCompactionState(ctx, req) } +// GetCompactionStateWithPlans gets the state of a compaction by plan func (s *Server) GetCompactionStateWithPlans(ctx context.Context, req *milvuspb.GetCompactionPlansRequest) (*milvuspb.GetCompactionPlansResponse, error) { return s.dataCoord.GetCompactionStateWithPlans(ctx, req) } +// WatchChannels starts watch channels by give request func (s *Server) WatchChannels(ctx context.Context, req *datapb.WatchChannelsRequest) (*datapb.WatchChannelsResponse, error) { return s.dataCoord.WatchChannels(ctx, req) }