Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 11de18f4da | |||
| f5bf40cf71 | |||
| 1f053cbb6b |
@@ -2,4 +2,6 @@ language: node_js
|
|||||||
node_js:
|
node_js:
|
||||||
- "4"
|
- "4"
|
||||||
- "4.3"
|
- "4.3"
|
||||||
|
notifications:
|
||||||
|
email: false
|
||||||
after_success: npm run coverage
|
after_success: npm run coverage
|
||||||
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "esqueue",
|
"name": "esqueue",
|
||||||
"version": "0.2.0",
|
"version": "0.2.1",
|
||||||
"description": "",
|
"description": "",
|
||||||
"main": "lib/index.js",
|
"main": "lib/index.js",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
|
|||||||
@@ -6,7 +6,7 @@ import Job from './job.js';
|
|||||||
import Worker from './worker.js';
|
import Worker from './worker.js';
|
||||||
import omit from 'lodash.omit';
|
import omit from 'lodash.omit';
|
||||||
|
|
||||||
const debug = logger('queue');
|
const debug = logger('esqueue:queue');
|
||||||
|
|
||||||
export default class Esqueue extends events.EventEmitter {
|
export default class Esqueue extends events.EventEmitter {
|
||||||
constructor(index, options = {}) {
|
constructor(index, options = {}) {
|
||||||
|
|||||||
@@ -5,7 +5,7 @@ import logger from './helpers/logger';
|
|||||||
import { jobStatuses } from './helpers/constants';
|
import { jobStatuses } from './helpers/constants';
|
||||||
import createIndex from './helpers/create_index';
|
import createIndex from './helpers/create_index';
|
||||||
|
|
||||||
const debug = logger('job');
|
const debug = logger('esqueue:job');
|
||||||
const puid = new Puid();
|
const puid = new Puid();
|
||||||
|
|
||||||
export default class Job extends events.EventEmitter {
|
export default class Job extends events.EventEmitter {
|
||||||
|
|||||||
@@ -6,7 +6,7 @@ import { jobStatuses } from './helpers/constants';
|
|||||||
import { WorkerTimeoutError } from './helpers/errors';
|
import { WorkerTimeoutError } from './helpers/errors';
|
||||||
|
|
||||||
const puid = new Puid();
|
const puid = new Puid();
|
||||||
const debug = logger('worker');
|
const debug = logger('esqueue:worker');
|
||||||
|
|
||||||
export default class Job extends events.EventEmitter {
|
export default class Job extends events.EventEmitter {
|
||||||
constructor(queue, type, workerFn, opts = {}) {
|
constructor(queue, type, workerFn, opts = {}) {
|
||||||
|
|||||||
Reference in New Issue
Block a user