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

Rename to naffkaInstance (@Kegsay review comment)

Browse source
This commit is contained in:
Neil Alexander 2020-10-15 12:49:01 +01:00
parent aec836e02b
commit cd5cd473e0
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
internal/setup/base.go
View file

@ -351,20 +351,20 @@ func setupKafka(cfg *config.Kafka) (sarama.Consumer, sarama.SyncProducer) {
// consuming the same topic from more than one place like we do with Kafka.
// Therefore, we will only open one Naffka connection in case Naffka is
// running on SQLite.
var naffkaDatabase *naffka.Naffka
var naffkaInstance *naffka.Naffka
// setupNaffka creates kafka consumer/producer pair from the config.
func setupNaffka(cfg *config.Kafka) (sarama.Consumer, sarama.SyncProducer) {
if naffkaDatabase != nil {
return naffkaDatabase, naffkaDatabase
if naffkaInstance != nil {
return naffkaInstance, naffkaInstance
}
naffkaDB, err := naffkaStorage.NewDatabase(string(cfg.Database.ConnectionString))
if err != nil {
logrus.WithError(err).Panic("Failed to setup naffka database")
}
naffkaDatabase, err = naffka.New(naffkaDB)
naffkaInstance, err = naffka.New(naffkaDB)
if err != nil {
logrus.WithError(err).Panic("Failed to setup naffka")
}
return naffkaDatabase, naffkaDatabase
return naffkaInstance, naffkaInstance
}