srv, listen := s.stubServer(&unhealthyHandler{})
defer srv.Close()
s.handler.Config.Clusters["zzzzz"].SystemNodes["localhost"] = arvados.SystemNode{
- Keepstore: arvados.Keepstore{Listen: listen},
+ Keepstore: arvados.SystemServiceInstance{Listen: listen},
}
s.handler.ServeHTTP(s.resp, s.req)
s.checkUnhealthy(c)
srv, listen := s.stubServer(&healthyHandler{})
defer srv.Close()
s.handler.Config.Clusters["zzzzz"].SystemNodes["localhost"] = arvados.SystemNode{
- Keepstore: arvados.Keepstore{Listen: listen},
+ Keepproxy: arvados.SystemServiceInstance{Listen: listen},
+ Keepstore: arvados.SystemServiceInstance{Listen: listen},
+ Keepweb: arvados.SystemServiceInstance{Listen: listen},
+ Nodemanager: arvados.SystemServiceInstance{Listen: listen},
+ RailsAPI: arvados.SystemServiceInstance{Listen: listen},
+ Websocket: arvados.SystemServiceInstance{Listen: listen},
+ Workbench: arvados.SystemServiceInstance{Listen: listen},
}
s.handler.ServeHTTP(s.resp, s.req)
resp := s.checkOK(c)
- ep := resp.Checks["localhost/keepstore/_health/ping"]
+ svc := "keepstore+http://localhost" + listen + "/_health/ping"
+ c.Logf("%#v", resp)
+ ep := resp.Checks[svc]
c.Check(ep.Health, check.Equals, "OK")
- c.Check(ep.Status, check.Equals, 200)
+ c.Check(ep.HTTPStatusCode, check.Equals, 200)
}
func (s *AggregatorSuite) TestHealthyAndUnhealthy(c *check.C) {
srvU, listenU := s.stubServer(&unhealthyHandler{})
defer srvU.Close()
s.handler.Config.Clusters["zzzzz"].SystemNodes["localhost"] = arvados.SystemNode{
- Keepstore: arvados.Keepstore{Listen: listenH},
+ Keepproxy: arvados.SystemServiceInstance{Listen: listenH},
+ Keepstore: arvados.SystemServiceInstance{Listen: listenH},
+ Keepweb: arvados.SystemServiceInstance{Listen: listenH},
+ Nodemanager: arvados.SystemServiceInstance{Listen: listenH},
+ RailsAPI: arvados.SystemServiceInstance{Listen: listenH},
+ Websocket: arvados.SystemServiceInstance{Listen: listenH},
+ Workbench: arvados.SystemServiceInstance{Listen: listenH},
}
s.handler.Config.Clusters["zzzzz"].SystemNodes["127.0.0.1"] = arvados.SystemNode{
- Keepstore: arvados.Keepstore{Listen: listenU},
+ Keepstore: arvados.SystemServiceInstance{Listen: listenU},
}
s.handler.ServeHTTP(s.resp, s.req)
resp := s.checkUnhealthy(c)
- ep := resp.Checks["localhost/keepstore/_health/ping"]
+ ep := resp.Checks["keepstore+http://localhost"+listenH+"/_health/ping"]
c.Check(ep.Health, check.Equals, "OK")
- c.Check(ep.Status, check.Equals, 200)
- ep = resp.Checks["127.0.0.1/keepstore/_health/ping"]
+ c.Check(ep.HTTPStatusCode, check.Equals, 200)
+ ep = resp.Checks["keepstore+http://127.0.0.1"+listenU+"/_health/ping"]
c.Check(ep.Health, check.Equals, "ERROR")
- c.Check(ep.Status, check.Equals, 200)
+ c.Check(ep.HTTPStatusCode, check.Equals, 200)
+ c.Logf("%#v", ep)
}
func (s *AggregatorSuite) checkError(c *check.C) {
srv, listen := s.stubServer(&slowHandler{})
defer srv.Close()
s.handler.Config.Clusters["zzzzz"].SystemNodes["localhost"] = arvados.SystemNode{
- Keepstore: arvados.Keepstore{Listen: listen},
+ Keepstore: arvados.SystemServiceInstance{Listen: listen},
}
s.handler.ServeHTTP(s.resp, s.req)
resp := s.checkUnhealthy(c)
- ep := resp.Checks["localhost/keepstore/_health/ping"]
+ ep := resp.Checks["keepstore+http://localhost"+listen+"/_health/ping"]
c.Check(ep.Health, check.Equals, "ERROR")
- c.Check(ep.Status, check.Equals, 0)
+ c.Check(ep.HTTPStatusCode, check.Equals, 0)
rt, err := ep.ResponseTime.Float64()
c.Check(err, check.IsNil)
c.Check(rt > 0.005, check.Equals, true)