ClusterSubscriber.d.ts 451 B

123456789101112131415
  1. /// <reference types="node" />
  2. import { EventEmitter } from "events";
  3. import ConnectionPool from "./ConnectionPool";
  4. export default class ClusterSubscriber {
  5. private connectionPool;
  6. private emitter;
  7. private started;
  8. private subscriber;
  9. private lastActiveSubscriber;
  10. constructor(connectionPool: ConnectionPool, emitter: EventEmitter);
  11. getInstance(): any;
  12. start(): void;
  13. stop(): void;
  14. private selectSubscriber;
  15. }