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
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 =
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),
[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),
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),