import { type MethodCode } from "../compression.ts"; /** * Handles encoding and writing ClickHouse protocol packets. * Uses optimized BufferWriter internally. */ export declare class StreamingWriter { private writer; constructor(initialCapacity?: number); writeVarInt(value: bigint | number): void; writeString(str: string): void; writeU8(v: number): void; writeU32LE(v: number): void; writeU64LE(v: bigint): void; writeI32LE(v: number): void; flush(): Uint8Array; encodeHello(database: string, user: string, pass: string): Uint8Array; /** * Encode the addendum packet sent after receiving ServerHello. * @param revision - Negotiated protocol revision */ encodeAddendum(revision: bigint): Uint8Array; encodeQuery(qid: string, query: string, revision: bigint, settings?: Record, compression?: boolean, params?: Record): Uint8Array; encodeData(tableName: string, rowsCount: number, columns: { name: string; type: string; data: Uint8Array; }[], revision: bigint, compress?: boolean, method?: MethodCode): Uint8Array; private encodeDataBlockContent; encodeCancel(): Uint8Array; encodePing(): Uint8Array; } //# sourceMappingURL=writer.d.ts.map