privatevoid.net/depot
1
1
Fork 0
Code Issues 23 Pull requests 2 Projects 3 Releases Packages Wiki Activity Actions

modules/consul-service-registry: allow binding multiple services to one systemd unit

Browse source
This commit is contained in:
Max Headroom 2023-03-06 16:42:14 +01:00
parent 027d681ede
commit 4d6c88ce97
5 changed files with 20 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
cluster/services/dns/authoritative.nix
View file

@ -65,7 +65,7 @@ in {
consul.services.pdns = {
mode = "external";
definition.service = {
definition = {
name = "authoritative-dns-backend";
address = config.links.localAuthoritativeDNS.ipv4;
port = config.links.localAuthoritativeDNS.port;

2
cluster/services/irc/irc-host.nix
View file

@ -108,7 +108,7 @@ in {
};
consul.services.ngircd = {
definition.service = {
definition = {
name = "irc";
address = linkSecure.ipv4;
port = linkSecure.port;

2
cluster/services/patroni/worker.nix
View file

@ -75,7 +75,7 @@ in
consul.services.patroni = {
mode = "external";
definition.service = rec {
definition = rec {
name = "patroni";
address = getMeshIp vars.hostName;
port = cluster.config.links.patroni-pg-internal.port;

2
cluster/services/websites/host.nix
View file

@ -23,7 +23,7 @@ in {
consul.services.nginx = {
mode = "external";
definition.service = {
definition = {
name = "static-lb";
address = lib.toLower "${config.networking.hostName}.${config.networking.domain}";
port = 443;

30
modules/consul-service-registry/default.nix
View file

@ -26,32 +26,34 @@ let
};
});
attachToService = name: conf: let
serviceJson = pkgs.writeText "consul-service-${name}.json" (builtins.toJSON conf.definition);
attachToService = unit: servicesRaw: let
services = map (getAttr "definition") servicesRaw;
servicesJson = pkgs.writeText "consul-services-${unit}.json" (builtins.toJSON { inherit services; });
mode = if any (x: x.mode == "external") servicesRaw then "external" else "direct";
in {
name = {
direct = conf.unit;
external = "register-consul-svc-${conf.unit}";
}.${conf.mode};
direct = unit;
external = "register-consul-svc-${unit}";
}.${mode};
value = {
direct = {
serviceConfig = {
ExecStartPost = "${consul} services register ${serviceJson}";
ExecStopPost = "${consul} services deregister ${serviceJson}";
ExecStartPost = "${consul} services register ${servicesJson}";
ExecStopPost = "${consul} services deregister ${servicesJson}";
};
};
external = {
after = [ "${conf.unit}.service" ];
wantedBy = [ "${conf.unit}.service" ];
unitConfig.BindsTo = "${conf.unit}.service";
after = [ "${unit}.service" ];
wantedBy = [ "${unit}.service" ];
unitConfig.BindsTo = "${unit}.service";
serviceConfig = {
Type = "oneshot";
RemainAfterExit = true;
ExecStart = "${consul} services register ${serviceJson}";
ExecStop = "${consul} services deregister ${serviceJson}";
ExecStart = "${consul} services register ${servicesJson}";
ExecStop = "${consul} services deregister ${servicesJson}";
};
};
}.${conf.mode};
}.${mode};
};
in
@ -64,7 +66,7 @@ in
};
config = lib.mkIf (cfg.services != {}) {
systemd.services = mapAttrs' attachToService cfg.services;
systemd.services = mapAttrs' attachToService (groupBy (getAttr "unit") (attrValues cfg.services));
warnings = optional (!config.services.consul.enable) "Consul service registrations found, but Consul agent is not enabled on this machine.";
};
}