summary refs log tree commit diff
path: root/modules/monitoring/synapse.nix
blob: 027110848dd5b356b6b823f10fa7e9fa700ad654 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
{ lib, config, ... }:
let
  cfg = config.monitoring;
in
{
  config = lib.mkIf (cfg.monitorAll && config.services.matrix-synapse.enable) {
    services.matrix-synapse.settings.listeners = [
      {
        type = "http";
        port = 9200;
        tls = false;
        resources = [
          {
            names = [ "metrics" ];
            compress = false;
          }
        ];
      }
    ];

    #services.matrix-synapse.workers = (
    #  let
    #    workerNames = config.services.matrix-synapse.workers;

    #    hasMetricsListener =
    #      (workerName:
    #      lib.any (
    #        listener: listener.type == "http" && (lib.any (resourceName: resourceName == "metrics") listener.resources)
    #      ) config.services.matrix-synapse.workers.${workerName}.worker_listeners);

    #    workerNamesWithoutMetrics = lib.traceVal lib.filter (workerName: (!hasMetricsListener workerName)) workerNames;
    #  in
    #  lib.listToAttrs (
    #    lib.imap (index: workerName: {
    #      name = workerName;
    #      value = {
    #        worker_listeners = [
    #          {
    #            type = "http";
    #            port = 9200 + index;
    #            resources = [
    #              {
    #                names = [ "metrics" ];
    #                compress = false;
    #              }
    #            ];
    #          }
    #        ];
    #      };
    #    }) workerNamesWithoutMetrics
    #  )
    #);

    services.matrix-synapse.workers = (
      lib.listToAttrs (
        lib.imap (index: workerName: {
          name = workerName;
          value = {
            worker_listeners = [
              {
                type = "http";
                port = 9200 + index + 1;
                resources = [
                  {
                    names = [ "metrics" ];
                    compress = false;
                  }
                ];
              }
            ];
          };
        }) config.monitoring.synapse.workerNames
      )
    );

    services.prometheus.scrapeConfigs = (
      (lib.map (interval: {
        job_name = "synapse-main-${toString interval}s";
        scrape_interval = "${toString interval}s";
        static_configs = [ { targets = [ "localhost:9200" ]; } ];
      }) cfg.prometheusScrapeIntervals)
      ++ lib.flatten (
        lib.imap (
          index: workerName:
          lib.map (interval: {
            job_name = "synapse-${workerName}-${toString interval}s";
            scrape_interval = "${toString interval}s";
            static_configs = [ { targets = [ "localhost:${toString (9200 + index + 1)}" ]; } ];
          }) cfg.prometheusScrapeIntervals
        ) config.monitoring.synapse.workerNames
      )
    );

    services.grafana.provision.dashboards.settings = {
      apiVersion = 1;
      providers = [
        {
          name = "matrix-synapse";
          orgId = 1;
          type = "file";
          options = {
            path = builtins.fetchurl {
              url = "https://raw.githubusercontent.com/element-hq/synapse/master/contrib/grafana/synapse.json";
              sha256 = "07qlr0waw9phmyd38bv22bn5v303w3397b89l44l3lzwhpnhs16s";
            };
          };
        }
      ];
    };

  };
}