import { type RuntimeAdapterClientConfig } from "./services-client/index.js";
import type { ServicesRetainedRecipientLogger } from "./services-retained-recipient.js";
export interface ServicesControlStreamOptions {
    clientConfig: RuntimeAdapterClientConfig;
    runtimeKey: string;
    onMessage: (frame: unknown) => void;
    onForceUnregister: (row: Record<string, unknown>) => boolean;
    onOpen: () => void;
    onRegistrationRetired: (endpointId: string) => void;
    logger: Pick<ServicesRetainedRecipientLogger, "warn">;
    timing?: {
        heartbeatIntervalMs?: number;
        heartbeatProbeTimeoutMs?: number;
        backoffInitialMs?: number;
        backoffMaxMs?: number;
    };
}
export declare class ServicesControlStream {
    private readonly options;
    private nodeId;
    private stopped;
    private ws;
    private keepalive;
    private stableTimer;
    private reconnectTimer;
    private failedAttempts;
    constructor(options: ServicesControlStreamOptions);
    start(nodeId: string): void;
    stop(): void;
    private connect;
    private handleClose;
    private endConnection;
    private scheduleReconnect;
    private clearReconnectTimer;
    private handleMessage;
    private ack;
}
//# sourceMappingURL=services-control-stream.d.ts.map