summary refs log tree commit diff
path: root/modules/software-templates/synapse-workers/stream-writers/account_data-stream-writer.nix
diff options
context:
space:
mode:
Diffstat (limited to 'modules/software-templates/synapse-workers/stream-writers/account_data-stream-writer.nix')
-rw-r--r--modules/software-templates/synapse-workers/stream-writers/account_data-stream-writer.nix7
1 files changed, 4 insertions, 3 deletions
diff --git a/modules/software-templates/synapse-workers/stream-writers/account_data-stream-writer.nix b/modules/software-templates/synapse-workers/stream-writers/account_data-stream-writer.nix

index 3f8363a..33ccc25 100644 --- a/modules/software-templates/synapse-workers/stream-writers/account_data-stream-writer.nix +++ b/modules/software-templates/synapse-workers/stream-writers/account_data-stream-writer.nix
@@ -4,7 +4,7 @@ let cfg = config.services.matrix-synapse; workerLib = import ../lib.nix; dbGroup = "medium"; -# streamWriterType = "account_data"; + # streamWriterType = "account_data"; workers = lib.range 0 (cfg.accountDataStreamWriters - 1); workerName = "account_data_stream_writer"; tasks = [ "stream_account_data" ]; @@ -12,7 +12,8 @@ let in let enabledResources = lib.attrNames workerRoutes; - streamTypes = [] + streamTypes = + [ ] ++ lib.optional (lib.elem "stream_account_data" tasks) "account_data" ++ lib.optional (lib.elem "stream_presence" tasks) "presence" ++ lib.optional (lib.elem "stream_push_rules" tasks) "push_rules" @@ -36,7 +37,7 @@ in ); #stream_writers.${streamWriterType} = lib.map (index: "${workerName}-${toString index}") workers; -# stream_writers = lib.listToA + # stream_writers = lib.listToA # map `streams` to `workers` stream_writers = lib.listToAttrs ( lib.map (stream: {