diff --git a/internal/distributed/datacoord/client/client.go b/internal/distributed/datacoord/client/client.go index 0f492da4aef124f642ac7d2c8200d58a0422a2ae..24dfe3d9f189f7f0cd36152d8f29eca3089c16db 100644 --- a/internal/distributed/datacoord/client/client.go +++ b/internal/distributed/datacoord/client/client.go @@ -238,6 +238,7 @@ func (c *Client) GetComponentStates(ctx context.Context) (*internalpb.ComponentS return ret.(*internalpb.ComponentStates), err } +// GetTimeTickChannel return the name of time tick channel. func (c *Client) GetTimeTickChannel(ctx context.Context) (*milvuspb.StringResponse, error) { ret, err := c.recall(func() (interface{}, error) { client, err := c.getGrpcClient() @@ -253,6 +254,7 @@ func (c *Client) GetTimeTickChannel(ctx context.Context) (*milvuspb.StringRespon return ret.(*milvuspb.StringResponse), err } +// GetStatisticsChannel return the name of statistics channel. func (c *Client) GetStatisticsChannel(ctx context.Context) (*milvuspb.StringResponse, error) { ret, err := c.recall(func() (interface{}, error) { client, err := c.getGrpcClient()