test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-11-30 02:48:45 +08:00
Code Issues Actions 11 Packages Projects Releases Wiki Activity

[skip-ci]Fix golint on cmd/components (#8896)

Browse Source 
Signed-off-by: yangxuan <xuan.yang@zilliz.com>
This commit is contained in:
XuanYang-cn 2021-09-29 23:20:11 +08:00 committed by GitHub
parent 299a83b10d
commit 87b1d66d74
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cmd/components/proxy.go
View File

@ -20,6 +20,7 @@ import (
"github.com/milvus-io/milvus/internal/msgstream"
)
// Proxy implements Proxy grpc server
type Proxy struct {
svr *grpcproxy.Server
}
@ -53,6 +54,7 @@ func (n *Proxy) Stop() error {
return nil
}
// GetComponentStates returns Proxy's states
func (n *Proxy) GetComponentStates(ctx context.Context, request *internalpb.GetComponentStatesRequest) (*internalpb.ComponentStates, error) {
return n.svr.GetComponentStates(ctx, request)
}

2
cmd/components/query_coord.go
View File

@ -20,6 +20,7 @@ import (
"github.com/milvus-io/milvus/internal/msgstream"
)
// QueryCoord implements QueryCoord grpc server
type QueryCoord struct {
ctx context.Context
svr *grpcquerycoord.Server
@ -54,6 +55,7 @@ func (qs *QueryCoord) Stop() error {
return nil
}
// GetComponentStates returns QueryCoord's states
func (qs *QueryCoord) GetComponentStates(ctx context.Context, request *internalpb.GetComponentStatesRequest) (*internalpb.ComponentStates, error) {
return qs.svr.GetComponentStates(ctx, request)
}

2
cmd/components/query_node.go
View File

@ -20,6 +20,7 @@ import (
"github.com/milvus-io/milvus/internal/msgstream"
)
// QueryNode implements QueryNode grpc server
type QueryNode struct {
ctx context.Context
svr *grpcquerynode.Server
@ -55,6 +56,7 @@ func (q *QueryNode) Stop() error {
return nil
}
// GetComponentStates returns QueryNode's states
func (q *QueryNode) GetComponentStates(ctx context.Context, request *internalpb.GetComponentStatesRequest) (*internalpb.ComponentStates, error) {
return q.svr.GetComponentStates(ctx, request)
}

2
cmd/components/root_coord.go
View File

@ -22,6 +22,7 @@ import (
"github.com/opentracing/opentracing-go"
)
// RootCoord implements RoodCoord grpc server
type RootCoord struct {
ctx context.Context
svr *rc.Server
@ -58,6 +59,7 @@ func (rc *RootCoord) Stop() error {
return nil
}
// GetComponentStates returns RootCoord's states
func (rc *RootCoord) GetComponentStates(ctx context.Context, request *internalpb.GetComponentStatesRequest) (*internalpb.ComponentStates, error) {
return rc.svr.GetComponentStates(ctx, request)
}