diff --git a/internal/distributed/datacoord/service.go b/internal/distributed/datacoord/service.go index 2b79a5e230..3b4553e587 100644 --- a/internal/distributed/datacoord/service.go +++ b/internal/distributed/datacoord/service.go @@ -226,6 +226,7 @@ func (s *Server) GetPartitionStatistics(ctx context.Context, req *datapb.GetPart return s.dataCoord.GetPartitionStatistics(ctx, req) } +// GetSegmentInfoChannel gets channel to which datacoord sends segment information func (s *Server) GetSegmentInfoChannel(ctx context.Context, req *datapb.GetSegmentInfoChannelRequest) (*milvuspb.StringResponse, error) { return s.dataCoord.GetSegmentInfoChannel(ctx) }