OpenCloud
/
MatrixSynapse
mirror of https://github.com/matrix-org/synapse
1
0
Fork 0
Code Issues Releases Wiki Activity

Tweak comments

rei/cwas_extension
Olivier Wilkinson (reivilibre) 2023-11-16 15:26:11 +00:00
parent 94a85b36f7
commit 26073fa778
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
docker/configure_workers_and_start.py
View File

@ -82,21 +82,21 @@ MAIN_PROCESS_UNIX_SOCKET_PUBLIC_PATH = "/run/main_public.sock"
MAIN_PROCESS_UNIX_SOCKET_PRIVATE_PATH = "/run/main_private.sock" MAIN_PROCESS_UNIX_SOCKET_PRIVATE_PATH = "/run/main_private.sock"
@dataclass
class WorkerTemplate:
listener_resources: Set[str] = field(default_factory=set)
endpoint_patterns: Set[str] = field(default_factory=set)
# (worker_name) -> {config}
shared_extra_conf: Callable[[str], Dict[str, Any]] = lambda _worker_name: {}
worker_extra_conf: str = ""
# Workers with exposed endpoints needs either "client", "federation", or "media" listener_resources # Workers with exposed endpoints needs either "client", "federation", or "media" listener_resources
# Watching /_matrix/client needs a "client" listener # Watching /_matrix/client needs a "client" listener
# Watching /_matrix/federation needs a "federation" listener # Watching /_matrix/federation needs a "federation" listener
# Watching /_matrix/media and related needs a "media" listener # Watching /_matrix/media and related needs a "media" listener
# Stream Writers require "client" and "replication" listeners because they # Stream Writers require "client" and "replication" listeners because they
# have to attach by instance_map to the master process and have client endpoints. # have to attach by instance_map to the master process and have client endpoints.
@dataclass
class WorkerTemplate:
listener_resources: Set[str] = field(default_factory=set)
endpoint_patterns: Set[str] = field(default_factory=set)
# (worker_name) -> {}
shared_extra_conf: Callable[[str], Dict[str, Any]] = lambda _worker_name: {}
worker_extra_conf: str = ""
WORKERS_CONFIG: Dict[str, WorkerTemplate] = { WORKERS_CONFIG: Dict[str, WorkerTemplate] = {
"pusher": WorkerTemplate(), "pusher": WorkerTemplate(),
"user_dir": WorkerTemplate( "user_dir": WorkerTemplate(