From 95eb3545d6c019ec38cbe6aee76b759704c7da0b Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Mon, 17 Jan 2022 13:39:34 +0000 Subject: [PATCH] Tweak metrics --- federationapi/routing/send.go | 12 ++---------- 1 file changed, 2 insertions(+), 10 deletions(-) diff --git a/federationapi/routing/send.go b/federationapi/routing/send.go index ec50c6c12..d98038ed8 100644 --- a/federationapi/routing/send.go +++ b/federationapi/routing/send.go @@ -70,20 +70,11 @@ var ( 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() { 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()) results[event.EventID()] = gomatrixserverlib.PDUResult{} + pduCountTotal.WithLabelValues("success").Inc() } wg.Wait()