d-event-emitter v(0.2.1)
event emitter using interprocess network layer
Installation
npm install d-event-emitter
Basic configuration
Details of the infrastructure must be provided, and the corresponding security certificates
const DEmmiter = require("d-event-emitter")
//array with the infrastructure configuration
let infraarr = [{
name: "test1", //name of the worker
host: "127.0.0.1", //host
port: 65000, //port
eligible: true, //if true worker can act as leader
startleader: true // when start there must be only one :)
},{
name: "test2",
host: "127.0.0.1",
port: 65001,
eligible: true,
startleader: false
}]
let emitter = new DEmmiter({
name: argv.name,
infra: infraarr,
electionTime: [60000,120000], //interval of election
delayTime: 3000, //delay start time before first election
heartbeatTime: 6000, //heartbeat event timer
level: "debug" //optional parameter for debugging, default value: error (log4js)
// if SSL certificates are not included, the connection will be made using insecure mode
ssl:{
ca: "./certificates/ca.crt", //SSL ca certificate
cert_chain: "./certificates/server.crt", // SSL cert_chain certificate
private_key: "./certificates/server.key" // SSL private key
}
})Examples
Basic usage examples are detailed below. Arguments passed to the event must be serializable values. Other usage examples are located in the examples folder
//setting a listener
emitter.on("myEvent",(args)=>{
console.log("listener args::"+JSON.stringify(args))
})
emitter.emit("myEvent",{test:"qwerty",date: new Date().getTime()}).catch((error)=>{
console.log("no other clients?")
})Wildcard character ("*") support for namespace in event listening
//setting a listener
emitter.on("myNamespace.MyEvent1",(args)=>{
console.log("listener event1 args::"+JSON.stringify(args))
})
emitter.on("myNamespace.*",(args)=>{
console.log("listener all events args::"+JSON.stringify(args))
})
emitter.emit("myNamespace.MyEvent1",{test:"event1",date: new Date().getTime()})
emitter.emit("myNamespace.MyEvent2",{test:"event2",date: new Date().getTime()})