diff options
| author | Marko Kreen | 2009-04-21 10:08:08 +0000 |
|---|---|---|
| committer | Marko Kreen | 2009-04-21 10:08:08 +0000 |
| commit | 442c233239f0f860a8ef8cda19b04faec2a2f0be (patch) | |
| tree | 8bae73a65a9549e7d6af9ff6bc7c5b87a1b409b3 /sql/pgq/structure | |
| parent | 52720f5652984a2ef5e6b5e333fd97f3ee8799fd (diff) | |
pgq: Drop failed event handling.
Badly designed and unused concept. If such thing is needed
it's much better to handle them via actual queue.
Diffstat (limited to 'sql/pgq/structure')
| -rw-r--r-- | sql/pgq/structure/func_public.sql | 5 | ||||
| -rw-r--r-- | sql/pgq/structure/grants.sql | 1 | ||||
| -rw-r--r-- | sql/pgq/structure/tables.sql | 24 |
3 files changed, 0 insertions, 30 deletions
diff --git a/sql/pgq/structure/func_public.sql b/sql/pgq/structure/func_public.sql index b6a3d56e..de8b132c 100644 --- a/sql/pgq/structure/func_public.sql +++ b/sql/pgq/structure/func_public.sql @@ -21,7 +21,6 @@ \i functions/pgq.next_batch.sql \i functions/pgq.get_batch_events.sql \i functions/pgq.get_batch_cursor.sql -\i functions/pgq.event_failed.sql \i functions/pgq.event_retry.sql \i functions/pgq.finish_batch.sql @@ -32,7 +31,3 @@ \i functions/pgq.version.sql \i functions/pgq.get_batch_info.sql --- Group: Failed queue browsing - -\i functions/pgq.failed_queue.sql - diff --git a/sql/pgq/structure/grants.sql b/sql/pgq/structure/grants.sql index 97a22cbf..d5f8ef1f 100644 --- a/sql/pgq/structure/grants.sql +++ b/sql/pgq/structure/grants.sql @@ -7,4 +7,3 @@ grant select on table pgq.queue to public; grant select on table pgq.subscription to public; grant select on table pgq.event_template to public; grant select on table pgq.retry_queue to public; -grant select on table pgq.failed_queue to public; diff --git a/sql/pgq/structure/tables.sql b/sql/pgq/structure/tables.sql index 3d2dfdcc..521d1a9d 100644 --- a/sql/pgq/structure/tables.sql +++ b/sql/pgq/structure/tables.sql @@ -218,27 +218,3 @@ alter table pgq.retry_queue alter column ev_owner set not null; alter table pgq.retry_queue alter column ev_txid drop not null; create index rq_retry_idx on pgq.retry_queue (ev_retry_after); --- ---------------------------------------------------------------------- --- Table: pgq.failed_queue --- --- Events whose processing failed. --- --- Columns: --- ev_failed_reason - consumer's excuse for not processing --- ev_failed_time - when it was tagged failed --- ev_queue - queue id --- * - same as pgq.event_template --- ---------------------------------------------------------------------- -create table pgq.failed_queue ( - ev_failed_reason text, - ev_failed_time timestamptz not null, - - -- all event fields - like pgq.event_template, - - constraint fq_pkey primary key (ev_owner, ev_id) -); -alter table pgq.failed_queue alter column ev_owner set not null; -alter table pgq.failed_queue alter column ev_txid drop not null; - - |
