Add monTimeout param in storagecluster CR

api/v1/storagecluster_types.go

@@ -216,6 +216,9 @@ type ManageCephCluster struct {
 
 	// Whether to allow updating the device class after the OSD is initially provisioned
 	AllowDeviceClassUpdate bool `json:"allowDeviceClassUpdate,omitempty"`
+
+	// CephClusterHealthCheckSpec represent the healthcheck for Ceph daemons
+	HealthCheck *rookCephv1.CephClusterHealthCheckSpec `json:"healthCheck,omitempty"`
 }
 
 // ManageCephConfig defines how to reconcile the Ceph configuration

controllers/storagecluster/cephcluster.go

@@ -503,6 +503,10 @@ func newCephCluster(sc *ocsv1.StorageCluster, cephImage string, kmsConfigMap *co
 		cephCluster.Spec.DisruptionManagement.OSDMaintenanceTimeout = sc.Spec.ManagedResources.CephCluster.OsdMaintenanceTimeout
 	}
 
+	if sc.Spec.ManagedResources.CephCluster.HealthCheck != nil {
+		cephCluster.Spec.HealthCheck =  *sc.Spec.ManagedResources.CephCluster.HealthCheck
+	}
+
 	if sc.Spec.LogCollector != nil {
 		if sc.Spec.LogCollector.Periodicity != "" {
 			cephCluster.Spec.LogCollector.Periodicity = sc.Spec.LogCollector.Periodicity

controllers/storagecluster/cephcluster_test.go

@@ -1539,6 +1539,21 @@ func TestEnsureUpgradeReliabilityParams(t *testing.T) {
 	assert.Equal(t, 45*time.Minute, expected.Spec.DisruptionManagement.OSDMaintenanceTimeout)
 }
 
+func TestMonTimeOutParam(t *testing.T) {
+	sc := &ocsv1.StorageCluster{}
+	mockStorageCluster.DeepCopyInto(sc)
+	sc.Spec.ManagedResources.CephCluster.HealthCheck = &rookCephv1.CephClusterHealthCheckSpec{
+		DaemonHealth: rookCephv1.DaemonHealthSpec{
+			Monitor: rookCephv1.HealthCheckSpec{
+				Timeout: "3",
+			},
+		},
+	}
+	expected := newCephCluster(sc, "", nil, log)
+	assert.Equal(t, "3", expected.Spec.HealthCheck.DaemonHealth.Monitor.Timeout)
+	assert.Equal(t, false, expected.Spec.HealthCheck.DaemonHealth.Monitor.Disabled)
+}
+
 func TestDetermineDefaultCephDeviceClass(t *testing.T) {
 	cases := []struct {
 		label                 string