MEDIUM: runtime: add all fields for runtime server.

Add ~20 new read-only fields to the RuntimeServer model parsed from
HAProxy's 'show servers state' output, including backend_id, backend_name,
uweight, iweight, check_status, check_state, agent_state, fqdn, use_ssl,
and more. Also add SetServerSSL method for toggling SSL on servers.

Author: AdamJCrawford

runtime/interface.go

@@ -85,6 +85,8 @@ type Servers interface {
 	SetServerAgentAddr(backend, server string, addr string) error
 	// SetServerAgentSend set agent-send for server
 	SetServerAgentSend(backend, server string, send string) error
+	// SetServerSSL set ssl for server
+	SetServerSSL(backend, server string, ssl string) error
 	// GetServerState returns server runtime state
 	GetServersState(backend string) (models.RuntimeServers, error)
 	// GetServerState returns server runtime state

runtime/runtime_client.go

@@ -412,6 +412,19 @@ func (c *client) SetServerAgentSend(backend, server string, send string) error {
 	return nil
 }
 
+// SetServerSSL set ssl for server
+func (c *client) SetServerSSL(backend, server string, ssl string) error {
+	if !c.runtime.IsValid() {
+		return errors.New("no valid runtime found")
+	}
+	err := c.runtime.SetServerSSL(backend, server, ssl)
+	if err != nil {
+		return fmt.Errorf("%s %w", c.runtime.socketPath, err)
+	}
+
+	return nil
+}
+
 // GetServerState returns server runtime state
 func (c *client) GetServersState(backend string) (models.RuntimeServers, error) {
 	if !c.runtime.IsValid() {

runtime/servers.go

@@ -127,6 +127,12 @@ func (s *SingleRuntime) SetServerAgentSend(backend, server string, send string)
 	return s.Execute(cmd)
 }
 
+// SetServerSSL set ssl for server
+func (s *SingleRuntime) SetServerSSL(backend, server string, ssl string) error {
+	cmd := fmt.Sprintf("set server %s/%s ssl %s", backend, server, ssl)
+	return s.Execute(cmd)
+}
+
 // GetServersState returns servers runtime state
 func (s *SingleRuntime) GetServersState(backend string) (models.RuntimeServers, error) {
 	cmd := "show servers state " + backend
@@ -179,13 +185,23 @@ func parseRuntimeServers(output string) (models.RuntimeServers, error) {
 	return result, nil
 }
 
+func parseInt64P(s string) *int64 {
+	v, err := strconv.ParseInt(s, 10, 64)
+	if err != nil {
+		return nil
+	}
+	return &v
+}
+
 func parseRuntimeServer(line string) *models.RuntimeServer {
 	fields := strings.Split(line, " ")
 
-	if len(fields) < 19 {
+	if len(fields) < 25 {
 		return nil
 	}
 
+	backendID := parseInt64P(fields[0])
+
 	p, err := strconv.ParseInt(fields[18], 10, 64)
 	var port *int64
 	if err == nil {
@@ -198,6 +214,21 @@ func parseRuntimeServer(line string) *models.RuntimeServer {
 		weight = &w
 	}
 
+	uweight := parseInt64P(fields[7])
+	iweight := parseInt64P(fields[8])
+	lastTimeChange := parseInt64P(fields[9])
+	checkStatus := parseInt64P(fields[10])
+	checkResult := parseInt64P(fields[11])
+	checkHealth := parseInt64P(fields[12])
+	checkState := parseInt64P(fields[13])
+	agentState := parseInt64P(fields[14])
+	backendForcedID := parseInt64P(fields[15])
+	forecedID := parseInt64P(fields[16])
+	checkPort := parseInt64P(fields[21])
+	agentPort := parseInt64P(fields[24])
+
+	useSsl := fields[20] == "1"
+
 	admState, _ := misc.GetServerAdminState(fields[6])
 
 	var opState string
@@ -211,12 +242,31 @@ func parseRuntimeServer(line string) *models.RuntimeServer {
 	}
 
 	return &models.RuntimeServer{
+		BackendID:        backendID,
+		BackendName:      fields[1],
 		Name:             fields[3],
 		Address:          fields[4],
 		Port:             port,
 		ID:               fields[2],
 		AdminState:       admState,
 		OperationalState: opState,
 		Weight:           weight,
+		Uweight:          uweight,
+		Iweight:          iweight,
+		LastTimeChange:   lastTimeChange,
+		CheckStatus:      checkStatus,
+		CheckResult:      checkResult,
+		CheckHealth:      checkHealth,
+		CheckState:       checkState,
+		AgentState:       agentState,
+		BackendForcedID:  backendForcedID,
+		ForecedID:        forecedID,
+		Fqdn:             fields[17],
+		Srvrecord:        fields[19],
+		UseSsl:           useSsl,
+		CheckPort:        checkPort,
+		CheckAddr:        fields[22],
+		AgentAddr:        fields[23],
+		AgentPort:        agentPort,
 	}
 }

specification/models/runtime/server.yaml

@@ -28,6 +28,80 @@ server:
     weight:
       type: integer
       x-nullable: true
+    backend_id:
+      type: integer
+      readOnly: true
+      x-nullable: true
+    backend_name:
+      type: string
+      readOnly: true
+    uweight:
+      type: integer
+      readOnly: true
+      x-nullable: true
+    iweight:
+      type: integer
+      readOnly: true
+      x-nullable: true
+    last_time_change:
+      type: integer
+      readOnly: true
+      x-nullable: true
+    check_status:
+      type: integer
+      readOnly: true
+      x-nullable: true
+    check_result:
+      type: integer
+      readOnly: true
+      x-nullable: true
+    check_health:
+      type: integer
+      readOnly: true
+      x-nullable: true
+    check_state:
+      type: integer
+      readOnly: true
+      x-nullable: true
+    agent_state:
+      type: integer
+      readOnly: true
+      x-nullable: true
+    backend_forced_id:
+      type: integer
+      readOnly: true
+      x-nullable: true
+    foreced_id:
+      type: integer
+      readOnly: true
+      x-nullable: true
+    fqdn:
+      type: string
+      readOnly: true
+    srvrecord:
+      type: string
+      readOnly: true
+    use_ssl:
+      type: boolean
+      readOnly: true
+    check_port:
+      type: integer
+      readOnly: true
+      x-nullable: true
+      minimum: 0
+      maximum: 65535
+    check_addr:
+      type: string
+      readOnly: true
+    agent_addr:
+      type: string
+      readOnly: true
+    agent_port:
+      type: integer
+      readOnly: true
+      x-nullable: true
+      minimum: 0
+      maximum: 65535
   example:
     server_id: 1
     server_name: web_server