import type { RdiSDK } from '@rdi-ui/sdk';
import type { ActionIdResponse, ConnectionStatusSingleConnection, 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';
import type { GetDlqRecordsRequest, RdiClient } from './RdiClient';
export interface RdiClientAuthState {
    jwtToken?: string;
}
export interface BaseRdiClientOptions {
    version: ResolvedClientVersion;
    authState?: RdiClientAuthState;
}
export declare abstract class BaseRdiClient implements RdiClient {
    readonly config: RdiClientConfig;
    readonly version: ResolvedClientVersion;
    protected readonly sdk: RdiSDK;
    protected readonly authState: RdiClientAuthState;
    constructor(config: RdiClientConfig, sdk: RdiSDK, options: BaseRdiClientOptions);
    abstract getPipeline(pipelineName?: string): Promise<PipelineResponse>;
    abstract getPipelineStatus(pipelineName: string): Promise<StatusResponse>;
    abstract startPipeline(pipelineName: string, source?: string): Promise<PipelineOperationResponse>;
    abstract stopPipeline(pipelineName: string, source?: string): Promise<PipelineOperationResponse>;
    abstract resetPipeline(pipelineName: string, source?: string): Promise<PipelineOperationResponse>;
    flushTarget(_pipelineName: string, _targetName: string): Promise<FlushResponse>;
    abstract createPipeline(request: CreatePipelineRequest, dryRun?: boolean): Promise<PipelineOperationResponse>;
    abstract updatePipeline(pipelineName: string, request: UpdatePipelineRequest, options?: {
        dryRun?: boolean;
        validateCdc?: boolean;
    }): Promise<PipelineOperationResponse>;
    abstract patchPipeline(pipelineName: string, request: PatchRequest, options?: {
        dryRun?: boolean;
        validateCdc?: boolean;
    }): Promise<PipelineOperationResponse>;
    abstract deletePipeline(pipelineName: string): Promise<void>;
    /** @inheritDoc */
    abstract getProcessorMetrics(pipelineName: string): Promise<MonitoringStatistics>;
    getDlqStreams(_pipelineName: string): Promise<Record<string, DlqTableInfo>>;
    getDlqStream(_pipelineName: string, _fullTableName: string): Promise<Record<string, DlqTableInfo>>;
    getDlqRecords(_request: GetDlqRecordsRequest): Promise<DlqRecordsResponse>;
    abstract testSource(pipelineName: string, request: SourceDbConnectionTest): Promise<SourceTestResponse>;
    login(credentials: CredentialsInfo): Promise<void>;
    protected wrapError(error: unknown, operation: string): never;
    protected extractInvalidProperties(errors?: Array<{
        details?: Record<string, unknown>;
    }>): Record<string, string> | undefined;
    protected normalizeTargetTestResponse(raw: ConnectionStatusSingleConnection): TargetTestResponse;
    protected normalizeSourceTestResponse(raw: ConnectionStatusSingleConnection): SourceTestResponse;
    protected omitUndefined<T extends object>(value: T): Partial<T>;
    protected isV2ValidationError(error: unknown): error is Error & {
        detail: string;
        errors?: Array<{
            message: string;
            details?: Record<string, unknown>;
        }> | null;
    };
    getMonitoringStatistics(): Promise<StatisticsResponse>;
    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>;
    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>;
    /** Jobs schemas are not yet exposed by the generated SDK. Keep auth in the shared client. */
    getJobsSchemas(): Promise<JobSchemaResponse>;
    getConfigSchemas(): Promise<ConfigSchemaResponse>;
}