(ctx context.Context, pgAdvisoryXactLock int64)
| 115 | } |
| 116 | |
| 117 | func (m queryMetricsStore) AcquireLock(ctx context.Context, pgAdvisoryXactLock int64) error { |
| 118 | start := time.Now() |
| 119 | r0 := m.s.AcquireLock(ctx, pgAdvisoryXactLock) |
| 120 | m.queryLatencies.WithLabelValues("AcquireLock").Observe(time.Since(start).Seconds()) |
| 121 | m.queryCounts.WithLabelValues(httpmw.ExtractHTTPRoute(ctx), httpmw.ExtractHTTPMethod(ctx), "AcquireLock").Inc() |
| 122 | return r0 |
| 123 | } |
| 124 | |
| 125 | func (m queryMetricsStore) AcquireNotificationMessages(ctx context.Context, arg database.AcquireNotificationMessagesParams) ([]database.AcquireNotificationMessagesRow, error) { |
| 126 | start := time.Now() |
nothing calls this directly
no test coverage detected