admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-01-07 19:31:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

quick fix queryCoordV2 active-standby (#21395)

Browse Source 
Signed-off-by: wayblink <anyang.wang@zilliz.com>
This commit is contained in:
wayblink 2022-12-28 10:49:29 +08:00 committed by GitHub
parent 2aed48c433
commit 0bcedbd2bf
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 19 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
internal/querycoordv2/server.go
View File

@ -325,6 +325,25 @@ func (s *Server) Start() error {
return err
}
if s.enableActiveStandBy {
s.activateFunc = func() {
log.Info("querycoord switch from standby to active, activating")
s.startServerLoop()
s.UpdateStateCode(commonpb.StateCode_Healthy)
}
s.UpdateStateCode(commonpb.StateCode_StandBy)
} else {
s.startServerLoop()
s.UpdateStateCode(commonpb.StateCode_Healthy)
}
log.Info("QueryCoord started")
s.afterStart()
return nil
}
func (s *Server) startServerLoop() {
log.Info("start cluster...")
s.cluster.Start(s.ctx)
@ -341,23 +360,6 @@ func (s *Server) Start() error {
s.collectionObserver.Start(s.ctx)
s.leaderObserver.Start(s.ctx)
s.targetObserver.Start(s.ctx)
if s.enableActiveStandBy {
s.activateFunc = func() {
// todo to complete
log.Info("querycoord switch from standby to active, activating")
s.initMeta()
s.UpdateStateCode(commonpb.StateCode_Healthy)
}
s.UpdateStateCode(commonpb.StateCode_StandBy)
} else {
s.UpdateStateCode(commonpb.StateCode_Healthy)
}
log.Info("QueryCoord started")
s.afterStart()
return nil
}
func (s *Server) Stop() error {