sync/src/io/cluster/redisclusterclient.js

22 lines
549 B
JavaScript

import Promise from 'bluebird';
const ONE_SECOND = 1000;
const ERR_TIMEOUT = 'Timed out when retrieving server information';
class RedisClusterClient {
constructor(frontendPool) {
this.frontendPool = frontendPool;
}
getSocketConfig(channel) {
return this.frontendPool.getFrontends(channel).then(result => {
if (!Array.isArray(result)) {
result = [];
}
return { servers: result };
}).timeout(ONE_SECOND, ERR_TIMEOUT);
}
}
export { RedisClusterClient };