More newgrants fixes..
authorMarko Kreen <markokr@gmail.com>
Mon, 4 Mar 2013 09:23:29 +0000 (11:23 +0200)
committerMarko Kreen <markokr@gmail.com>
Mon, 4 Mar 2013 09:23:29 +0000 (11:23 +0200)
sql/pgq/structure/grants.ini
sql/pgq_node/structure/grants.ini

index f44aebccc81c3a2f907f484ae22ad11c4a30dc6e..b83d27c59cce2b6b245a8339ac2d617e71ac756a 100644 (file)
@@ -24,24 +24,22 @@ on.tables =
        pgq.queue,
        pgq.tick,
        pgq.subscription
+pgq_admin = select, insert, update, delete
 pgq_reader = select
 public = select
 
 [5.event.tables]
 on.tables = pgq.event_template
 pgq_reader = select
+pgq_admin = select, truncate
 
 # drop public access to events
 public =
 
 [6.retry.event]
 on.tables = pgq.retry_queue
-pgq_reader = select
 pgq_admin = select, insert, update, delete
 
-# drop public access to events
-public =
-
 
 #
 # define various groups of functions
@@ -76,6 +74,7 @@ pgq_read_fns =
        pgq.event_retry(bigint, bigint, timestamptz),
        pgq.event_retry(bigint, bigint, integer),
        pgq.batch_retry(bigint, integer),
+       pgq.force_tick(text),
        pgq.finish_batch(bigint)
 
 pgq_write_fns =
@@ -98,7 +97,6 @@ pgq_system_fns =
        pgq.grant_perms(text),
        pgq._grant_perms_from(text,text,text,text),
        pgq.tune_storage(text),
-       pgq.force_tick(text),
        pgq.seq_setval(text, int8),
        pgq.create_queue(text),
        pgq.drop_queue(text, bool),
index 7c364fbbf47bb8fcc91fb64f5d53a8865e06d693..ef095b6d180510e94c7144bc5a8fc07be1f5ad7c 100644 (file)
@@ -42,6 +42,8 @@ on.tables =
 [DEFAULT]
 
 pgq_node_remote_fns =
+       pgq_node.register_location(text, text, text, boolean),
+       pgq_node.unregister_location(text, text),
        pgq_node.get_consumer_info(text),
        pgq_node.get_consumer_state(text, text),
        pgq_node.get_queue_locations(text),
@@ -70,8 +72,6 @@ pgq_node_consumer_fns =
        pgq_node.set_consumer_error(text, text, text)
 
 pgq_node_worker_fns =
-       pgq_node.register_location(text, text, text, boolean),
-       pgq_node.unregister_location(text, text),
        pgq_node.create_node(text, text, text, text, text, bigint, text),
        pgq_node.drop_node(text, text),
        pgq_node.demote_root(text, int4, text),