redis.tsā¢773 B
import { createClient } from 'redis';
const redisClient = createClient({
url: process.env.REDIS_URL || 'redis://localhost:6379',
});
redisClient.on('error', err => {
console.error('Redis Client Error:', err);
});
redisClient.on('connect', () => {
console.log('Redis Client Connected');
});
export const connectRedis = async () => {
try {
if (!redisClient.isOpen) {
await redisClient.connect();
}
} catch (error) {
console.error('Redis Connection Error:', error);
throw error;
}
};
export const disconnectRedis = async () => {
try {
if (redisClient.isOpen) {
await redisClient.disconnect();
}
} catch (error) {
console.error('Redis Disconnect Error:', error);
throw error;
}
};
export default redisClient;