/**
 * RDI API v2 client implementation.
 *
 * @packageDocumentation
 */
import type { RdiSDK } from '@rdi-ui/sdk';
import type { DlqRecordsResponse, DlqTableInfo, FlushResponse, PipelineSecretResponse, PipelineSourceSchemaResponse, SchemaResponse } from '@rdi-ui/sdk/models';
import type { GetSchemasRequest, GetSourceSchemasRequest, UpdateSecretRequest } from '@rdi-ui/sdk/models/operations';
import type { RdiClientConfig } from '../config/types';
import type { MonitoringStatistics } from '../metrics/types';
import type { CreatePipelineRequest, PatchRequest, PipelineOperationResponse, PipelineResponse, SourceDbConnectionTest, SourceTestResponse, StatusResponse, UpdatePipelineRequest } from '../pipeline/types';
import { BaseRdiClient, type RdiClientAuthState } from './BaseRdiClient';
import type { GetDlqRecordsRequest } from './RdiClient';
interface RdiClientV2Options {
    authState?: RdiClientAuthState;
}
export declare class RdiClientV2 extends BaseRdiClient {
    constructor(config: RdiClientConfig, sdk: RdiSDK, options?: RdiClientV2Options);
    getSchemas(request: GetSchemasRequest): Promise<PipelineSourceSchemaResponse>;
    getSourceSchemas(request: GetSourceSchemasRequest, pipelineName: string): Promise<SchemaResponse>;
    getPipeline(pipelineName?: string): Promise<PipelineResponse>;
    /**
     * Status plus a v1-compatible run state, derived from the collector metric
     * collections — one per source. The rolled-up `state` is the least-advanced
     * collector; `collectorStates` keeps the per-source breakdown. Metrics are
     * best-effort: a metrics outage degrades to `not-running` rather than failing
     * the status query.
     */
    getPipelineStatus(pipelineName: string): Promise<StatusResponse>;
    private getRawPipelineStatus;
    /**
     * Reads the pre-multi-source `collector-source_metrics` collection by name.
     * Best-effort: an unavailable collection means "no collector reported".
     */
    private getLegacyCollectorStates;
    /** @inheritDoc */
    getProcessorMetrics(pipelineName: string): Promise<MonitoringStatistics>;
    startPipeline(pipelineName: string, source?: string): Promise<PipelineOperationResponse>;
    stopPipeline(pipelineName: string, source?: string): Promise<PipelineOperationResponse>;
    resetPipeline(pipelineName: string, source?: string): Promise<PipelineOperationResponse>;
    flushTarget(pipelineName: string, targetName: string): Promise<FlushResponse>;
    updateSecret(request: UpdateSecretRequest): Promise<PipelineSecretResponse>;
    createPipeline(request: CreatePipelineRequest, dryRun?: boolean): Promise<PipelineOperationResponse>;
    updatePipeline(pipelineName: string, request: UpdatePipelineRequest, options?: {
        dryRun?: boolean;
        validateCdc?: boolean;
    }): Promise<PipelineOperationResponse>;
    patchPipeline(pipelineName: string, request: PatchRequest, options?: {
        dryRun?: boolean;
        validateCdc?: boolean;
    }): Promise<PipelineOperationResponse>;
    deletePipeline(pipelineName: string): Promise<void>;
    getDlqStreams(pipelineName: string): Promise<Record<string, DlqTableInfo>>;
    getDlqStream(pipelineName: string, fullTableName: string): Promise<Record<string, DlqTableInfo>>;
    getDlqRecords({ pipelineName, fullTableName, limit, offset, sortOrder, fields }: GetDlqRecordsRequest): Promise<DlqRecordsResponse>;
    testSource(pipelineName: string, request: SourceDbConnectionTest): Promise<SourceTestResponse>;
}
export {};