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

[skip ci] Fix golint warning of roles.go (#11024)

Browse Source 
Signed-off-by: dragondriver <jiquan.long@zilliz.com>
This commit is contained in:
dragondriver 2021-11-01 22:35:18 +08:00 committed by GitHub
parent b632de8dd2
commit 4dd6051eb2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
cmd/roles/roles.go
View File

@ -56,6 +56,7 @@ func newMsgFactory(localMsg bool) msgstream.Factory {
return msgstream.NewPmsFactory()
}
// MilvusRoles determines to run which components.
type MilvusRoles struct {
EnableRootCoord bool `env:"ENABLE_ROOT_COORD"`
EnableProxy bool `env:"ENABLE_PROXY"`
@ -68,6 +69,7 @@ type MilvusRoles struct {
EnableMsgStreamCoord bool `env:"ENABLE_MSGSTREAM_COORD"`
}
// EnvValue not used now.
func (mr *MilvusRoles) EnvValue(env string) bool {
env = strings.ToLower(env)
env = strings.Trim(env, " ")
@ -330,6 +332,7 @@ func (mr *MilvusRoles) runMsgStreamCoord(ctx context.Context) *components.MsgStr
return mss
}
// Run runs Milvus components.
func (mr *MilvusRoles) Run(localMsg bool, alias string) {
if os.Getenv(metricsinfo.DeployModeEnvKey) == metricsinfo.StandaloneDeployMode {
closer := trace.InitTracing("standalone")