import type { Server } from 'node:http';
import type { QueryDef, SqlFragment } from '@risingwave/wavelet';
import type { CursorManager, ViewDiff } from './cursor-manager.js';
import type { JwtVerifier } from './jwt.js';
export declare class WebSocketFanout {
    private cursorManager;
    private jwt;
    private queries;
    private wss;
    private subscribers;
    constructor(cursorManager: CursorManager, jwt: JwtVerifier, queries: Record<string, QueryDef | SqlFragment>);
    attach(server: Server, pathPrefix?: string): void;
    private handleConnection;
    broadcast(queryName: string, diff: ViewDiff): void;
    private filterSnapshotRows;
    private filterDiffForSubscriber;
    private filterDiff;
    private getFilterBy;
    private isEmptyDiff;
    private serializeDiffMessage;
    private compareCursor;
    closeAll(): void;
}
//# sourceMappingURL=ws-fanout.d.ts.map