MirrorMirror
/
riju
mirror of https://github.com/radian-software/riju.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add taint to supervisor

This commit is contained in:
Radon Rosborough 2021-08-15 17:36:24 -07:00
parent e07752d65a
commit 50b487bf5f
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
supervisor/src/main.go
View File

@ -117,6 +117,14 @@ func (sv *supervisor) ServeHTTP(w http.ResponseWriter, r *http.Request) {
http.Error(w, "401 wrong access token", http.StatusUnauthorized) http.Error(w, "401 wrong access token", http.StatusUnauthorized)
return return
} }
if r.URL.Path == "/api/supervisor/v1/taint" {
if r.Method != http.MethodPost {
http.Error(w, "405 method not allowed", http.StatusMethodNotAllowed)
return
}
sv.deployConfigHash = "tainted"
return
}
if r.URL.Path == "/api/supervisor/v1/reload" { if r.URL.Path == "/api/supervisor/v1/reload" {
if r.Method != http.MethodPost { if r.Method != http.MethodPost {
http.Error(w, "405 method not allowed", http.StatusMethodNotAllowed) http.Error(w, "405 method not allowed", http.StatusMethodNotAllowed)
@ -322,6 +330,7 @@ func (sv *supervisor) reload() error {
deployCfgHash := fmt.Sprintf("%x", h.Sum(nil)) deployCfgHash := fmt.Sprintf("%x", h.Sum(nil))
if deployCfgHash == sv.deployConfigHash { if deployCfgHash == sv.deployConfigHash {
sv.status(fmt.Sprintf("config hash remains at %s", deployCfgHash)) sv.status(fmt.Sprintf("config hash remains at %s", deployCfgHash))
return nil
} else { } else {
sv.status(fmt.Sprintf( sv.status(fmt.Sprintf(
"config hash updated %s => %s", "config hash updated %s => %s",