projects / skytools.git / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 2293f78) | patch
sql/pgq: add quick stats to get_{queue|consumer}_info
authorMarko Kreen <markokr@gmail.com>
Tue, 3 Nov 2009 12:30:27 +0000 (14:30 +0200)
committerMarko Kreen <markokr@gmail.com>
Tue, 3 Nov 2009 12:43:44 +0000 (14:43 +0200)
commit9ae8e2db77129dbd2ed267e080c8856df2436d79
treeb032fc1aa08f5025f1b9c7a5dab4dd13a3c449d6tree
parent2293f7843ebf9a5222edf4d980785983c72187b1commit | diff
sql/pgq: add quick stats to get_{queue|consumer}_info

get_consumer_info().pending_events

  How batched events are availble for read.

get_queue_info().ev_per_sec

  Average event creation speed, based on recent 20 batches.

get_queue_info().ev_new

  How many events have appreased in queue since recent tick.
  Those are not yet in any batch so consumers cannot read them yet.
sql/pgq/functions/pgq.get_consumer_info.sql diff | blob | blame | history
sql/pgq/functions/pgq.get_queue_info.sql diff | blob | blame | history
Skytools master repo.