import { IngestStreamBuilder } from "./ingest-stream.js";
import type { AppendRowsResult, CatalogPage, DatabaseResource, IngestRequest, IngestResult, SchemaResource, StatementCancelResult, StatementRequest, StatementStatus, TableResource, TableResourceSummary } from "./protocol.js";
import type { ResultSet } from "./result.js";
import { Statement, StatementHandle } from "./statement.js";
import type { WaitOptions } from "./statement.js";
import { Table, type TableOptions } from "./table.js";
export interface RequestOptions {
    signal?: AbortSignal;
}
export interface CatalogListOptions extends RequestOptions {
    /** Number of resources to return. The server accepts values from 1 to 1000. */
    pageSize?: number;
    /** Opaque token returned as `next_page_token` by the previous page. */
    pageToken?: string;
}
export interface SchemaCatalogListOptions extends CatalogListOptions {
    database: string;
}
export interface TableCatalogListOptions extends CatalogListOptions {
    database: string;
    schema: string;
}
export interface SchemaReference extends RequestOptions {
    database: string;
    schema: string;
}
export interface TableReference extends SchemaReference {
    table: string;
}
export interface ClientOptions {
    fetch?: typeof globalThis.fetch;
    /** Default headers sent with every request. */
    headers?: HeadersInit;
    /**
     * ScopeDB API key. It is sent as a Bearer credential and must only be used
     * from trusted server-side code. It takes precedence over `token` and an
     * `Authorization` value in `headers`.
     */
    apiKey?: string;
    /**
     * Bearer token for authentication.
     * Equivalent to `headers: { Authorization: 'Bearer <token>' }`.
     * If `apiKey` is also provided, `apiKey` wins.
     *
     * @deprecated Use `apiKey`.
     */
    token?: string;
}
export declare class Client {
    private readonly endpoint;
    private readonly fetchFn;
    private readonly defaultHeaders;
    constructor(endpoint: string | URL, options?: ClientOptions);
    statement(scopeql: string): Statement;
    statementHandle(statementId: string): StatementHandle;
    table(table: string, options?: TableOptions): Table;
    ingestStream(statement: string): IngestStreamBuilder;
    /**
     * Executes a ScopeQL statement and returns all rows.
     *
     * Shorthand for `client.statement(scopeql).execute(options)`.
     *
     * @example
     * const result = await client.query("FROM events SELECT * LIMIT 10");
     * for (const row of result.toObjects()) {
     *   console.log(row);
     * }
     */
    query(scopeql: string, options?: WaitOptions): Promise<ResultSet>;
    listDatabases(options?: CatalogListOptions): Promise<CatalogPage<DatabaseResource>>;
    fetchDatabase(database: string, options?: RequestOptions): Promise<DatabaseResource>;
    listSchemas(reference: SchemaCatalogListOptions): Promise<CatalogPage<SchemaResource>>;
    listSchemas(database: string, options?: CatalogListOptions): Promise<CatalogPage<SchemaResource>>;
    fetchSchema(reference: SchemaReference): Promise<SchemaResource>;
    fetchSchema(database: string, schema: string, options?: RequestOptions): Promise<SchemaResource>;
    listTables(reference: TableCatalogListOptions): Promise<CatalogPage<TableResourceSummary>>;
    listTables(database: string, schema: string, options?: CatalogListOptions): Promise<CatalogPage<TableResourceSummary>>;
    fetchTable(reference: TableReference): Promise<TableResource>;
    fetchTable(database: string, schema: string, table: string, options?: RequestOptions): Promise<TableResource>;
    /** Iterates databases across all catalog pages. */
    iterateDatabases(options?: CatalogListOptions): AsyncGenerator<DatabaseResource>;
    /** Iterates schemas across all catalog pages. */
    iterateSchemas(reference: SchemaCatalogListOptions): AsyncGenerator<SchemaResource>;
    iterateSchemas(database: string, options?: CatalogListOptions): AsyncGenerator<SchemaResource>;
    /** Iterates table summaries across all catalog pages. */
    iterateTables(reference: TableCatalogListOptions): AsyncGenerator<TableResourceSummary>;
    iterateTables(database: string, schema: string, options?: CatalogListOptions): AsyncGenerator<TableResourceSummary>;
    /** @deprecated Use `client.table(name, location).append(ndjson)`. */
    appendRows(database: string, schema: string, table: string, ndjson: string, options?: RequestOptions): Promise<AppendRowsResult>;
    private sendAppendRows;
    insert(rows: string, transform: string, options?: RequestOptions): Promise<IngestResult>;
    /** @deprecated Use `client.statement(scopeql).submit()`. */
    submitStatement(request: StatementRequest, options?: RequestOptions): Promise<StatementStatus>;
    /** @deprecated Use `client.statementHandle(id).status()` or `.wait()`. */
    fetchStatement(statementId: string, options?: RequestOptions): Promise<StatementStatus>;
    /** @deprecated Use `client.statementHandle(id).cancel()`. */
    cancelStatement(statementId: string, options?: RequestOptions): Promise<StatementCancelResult>;
    ingest(request: IngestRequest, options?: RequestOptions): Promise<IngestResult>;
    private requestJson;
    private request;
    private makeUrl;
    private resourceUrl;
    private catalogUrl;
}
//# sourceMappingURL=client.d.ts.map