kinene - npm Package Compare versions

Comparing version 0.0.4 to 0.0.5

lib/services/kinene.js

		@@ -12,3 +12,3 @@ 'use strict';

		const Awschome = require('awschome');
		const AwschomePlugin = require('awschome');

		@@ -26,5 +26,5 @@ const LOGS_SOURCE = 'kinene';
		// Tell Awschome to only instance the kinesis sdk service
		this.awschome = await Ahem.instance(Awschome, { kinesis });
		const Awschome = await Ahem.instance(AwschomePlugin, { kinesis });

		const { kinesisService } = this.awschome.services();
		const { kinesisService } = Awschome.services();
		this.kinesis = kinesisService;
		@@ -64,3 +64,3 @@
		catch (err) {
		this.localLog(['error', 'kinesis', 'log'], JSON.stringify(err, null, 4));
		this.localLog(['error', 'kinene', 'log'], JSON.stringify(err, null, 4));
		}
		@@ -78,2 +78,4 @@ }

		this._ensureConfiguration();

		const { kinesisBackupUrl, testMode } = this.options;
		@@ -121,3 +123,3 @@

		this.localLog(['error', 'kinesis', 'putRecords', 'kinesis-backup'], {
		this.localLog(['error', 'kinene', 'putRecords', 'kinesis-backup'], {
		msg: 'Kinesis backup failed',
		@@ -176,3 +178,3 @@ logInfo,

		Hoek.assert(this.kinesis && this.streamName, 'kinesisService is improperly configured');
		Hoek.assert(this.kinesis && this.streamName, 'kinene is improperly configured');
		}
		@@ -179,0 +181,0 @@ };

package.json

New alerts