test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-12-03 04:19:18 +08:00
Code Issues Actions 13 Packages Projects Releases Wiki Activity

[skip ci]Fix golint error in datacoord (#11351)

Browse Source 
Signed-off-by: zhenshan.cao <zhenshan.cao@zilliz.com>
This commit is contained in:
zhenshan.cao 2021-11-05 23:03:10 +08:00 committed by GitHub
parent 0c4e09e341
commit fbb9a5a790
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/distributed/datacoord/client/client.go
View File

@ -238,6 +238,7 @@ func (c *Client) GetComponentStates(ctx context.Context) (*internalpb.ComponentS
return ret.(*internalpb.ComponentStates), err return ret.(*internalpb.ComponentStates), err
} }
// GetTimeTickChannel return the name of time tick channel.
func (c *Client) GetTimeTickChannel(ctx context.Context) (*milvuspb.StringResponse, error) { func (c *Client) GetTimeTickChannel(ctx context.Context) (*milvuspb.StringResponse, error) {
ret, err := c.recall(func() (interface{}, error) { ret, err := c.recall(func() (interface{}, error) {
client, err := c.getGrpcClient() client, err := c.getGrpcClient()
@ -253,6 +254,7 @@ func (c *Client) GetTimeTickChannel(ctx context.Context) (*milvuspb.StringRespon
return ret.(*milvuspb.StringResponse), err return ret.(*milvuspb.StringResponse), err
} }
// GetStatisticsChannel return the name of statistics channel.
func (c *Client) GetStatisticsChannel(ctx context.Context) (*milvuspb.StringResponse, error) { func (c *Client) GetStatisticsChannel(ctx context.Context) (*milvuspb.StringResponse, error) {
ret, err := c.recall(func() (interface{}, error) { ret, err := c.recall(func() (interface{}, error) {
client, err := c.getGrpcClient() client, err := c.getGrpcClient()