mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-07 15:03:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

comments

Browse source
This commit is contained in:
Mark Haines 2017-02-24 16:47:28 +00:00
parent 0eceb3bcd7
commit 735d477ad2
2 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
src/github.com/matrix-org/dendrite/roomserver/input/consumer.go
View file

@ -47,6 +47,7 @@ type Consumer struct {
ErrorLogger ErrorLogger ErrorLogger ErrorLogger
} }
// WriteOutputRoomEvent implements OutputRoomEventWriter
func (c *Consumer) WriteOutputRoomEvent(output api.OutputRoomEvent) error { func (c *Consumer) WriteOutputRoomEvent(output api.OutputRoomEvent) error {
var m sarama.ProducerMessage var m sarama.ProducerMessage
value, err := json.Marshal(output) value, err := json.Marshal(output)

2
src/github.com/matrix-org/dendrite/roomserver/input/events.go
View file

@ -40,7 +40,9 @@ type RoomEventDatabase interface {
GetLatestEventsForUpdate(roomNID types.RoomNID) ([]types.StateAtEventAndReference, string, types.RoomRecentEventsUpdater, error) GetLatestEventsForUpdate(roomNID types.RoomNID) ([]types.StateAtEventAndReference, string, types.RoomRecentEventsUpdater, error)
} }
// OutputRoomEventWriter has the APIs needed to write an event to the output logs.
type OutputRoomEventWriter interface { type OutputRoomEventWriter interface {
// Write an event.
WriteOutputRoomEvent(output api.OutputRoomEvent) error WriteOutputRoomEvent(output api.OutputRoomEvent) error
} }