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

Producer logging

Browse source
This commit is contained in:
Neil Alexander 2021-08-10 14:50:35 +01:00
parent f4cc3d28e6
commit f04bba4170
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 8 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
keyserver/producers/signingupdate.go
View file

@ -19,6 +19,7 @@ import (
"github.com/Shopify/sarama" "github.com/Shopify/sarama"
"github.com/matrix-org/dendrite/eduserver/api" "github.com/matrix-org/dendrite/eduserver/api"
"github.com/sirupsen/logrus"
) )
type SigningKeyUpdate struct { type SigningKeyUpdate struct {
@ -46,6 +47,12 @@ func (p *SigningKeyUpdate) ProduceSigningKeyUpdate(key api.SigningKeyUpdate) err
m.Value = sarama.ByteEncoder(value) m.Value = sarama.ByteEncoder(value)
_, _, err = p.Producer.SendMessage(&m) _, _, err = p.Producer.SendMessage(&m)
if err != nil {
return err return err
} }
logrus.WithFields(logrus.Fields{
"user_id": key.UserID,
}).Infof("Produced to cross-signing update topic '%s'", p.Topic)
return nil
}