| M | |
| maint_operations(0), pgq | |
| maint_retry_events(0), pgq | |
| maint_rotate_tables_step1(1), pgq | |
| maint_rotate_tables_step2(0), pgq | |
| maint_tables_to_vacuum(0), pgq | |
| N | |
| next_batch(2), pgq | |
| next_batch_custom(5), pgq | |
| next_batch_info(2), pgq | |
| Q | |
| quote_fqname(1), pgq | |
| R | |
| register_consumer(2), pgq | |
| register_consumer_at(3), pgq | |
| S | |
| seq_getval(1), pgq | |
| seq_setval(2), pgq | |
| set_queue_config(3), pgq | |
| sqltriga, pgq | |
| T | |
| ticker(0), pgq | |
| ticker(1), pgq | |
| ticker(3), pgq | |
| tune_storage(1), pgq | |
| U | |
| unregister_consumer(2), pgq | |
| V | |
| version(0), pgq |
Returns list of functions to call for maintenance.
pgq.maint_operations( out func_name text, out func_arg text ) returns setof record
Moves retry events back to main queue.
pgq.maint_retry_events() returns integer
Rotate tables for one queue.
pgq.maint_rotate_tables_step1( i_queue_name text ) returns integer
Stores the txid when the rotation was visible.
pgq.maint_rotate_tables_step2() returns integer
Returns list of tablenames that need frequent vacuuming.
pgq.maint_tables_to_vacuum() returns setof text
Old function that returns just batch_id.
pgq.next_batch( in i_queue_name text, in i_consumer_name text ) returns int8
Makes next block of events active.
pgq.next_batch_custom( in i_queue_name text, in i_consumer_name text, in i_min_lag interval, in i_min_count int4, in i_min_interval interval, out batch_id int8, out cur_tick_id int8, out prev_tick_id int8, out cur_tick_time timestamptz, out prev_tick_time timestamptz, out cur_tick_event_seq int8, out prev_tick_event_seq int8 ) as
Makes next block of events active.
pgq.next_batch_info( in i_queue_name text, in i_consumer_name text, out batch_id int8, out cur_tick_id int8, out prev_tick_id int8, out cur_tick_time timestamptz, out prev_tick_time timestamptz, out cur_tick_event_seq int8, out prev_tick_event_seq int8 ) as
Quete fully-qualified object name for SQL.
pgq.quote_fqname( i_name text ) returns text
Subscribe consumer on a queue.
pgq.register_consumer( x_queue_name text, x_consumer_id text ) returns integer
Extended registration, allows to specify tick_id.
pgq.register_consumer_at( x_queue_name text, x_consumer_name text, x_tick_pos bigint ) returns integer
Read current last_val from seq, without affecting it.
pgq.seq_getval( i_seq_name text ) returns bigint
Like setval() but does not allow going back.
pgq.seq_setval( i_seq_name text, i_new_value int8 ) returns bigint
Set configuration for specified queue.
pgq.set_queue_config( x_queue_name text, x_param_name text, x_param_value text ) returns integer
Trigger that generates queue events containing partial SQL.
pgq.sqltriga() RETURNS trigger AS
Creates ticks for all unpaused queues which dont have external ticker.
pgq.ticker() returns bigint
Check if tick is needed for the queue and insert it.
pgq.ticker( i_queue_name text ) returns bigint
External ticker: Insert a tick with a particular tick_id and timestamp.
pgq.ticker( i_queue_name text, i_tick_id bigint, i_orig_timestamp timestamptz, i_event_seq bigint ) returns bigint
Tunes storage settings for queue data tables
pgq.tune_storage( i_queue_name text ) returns integer
Unsubscribe consumer from the queue.
pgq.unregister_consumer( x_queue_name text, x_consumer_name text ) returns integer
Returns version string for pgq.
pgq.version() returns text