import type { AdapterCheckpoint, AdapterConfigurationResult, AdapterDiscovery, AdapterManifest, AdapterReadEvent, AdapterRecord, AdapterRequest, AdapterResult, DatasetSourceAdapter } from './adapter-types.js';
type FileConfig = {
    path: string;
    encoding?: 'utf8';
};
type DirectoryConfig = FileConfig & {
    recursive?: boolean;
};
type HttpConfig = {
    url: string;
    headers?: Record<string, string | {
        kind: 'opaque' | 'environment' | 'keychain' | 'vault';
        locator: string;
    }>;
};
declare abstract class LocalAdapter<T extends FileConfig> implements DatasetSourceAdapter<T> {
    abstract describe(): AdapterManifest;
    protected abstract valid(value: Record<string, unknown>): value is T;
    protected abstract discoverPath(config: T, request: AdapterRequest<T>): Promise<AdapterDiscovery>;
    protected abstract records(config: T, request: AdapterRequest<T> & {
        checkpoint?: AdapterCheckpoint;
    }): AsyncIterable<AdapterRecord>;
    configure(config: unknown): Promise<AdapterConfigurationResult<T>>;
    check(request: AdapterRequest<T>): Promise<AdapterResult<{
        sourceIdentity: string;
    }>>;
    discover(request: AdapterRequest<T>): Promise<AdapterResult<AdapterDiscovery>>;
    preview(request: AdapterRequest<T> & {
        count: number;
    }): Promise<AdapterResult<AdapterRecord[]>>;
    read(request: AdapterRequest<T> & {
        checkpoint?: AdapterCheckpoint;
    }): AsyncIterable<AdapterReadEvent>;
}
export declare class FileAdapter extends LocalAdapter<FileConfig> {
    #private;
    describe(): AdapterManifest;
    protected valid(value: Record<string, unknown>): value is FileConfig;
    protected discoverPath(config: FileConfig, request: AdapterRequest<FileConfig>): Promise<AdapterDiscovery>;
    protected records(config: FileConfig, request: AdapterRequest<FileConfig> & {
        checkpoint?: AdapterCheckpoint;
    }): AsyncIterable<AdapterRecord>;
}
declare abstract class LineAdapter<T extends FileConfig> extends LocalAdapter<T> {
    protected lineDiscovery(kind: string, config: T, request: AdapterRequest<T>, schema: Record<string, unknown>): Promise<AdapterDiscovery>;
    protected lines(config: T, request: AdapterRequest<T> & {
        checkpoint?: AdapterCheckpoint;
    }, parse: (line: string, ordinal: number, maxDepth: number) => unknown): AsyncIterable<AdapterRecord>;
}
export declare class JsonlAdapter extends LineAdapter<FileConfig> {
    #private;
    describe(): AdapterManifest;
    protected valid(value: Record<string, unknown>): value is FileConfig;
    protected discoverPath(config: FileConfig, request: AdapterRequest<FileConfig>): Promise<AdapterDiscovery>;
    protected records(config: FileConfig, request: AdapterRequest<FileConfig> & {
        checkpoint?: AdapterCheckpoint;
    }): AsyncIterable<AdapterRecord>;
}
export declare class CsvAdapter extends LineAdapter<FileConfig> {
    #private;
    describe(): AdapterManifest;
    protected valid(value: Record<string, unknown>): value is FileConfig;
    protected discoverPath(config: FileConfig, request: AdapterRequest<FileConfig>): Promise<AdapterDiscovery>;
    protected records(config: FileConfig, request: AdapterRequest<FileConfig> & {
        checkpoint?: AdapterCheckpoint;
    }): AsyncIterable<AdapterRecord>;
}
export declare class DirectoryAdapter extends LocalAdapter<DirectoryConfig> {
    #private;
    describe(): AdapterManifest;
    protected valid(value: Record<string, unknown>): value is DirectoryConfig;
    protected discoverPath(config: DirectoryConfig, request: AdapterRequest<DirectoryConfig>): Promise<AdapterDiscovery>;
    protected records(config: DirectoryConfig, request: AdapterRequest<DirectoryConfig> & {
        checkpoint?: AdapterCheckpoint;
    }): AsyncIterable<AdapterRecord>;
}
type FetchLike = typeof fetch;
type HostResolver = (hostname: string) => Promise<Array<{
    address: string;
}>>;
export declare class HttpAdapter implements DatasetSourceAdapter<HttpConfig> {
    #private;
    private readonly fetchImpl;
    private readonly resolveHost;
    constructor(fetchImpl?: FetchLike, resolveHost?: HostResolver);
    describe(): AdapterManifest;
    configure(config: unknown): Promise<AdapterConfigurationResult<HttpConfig>>;
    check(request: AdapterRequest<HttpConfig>): Promise<AdapterResult<{
        sourceIdentity: string;
    }>>;
    discover(request: AdapterRequest<HttpConfig>): Promise<AdapterResult<AdapterDiscovery>>;
    preview(request: AdapterRequest<HttpConfig> & {
        count: number;
    }): Promise<AdapterResult<AdapterRecord[]>>;
    read(request: AdapterRequest<HttpConfig> & {
        checkpoint?: AdapterCheckpoint;
    }): AsyncIterable<AdapterReadEvent>;
}
export declare function createBuiltinAdapterRegistry(): {
    adapters: (FileAdapter | JsonlAdapter | CsvAdapter | DirectoryAdapter | HttpAdapter)[];
    manifests: AdapterManifest[];
};
export {};
//# sourceMappingURL=adapters.d.ts.map