import { Dsn } from "../common/dsn";
export type SessionRecoveryHook = () => Promise<void>;
export declare class RetryConfig {
    readonly retries: number;
    readonly retryBackoffMs: number;
    readonly retryBackoffMaxMs: number;
    constructor(retries: number, retryBackoffMs: number, retryBackoffMaxMs: number);
    getBackoffDelay(attempt: number): number;
    static fromDsn(dsn: Dsn): RetryConfig;
}
export declare class WebSocketConnector {
    private _conn;
    private readonly _poolKey;
    private readonly _dsn;
    private _currentAddress;
    private _retryConfig;
    private _inflightStore;
    private readonly _suppressedSockets;
    private _reconnectLock;
    private _isReconnecting;
    private _allowReconnect;
    private _connectionReady;
    private _sessionRecoveryHook;
    private _sessionReady;
    private _timeout;
    constructor(dsn: Dsn, poolKey: string, timeout: number | undefined | null);
    refreshRetryConfig(dsn: Dsn): void;
    private buildUrl;
    private createConnection;
    private _onmessage;
    private shouldSkipReconnect;
    private failNonRetriableCallbacksOnDisconnect;
    private handleDisconnect;
    private extractReqId;
    private isRetriableAction;
    private extractBinaryAction;
    private isRetriableBinaryAction;
    isNetworkError(err: unknown): boolean;
    private send;
    ready(): Promise<void>;
    private getCurrentAddress;
    private selectLeastConnectedAddress;
    private sleep;
    private isReconnectAllowed;
    private triggerReconnect;
    private _doReconnect;
    private reconnect;
    private attemptReconnect;
    private replayRequests;
    private failAllInflightRequests;
    close(): void;
    readyState(): number;
    setSessionRecoveryHook(hook: SessionRecoveryHook | undefined | null): void;
    isSessionReady(): boolean;
    markSessionReady(): void;
    mergeDiscoveredEndpoints(instances: string[]): void;
    private recoverSessionContext;
    sendMsgDirect(message: string): Promise<any>;
    sendMsgNoResp(message: string): Promise<void>;
    sendMsg(message: string): Promise<unknown>;
    sendBinaryMsg(reqId: bigint, action: string, message: ArrayBuffer): Promise<unknown>;
    private sendAndTrackResponse;
    getPoolKey(): string;
    getReconnectRetries(): number;
}
//# sourceMappingURL=wsConnector.d.ts.map