add raw name of system cluster when initializing
This commit is contained in:
parent
2609e51623
commit
3bd248f80f
|
@ -248,6 +248,7 @@ func (module *Module) initTempClient(r *http.Request) (error, elastic.API,SetupR
|
||||||
cfg.Schema=uri.Scheme
|
cfg.Schema=uri.Scheme
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
cfg.ID = tempID
|
cfg.ID = tempID
|
||||||
cfg.Name = "INFINI_SYSTEM ("+util.PickRandomName()+")"
|
cfg.Name = "INFINI_SYSTEM ("+util.PickRandomName()+")"
|
||||||
elastic.InitMetadata(&cfg, true)
|
elastic.InitMetadata(&cfg, true)
|
||||||
|
@ -256,10 +257,18 @@ func (module *Module) initTempClient(r *http.Request) (error, elastic.API,SetupR
|
||||||
return err,nil,request
|
return err,nil,request
|
||||||
}
|
}
|
||||||
|
|
||||||
|
global.Register(elastic.GlobalSystemElasticsearchID,tempID)
|
||||||
|
|
||||||
elastic.UpdateConfig(cfg)
|
elastic.UpdateConfig(cfg)
|
||||||
elastic.UpdateClient(cfg, client)
|
elastic.UpdateClient(cfg, client)
|
||||||
|
health, err := client.ClusterHealth()
|
||||||
|
if err != nil {
|
||||||
|
return err,nil,request
|
||||||
|
}
|
||||||
|
if health != nil {
|
||||||
|
cfg.RawName = health.Name
|
||||||
|
}
|
||||||
cfg.Version=client.GetVersion()
|
cfg.Version=client.GetVersion()
|
||||||
global.Register(elastic.GlobalSystemElasticsearchID,tempID)
|
|
||||||
|
|
||||||
return err, client,request
|
return err, client,request
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue