Merge pull request #8 from Starttoaster/ceph-status

Add ceph status endpoint

Author: Starttoaster

cluster.go

@@ -96,3 +96,31 @@ func (s *ClusterService) GetClusterResources() (*GetClusterResourcesResponse, *h
 
 	return d, resp, nil
 }
+
+// GetClusterCephStatusResponse contains the response for the /cluster/ceph/status endpoint
+type GetClusterCephStatusResponse struct {
+	Data GetClusterCephStatusData `json:"data"`
+}
+
+// GetClusterCephStatusData contains data of a ceph cluster's status from GetClusterCephStatus
+type GetClusterCephStatusData struct {
+	Health CephHealthStatus `json:"health"`
+}
+
+// GetClusterCephStatus makes a GET request to the /cluster/resources endpoint
+// https://pve.proxmox.com/pve-docs/api-viewer/index.html#/cluster/resources
+func (s *ClusterService) GetClusterCephStatus() (*GetClusterCephStatusResponse, *http.Response, error) {
+	u := "cluster/ceph/status"
+	req, err := s.client.NewRequest(http.MethodGet, u, nil)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	d := new(GetClusterCephStatusResponse)
+	resp, err := s.client.Do(req, d)
+	if err != nil {
+		return nil, resp, err
+	}
+
+	return d, resp, nil
+}

cluster_test.go

@@ -24,6 +24,33 @@ func testIntOrString(is IntOrString) *IntOrString {
 	return &is
 }
 
+func TestGetClusterCephStatus(t *testing.T) {
+	mux, server, client := setup(t)
+	defer teardown(server)
+
+	mux.HandleFunc("/api2/json/cluster/ceph/status", func(w http.ResponseWriter, r *http.Request) {
+		w.Header().Set("Content-Type", "application/json")
+		w.WriteHeader(http.StatusOK)
+		_, err := fmt.Fprint(w, fixture("clusters/get_cluster_ceph_status.json"))
+		if err != nil {
+			return
+		}
+	})
+
+	want := GetClusterCephStatusResponse{
+		Data: GetClusterCephStatusData{
+			Health: CephHealthStatus{
+				Status: "HEALTH_OK",
+			},
+		},
+	}
+
+	r, resp, err := client.Cluster.GetClusterCephStatus()
+	require.NoError(t, err)
+	require.NotNil(t, resp)
+	require.Equal(t, want, *r)
+}
+
 func TestGetClusterResources(t *testing.T) {
 	mux, server, client := setup(t)
 	defer teardown(server)
@@ -101,3 +128,64 @@ func TestGetClusterResources(t *testing.T) {
 	require.NotNil(t, resp)
 	require.Equal(t, want, *r)
 }
+
+func TestGetClusterStatus(t *testing.T) {
+	mux, server, client := setup(t)
+	defer teardown(server)
+
+	mux.HandleFunc("/api2/json/cluster/status", func(w http.ResponseWriter, r *http.Request) {
+		w.Header().Set("Content-Type", "application/json")
+		w.WriteHeader(http.StatusOK)
+		_, err := fmt.Fprint(w, fixture("clusters/get_cluster_status.json"))
+		if err != nil {
+			return
+		}
+	})
+
+	want := GetClusterStatusResponse{
+		Data: []GetClusterStatusData{
+			{
+				Type:    "cluster",
+				ID:      "cluster",
+				Version: testInt(5),
+				Quorate: testInt(1),
+				Name:    "prd",
+			},
+			{
+				NodeID: testInt(2),
+				Type:   "node",
+				IP:     testStr("10.0.1.2"),
+				Name:   "cmp2",
+				Level:  testStr(""),
+				Online: testInt(1),
+				ID:     "node/cmp2",
+				Local:  testInt(0),
+			},
+			{
+				NodeID: testInt(4),
+				Type:   "node",
+				IP:     testStr("10.0.1.3"),
+				Name:   "cmp3",
+				Level:  testStr(""),
+				Online: testInt(1),
+				ID:     "node/cmp3",
+				Local:  testInt(0),
+			},
+			{
+				NodeID: testInt(1),
+				Type:   "node",
+				IP:     testStr("10.0.1.1"),
+				Name:   "cmp1",
+				Level:  testStr(""),
+				Online: testInt(1),
+				ID:     "node/cmp1",
+				Local:  testInt(1),
+			},
+		},
+	}
+
+	r, resp, err := client.Cluster.GetClusterStatus()
+	require.NoError(t, err)
+	require.NotNil(t, resp)
+	require.Equal(t, want, *r)
+}

testdata/clusters/get_cluster_ceph_status.json

@@ -0,0 +1,7 @@
+{
+  "data": {
+    "health": {
+      "status": "HEALTH_OK"
+    }
+  }
+}

testdata/clusters/get_cluster_status.json

@@ -0,0 +1,42 @@
+{
+  "data": [
+    {
+      "type": "cluster",
+      "id": "cluster",
+      "version": 5,
+      "quorate": 1,
+      "nodes": 3,
+      "name": "prd"
+    },
+    {
+      "nodeid": 2,
+      "type": "node",
+      "ip": "10.0.1.2",
+      "name": "cmp2",
+      "level": "",
+      "online": 1,
+      "id": "node/cmp2",
+      "local": 0
+    },
+    {
+      "nodeid": 4,
+      "type": "node",
+      "ip": "10.0.1.3",
+      "name": "cmp3",
+      "level": "",
+      "online": 1,
+      "id": "node/cmp3",
+      "local": 0
+    },
+    {
+      "name": "cmp1",
+      "ip": "10.0.1.1",
+      "level": "",
+      "id": "node/cmp1",
+      "online": 1,
+      "local": 1,
+      "nodeid": 1,
+      "type": "node"
+    }
+  ]
+}

types.go

@@ -59,6 +59,11 @@ type Swap struct {
 	Used  int `json:"used"`
 }
 
+// CephHealthStatus status of ceph health
+type CephHealthStatus struct {
+	Status string `json:"status"`
+}
+
 // IntOrString is an alias for some returns from the Proxmox API where we've identified that some versions return a string, and others return an integer
 // For example, LXC VMIDs were a string return in PVE 8.1.x, and are an integer in 8.2.x
 // Since it can be either depending on the version of Proxmox queried, we're going to return the looser type. String in this case.