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:
parent
c1cb1ffcad
commit
c007bbeeb9
|
@ -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" { };
|
||||||
})
|
})
|
||||||
|
|
Loading…
Reference in a new issue