From 9156b7f07dae8692e1d3273e9ee15037b9e7614b Mon Sep 17 00:00:00 2001 From: Andre Medeiros Date: Wed, 7 Jul 2021 21:58:36 -0400 Subject: [PATCH] measure dequeue time --- cmd/apollo-worker/main.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/cmd/apollo-worker/main.go b/cmd/apollo-worker/main.go index ff31af7..d91cf59 100644 --- a/cmd/apollo-worker/main.go +++ b/cmd/apollo-worker/main.go @@ -63,6 +63,7 @@ func accountWorker(id int, rc *reddit.Client, db *sql.DB, logger *log.Logger, st continue } + t1 := time.Now() query := ` SELECT id, username, access_token, refresh_token, expires_at, last_message_id, last_checked_at FROM accounts WHERE last_checked_at + 5 <= $1::float @@ -73,10 +74,12 @@ func accountWorker(id int, rc *reddit.Client, db *sql.DB, logger *log.Logger, st account := &data.Account{} err = tx.QueryRow(query, args...).Scan(&account.ID, &account.Username, &account.AccessToken, &account.RefreshToken, &account.ExpiresAt, &account.LastMessageID, &account.LastCheckedAt) + t2 := time.Now() + statsd.Histogram("apollo.dequeue.latency", float64(t2.Sub(t1).Milliseconds()), []string{}, rate) if account.ID == 0 { tx.Commit() - time.Sleep(100 * time.Millisecond) + time.Sleep(10 * time.Millisecond) continue } @@ -94,9 +97,9 @@ func accountWorker(id int, rc *reddit.Client, db *sql.DB, logger *log.Logger, st tokens.AccessToken, tokens.RefreshToken, int64(now+3500), account.ID) } - t1 := time.Now() + t1 = time.Now() msgs, err := rac.MessageInbox(account.LastMessageID) - t2 := time.Now() + t2 = time.Now() statsd.Histogram("reddit.api.latency", float64(t2.Sub(t1).Milliseconds()), []string{}, rate) if err != nil {