mirrors/synapse
1
0
Fork 0
mirror of https://github.com/element-hq/synapse.git synced 2024-11-22 01:25:44 +03:00
Code Issues Projects Releases Packages Wiki Activity

support testing admin worker in complement

Browse source
This commit is contained in:
H. Shay 2024-11-05 11:52:30 -08:00
parent fba8716c0c
commit ea44779bb7
2 changed files with 12 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
docker/complement/conf/start_for_complement.sh
View file

@ -65,7 +65,8 @@ if [[ -n "$SYNAPSE_COMPLEMENT_USE_WORKERS" ]]; then
client_reader, \
appservice, \
pusher, \
stream_writers=account_data+presence+receipts+to_device+typing"
stream_writers=account_data+presence+receipts+to_device+typing, \
admin"
fi
log "Workers requested: $SYNAPSE_WORKER_TYPES"

10
docker/configure_workers_and_start.py
View file

@ -135,6 +135,14 @@ WORKERS_CONFIG: Dict[str, Dict[str, Any]] = {
},
"worker_extra_conf": "enable_media_repo: true",
},
"admin": {
"app": "synapse.app.generic_worker",
"listener_resources": ["replication", "admin"],
"endpoint_patterns": ["^/_synapse/admin/v2/rooms/.*$"],
"shared_extra_conf": {},
"worker_extra_conf": "",
},
"appservice": {
"app": "synapse.app.generic_worker",
"listener_resources": [],
@ -574,6 +582,7 @@ def is_sharding_allowed_for_worker_type(worker_type: str) -> bool:
"receipts",
"typing",
"to_device",
"admin"
]
@ -1076,6 +1085,7 @@ def main(args: List[str], environ: MutableMapping[str, str]) -> None:
# Split type names by comma, ignoring whitespace.
worker_types = split_and_strip_string(worker_types_env, ",")
requested_worker_types = parse_worker_types(worker_types)
log(f"requested_worker_types {requested_worker_types}")
# Always regenerate all other config files
log("Generating worker config files")