projects / skytools.git / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 0b97591) | patch
sql/pgq_coop: Cooperative consuming
authorMarko Kreen <markokr@gmail.com>
Wed, 8 Apr 2009 12:40:29 +0000 (15:40 +0300)
committerMarko Kreen <markokr@gmail.com>
Wed, 8 Apr 2009 16:42:31 +0000 (19:42 +0300)
commitd8da10cf20ec97823b358dc576a60941999f067e
tree55ef3ca180cbe78d55d4809934db6e0068cc3553tree
parent0b975917317d799412067a063552d14bcc2268cdcommit | diff
sql/pgq_coop: Cooperative consuming

This module allows several consumers (subconsumers)
to share events between them so each subconsumers
sees only part of .

Implementation uses design described here:

 http://lists.pgfoundry.org/pipermail/skytools-users/2008-July/000653.html
 http://lists.pgfoundry.org/pipermail/skytools-users/2008-July/000671.html

Except instead <group>.<consumer> terminology <consumer>.<subconsumer>
is used.  Having 'consumer' mean different things seemed confusing.

Implemented by Asko Tiidumaa
doc/Makefile diff | blob | blame | history
sql/Makefile diff | blob | blame | history
sql/pgq_coop/Makefile [new file with mode: 0644] blob
sql/pgq_coop/expected/pgq_coop_test.out [new file with mode: 0644] blob
sql/pgq_coop/functions/pgq_coop.finish_batch.sql [new file with mode: 0644] blob
sql/pgq_coop/functions/pgq_coop.next_batch.sql [new file with mode: 0644] blob
sql/pgq_coop/functions/pgq_coop.register_subconsumer.sql [new file with mode: 0644] blob
sql/pgq_coop/functions/pgq_coop.unregister_subconsumer.sql [new file with mode: 0644] blob
sql/pgq_coop/sql/pgq_coop_test.sql [new file with mode: 0644] blob
sql/pgq_coop/structure/functions.sql [new file with mode: 0644] blob
sql/pgq_coop/structure/schema.sql [new file with mode: 0644] blob
Skytools master repo.