0.1.28 • Published 4 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
4 years ago
0.1.27
4 years ago
0.1.26
4 years ago
0.1.24
4 years ago
0.1.25
4 years ago
0.1.23
4 years ago
0.1.22
4 years ago
0.1.20
4 years ago
0.1.21
4 years ago
0.1.19
4 years ago
0.1.14
4 years ago
0.1.15
4 years ago
0.1.16
4 years ago
0.1.17
4 years ago
0.1.18
4 years ago
0.1.10
4 years ago
0.1.11
4 years ago
0.1.12
4 years ago
0.1.13
4 years ago
0.1.8
4 years ago
0.1.7
4 years ago
0.1.9
4 years ago
0.1.6
4 years ago
0.1.5
4 years ago
0.1.2
4 years ago
0.1.4
4 years ago
0.1.3
4 years ago
0.1.1
4 years ago
0.1.0
4 years ago
1.0.0
4 years ago