summaryrefslogtreecommitdiff
path: root/sql/pgq/structure
diff options
context:
space:
mode:
authorMarko Kreen2009-04-21 10:08:08 +0000
committerMarko Kreen2009-04-21 10:08:08 +0000
commit442c233239f0f860a8ef8cda19b04faec2a2f0be (patch)
tree8bae73a65a9549e7d6af9ff6bc7c5b87a1b409b3 /sql/pgq/structure
parent52720f5652984a2ef5e6b5e333fd97f3ee8799fd (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.sql5
-rw-r--r--sql/pgq/structure/grants.sql1
-rw-r--r--sql/pgq/structure/tables.sql24
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;
-
-