diff options
| author | Neil Alexander <neilalexander@users.noreply.github.com> | 2020-01-03 14:07:05 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-01-03 14:07:05 +0000 |
| commit | c28577ea25d4f9c82110450f7f371905c2750f71 (patch) | |
| tree | 7eda596a39f4c6ef2fbb2fc3f6a7caeb4ccc77d1 /syncapi/consumers/roomserver.go | |
| parent | 6cab62246816baf1fdd026744727cba9a7b21c28 (diff) | |
Implement storage interfaces (#841)
* Implement interfaces for federationsender storage
* Implement interfaces for mediaapi storage
* Implement interfaces for publicroomsapi storage
* Implement interfaces for roomserver storage
* Implement interfaces for syncapi storage
* Implement interfaces for keydb storage
* common.PartitionStorer in publicroomsapi interface
* Update copyright notices
Diffstat (limited to 'syncapi/consumers/roomserver.go')
| -rw-r--r-- | syncapi/consumers/roomserver.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/syncapi/consumers/roomserver.go b/syncapi/consumers/roomserver.go index e4f1ab46..cde2f508 100644 --- a/syncapi/consumers/roomserver.go +++ b/syncapi/consumers/roomserver.go @@ -33,7 +33,7 @@ import ( // OutputRoomEventConsumer consumes events that originated in the room server. type OutputRoomEventConsumer struct { roomServerConsumer *common.ContinualConsumer - db *storage.SyncServerDatasource + db storage.Database notifier *sync.Notifier query api.RoomserverQueryAPI } @@ -43,7 +43,7 @@ func NewOutputRoomEventConsumer( cfg *config.Dendrite, kafkaConsumer sarama.Consumer, n *sync.Notifier, - store *storage.SyncServerDatasource, + store storage.Database, queryAPI api.RoomserverQueryAPI, ) *OutputRoomEventConsumer { |