import { PreferredClickhouseService } from "../clickhouse/client"; import { NodeClickHouseClientConfigOptions } from "@clickhouse/client/dist/config"; import { ClickHouseSettings } from "@clickhouse/client"; /** * Custom error class for ClickHouse resource-related errors */ declare const ERROR_TYPE_CONFIG: Record<"MEMORY_LIMIT" | "OVERCOMMIT" | "TIMEOUT", { discriminators: string[]; }>; type ErrorType = keyof typeof ERROR_TYPE_CONFIG; export declare class ClickHouseResourceError extends Error { static ERROR_ADVICE_MESSAGE: string; readonly errorType: ErrorType; constructor(errType: ErrorType, originalError: Error); static wrapIfResourceError(originalError: Error): Error; } export declare function upsertClickhouse>(opts: { table: "scores" | "traces" | "observations" | "traces_null"; records: T[]; eventBodyMapper: (body: T) => Record; tags?: Record; }): Promise; export declare function queryClickhouseStream(opts: { query: string; params?: Record | undefined; clickhouseConfigs?: NodeClickHouseClientConfigOptions; tags?: Record; preferredClickhouseService?: PreferredClickhouseService; clickhouseSettings?: ClickHouseSettings; }): AsyncGenerator; export declare function queryClickhouse(opts: { query: string; params?: Record | undefined; clickhouseConfigs?: NodeClickHouseClientConfigOptions; tags?: Record; preferredClickhouseService?: PreferredClickhouseService; clickhouseSettings?: ClickHouseSettings; }): Promise; export declare function commandClickhouse(opts: { query: string; params?: Record | undefined; clickhouseConfigs?: NodeClickHouseClientConfigOptions; tags?: Record; }): Promise; export declare function parseClickhouseUTCDateTimeFormat(dateStr: string): Date; export declare function clickhouseCompliantRandomCharacters(): string; export {}; //# sourceMappingURL=clickhouse.d.ts.map