sql/pgq update
authorMarko Kreen <markokr@gmail.com>
Fri, 13 Feb 2009 10:29:12 +0000 (12:29 +0200)
committerMarko Kreen <markokr@gmail.com>
Fri, 13 Feb 2009 12:21:08 +0000 (14:21 +0200)
commit67e3ac04a87179e4283f71a5b8a55e3ddde30791
tree8c8bb31d9ded22b010ffc89142eebabc15bf2a90
parent5521e5fc2f399a923fa7fb313bbe797cfa0d5baa
sql/pgq update

structure:
- event_seq field for pgq.tick table, to store last value
  from event_id_seq
- 'disabled' field for pgq.queue, which can disable any
  direct inserts to queue.  inserts are allowed only
  if session_role = 'replica'

functions:

- pgq.next_batch_info() as next_batch() but returns full details
- pgq.ticker(): now contains ticker logic that previously
  was located in python code - it uses the event_seq field
  in tick table to know about last sequence value
- pgq.insert_event_raw() - check disabled flag
- pgq.seq_getval() / pgq.seq_setval() functions for safe
  sequence variable manipulation

- remove denytriga, now regular triggers can play the role
- use OUT parameters instead of ret types
- pgq.force_tick(): silently ignore the request on disabled queues
- pgq.maint_retry_events(): fwd port bugfix from 2.1-stable
- pgq.maint_rotate_tables(): cleanup from 2.1-stable
- pgq.maint_tables_to_vacuum(): add more tables
- triggers/common.c: bugfix from 2.1-stable
30 files changed:
sql/pgq/Makefile
sql/pgq/expected/denytriga.out [deleted file]
sql/pgq/expected/pgq_core.out
sql/pgq/functions/pgq.current_event_table.sql
sql/pgq/functions/pgq.force_tick.sql
sql/pgq/functions/pgq.get_batch_events.sql
sql/pgq/functions/pgq.get_consumer_info.sql
sql/pgq/functions/pgq.get_queue_info.sql
sql/pgq/functions/pgq.maint_retry_events.sql
sql/pgq/functions/pgq.maint_rotate_tables.sql
sql/pgq/functions/pgq.maint_tables_to_vacuum.sql
sql/pgq/functions/pgq.next_batch.sql
sql/pgq/functions/pgq.seq_funcs.sql
sql/pgq/functions/pgq.ticker.sql
sql/pgq/lowlevel/insert_event.c
sql/pgq/sql/denytriga.sql [deleted file]
sql/pgq/sql/pgq_core.sql
sql/pgq/sql/pgq_init.sql
sql/pgq/structure/install.sql
sql/pgq/structure/tables.sql
sql/pgq/structure/types.sql [deleted file]
sql/pgq/structure/uninstall_pgq.sql
sql/pgq/triggers/Makefile
sql/pgq/triggers/common.c
sql/pgq/triggers/common.h
sql/pgq/triggers/denytriga.c [deleted file]
sql/pgq/triggers/logtriga.c
sql/pgq/triggers/logutriga.c
sql/pgq/triggers/pgq_triggers.sql.in
sql/pgq/triggers/sqltriga.c