diff options
| author | kegsay <kegan@matrix.org> | 2022-05-05 19:30:38 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-05-05 19:30:38 +0100 |
| commit | 9957752a9d60d4519cc0b7e8b9b40a781240c27d (patch) | |
| tree | 80de96398e63ea04a334802212f828d983a98b6e /userapi/consumers | |
| parent | e4da04e75b4cba1c9afb63b9973444e1da12021b (diff) | |
Define component interfaces based on consumers (2/2) (#2425)
* convert remaining interfaces
* Tidy up the userapi interfaces
Diffstat (limited to 'userapi/consumers')
| -rw-r--r-- | userapi/consumers/syncapi_streamevent.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/userapi/consumers/syncapi_streamevent.go b/userapi/consumers/syncapi_streamevent.go index 9ef7b508..7807c763 100644 --- a/userapi/consumers/syncapi_streamevent.go +++ b/userapi/consumers/syncapi_streamevent.go @@ -29,7 +29,7 @@ type OutputStreamEventConsumer struct { ctx context.Context cfg *config.UserAPI userAPI api.UserInternalAPI - rsAPI rsapi.RoomserverInternalAPI + rsAPI rsapi.UserRoomserverAPI jetstream nats.JetStreamContext durable string db storage.Database @@ -45,7 +45,7 @@ func NewOutputStreamEventConsumer( store storage.Database, pgClient pushgateway.Client, userAPI api.UserInternalAPI, - rsAPI rsapi.RoomserverInternalAPI, + rsAPI rsapi.UserRoomserverAPI, syncProducer *producers.SyncAPI, ) *OutputStreamEventConsumer { return &OutputStreamEventConsumer{ @@ -455,7 +455,7 @@ func (s *OutputStreamEventConsumer) evaluatePushRules(ctx context.Context, event type ruleSetEvalContext struct { ctx context.Context - rsAPI rsapi.RoomserverInternalAPI + rsAPI rsapi.UserRoomserverAPI mem *localMembership roomID string roomSize int |