mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2024-11-22 22:31:56 -06:00
Code Issues Packages Projects Releases Wiki Activity

Tweak metrics

Browse source
This commit is contained in:
Neil Alexander 2022-01-17 13:39:34 +00:00
parent eef6940b64
commit 95eb3545d6
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 2 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
federationapi/routing/send.go
View file

@ -70,20 +70,11 @@ var (
Help: "Number of incoming EDUs from remote servers", Help: "Number of incoming EDUs from remote servers",
}, },
) )
processEventSummary = prometheus.NewSummaryVec(
prometheus.SummaryOpts{
Namespace: "dendrite",
Subsystem: "federationapi",
Name: "process_event",
Help: "How long it takes to process an incoming event and what work had to be done for it",
},
[]string{"work", "outcome"},
)
) )
func init() { func init() {
prometheus.MustRegister( prometheus.MustRegister(
pduCountTotal, eduCountTotal, processEventSummary, pduCountTotal, eduCountTotal,
) )
} }
@ -305,6 +296,7 @@ func (t *txnReq) processTransaction(ctx context.Context) (*gomatrixserverlib.Res
util.GetLogger(ctx).WithError(err).Infof("XXX: Submitted event %q into input queue", event.EventID()) util.GetLogger(ctx).WithError(err).Infof("XXX: Submitted event %q into input queue", event.EventID())
results[event.EventID()] = gomatrixserverlib.PDUResult{} results[event.EventID()] = gomatrixserverlib.PDUResult{}
pduCountTotal.WithLabelValues("success").Inc()
} }
wg.Wait() wg.Wait()