Skip to content

Instantly share code, notes, and snippets.

@tristanls
Created October 19, 2013 01:44
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save tristanls/7050760 to your computer and use it in GitHub Desktop.
Save tristanls/7050760 to your computer and use it in GitHub Desktop.
node and seed examples for gossipmoner
var Gossipmonger = require('../index.js');
var gossipmonger = new Gossipmonger(
{
id: String(Math.random()*1E17),
transport: {
host: "0.0.0.0",
port: 9742
}
},
{ // options
seeds: [{
id: "seed",
transport: {
host: "0.0.0.0",
port: 9741
}
}]
});
gossipmonger.on('error', function (error) {
console.dir(error);
});
gossipmonger.on('new peer', function (newPeer) {
console.log("found new peer " + newPeer.id + " at " + newPeer.transport);
});
gossipmonger.on('peer dead', function (deadPeer) {
console.log("peer " + deadPeer.id + " is now assumed unreachable");
});
gossipmonger.on('peer live', function (livePeer) {
console.log("peer " + livePeer.id + " is live again");
});
gossipmonger.on('update', function (peerId, key, value) {
console.log("peer " + peerId + " updated key " + key + " with " + value);
});
gossipmonger.transport.listen(function () {
console.log('listening');
gossipmonger.gossip();
setInterval(function () {
gossipmonger.update('foo', 'bar');
}, 4000);
});
var Gossipmonger = require('../');
var gossipmonger = new Gossipmonger(
{
id: String(Math.random()*1E17),
transport: {
host: "0.0.0.0",
port: 9741
}
});
console.log("Seed.");
gossipmonger.on('error', function (error) {
console.dir(error);
});
gossipmonger.on('new peer', function (newPeer) {
console.log("found new peer " + newPeer.id + " at " + newPeer.transport);
});
gossipmonger.on('peer dead', function (deadPeer) {
console.log("peer " + deadPeer.id + " is now assumed unreachable");
});
gossipmonger.on('peer live', function (livePeer) {
console.log("peer " + livePeer.id + " is live again");
});
gossipmonger.on('update', function (peerId, key, value) {
console.log("peer " + peerId + " updated key " + key + " with " + value);
});
gossipmonger.transport.listen(function () {
gossipmonger.gossip();
setInterval(function () {
gossipmonger.update('foo', 'bar');
}, 4000);
});
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment