0.1.28 • Published 5 years ago
redis-event-stream v0.1.28
redis-event-stream
**Simplified redis5 stream client for event driven architecture.
Installation
npm install redis-event-stream
Examples
Configuration & Event Receiver
const { redisClient } = require('./redis'); //setup redis connection first
const eventMaster = require('redis-event-stream');
const sampleReceiver = async event => {
console.log(`feedbackSeen Event Received!!`);
console.log(JSON.stringify(event, undefined, 2));
return true;
//After the resolver consumes the event, it must return true.
//Then that event will be removed from the stream group consumer list
};
const { eventReceiver, eventEmitter } = eventMaster({ service: 'SERVICE_NAME', numOfReplicas: 1, redisClient });
eventReceiver({
receivers: [{ resolver: sampleReceiver, stream: 'EVENT_NAME', consumer: 'INSTANCE_ID' }]
});
Event Emitter
const { eventReceiver, eventEmitter } = eventMaster({ service: 'SERVICE_NAME', numOfReplicas: 1, redisClient });
//after some business logic
let eventBody = { foo: bar };
eventEmitter({ stream: 'EVENT_NAME', event: eventBody });
Contributing
If you find a bug or want to propose a feature, refer to the issues page.
0.1.28
5 years ago
0.1.27
5 years ago
0.1.26
5 years ago
0.1.24
5 years ago
0.1.25
5 years ago
0.1.23
5 years ago
0.1.22
5 years ago
0.1.20
5 years ago
0.1.21
5 years ago
0.1.19
5 years ago
0.1.14
5 years ago
0.1.15
5 years ago
0.1.16
5 years ago
0.1.17
5 years ago
0.1.18
5 years ago
0.1.10
5 years ago
0.1.11
5 years ago
0.1.12
5 years ago
0.1.13
5 years ago
0.1.8
5 years ago
0.1.7
5 years ago
0.1.9
5 years ago
0.1.6
5 years ago
0.1.5
5 years ago
0.1.2
5 years ago
0.1.4
5 years ago
0.1.3
5 years ago
0.1.1
5 years ago
0.1.0
5 years ago
1.0.0
5 years ago