Fixup admin handler
parent
bf99c8e87e
commit
1ebfa39a73
|
@ -43,7 +43,6 @@ from synapse.replication.slave.storage.push_rule import SlavedPushRuleStore
|
||||||
from synapse.replication.slave.storage.receipts import SlavedReceiptsStore
|
from synapse.replication.slave.storage.receipts import SlavedReceiptsStore
|
||||||
from synapse.replication.slave.storage.registration import SlavedRegistrationStore
|
from synapse.replication.slave.storage.registration import SlavedRegistrationStore
|
||||||
from synapse.replication.slave.storage.room import RoomStore
|
from synapse.replication.slave.storage.room import RoomStore
|
||||||
from synapse.replication.tcp.client import ReplicationClientHandler
|
|
||||||
from synapse.server import HomeServer
|
from synapse.server import HomeServer
|
||||||
from synapse.util.logcontext import LoggingContext
|
from synapse.util.logcontext import LoggingContext
|
||||||
from synapse.util.versionstring import get_version_string
|
from synapse.util.versionstring import get_version_string
|
||||||
|
@ -79,17 +78,6 @@ class AdminCmdServer(HomeServer):
|
||||||
def start_listening(self, listeners):
|
def start_listening(self, listeners):
|
||||||
pass
|
pass
|
||||||
|
|
||||||
def build_tcp_replication(self):
|
|
||||||
return AdminCmdReplicationHandler(self)
|
|
||||||
|
|
||||||
|
|
||||||
class AdminCmdReplicationHandler(ReplicationClientHandler):
|
|
||||||
async def on_rdata(self, stream_name, token, rows):
|
|
||||||
pass
|
|
||||||
|
|
||||||
def get_streams_to_replicate(self):
|
|
||||||
return {}
|
|
||||||
|
|
||||||
|
|
||||||
@defer.inlineCallbacks
|
@defer.inlineCallbacks
|
||||||
def export_data_command(hs, args):
|
def export_data_command(hs, args):
|
||||||
|
|
Loading…
Reference in New Issue