Fix comments and rename NewOutputRoomEvent

This commit is contained in:
Erik Johnston 2017-10-10 12:13:58 +01:00
parent 82eeab816f
commit 760d6cecd5
4 changed files with 5 additions and 5 deletions

View file

@ -36,7 +36,7 @@ type OutputRoomEventConsumer struct {
serverName string
}
// NewOutputRoomEventConsumer creates a new OutputRoomEvent consumer. Call Start() to begin consuming from room servers.
// NewOutputRoomEventConsumer creates a new OutputRoomEventConsumer. Call Start() to begin consuming from room servers.
func NewOutputRoomEventConsumer(
cfg *config.Dendrite,
kafkaConsumer sarama.Consumer,

View file

@ -38,7 +38,7 @@ type OutputRoomEventConsumer struct {
query api.RoomserverQueryAPI
}
// NewOutputRoomEventConsumer creates a new OutputRoomEvent consumer. Call Start() to begin consuming from room servers.
// NewOutputRoomEventConsumer creates a new OutputRoomEventConsumer. Call Start() to begin consuming from room servers.
func NewOutputRoomEventConsumer(
cfg *config.Dendrite,
kafkaConsumer sarama.Consumer,

View file

@ -33,8 +33,8 @@ type OutputRoomEventConsumer struct {
query api.RoomserverQueryAPI
}
// NewOutputRoomEvent creates a new OutputRoomEvent consumer. Call Start() to begin consuming from room servers.
func NewOutputRoomEvent(
// NewOutputRoomEventConsumer creates a new OutputRoomEventConsumer. Call Start() to begin consuming from room servers.
func NewOutputRoomEventConsumer(
cfg *config.Dendrite,
kafkaConsumer sarama.Consumer,
store *storage.PublicRoomsServerDatabase,

View file

@ -38,7 +38,7 @@ type OutputRoomEventConsumer struct {
query api.RoomserverQueryAPI
}
// NewOutputRoomEventConsumer creates a new OutputRoomEvent consumer. Call Start() to begin consuming from room servers.
// NewOutputRoomEventConsumer creates a new OutputRoomEventConsumer. Call Start() to begin consuming from room servers.
func NewOutputRoomEventConsumer(
cfg *config.Dendrite,
kafkaConsumer sarama.Consumer,