Update proxymanager.go (#135)
This commit is contained in:
@@ -334,7 +334,31 @@ func (pm *ProxyManager) upstreamIndex(c *gin.Context) {
|
|||||||
|
|
||||||
// Iterate over sorted keys
|
// Iterate over sorted keys
|
||||||
for _, modelID := range modelIDs {
|
for _, modelID := range modelIDs {
|
||||||
html.WriteString(fmt.Sprintf("<li><a href=\"/upstream/%s\">%s</a></li>", modelID, modelID))
|
// Get process state
|
||||||
|
processGroup := pm.findGroupByModelName(modelID)
|
||||||
|
var state string
|
||||||
|
if processGroup != nil {
|
||||||
|
process := processGroup.processes[modelID]
|
||||||
|
if process != nil {
|
||||||
|
var stateStr string
|
||||||
|
switch process.CurrentState() {
|
||||||
|
case StateReady:
|
||||||
|
stateStr = "Ready"
|
||||||
|
case StateStarting:
|
||||||
|
stateStr = "Starting"
|
||||||
|
case StateStopping:
|
||||||
|
stateStr = "Stopping"
|
||||||
|
case StateFailed:
|
||||||
|
stateStr = "Failed"
|
||||||
|
case StateShutdown:
|
||||||
|
stateStr = "Shutdown"
|
||||||
|
default:
|
||||||
|
stateStr = "Unknown"
|
||||||
|
}
|
||||||
|
state = stateStr
|
||||||
|
}
|
||||||
|
}
|
||||||
|
html.WriteString(fmt.Sprintf("<li><a href=\"/upstream/%s\">%s</a> - %s</li>", modelID, modelID, state))
|
||||||
}
|
}
|
||||||
html.WriteString("</ul></body></html>")
|
html.WriteString("</ul></body></html>")
|
||||||
c.Header("Content-Type", "text/html")
|
c.Header("Content-Type", "text/html")
|
||||||
|
|||||||
Reference in New Issue
Block a user