Remove check for flux ping when adding and updating flux service (#4361)
parent
819c554533
commit
43afa38b0a
|
@ -123,15 +123,6 @@ func (s *Service) NewService(w http.ResponseWriter, r *http.Request) {
|
|||
return
|
||||
}
|
||||
|
||||
if req.Type != nil && req.URL != nil && *req.Type == "flux" {
|
||||
err := pingFlux(ctx, *req.URL, req.InsecureSkipVerify)
|
||||
if err != nil {
|
||||
msg := fmt.Sprintf("Unable to reach flux %s: %v", *req.URL, err)
|
||||
Error(w, http.StatusGatewayTimeout, msg, s.Logger)
|
||||
return
|
||||
}
|
||||
}
|
||||
|
||||
srv := chronograf.Server{
|
||||
SrcID: srcID,
|
||||
Name: *req.Name,
|
||||
|
@ -320,15 +311,6 @@ func (s *Service) UpdateService(w http.ResponseWriter, r *http.Request) {
|
|||
srv.Metadata = *req.Metadata
|
||||
}
|
||||
|
||||
if srv.Type == "flux" {
|
||||
err := pingFlux(ctx, srv.URL, srv.InsecureSkipVerify)
|
||||
if err != nil {
|
||||
msg := fmt.Sprintf("Unable to reach flux %s: %v", srv.URL, err)
|
||||
Error(w, http.StatusGatewayTimeout, msg, s.Logger)
|
||||
return
|
||||
}
|
||||
}
|
||||
|
||||
if err := s.Store.Servers(ctx).Update(ctx, srv); err != nil {
|
||||
msg := fmt.Sprintf("Error updating service ID %d", id)
|
||||
Error(w, http.StatusInternalServerError, msg, s.Logger)
|
||||
|
|
Loading…
Reference in New Issue