UNPKG

1.47 kBTypeScriptView Raw
1import { RequestExecutor, IRequestExecutorOptions } from "./RequestExecutor";
2import { DocumentConventions } from "..";
3import { ServerNode } from "./ServerNode";
4import { IAuthOptions } from "../Auth/AuthOptions";
5export declare class ClusterRequestExecutor extends RequestExecutor {
6 private _clusterTopologySemaphore;
7 protected constructor(authOptions: IAuthOptions, conventions: DocumentConventions);
8 static createForSingleNodeWithConfigurationUpdates(url: string, databaseName: string, opts: IRequestExecutorOptions): ClusterRequestExecutor;
9 static createForSingleNodeWithoutConfigurationUpdates(url: string, databaseName: string, opts: IRequestExecutorOptions): ClusterRequestExecutor;
10 static createForSingleNode(url: string, opts: IRequestExecutorOptions): ClusterRequestExecutor;
11 static createForSingleNode(url: string, opts: IRequestExecutorOptions): ClusterRequestExecutor;
12 static create(initialUrls: string[], database: string, opts?: IRequestExecutorOptions): ClusterRequestExecutor;
13 static create(initialUrls: string[], opts?: IRequestExecutorOptions): ClusterRequestExecutor;
14 protected _performHealthCheck(serverNode: ServerNode, nodeIndex: number): Promise<void>;
15 updateTopology(node: ServerNode, timeout: number, forceUpdate: boolean): Promise<boolean>;
16 protected _updateClientConfigurationAsync(): Promise<void>;
17 protected _throwExceptions(details: string): void;
18 dispose(): void;
19}