Skip to content
This repository has been archived by the owner on Nov 16, 2023. It is now read-only.

Commit

Permalink
add getInfo
Browse files Browse the repository at this point in the history
  • Loading branch information
jeffmcaffer committed Feb 20, 2017
1 parent 8f58ff1 commit 32caff9
Showing 1 changed file with 17 additions and 0 deletions.
17 changes: 17 additions & 0 deletions lib/crawlerClient.js
Original file line number Diff line number Diff line change
Expand Up @@ -156,6 +156,23 @@ class CrawlerClient {
});
return deferred.promise;
}

getInfo(queueName) {
const deferred = Q.defer();
request.get(`${this.url}/queues/${queueName}/info`, {
headers: {
'X-token': this.authToken
},
json: true
}, (error, response, body) => {
if (error || response.statusCode > 299) {
return deferred.reject(new Error(`Failed to get info for queue ${queueName}: ${error ? error.message : body.message}.`));
}
deferred.resolve(body);
});
return deferred.promise;
}

}

module.exports = CrawlerClient;

0 comments on commit 32caff9

Please sign in to comment.