···

       
3
       
 
       
with lib;

     

       
4
       
 
       


     

       
5
       
 
       
let

     

       
6
       
-
       
  cfg  = config.services.ceph;

     

       
7
       
 
       


     

       
8
       
 
       
  # function that translates "camelCaseOptions" to "camel case options", credits to tilpner in #nixos@freenode

     

       
9
       
 
       
  expandCamelCase = replaceStrings upperChars (map (s: " ${s}") lowerChars);

     

       
10
       
 
       
  expandCamelCaseAttrs = mapAttrs' (name: value: nameValuePair (expandCamelCase name) value);

     

       
11
       
 
       


     

       
12
       
-
       
  makeServices = (daemonType: daemonIds:

     

       
13
       
 
       
    mkMerge (map (daemonId:

     

       
14
       
-
       
      { "ceph-${daemonType}-${daemonId}" = makeService daemonType daemonId cfg.global.clusterName pkgs.ceph; })

     

       
15
       
-
       
      daemonIds));

     

       
16
       
 
       


     

       
17
       
-
       
  makeService = (daemonType: daemonId: clusterName: ceph:

     

       
18
       
 
       
    let

     

       
19
       
 
       
      stateDirectory = "ceph/${if daemonType == "rgw" then "radosgw" else daemonType}/${clusterName}-${daemonId}"; in {

     

       
20
       
 
       
    enable = true;

     
···

       
54
       
 
       
    } // optionalAttrs ( daemonType == "mon") {

     

       
55
       
 
       
      RestartSec = "10";

     

       
56
       
 
       
    };

     

       
57
       
-
       
  });

     

       
58
       
 
       


     

       
59
       
-
       
  makeTarget = (daemonType:

     

       
60
       
 
       
    {

     

       
61
       
 
       
      "ceph-${daemonType}" = {

     

       
62
       
 
       
        description = "Ceph target allowing to start/stop all ceph-${daemonType} services at once";

     
···

       
65
       
 
       
        before = [ "ceph.target" ];

     

       
66
       
 
       
        unitConfig.StopWhenUnneeded = true;

     

       
67
       
 
       
      };

     

       
68
       
-
       
    }

     

       
69
       
-
       
  );

     

       
70
       
 
       
in

     

       
71
       
 
       
{

     

       
72
       
 
       
  options.services.ceph = {

     
···

       
211
       
 
       
          to the id part in ceph i.e. [ "name1" ] would result in mgr.name1

     

       
212
       
 
       
        '';

     

       
213
       
 
       
      };

     

       
0
       
 
       

     

       
214
       
 
       
      extraConfig = mkOption {

     

       
215
       
 
       
        type = with types; attrsOf str;

     

       
216
       
 
       
        default = {};

     
···

       
231
       
 
       
          to the id part in ceph i.e. [ "name1" ] would result in mon.name1

     

       
232
       
 
       
        '';

     

       
233
       
 
       
      };

     

       
0
       
 
       

     

       
234
       
 
       
      extraConfig = mkOption {

     

       
235
       
 
       
        type = with types; attrsOf str;

     

       
236
       
 
       
        default = {};

     
···

       
251
       
 
       
          to the id part in ceph i.e. [ "name1" ] would result in osd.name1

     

       
252
       
 
       
        '';

     

       
253
       
 
       
      };

     

       
254
       
-
       


     

       
255
       
 
       
      extraConfig = mkOption {

     

       
256
       
 
       
        type = with types; attrsOf str;

     

       
257
       
 
       
        default = {

     
···

       
279
       
 
       
          to the id part in ceph i.e. [ "name1" ] would result in mds.name1

     

       
280
       
 
       
        '';

     

       
281
       
 
       
      };

     

       
0
       
 
       

     

       
282
       
 
       
      extraConfig = mkOption {

     

       
283
       
 
       
        type = with types; attrsOf str;

     

       
284
       
 
       
        default = {};

     
···

       
290
       
 
       


     

       
291
       
 
       
    rgw = {

     

       
292
       
 
       
      enable = mkEnableOption (lib.mdDoc "Ceph RadosGW daemon");

     

       
0
       
 
       

     

       
293
       
 
       
      daemons = mkOption {

     

       
294
       
 
       
        type = with types; listOf str;

     

       
295
       
 
       
        default = [];

     
···

       
328
       
 
       
      { assertion = cfg.global.fsid != "";

     

       
329
       
 
       
        message = "fsid has to be set to a valid uuid for the cluster to function";

     

       
330
       
 
       
      }

     

       
331
       
-
       
      { assertion = cfg.mon.enable == true -> cfg.mon.daemons != [];

     

       
332
       
 
       
        message = "have to set id of atleast one MON if you're going to enable Monitor";

     

       
333
       
 
       
      }

     

       
334
       
-
       
      { assertion = cfg.mds.enable == true -> cfg.mds.daemons != [];

     

       
335
       
 
       
        message = "have to set id of atleast one MDS if you're going to enable Metadata Service";

     

       
336
       
 
       
      }

     

       
337
       
-
       
      { assertion = cfg.osd.enable == true -> cfg.osd.daemons != [];

     

       
338
       
 
       
        message = "have to set id of atleast one OSD if you're going to enable OSD";

     

       
339
       
 
       
      }

     

       
340
       
-
       
      { assertion = cfg.mgr.enable == true -> cfg.mgr.daemons != [];

     

       
341
       
 
       
        message = "have to set id of atleast one MGR if you're going to enable MGR";

     

       
342
       
 
       
      }

     

       
343
       
 
       
    ];

     

···

       
3
       
 
       
with lib;

     

       
4
       
 
       


     

       
5
       
 
       
let

     

       
6
       
+
       
  cfg = config.services.ceph;

     

       
7
       
 
       


     

       
8
       
 
       
  # function that translates "camelCaseOptions" to "camel case options", credits to tilpner in #nixos@freenode

     

       
9
       
 
       
  expandCamelCase = replaceStrings upperChars (map (s: " ${s}") lowerChars);

     

       
10
       
 
       
  expandCamelCaseAttrs = mapAttrs' (name: value: nameValuePair (expandCamelCase name) value);

     

       
11
       
 
       


     

       
12
       
+
       
  makeServices = daemonType: daemonIds:

     

       
13
       
 
       
    mkMerge (map (daemonId:

     

       
14
       
+
       
      { "ceph-${daemonType}-${daemonId}" = makeService daemonType daemonId cfg.global.clusterName cfg.${daemonType}.package; })

     

       
15
       
+
       
      daemonIds);

     

       
16
       
 
       


     

       
17
       
+
       
  makeService = daemonType: daemonId: clusterName: ceph:

     

       
18
       
 
       
    let

     

       
19
       
 
       
      stateDirectory = "ceph/${if daemonType == "rgw" then "radosgw" else daemonType}/${clusterName}-${daemonId}"; in {

     

       
20
       
 
       
    enable = true;

     
···

       
54
       
 
       
    } // optionalAttrs ( daemonType == "mon") {

     

       
55
       
 
       
      RestartSec = "10";

     

       
56
       
 
       
    };

     

       
57
       
+
       
  };

     

       
58
       
 
       


     

       
59
       
+
       
  makeTarget = daemonType:

     

       
60
       
 
       
    {

     

       
61
       
 
       
      "ceph-${daemonType}" = {

     

       
62
       
 
       
        description = "Ceph target allowing to start/stop all ceph-${daemonType} services at once";

     
···

       
65
       
 
       
        before = [ "ceph.target" ];

     

       
66
       
 
       
        unitConfig.StopWhenUnneeded = true;

     

       
67
       
 
       
      };

     

       
68
       
+
       
    };

     

       
0
       
 
       

     

       
69
       
 
       
in

     

       
70
       
 
       
{

     

       
71
       
 
       
  options.services.ceph = {

     
···

       
210
       
 
       
          to the id part in ceph i.e. [ "name1" ] would result in mgr.name1

     

       
211
       
 
       
        '';

     

       
212
       
 
       
      };

     

       
213
       
+
       
      package = mkPackageOptionMD pkgs "ceph" { };

     

       
214
       
 
       
      extraConfig = mkOption {

     

       
215
       
 
       
        type = with types; attrsOf str;

     

       
216
       
 
       
        default = {};

     
···

       
231
       
 
       
          to the id part in ceph i.e. [ "name1" ] would result in mon.name1

     

       
232
       
 
       
        '';

     

       
233
       
 
       
      };

     

       
234
       
+
       
      package = mkPackageOptionMD pkgs "ceph" { };

     

       
235
       
 
       
      extraConfig = mkOption {

     

       
236
       
 
       
        type = with types; attrsOf str;

     

       
237
       
 
       
        default = {};

     
···

       
252
       
 
       
          to the id part in ceph i.e. [ "name1" ] would result in osd.name1

     

       
253
       
 
       
        '';

     

       
254
       
 
       
      };

     

       
255
       
+
       
      package = mkPackageOptionMD pkgs "ceph" { };

     

       
256
       
 
       
      extraConfig = mkOption {

     

       
257
       
 
       
        type = with types; attrsOf str;

     

       
258
       
 
       
        default = {

     
···

       
280
       
 
       
          to the id part in ceph i.e. [ "name1" ] would result in mds.name1

     

       
281
       
 
       
        '';

     

       
282
       
 
       
      };

     

       
283
       
+
       
      package = mkPackageOptionMD pkgs "ceph" { };

     

       
284
       
 
       
      extraConfig = mkOption {

     

       
285
       
 
       
        type = with types; attrsOf str;

     

       
286
       
 
       
        default = {};

     
···

       
292
       
 
       


     

       
293
       
 
       
    rgw = {

     

       
294
       
 
       
      enable = mkEnableOption (lib.mdDoc "Ceph RadosGW daemon");

     

       
295
       
+
       
      package = mkPackageOptionMD pkgs "ceph" { };

     

       
296
       
 
       
      daemons = mkOption {

     

       
297
       
 
       
        type = with types; listOf str;

     

       
298
       
 
       
        default = [];

     
···

       
331
       
 
       
      { assertion = cfg.global.fsid != "";

     

       
332
       
 
       
        message = "fsid has to be set to a valid uuid for the cluster to function";

     

       
333
       
 
       
      }

     

       
334
       
+
       
      { assertion = cfg.mon.enable -> cfg.mon.daemons != [];

     

       
335
       
 
       
        message = "have to set id of atleast one MON if you're going to enable Monitor";

     

       
336
       
 
       
      }

     

       
337
       
+
       
      { assertion = cfg.mds.enable -> cfg.mds.daemons != [];

     

       
338
       
 
       
        message = "have to set id of atleast one MDS if you're going to enable Metadata Service";

     

       
339
       
 
       
      }

     

       
340
       
+
       
      { assertion = cfg.osd.enable -> cfg.osd.daemons != [];

     

       
341
       
 
       
        message = "have to set id of atleast one OSD if you're going to enable OSD";

     

       
342
       
 
       
      }

     

       
343
       
+
       
      { assertion = cfg.mgr.enable -> cfg.mgr.daemons != [];

     

       
344
       
 
       
        message = "have to set id of atleast one MGR if you're going to enable MGR";

     

       
345
       
 
       
      }

     

       
346
       
 
       
    ];