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()})

License

Apache 2.0