diff --git a/internal/distributed/datanode/service.go b/internal/distributed/datanode/service.go index c8ff8672e2..816855508e 100644 --- a/internal/distributed/datanode/service.go +++ b/internal/distributed/datanode/service.go @@ -287,6 +287,7 @@ func (s *Server) GetComponentStates(ctx context.Context, req *internalpb.GetComp return s.datanode.GetComponentStates(ctx) } +// GetStatisticsChannel gets the statistics channel of Datanode. func (s *Server) GetStatisticsChannel(ctx context.Context, req *internalpb.GetStatisticsChannelRequest) (*milvuspb.StringResponse, error) { return s.datanode.GetStatisticsChannel(ctx) }