feat: introduce ofborg gerrit streamer

This pipes events from Gerrit into the whole AMQP broker and enable all
the system to react to VCS changes.

We need a filter to transform raw Gerrit events into ofBorg specific
events that we will continue to send in the system.

Signed-off-by: Raito Bezarius <masterancpp@gmail.com>
This commit is contained in:
raito 2024-11-14 23:04:42 +01:00
parent 726e2928ad
commit 91c0e260f3

View file

@ -30,6 +30,8 @@ in {
mass-rebuilder.enable = mkEnableOption "ofborg evaluator worker for mass rebuilds jobs"; mass-rebuilder.enable = mkEnableOption "ofborg evaluator worker for mass rebuilds jobs";
stats.enable = mkEnableOption "ofborg prometheus worker"; stats.enable = mkEnableOption "ofborg prometheus worker";
gerrit-events-streamer.enable = mkEnableOption "ofborg's Gerrit event streamer";
package = mkPackageOption pkgs "ofborg" { }; package = mkPackageOption pkgs "ofborg" { };
settings = mkOption { settings = mkOption {
@ -107,6 +109,9 @@ in {
(mkIf cfg.pastebin.enable { (mkIf cfg.pastebin.enable {
systemd.services.ofborg-pastebin = mkOfborgWorker "pastebin-worker" { }; systemd.services.ofborg-pastebin = mkOfborgWorker "pastebin-worker" { };
}) })
(mkIf cfg.gerrit-events-streamer.enable {
systemd.services.ofborg-gerrit-streamer = mkOfborgWorker "gerrit-events-streamer" { };
})
(mkIf cfg.mass-rebuilder.enable { (mkIf cfg.mass-rebuilder.enable {
systemd.services.ofborg-mass-rebuilder = mkOfborgWorker "mass-rebuilder" { }; systemd.services.ofborg-mass-rebuilder = mkOfborgWorker "mass-rebuilder" { };
}) })