w33ble/elastiq
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

make index the first param

Browse Source
This commit is contained in:
Joe Fleming
2016-04-15 16:05:43 -07:00
parent 98f179e64a
commit 600f2eb529
2 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/index.js
View File

@@ -3,12 +3,13 @@ import createClient from './helpers/create_client';
import { omit } from 'lodash'; import { omit } from 'lodash';
export default class Elastique extends events.EventEmitter { export default class Elastique extends events.EventEmitter {
constructor(options = {}) { constructor(index, options = {}) {
if (!options.index) throw new Error('Must specify an index to write to'); if (!index) throw new Error('Must specify an index to write to');
super(); super();
this.ready = true; this.ready = true;
this.index = index;
this.settings = Object.assign({ this.settings = Object.assign({
interval: '1w', interval: '1w',
timeout: 10000, timeout: 10000,

6
test/index.js
View File

@@ -9,8 +9,7 @@ describe('Elastique class', function () {
}); });
it('should throw with an invalid host', function () { it('should throw with an invalid host', function () {
const init = () => new Elastique({ const init = () => new Elastique('elastique', {
index: 'elastique',
client: { host: 'nope://nope' } client: { host: 'nope://nope' }
}); });
@@ -18,8 +17,7 @@ describe('Elastique class', function () {
}); });
it('should throw with invalid hosts', function () { it('should throw with invalid hosts', function () {
const init = () => new Elastique({ const init = () => new Elastique('elastique', {
index: 'elastique',
client: { hosts: [{ host: 'localhost', protocol: 'nope' }] } client: { hosts: [{ host: 'localhost', protocol: 'nope' }] }
}); });