Skip to content

Commit

Permalink
Register correct metric
Browse files Browse the repository at this point in the history
  • Loading branch information
neilalexander committed Jul 2, 2021
1 parent a9ddbfa commit 3911f3a
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions roomserver/internal/input/input.go
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,6 @@ type inputWorker struct {
r *Inputer
running atomic.Bool
input *fifoQueue
roomID string
}

// Guarded by a CAS on w.running
Expand Down Expand Up @@ -126,7 +125,7 @@ func (r *Inputer) WriteOutputEvents(roomID string, updates []api.OutputEvent) er
}

func init() {
prometheus.MustRegister(processRoomEventDuration)
prometheus.MustRegister(roomserverInputBackpressure)
}

var roomserverInputBackpressure = prometheus.NewSummaryVec(
Expand Down

0 comments on commit 3911f3a

Please sign in to comment.