/**
 * Debuggable Pipeline Module - Enhanced pipeline module with integrated tracing
 * 可调试流水线模块 - 带有集成跟踪的增强流水线模块
 */
import { BaseModule, BaseModuleRecordingConfig } from 'rcc-basemodule';
import { DebugCenter } from 'rcc-debugcenter';
import { ErrorHandlingCenter } from 'rcc-errorhandling';
import { PipelineExecutionContext, ExecutionContextFactory, PipelineStage, ExecutionError } from './PipelineExecutionContext';
import { PipelineTracker } from '../framework/PipelineTracker';
/**
 * Debuggable pipeline module configuration
 * 可调试流水线模块配置
 */
export interface DebuggablePipelineModuleConfig {
    id: string;
    name: string;
    version: string;
    description: string;
    type: 'provider' | 'scheduler' | 'tracker' | 'pipeline' | 'debuggable-pipeline';
    enableTracing?: boolean;
    tracerConfig?: Partial<any>;
    recordingConfig?: Partial<BaseModuleRecordingConfig>;
    maxConcurrentExecutions?: number;
    executionTimeout?: number;
    enablePerformanceMetrics?: boolean;
    enableEnhancedErrorHandling?: boolean;
    errorRecoveryAttempts?: number;
    providerName?: string;
    endpoint?: string;
    supportedModels?: string[];
    defaultModel?: string;
    maxConcurrentRequests?: number;
    requestTimeout?: number;
    loadBalancingStrategy?: 'round-robin' | 'random' | 'weighted' | 'least-connections';
    oauth?: {
        clientId: string;
        clientSecret: string;
        scopes: string[];
    };
}
/**
 * Execution operation options
 * 执行操作选项
 */
export interface ExecutionOptions {
    /** Custom execution ID */
    executionId?: string;
    /** Custom trace ID */
    traceId?: string;
    /** Custom session ID */
    sessionId?: string;
    /** Request timeout in milliseconds */
    timeout?: number;
    /** Enable retry on failure */
    enableRetry?: boolean;
    /** Maximum retry attempts */
    maxRetries?: number;
    /** Retry delay in milliseconds */
    retryDelay?: number;
    /** Additional metadata */
    metadata?: Record<string, any>;
    /** Parent execution context */
    parentContext?: PipelineExecutionContext;
    /** Stage-specific configuration */
    stageConfig?: Record<string, any>;
}
/**
 * Execution result with comprehensive information
 * 执行结果，包含完整信息
 */
export interface ExecutionResult<T = any> {
    /** Execution ID */
    executionId: string;
    /** Request ID */
    requestId: string;
    /** Trace ID */
    traceId: string;
    /** Execution status */
    status: 'success' | 'failed' | 'timeout' | 'cancelled';
    /** Execution result data */
    data?: T;
    /** Error information if failed */
    error?: ExecutionError;
    /** Execution timing */
    timing: {
        startTime: number;
        endTime: number;
        duration: number;
    };
    /** Execution context */
    context: PipelineExecutionContext;
    /** Performance metrics */
    metrics?: ExecutionMetrics;
    /** Trace summary */
    traceSummary?: TraceSummary;
}
/**
 * Execution metrics for performance analysis
 * 执行指标，用于性能分析
 */
export interface ExecutionMetrics {
    /** Memory usage */
    memoryUsage?: {
        start: number;
        end: number;
        peak: number;
    };
    /** CPU usage */
    cpuUsage?: {
        start: number;
        end: number;
        average: number;
    };
    /** Network requests */
    networkRequests?: number;
    /** Database queries */
    databaseQueries?: number;
    /** External service calls */
    externalServiceCalls?: number;
}
/**
 * Trace summary for analysis
 * 跟踪摘要，用于分析
 */
export interface TraceSummary {
    totalStages: number;
    completedStages: number;
    failedStages: number;
    stageTransitions: Array<{
        from: PipelineStage;
        to: PipelineStage;
        duration: number;
    }>;
    errors: ExecutionError[];
}
/**
 * Debuggable Pipeline Module - Main class with integrated tracing and monitoring
 * 可调试流水线模块 - 主类，集成了跟踪和监控
 */
export declare class DebuggablePipelineModule extends BaseModule {
    protected config: DebuggablePipelineModuleConfig;
    protected tracker: PipelineTracker;
    protected errorHandler: ErrorHandlingCenter;
    protected contextFactory: ExecutionContextFactory;
    protected debugCenter: DebugCenter;
    constructor(config: DebuggablePipelineModuleConfig);
    initialize(): Promise<void>;
    /**
     * Set recording configuration
     * 设置录制配置
     */
    setRecordingConfig(config: Partial<BaseModuleRecordingConfig>): void;
    /**
     * Log debug message
     * 记录调试信息
     */
    protected logDebug(message: string, data?: any): void;
    /**
     * Log warning message
     * 记录警告信息
     */
    protected logWarn(message: string, data?: any): void;
    /**
     * Log error message
     * 记录错误信息
     */
    protected logError(message: string, data?: any): void;
    /**
     * Execute operation with full tracing and error handling
     * 执行操作并带有完整的跟踪和错误处理
     */
    executeWithTracing<T>(operation: (context: PipelineExecutionContext) => Promise<T>, stage: PipelineStage, request?: any, options?: ExecutionOptions): Promise<ExecutionResult<T>>;
    /**
     * Execute with timeout and retry logic
     * 执行带超时和重试逻辑
     */
    private executeWithTimeoutAndRetry;
    /**
     * Handle execution errors with comprehensive error handling
     * 处理执行错误并提供全面的错误处理
     */
    private handleExecutionError;
    /**
     * Collect performance metrics
     * 收集性能指标
     */
    private collectPerformanceMetrics;
    /**
     * Generate trace summary for analysis
     * 生成跟踪摘要用于分析
     */
    private generateTraceSummary;
    private categorizeError;
    private determineSeverity;
    private isErrorRecoverable;
    /**
     * Record error with tracker
     * 使用跟踪器记录错误
     */
    private recordError;
    private generateErrorId;
    private getErrorStatus;
    private setupTraceListeners;
    private handleTraceError;
    private handleTraceCompletion;
    private handleStageChange;
    /**
     * Get tracer instance
     * 获取跟踪器实例
     */
    getTracker(): PipelineTracker;
    /**
     * Get execution statistics
     * 获取执行统计
     */
    getExecutionStatistics(): any;
    /**
     * Get active execution contexts
     * 获取活动执行上下文
     */
    getActiveExecutionContexts(): PipelineExecutionContext[];
    /**
     * Get trace chains
     * 获取跟踪链
     */
    getTraceChains(): any[];
    /**
     * Update module configuration
     * 更新模块配置
     */
    updateConfig(newConfig: Partial<DebuggablePipelineModuleConfig>): void;
    destroy(): Promise<void>;
}
//# sourceMappingURL=DebuggablePipelineModule.d.ts.map