/**
 * RDI Client Interface
 *
 * Public contract for all RDI client implementations.
 *
 * @packageDocumentation
 */
import type { ActionIdResponse, CredentialsInfo, DlqRecordsResponse, DlqTableInfo, FlushResponse, JobDryRunBody, JobDryRunSuccessResponse, MetadataResponse, OperationResponse, PipelineSecretResponse, PipelineSourceSchemaResponse, SchemaResponse, StatisticsResponse } from '@rdi-ui/sdk/models';
import type { DeleteSecretProviderRequest, GetMetadataRequest, GetSchemasRequest, GetSourceSchemasRequest, UpdateSecretRequest, UpsertSecretProviderRequest } from '@rdi-ui/sdk/models/operations';
import type { RdiClientConfig, ResolvedClientVersion } from '../config/types';
import type { MonitoringStatistics } from '../metrics/types';
import type { ConfigSchemaResponse, JobSchemaResponse, CreatePipelineRequest, PatchRequest, PipelineOperationResponse, PipelineResponse, SecretsRequest, SetMultiKeySecretRequest, SourceDbConnectionTest, SourceTestResponse, StatusResponse, TargetDbRequest, TargetTestResponse, UpdatePipelineRequest } from '../pipeline/types';
export interface GetDlqRecordsRequest {
    pipelineName: string;
    fullTableName: string;
    limit?: number;
    offset?: number;
    sortOrder?: 'asc' | 'desc';
    fields?: string | null;
}
export interface RdiClient {
    readonly config: RdiClientConfig;
    readonly version: ResolvedClientVersion;
    login(credentials: CredentialsInfo): Promise<void>;
    getPipeline(pipelineName?: string): Promise<PipelineResponse>;
    getPipelineStatus(pipelineName: string): Promise<StatusResponse>;
    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>;
    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(request: GetDlqRecordsRequest): Promise<DlqRecordsResponse>;
    getMonitoringStatistics(): Promise<StatisticsResponse>;
    /**
     * @deprecated Temporary compatibility workaround while UI migrates to
     * processor-specific visualizations. Prefer consuming raw metric
     * collections and rendering separate classic/flink views so each processor
     * type can surface its own meaningful dataset.
     */
    getProcessorMetrics(pipelineName: string): Promise<MonitoringStatistics>;
    getSchemas(request: GetSchemasRequest): Promise<PipelineSourceSchemaResponse>;
    getSourceSchemas(request: GetSourceSchemasRequest, pipelineName: string): Promise<SchemaResponse>;
    getMetadata(request: GetMetadataRequest): Promise<MetadataResponse>;
    jobDryRun(request: JobDryRunBody): Promise<JobDryRunSuccessResponse>;
    testTarget(pipelineName: string, request: TargetDbRequest): Promise<TargetTestResponse>;
    testSource(pipelineName: string, request: SourceDbConnectionTest): Promise<SourceTestResponse>;
    setSecrets(request: SecretsRequest): Promise<OperationResponse>;
    setMultiKeySecret(request: SetMultiKeySecretRequest): Promise<OperationResponse>;
    updateSecret(request: UpdateSecretRequest): Promise<PipelineSecretResponse>;
    upsertSecretProvider(request: UpsertSecretProviderRequest): Promise<ActionIdResponse>;
    deleteSecretProvider(request: DeleteSecretProviderRequest): Promise<ActionIdResponse>;
    getConfigSchemas(): Promise<ConfigSchemaResponse>;
    getJobsSchemas(): Promise<JobSchemaResponse>;
}