| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152 |
- import { EventEmitter } from 'events';
- import { ConnectionOptions, RedisClient } from '../interfaces';
- import { DatabaseType } from '../types';
- interface RedisCapabilities {
- canDoubleTimeout: boolean;
- canBlockFor1Ms: boolean;
- }
- export interface RawCommand {
- content: string;
- name: string;
- keys: number;
- }
- export declare class RedisConnection extends EventEmitter {
- private readonly extraOptions?;
- static minimumVersion: string;
- static recommendedMinimumVersion: string;
- closing: boolean;
- capabilities: RedisCapabilities;
- status: 'initializing' | 'ready' | 'closing' | 'closed';
- private dbType;
- protected _client: RedisClient;
- private readonly opts;
- private readonly initializing;
- private version;
- protected packageVersion: string;
- private skipVersionCheck;
- private handleClientError;
- private handleClientClose;
- private handleClientReady;
- constructor(opts: ConnectionOptions, extraOptions?: {
- shared?: boolean;
- blocking?: boolean;
- skipVersionCheck?: boolean;
- skipWaitingForReady?: boolean;
- });
- private checkBlockingOptions;
- /**
- * Waits for a redis client to be ready.
- * @param redis - client
- */
- static waitUntilReady(client: RedisClient): Promise<void>;
- get client(): Promise<RedisClient>;
- protected loadCommands(packageVersion: string, providedScripts?: Record<string, RawCommand>): void;
- private init;
- disconnect(wait?: boolean): Promise<void>;
- reconnect(): Promise<void>;
- close(force?: boolean): Promise<void>;
- private getRedisVersionAndType;
- get redisVersion(): string;
- get databaseType(): DatabaseType;
- }
- export {};
|