Commitad7f470

committed

Only measure dispatch time

Signed-off-by: Danny Kopping <danny@coder.com>

1 parent093e86b commitad7f470Copy full SHA for ad7f470

File tree

-1

lines changed

-1

lines changed

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -210,6 +210,8 @@ func (n *notifier) deliver(ctx context.Context, msg database.AcquireNotification`
`210`	`210`
`211`	`211`	`start:=time.Now()`
`212`	`212`	`retryable,err:=deliver(ctx,msg.ID)`
	`213`	`+n.metrics.DispatcherSendSeconds.WithLabelValues(string(n.method)).Observe(time.Since(start).Seconds())`
	`214`	`+`
`213`	`215`	`iferr!=nil {`
`214`	`216`	`// Don't try to accumulate message responses if the context has been canceled.`
`215`	`217`	`//`
`@@ -241,7 +243,6 @@ func (n *notifier) deliver(ctx context.Context, msg database.AcquireNotification`
`241`	`243`	`success<-n.newSuccessfulDispatch(msg)`
`242`	`244`	`}`
`243`	`245`	`}`
`244`		`-n.metrics.DispatcherSendSeconds.WithLabelValues(string(n.method)).Observe(time.Since(start).Seconds())`
`245`	`246`	`n.metrics.PendingUpdates.Set(float64(len(success)+len(failure)))`
`246`	`247`
`247`	`248`	`returnnil`

Comments

(0)