Skip to content

Commit

Permalink
Move membership related files into membership dir
Browse files Browse the repository at this point in the history
  • Loading branch information
jwolski committed Aug 26, 2015
1 parent 36ad9cf commit f689174
Show file tree
Hide file tree
Showing 16 changed files with 13 additions and 20 deletions.
6 changes: 3 additions & 3 deletions index.js
Original file line number Diff line number Diff line change
Expand Up @@ -40,9 +40,9 @@ var Dissemination = require('./lib/dissemination.js');
var errors = require('./lib/errors.js');
var getTChannelVersion = require('./lib/util.js').getTChannelVersion;
var HashRing = require('./lib/ring');
var Membership = require('./lib/membership.js');
var MembershipIterator = require('./lib/membership-iterator.js');
var MembershipUpdateRollup = require('./lib/membership-update-rollup.js');
var Membership = require('./lib/membership/index.js');
var MembershipIterator = require('./lib/membership/iterator.js');
var MembershipUpdateRollup = require('./lib/membership/rollup.js');
var nulls = require('./lib/nulls');
var rawHead = require('./lib/request-proxy/util.js').rawHead;
var RequestProxy = require('./lib/request-proxy/index.js');
Expand Down
2 changes: 1 addition & 1 deletion lib/membership-set-listener.js
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
// THE SOFTWARE.
'use strict';

var Member = require('./member.js');
var Member = require('./membership/member.js');

module.exports = function createMembershipSetListener(ringpop) {
return function onMembershipSet(updates) {
Expand Down
2 changes: 1 addition & 1 deletion lib/membership-update-listener.js
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
// THE SOFTWARE.
'use strict';

var Member = require('./member.js');
var Member = require('./membership/member.js');

module.exports = function createListener(ringpop) {
return function onMembershipUpdated(updates) {
Expand Down
4 changes: 2 additions & 2 deletions lib/membership.js → lib/membership/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -23,8 +23,8 @@ var _ = require('underscore');
var EventEmitter = require('events').EventEmitter;
var farmhash = require('farmhash');
var Member = require('./member.js');
var MembershipUpdateRules = require('./membership-update-rules.js');
var mergeMembershipChangesets = require('./membership-changeset-merge.js');
var MembershipUpdateRules = require('./rules.js');
var mergeMembershipChangesets = require('./merge.js');
var util = require('util');
var uuid = require('node-uuid');

Expand Down
1 change: 0 additions & 1 deletion lib/membership-iterator.js → lib/membership/iterator.js
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
// THE SOFTWARE.

'use strict';

function MembershipIterator(ring) {
Expand Down
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
2 changes: 1 addition & 1 deletion lib/swim/join-response-merge.js
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
// THE SOFTWARE.
'use strict';

var mergeMembershipChangesets = require('../membership-changeset-merge.js');
var mergeMembershipChangesets = require('../membership/merge.js');

function hasSameChecksums(joinResponses) {
var lastChecksum = -1;
Expand Down
2 changes: 1 addition & 1 deletion test/join-response-merge-test.js
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
// THE SOFTWARE.
'use strict';

var Member = require('../lib/member.js');
var Member = require('../lib/membership/member.js');
var mergeJoinResponses = require('../lib/swim/join-response-merge.js');
var testRingpop = require('./lib/test-ringpop.js');

Expand Down
2 changes: 1 addition & 1 deletion test/membership-changeset-merge-test.js
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
// THE SOFTWARE.
'use strict';

var mergeMembershipChangesets = require('../lib/membership-changeset-merge.js');
var mergeMembershipChangesets = require('../lib/membership/merge.js');
var testRingpop = require('./lib/test-ringpop.js');

testRingpop('merges incarnation numbers', function t(deps, assert) {
Expand Down
4 changes: 0 additions & 4 deletions test/membership-iterator-test.js
Original file line number Diff line number Diff line change
Expand Up @@ -17,11 +17,9 @@
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
// THE SOFTWARE.
var MembershipIterator = require('../lib/membership-iterator.js');
var testRingpop = require('./lib/test-ringpop.js');

testRingpop('iterates over two members correctly', function t(deps, assert) {
var ringpop = deps.ringpop;
var membership = deps.membership;
var iterator = deps.iterator;

Expand All @@ -36,7 +34,6 @@ testRingpop('iterates over two members correctly', function t(deps, assert) {
});

testRingpop('iterates over three members correctly', function t(deps, assert) {
var ringpop = deps.ringpop;
var membership = deps.membership;
var iterator = deps.iterator;

Expand All @@ -53,7 +50,6 @@ testRingpop('iterates over three members correctly', function t(deps, assert) {
});

testRingpop('skips over faulty member and 1 local member', function t(deps, assert) {
var ringpop = deps.ringpop;
var membership = deps.membership;
var iterator = deps.iterator;

Expand Down
2 changes: 1 addition & 1 deletion test/membership-test.js
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@
'use strict';

// Test dependencies
var Member = require('../lib/member.js');
var Member = require('../lib/membership/member.js');

// Test helpers
var testRingpop = require('./lib/test-ringpop.js');
Expand Down
2 changes: 1 addition & 1 deletion test/membership-update-rollup-test.js
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
// THE SOFTWARE.
'use strict';

var MembershipUpdateRollup = require('../lib/membership-update-rollup.js');
var MembershipUpdateRollup = require('../lib/membership/rollup.js');
var Ringpop = require('../index.js');
var test = require('tape');
var testRingpop = require('./lib/test-ringpop.js');
Expand Down
4 changes: 1 addition & 3 deletions test/swim_test.js
Original file line number Diff line number Diff line change
Expand Up @@ -18,9 +18,7 @@
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
// THE SOFTWARE.

var Member = require('../lib/member.js');
var Ringpop = require('../index.js');
var test = require('tape');
var Member = require('../lib/membership/member.js');
var testRingpop = require('./lib/test-ringpop.js');

testRingpop('starting and stopping gossip sets timer / unsets timers', function t(deps, assert) {
Expand Down

0 comments on commit f689174

Please sign in to comment.