| .gitignore | |
|
|
| .jscsrc | |
|
|
| .jshintrc | |
|
|
| .travis.yml | |
|
|
| LICENSE | |
|
|
| README.md | |
|
|
| debug.sql | |
|
|
| 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 | |
|
|
| sql/functions/pgq.upgrade_schema.sql | |
|
|
| sql/functions/pgq.version.sql | |
|
|
| sql/structure/roles.sql | |
|
|
| sql/structure/tables.sql | |
|
|
| sql/triggers/pgq.trigger_log_json.sql | |
|
|
| example-consumer.js | 42 |
|
|
| index.js | 3 |
|
|
| 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 |
|
|