/home/techb158/balavpn.abdallabala.com/node_modules/ioredis/built/cluster
NameSizeModeActions
ClusterOptions.d.ts63910666editdlrm
ClusterOptions.js7480666editdlrm
ClusterSubscriber.d.ts8860666editdlrm
ClusterSubscriber.js92420666editdlrm
ClusterSubscriberGroup.d.ts34430666editdlrm
ClusterSubscriberGroup.js157280666editdlrm
ConnectionPool.d.ts13240666editdlrm
ConnectionPool.js56550666editdlrm
DelayQueue.d.ts4790666editdlrm
DelayQueue.js14740666editdlrm
index.d.ts49480666editdlrm
index.js383430666editdlrm
ShardedSubscriber.d.ts11580666editdlrm
ShardedSubscriber.js50300666editdlrm
util.d.ts10800666editdlrm
util.js36350666editdlrm
Edit: /home/techb158/balavpn.abdallabala.com/node_modules/ioredis/built/cluster/ClusterSubscriber.d.ts (886B)
/// import { EventEmitter } from "events"; import ConnectionPool from "./ConnectionPool"; export default class ClusterSubscriber { private connectionPool; private emitter; private isSharded; private started; private subscriber; private lastActiveSubscriber; private slotRange; constructor(connectionPool: ConnectionPool, emitter: EventEmitter, isSharded?: boolean); getInstance(): any; /** * Associate this subscriber to a specific slot range. * * Returns the range or an empty array if the slot range couldn't be associated. * * BTW: This is more for debugging and testing purposes. * * @param range */ associateSlotRange(range: number[]): number[]; start(): void; stop(): void; isStarted(): boolean; private onSubscriberEnd; private selectSubscriber; }