| .gitignore | |
|
|
| .jscsrc | |
|
|
| .jshintrc | |
|
|
| .travis.yml | |
|
|
| LICENSE | |
|
|
| README.md | |
|
|
| debug.sql | |
|
|
| example-consumer.js | 42 | A 0 mins |
|
| index.js | 3 | A 0 mins |
|
| lib/consumer.js | 126 | B 6 hrs |
|
| lib/db.js | 33 | A 3 hrs |
|
| lib/dbapi.js | 140 | C 7 hrs |
|
| lib/event.js | 42 | A 0 mins |
|
| lib/eventbatch.js | 105 | A 1 hr |
|
| lib/files.js | 27 | A 0 mins |
|
| lib/installpgq.js | 36 | A 1 hr |
|
| lib/setup.js | 27 | A 0 mins |
|
| lib/ticker.js | 96 | C 1 day |
|
| package.json | |
|
|
| sql/functions/pgq.batch_event_sql.sql | |
|
|
| sql/functions/pgq.batch_event_tables.sql | |
|
|
| sql/functions/pgq.batch_retry.sql | |
|
|
| sql/functions/pgq.create_queue.sql | |
|
|
| sql/functions/pgq.current_event_table.sql | |
|
|
| sql/functions/pgq.drop_queue.sql | |
|
|
| sql/functions/pgq.event_retry.sql | |
|
|
| sql/functions/pgq.event_retry_raw.sql | |
|
|
| sql/functions/pgq.find_tick_helper.sql | |
|
|
| sql/functions/pgq.finish_batch.sql | |
|
|
| sql/functions/pgq.force_tick.sql | |
|
|
| sql/functions/pgq.get_batch_cursor.sql | |
|
|
| sql/functions/pgq.get_batch_events.sql | |
|
|
| sql/functions/pgq.get_batch_info.sql | |
|
|
| sql/functions/pgq.get_consumer_info.sql | |
|
|
| sql/functions/pgq.get_queue_info.sql | |
|
|
| sql/functions/pgq.grant_perms.sql | |
|
|
| sql/functions/pgq.insert_event.sql | |
|
|
| sql/functions/pgq.insert_event_raw.sql | |
|
|
| sql/functions/pgq.maint_operations.sql | |
|
|
| sql/functions/pgq.maint_retry_events.sql | |
|
|
| sql/functions/pgq.maint_rotate_tables.sql | |
|
|
| sql/functions/pgq.maint_tables_to_vacuum.sql | |
|
|
| sql/functions/pgq.next_batch.sql | |
|
|
| sql/functions/pgq.quote_fqname.sql | |
|
|
| sql/functions/pgq.register_consumer.sql | |
|
|
| sql/functions/pgq.seq_funcs.sql | |
|
|
| sql/functions/pgq.set_queue_config.sql | |
|
|
| sql/functions/pgq.ticker.sql | |
|
|
| sql/functions/pgq.tune_storage.sql | |
|
|
| sql/functions/pgq.unregister_consumer.sql | |
|
|