|
28 | 28 | from synapse.config.logger import setup_logging
|
29 | 29 | from synapse.events import EventBase
|
30 | 30 | from synapse.handlers.admin import ExfiltrationWriter
|
31 |
| -from synapse.replication.slave.storage.devices import SlavedDeviceStore |
32 |
| -from synapse.replication.slave.storage.events import SlavedEventStore |
33 |
| -from synapse.replication.slave.storage.filtering import SlavedFilteringStore |
34 |
| -from synapse.replication.slave.storage.push_rule import SlavedPushRuleStore |
35 | 31 | from synapse.server import HomeServer
|
36 | 32 | from synapse.storage.database import DatabasePool, LoggingDatabaseConnection
|
37 | 33 | from synapse.storage.databases.main.account_data import AccountDataWorkerStore
|
|
40 | 36 | ApplicationServiceWorkerStore,
|
41 | 37 | )
|
42 | 38 | from synapse.storage.databases.main.deviceinbox import DeviceInboxWorkerStore
|
| 39 | +from synapse.storage.databases.main.devices import DeviceWorkerStore |
| 40 | +from synapse.storage.databases.main.event_federation import EventFederationWorkerStore |
| 41 | +from synapse.storage.databases.main.event_push_actions import ( |
| 42 | + EventPushActionsWorkerStore, |
| 43 | +) |
| 44 | +from synapse.storage.databases.main.events_worker import EventsWorkerStore |
| 45 | +from synapse.storage.databases.main.filtering import FilteringWorkerStore |
| 46 | +from synapse.storage.databases.main.push_rule import PushRulesWorkerStore |
43 | 47 | from synapse.storage.databases.main.receipts import ReceiptsWorkerStore
|
44 | 48 | from synapse.storage.databases.main.registration import RegistrationWorkerStore
|
| 49 | +from synapse.storage.databases.main.relations import RelationsWorkerStore |
45 | 50 | from synapse.storage.databases.main.room import RoomWorkerStore
|
| 51 | +from synapse.storage.databases.main.roommember import RoomMemberWorkerStore |
| 52 | +from synapse.storage.databases.main.signatures import SignatureWorkerStore |
| 53 | +from synapse.storage.databases.main.state import StateGroupWorkerStore |
| 54 | +from synapse.storage.databases.main.stream import StreamWorkerStore |
46 | 55 | from synapse.storage.databases.main.tags import TagsWorkerStore
|
| 56 | +from synapse.storage.databases.main.user_erasure_store import UserErasureWorkerStore |
47 | 57 | from synapse.types import StateMap
|
48 | 58 | from synapse.util import SYNAPSE_VERSION
|
49 | 59 | from synapse.util.logcontext import LoggingContext
|
|
52 | 62 |
|
53 | 63 |
|
54 | 64 | class AdminCmdSlavedStore(
|
55 |
| - SlavedFilteringStore, |
56 |
| - SlavedPushRuleStore, |
57 |
| - SlavedEventStore, |
58 |
| - SlavedDeviceStore, |
| 65 | + FilteringWorkerStore, |
| 66 | + DeviceWorkerStore, |
59 | 67 | TagsWorkerStore,
|
60 | 68 | DeviceInboxWorkerStore,
|
61 | 69 | AccountDataWorkerStore,
|
| 70 | + PushRulesWorkerStore, |
62 | 71 | ApplicationServiceTransactionWorkerStore,
|
63 | 72 | ApplicationServiceWorkerStore,
|
64 |
| - RegistrationWorkerStore, |
| 73 | + RoomMemberWorkerStore, |
| 74 | + RelationsWorkerStore, |
| 75 | + EventFederationWorkerStore, |
| 76 | + EventPushActionsWorkerStore, |
| 77 | + StateGroupWorkerStore, |
| 78 | + SignatureWorkerStore, |
| 79 | + UserErasureWorkerStore, |
65 | 80 | ReceiptsWorkerStore,
|
| 81 | + StreamWorkerStore, |
| 82 | + EventsWorkerStore, |
| 83 | + RegistrationWorkerStore, |
66 | 84 | RoomWorkerStore,
|
67 | 85 | ):
|
68 | 86 | def __init__(
|
|
0 commit comments