|
90 | 90 | # have to attach by instance_map to the master process and have client endpoints. |
91 | 91 | WORKERS_CONFIG: Dict[str, Dict[str, Any]] = { |
92 | 92 | "pusher": { |
93 | | - "app": "synapse.app.generic_worker", |
94 | 93 | "listener_resources": [], |
95 | 94 | "endpoint_patterns": [], |
96 | 95 | "shared_extra_conf": {}, |
97 | 96 | "worker_extra_conf": "", |
98 | 97 | }, |
99 | 98 | "user_dir": { |
100 | | - "app": "synapse.app.generic_worker", |
101 | 99 | "listener_resources": ["client"], |
102 | 100 | "endpoint_patterns": [ |
103 | 101 | "^/_matrix/client/(api/v1|r0|v3|unstable)/user_directory/search$" |
|
108 | 106 | "worker_extra_conf": "", |
109 | 107 | }, |
110 | 108 | "media_repository": { |
111 | | - "app": "synapse.app.generic_worker", |
112 | 109 | "listener_resources": ["media"], |
113 | 110 | "endpoint_patterns": [ |
114 | 111 | "^/_matrix/media/", |
|
126 | 123 | "worker_extra_conf": "enable_media_repo: true", |
127 | 124 | }, |
128 | 125 | "appservice": { |
129 | | - "app": "synapse.app.generic_worker", |
130 | 126 | "listener_resources": [], |
131 | 127 | "endpoint_patterns": [], |
132 | 128 | "shared_extra_conf": { |
|
135 | 131 | "worker_extra_conf": "", |
136 | 132 | }, |
137 | 133 | "federation_sender": { |
138 | | - "app": "synapse.app.generic_worker", |
139 | 134 | "listener_resources": [], |
140 | 135 | "endpoint_patterns": [], |
141 | 136 | "shared_extra_conf": {}, |
142 | 137 | "worker_extra_conf": "", |
143 | 138 | }, |
144 | 139 | "synchrotron": { |
145 | | - "app": "synapse.app.generic_worker", |
146 | 140 | "listener_resources": ["client"], |
147 | 141 | "endpoint_patterns": [ |
148 | 142 | "^/_matrix/client/(v2_alpha|r0|v3)/sync$", |
|
154 | 148 | "worker_extra_conf": "", |
155 | 149 | }, |
156 | 150 | "client_reader": { |
157 | | - "app": "synapse.app.generic_worker", |
158 | 151 | "listener_resources": ["client"], |
159 | 152 | "endpoint_patterns": [ |
160 | 153 | "^/_matrix/client/(api/v1|r0|v3|unstable)/publicRooms$", |
|
189 | 182 | "worker_extra_conf": "", |
190 | 183 | }, |
191 | 184 | "federation_reader": { |
192 | | - "app": "synapse.app.generic_worker", |
193 | 185 | "listener_resources": ["federation"], |
194 | 186 | "endpoint_patterns": [ |
195 | 187 | "^/_matrix/federation/(v1|v2)/event/", |
|
216 | 208 | "worker_extra_conf": "", |
217 | 209 | }, |
218 | 210 | "federation_inbound": { |
219 | | - "app": "synapse.app.generic_worker", |
220 | 211 | "listener_resources": ["federation"], |
221 | 212 | "endpoint_patterns": ["/_matrix/federation/(v1|v2)/send/"], |
222 | 213 | "shared_extra_conf": {}, |
223 | 214 | "worker_extra_conf": "", |
224 | 215 | }, |
225 | 216 | "event_persister": { |
226 | | - "app": "synapse.app.generic_worker", |
227 | 217 | "listener_resources": ["replication"], |
228 | 218 | "endpoint_patterns": [], |
229 | 219 | "shared_extra_conf": {}, |
230 | 220 | "worker_extra_conf": "", |
231 | 221 | }, |
232 | 222 | "background_worker": { |
233 | | - "app": "synapse.app.generic_worker", |
234 | 223 | "listener_resources": [], |
235 | 224 | "endpoint_patterns": [], |
236 | 225 | # This worker cannot be sharded. Therefore, there should only ever be one |
|
239 | 228 | "worker_extra_conf": "", |
240 | 229 | }, |
241 | 230 | "event_creator": { |
242 | | - "app": "synapse.app.generic_worker", |
243 | 231 | "listener_resources": ["client"], |
244 | 232 | "endpoint_patterns": [ |
245 | 233 | "^/_matrix/client/(api/v1|r0|v3|unstable)/rooms/.*/redact", |
|
253 | 241 | "worker_extra_conf": "", |
254 | 242 | }, |
255 | 243 | "frontend_proxy": { |
256 | | - "app": "synapse.app.generic_worker", |
257 | 244 | "listener_resources": ["client", "replication"], |
258 | 245 | "endpoint_patterns": ["^/_matrix/client/(api/v1|r0|v3|unstable)/keys/upload"], |
259 | 246 | "shared_extra_conf": {}, |
260 | 247 | "worker_extra_conf": "", |
261 | 248 | }, |
262 | 249 | "account_data": { |
263 | | - "app": "synapse.app.generic_worker", |
264 | 250 | "listener_resources": ["client", "replication"], |
265 | 251 | "endpoint_patterns": [ |
266 | 252 | "^/_matrix/client/(r0|v3|unstable)/.*/tags", |
|
270 | 256 | "worker_extra_conf": "", |
271 | 257 | }, |
272 | 258 | "presence": { |
273 | | - "app": "synapse.app.generic_worker", |
274 | 259 | "listener_resources": ["client", "replication"], |
275 | 260 | "endpoint_patterns": ["^/_matrix/client/(api/v1|r0|v3|unstable)/presence/"], |
276 | 261 | "shared_extra_conf": {}, |
277 | 262 | "worker_extra_conf": "", |
278 | 263 | }, |
279 | 264 | "receipts": { |
280 | | - "app": "synapse.app.generic_worker", |
281 | 265 | "listener_resources": ["client", "replication"], |
282 | 266 | "endpoint_patterns": [ |
283 | 267 | "^/_matrix/client/(r0|v3|unstable)/rooms/.*/receipt", |
|
287 | 271 | "worker_extra_conf": "", |
288 | 272 | }, |
289 | 273 | "to_device": { |
290 | | - "app": "synapse.app.generic_worker", |
291 | 274 | "listener_resources": ["client", "replication"], |
292 | 275 | "endpoint_patterns": ["^/_matrix/client/(r0|v3|unstable)/sendToDevice/"], |
293 | 276 | "shared_extra_conf": {}, |
294 | 277 | "worker_extra_conf": "", |
295 | 278 | }, |
296 | 279 | "typing": { |
297 | | - "app": "synapse.app.generic_worker", |
298 | 280 | "listener_resources": ["client", "replication"], |
299 | 281 | "endpoint_patterns": [ |
300 | 282 | "^/_matrix/client/(api/v1|r0|v3|unstable)/rooms/.*/typing" |
|
0 commit comments