···

       
5
       
 
       
let

     

       
6
       
 
       
  cfg = config.services.collectd;

     

       
7
       
 
       


     

       
8
       
-
       
  unvalidated_conf = pkgs.writeText "collectd-unvalidated.conf" ''

     

       
9
       
-
       
    BaseDir "${cfg.dataDir}"

     

       
10
       
-
       
    AutoLoadPlugin ${boolToString cfg.autoLoadPlugin}

     

       
11
       
-
       
    Hostname "${config.networking.hostName}"

     

       
12
       
-
       


     

       
13
       
-
       
    LoadPlugin syslog

     

       
14
       
-
       
    <Plugin "syslog">

     

       
15
       
-
       
      LogLevel "info"

     

       
16
       
-
       
      NotifyLevel "OKAY"

     

       
17
       
-
       
    </Plugin>

     

       
18
       
-
       


     

       
19
       
-
       
    ${concatStrings (mapAttrsToList (plugin: pluginConfig: ''

     

       
20
       
-
       
      LoadPlugin ${plugin}

     

       
21
       
-
       
      <Plugin "${plugin}">

     

       
22
       
-
       
      ${pluginConfig}

     

       
23
       
-
       
      </Plugin>

     

       
24
       
-
       
    '') cfg.plugins)}

     

       
25
       
-
       


     

       
26
       
-
       
    ${concatMapStrings (f: ''

     

       
27
       
-
       
      Include "${f}"

     

       
28
       
-
       
    '') cfg.include}

     

       
29
       
-
       


     

       
30
       
-
       
    ${cfg.extraConfig}

     

       
31
       
-
       
  '';

     

       
32
       
 
       


     

       
33
       
 
       
  conf = if cfg.validateConfig then

     

       
34
       
 
       
    pkgs.runCommand "collectd.conf" {} ''

     

       
35
       
 
       
      echo testing ${unvalidated_conf}

     

       
0
       
 
       

     

       
36
       
 
       
      # collectd -t fails if BaseDir does not exist.

     

       
37
       
-
       
      sed '1s/^BaseDir.*$/BaseDir "."/' ${unvalidated_conf} > collectd.conf

     

       
38
       
 
       
      ${package}/bin/collectd -t -C collectd.conf

     

       
39
       
 
       
      cp ${unvalidated_conf} $out

     

       
40
       
 
       
    '' else unvalidated_conf;

     
···

       
123
       
 
       
    extraConfig = mkOption {

     

       
124
       
 
       
      default = "";

     

       
125
       
 
       
      description = ''

     

       
126
       
-
       
        Extra configuration for collectd.

     

       
0
       
 
       

     

       
127
       
 
       
      '';

     

       
128
       
 
       
      type = lines;

     

       
129
       
 
       
    };

     
···

       
131
       
 
       
  };

     

       
132
       
 
       


     

       
133
       
 
       
  config = mkIf cfg.enable {

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
134
       
 
       
    systemd.tmpfiles.rules = [

     

       
135
       
 
       
      "d '${cfg.dataDir}' - ${cfg.user} - - -"

     

       
136
       
 
       
    ];

     

···

       
5
       
 
       
let

     

       
6
       
 
       
  cfg = config.services.collectd;

     

       
7
       
 
       


     

       
8
       
+
       
  baseDirLine = ''BaseDir "${cfg.dataDir}"'';

     

       
9
       
+
       
  unvalidated_conf = pkgs.writeText "collectd-unvalidated.conf" cfg.extraConfig;

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
10
       
 
       


     

       
11
       
 
       
  conf = if cfg.validateConfig then

     

       
12
       
 
       
    pkgs.runCommand "collectd.conf" {} ''

     

       
13
       
 
       
      echo testing ${unvalidated_conf}

     

       
14
       
+
       
      cp ${unvalidated_conf} collectd.conf

     

       
15
       
 
       
      # collectd -t fails if BaseDir does not exist.

     

       
16
       
+
       
      substituteInPlace collectd.conf --replace ${lib.escapeShellArgs [ baseDirLine ]} 'BaseDir "."'

     

       
17
       
 
       
      ${package}/bin/collectd -t -C collectd.conf

     

       
18
       
 
       
      cp ${unvalidated_conf} $out

     

       
19
       
 
       
    '' else unvalidated_conf;

     
···

       
102
       
 
       
    extraConfig = mkOption {

     

       
103
       
 
       
      default = "";

     

       
104
       
 
       
      description = ''

     

       
105
       
+
       
        Extra configuration for collectd. Use mkBefore to add lines before the

     

       
106
       
+
       
        default config, and mkAfter to add them below.

     

       
107
       
 
       
      '';

     

       
108
       
 
       
      type = lines;

     

       
109
       
 
       
    };

     
···

       
111
       
 
       
  };

     

       
112
       
 
       


     

       
113
       
 
       
  config = mkIf cfg.enable {

     

       
114
       
+
       
    # 1200 is after the default (1000) but before mkAfter (1500).

     

       
115
       
+
       
    services.collectd.extraConfig = lib.mkOrder 1200 ''

     

       
116
       
+
       
      ${baseDirLine}

     

       
117
       
+
       
      AutoLoadPlugin ${boolToString cfg.autoLoadPlugin}

     

       
118
       
+
       
      Hostname "${config.networking.hostName}"

     

       
119
       
+
       


     

       
120
       
+
       
      LoadPlugin syslog

     

       
121
       
+
       
      <Plugin "syslog">

     

       
122
       
+
       
        LogLevel "info"

     

       
123
       
+
       
        NotifyLevel "OKAY"

     

       
124
       
+
       
      </Plugin>

     

       
125
       
+
       


     

       
126
       
+
       
      ${concatStrings (mapAttrsToList (plugin: pluginConfig: ''

     

       
127
       
+
       
        LoadPlugin ${plugin}

     

       
128
       
+
       
        <Plugin "${plugin}">

     

       
129
       
+
       
        ${pluginConfig}

     

       
130
       
+
       
        </Plugin>

     

       
131
       
+
       
      '') cfg.plugins)}

     

       
132
       
+
       


     

       
133
       
+
       
      ${concatMapStrings (f: ''

     

       
134
       
+
       
        Include "${f}"

     

       
135
       
+
       
      '') cfg.include}

     

       
136
       
+
       
    '';

     

       
137
       
+
       


     

       
138
       
 
       
    systemd.tmpfiles.rules = [

     

       
139
       
 
       
      "d '${cfg.dataDir}' - ${cfg.user} - - -"

     

       
140
       
 
       
    ];

     

···

       
3
       
 
       
  meta = { };

     

       
4
       
 
       


     

       
5
       
 
       
  nodes.machine =

     

       
6
       
-
       
    { pkgs, ... }:

     

       
7
       
 
       


     

       
8
       
 
       
    {

     

       
9
       
 
       
      services.collectd = {

     

       
10
       
 
       
        enable = true;

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
11
       
 
       
        plugins = {

     

       
12
       
 
       
          rrdtool = ''

     

       
13
       
 
       
            DataDir "/var/lib/collectd/rrd"

     
···

       
26
       
 
       
    machine.succeed(f"rrdinfo {file} | logger")

     

       
27
       
 
       
    # check that this file contains a shortterm metric

     

       
28
       
 
       
    machine.succeed(f"rrdinfo {file} | grep -F 'ds[shortterm].min = '")

     

       
0
       
 
       

     

       
0
       
 
       

     

       
29
       
 
       
    # check that there are frequent updates

     

       
30
       
 
       
    machine.succeed(f"cp {file} before")

     

       
31
       
 
       
    machine.wait_until_fails(f"cmp before {file}")

     

···

       
3
       
 
       
  meta = { };

     

       
4
       
 
       


     

       
5
       
 
       
  nodes.machine =

     

       
6
       
+
       
    { pkgs, lib, ... }:

     

       
7
       
 
       


     

       
8
       
 
       
    {

     

       
9
       
 
       
      services.collectd = {

     

       
10
       
 
       
        enable = true;

     

       
11
       
+
       
        extraConfig = lib.mkBefore ''

     

       
12
       
+
       
          Interval 30

     

       
13
       
+
       
        '';

     

       
14
       
 
       
        plugins = {

     

       
15
       
 
       
          rrdtool = ''

     

       
16
       
 
       
            DataDir "/var/lib/collectd/rrd"

     
···

       
29
       
 
       
    machine.succeed(f"rrdinfo {file} | logger")

     

       
30
       
 
       
    # check that this file contains a shortterm metric

     

       
31
       
 
       
    machine.succeed(f"rrdinfo {file} | grep -F 'ds[shortterm].min = '")

     

       
32
       
+
       
    # check that interval was set before the plugins

     

       
33
       
+
       
    machine.succeed(f"rrdinfo {file} | grep -F 'step = 30'")

     

       
34
       
 
       
    # check that there are frequent updates

     

       
35
       
 
       
    machine.succeed(f"cp {file} before")

     

       
36
       
 
       
    machine.wait_until_fails(f"cmp before {file}")