changefeed - npm Package Compare versions

Comparing version 1.1.10 to 1.2.0

CHANGES.md

		@@ -17,1 +17,9 @@ # Changes
		* The publisher now emits a `registration` event when listeners register.

		### 1.2.0
		* Listener properly emits `bootstrap` after successful backoff.
		* Listener returns error objects when `error` is emitted.
		* Listener changefeed item recieved logs are now trace instead of debug.
		* Listener emits `connection-reset` instead of `connection-end` when a
		watershed `connectionReset` event is handled. `connection-end` is still
		emitted when watershed emits `connectionReset`.

lib/listener.js

		@@ -86,3 +86,3 @@ /*

		self.initBootstrap = true;
		self.initBootstrap = false;
		}
		@@ -141,3 +141,3 @@
		log.error('err: %j', err);
		self.emit('error');
		self.emit('error', err);
		}
		@@ -154,3 +154,3 @@
		log.error('ex: %s', ex.message);
		self.emit('error');
		self.emit('error', new Error(ex.message));
		}
		@@ -175,3 +175,3 @@
		log.debug('cf: _connectionReset: start');
		self.emit('connection-end');
		self.emit('connection-reset');
		clearInterval(heartbeat);
		@@ -197,4 +197,4 @@ });
		log.info('cf: expBackoff reset');
		} else if (!self.initBootstrap) {
		log.debug({ cfItem: item }, 'cf: change item received');
		} else if (!self.initBootstrap && !isBootstrap) {
		log.trace({ cfItem: item }, 'cf: change item received');
		self.push(item);
		@@ -206,3 +206,3 @@ } else {
		self.initBootstrap);
		self.emit('error');
		self.emit('error', new Error('Invalid socket state'));
		}
		@@ -223,5 +223,5 @@ });
		log.error('cf: Error testing for compatibility.');
		self.emit('error');
		expBackoff.backoff();
		} else {
		self.initBootstrap = true;
		_upgrade();
		@@ -243,3 +243,3 @@ }
		log.error('cf: Backoff failed.');
		self.emit('error');
		self.emit('error', new Error('Backoff failed'));
		});
		@@ -246,0 +246,0 @@ expBackoff.on('ready', function _ready(number, delay) {

package.json

		{
		"name": "changefeed",
		"description": "Change Feed Modules",
		"version": "1.1.10",
		"version": "1.2.0",
		"author": "Joyent (joyent.com)",
		@@ -6,0 +6,0 @@ "repository": {

README.md

		@@ -8,3 +8,3 @@ <!--
		<!--
		Copyright (c) 2015, Joyent, Inc.
		Copyright (c) 2016, Joyent, Inc.
		-->
		@@ -14,6 +14,11 @@

		Provides support for publishing and listening to change feeds in SmartDataCenter
		/ Triton via Node.js libraries and a CLI.
		This repository is part of the Joyent Triton project. See the [contribution
		guidelines](https://github.com/joyent/triton/blob/master/CONTRIBUTING.md) --
		Triton does not use GitHub PRs -- and general documentation at the main
		[Triton project](https://github.com/joyent/triton) page.

		SDC Changefeed provides support for publishing and listening to change
		feeds in Triton via Node.js libraries and a CLI.


		## Installation
		@@ -20,0 +25,0 @@

New alerts