Allow the operator to restart the CC when tester processes are unreachable (#1925)

* Allow the operator to restart the CC when tester processes are unreachable

Author: johscheuer

api/v1beta2/foundationdb_status.go

@@ -54,6 +54,14 @@ type FoundationDBStatusMessage struct {
 	Name string `json:"name,omitempty"`
 	// Description contains a human friendly description of the message.
 	Description string `json:"description,omitempty"`
+	// UnreachableProcesses contains the unreachable processes. This value is only set for unreachable_processes messages.
+	UnreachableProcesses []FoundationDBUnreachableProcess `json:"unreachable_processes,omitempty"`
+}
+
+// FoundationDBUnreachableProcess provides information about an unreachable process
+type FoundationDBUnreachableProcess struct {
+	// Address provides the address of the unreachable process
+	Address string `json:"address,omitempty"`
 }
 
 // FoundationDBStatusCoordinatorInfo contains information about the client's

api/v1beta2/foundationdb_status_test.go

@@ -923,4 +923,21 @@ var _ = Describe("FoundationDBStatus", func() {
 			Expect(statusParsed.Cluster).To(Equal(status))
 		})
 	})
+
+	When("parsing a machine-readable status that contains the unreachable processes message", func() {
+		It("should parse the cluster messages correct", func() {
+			statusFile, err := os.OpenFile(filepath.Join("testdata", "unreachable_test_processes.json"), os.O_RDONLY, os.ModePerm)
+			Expect(err).NotTo(HaveOccurred())
+			defer statusFile.Close()
+			statusDecoder := json.NewDecoder(statusFile)
+			statusParsed := FoundationDBStatus{}
+			Expect(statusDecoder.Decode(&statusParsed)).NotTo(HaveOccurred())
+			Expect(statusParsed.Cluster.Messages).To(HaveLen(2))
+			Expect(statusParsed.Cluster.Messages[0].UnreachableProcesses).To(HaveLen(1))
+			Expect(statusParsed.Cluster.Messages[0].Name).To(Equal("unreachable_processes"))
+			Expect(statusParsed.Cluster.Messages[0].UnreachableProcesses[0].Address).To(Equal("100.82.115.41:4500:tls"))
+			Expect(statusParsed.Cluster.Messages[1].UnreachableProcesses).To(HaveLen(0))
+			Expect(statusParsed.Cluster.Messages[1].Name).To(Equal("status_incomplete"))
+		})
+	})
 })