From 983815864d6d052b3d46685feea02959e4b2238b Mon Sep 17 00:00:00 2001 From: Rory& Date: Thu, 4 Jul 2024 00:47:48 +0200 Subject: Synapse workers work --- .../matrix/synapse/workers/stream-writers/_.nix | 50 ---------------------- 1 file changed, 50 deletions(-) delete mode 100644 host/Rory-nginx/services/matrix/synapse/workers/stream-writers/_.nix (limited to 'host/Rory-nginx/services/matrix/synapse/workers/stream-writers/_.nix') diff --git a/host/Rory-nginx/services/matrix/synapse/workers/stream-writers/_.nix b/host/Rory-nginx/services/matrix/synapse/workers/stream-writers/_.nix deleted file mode 100644 index 6b0d2c2..0000000 --- a/host/Rory-nginx/services/matrix/synapse/workers/stream-writers/_.nix +++ /dev/null @@ -1,50 +0,0 @@ -{ - count, - separateEventWriters ? 1, - separateTypingWriters ? 1, - separateToDeviceWriters ? 1, - separateAccountDataWriters ? 1, - separateReceiptsWriters ? 1, - separatePresenceWriters ? 1, - separatePusherWriters ? 1, -}: -{ config, pkgs, lib, ... }: -let - eventWriters = lib.range 0 (count - 1); - typingWriters = lib.range 0 (count - 1); - deviceWriters = lib.range 0 (count - 1); - accountDataWriters = lib.range 0 (count - 1); - receiptsWriters = lib.range 0 (count - 1); - presenceWriters = lib.range 0 (count - 1); - pusherWriters = lib.range 0 (count - 1); -in -{ - services.matrix-synapse = { - settings = { - instance_map = lib.listToAttrs (lib.map (port: { - name = "stream-writer-${toString port}"; - value = { - path = "/run/matrix-synapse/stream-writer-${toString port}.sock"; - }; - }) federationSenders); - - stream_writers = { - events = lib.map (port: "stream-writer-events-${toString port}") federationSenders; - typing = lib.map (port: "stream-writer-typing-${toString port}") typingWriters; - to_device = lib.map (port: "stream-writer-to_device-${toString port}") deviceWriters; - account_data = lib.map (port: "stream-writer-account_data-${toString port}") accountDataWriters; - receipts = lib.map (port: "stream-writer-receipts-${toString port}") receiptsWriters; - presence = lib.map (port: "stream-writer-presence-${toString port}") presenceWriters; - push_rules = lib.map (port: "stream-writer-push_rules-${toString port}") pusherWriters; - }; - }; - - workers = lib.listToAttrs (lib.map (port: { - name = "stream-writerr-${toString port}"; - value = { - worker_app = "synapse.app.generic_worker"; - worker_listeners = [ ]; - }; - }) federationSenders); - }; -} \ No newline at end of file -- cgit 1.4.1