/** * Pipeline Event Emitter * * Provides an event-based communication channel for pipeline execution status. * Located in output layer since it's primarily used for providing user feedback. */ import { EventEmitter } from 'events'; import { type AgentThinkingData, type ConsolidationCompleteData, type EscalationAbortedData, type EscalationResolvedData, type EscalationTriggeredData, type LLMRequestData, type LLMResponseData, type MemoryAccessedData, type MemoryCreatedData, type MemoryPromotedData, type MemoryPrunedData, type MemoryStaledData, type PipelineEventData, type PipelineStartData, type StageCompleteData, type StageProgressData, type StageStartData, type ToolExecutionFailedData, type ToolHookBlockedData, type ToolHookPostData, type ToolHookTriggeredData, type ToolLoopExhaustedData } from '../types/pipeline.types.js'; export declare class PipelineEventEmitter extends EventEmitter { /** * Emit pipeline start event */ emitPipelineStart(data: PipelineStartData): void; /** * Emit pipeline complete event */ emitPipelineComplete(commandName: string, duration: number, success: boolean): void; /** * Emit pipeline error event */ emitPipelineError(commandName: string, error: string): void; /** * Emit stage start event */ emitStageStart(data: StageStartData): void; /** * Emit stage progress event */ emitStageProgress(data: StageProgressData): void; /** * Emit stage complete event */ emitStageComplete(data: StageCompleteData): void; /** * Emit stage error event */ emitStageError(stage: string, error: string): void; /** * Emit agent thinking event */ emitAgentThinking(data: AgentThinkingData): void; /** * Emit LLM request event */ emitLLMRequest(data: LLMRequestData): void; /** * Emit LLM response event */ emitLLMResponse(data: LLMResponseData): void; /** * Emit escalation triggered event */ emitEscalationTriggered(data: EscalationTriggeredData): void; /** * Emit escalation resolved event */ emitEscalationResolved(data: EscalationResolvedData): void; /** * Emit escalation aborted event */ emitEscalationAborted(data: EscalationAbortedData): void; /** * Emit tool hook triggered event */ emitToolHookTriggered(data: ToolHookTriggeredData): void; /** * Emit tool hook blocked event */ emitToolHookBlocked(data: ToolHookBlockedData): void; /** * Emit tool execution failed event */ emitToolExecutionFailed(data: ToolExecutionFailedData): void; /** * Emit tool loop exhausted event */ emitToolLoopExhausted(data: ToolLoopExhaustedData): void; /** * Emit tool hook post event */ emitToolHookPost(data: ToolHookPostData): void; /** * Emit memory created event */ emitMemoryCreated(data: MemoryCreatedData): void; /** * Emit memory promoted event */ emitMemoryPromoted(data: MemoryPromotedData): void; /** * Emit consolidation complete event */ emitConsolidationComplete(data: ConsolidationCompleteData): void; /** * Emit memory accessed event */ emitMemoryAccessed(data: MemoryAccessedData): void; /** * Emit memory staled event */ emitMemoryStaled(data: MemoryStaledData): void; /** * Emit memory pruned event */ emitMemoryPruned(data: MemoryPrunedData): void; /** * Subscribe to all events */ onAny(handler: (event: PipelineEventData) => void): void; /** * Unsubscribe from all events */ offAny(handler: (event: PipelineEventData) => void): void; } export declare function getPipelineEmitter(): PipelineEventEmitter; export declare function setPipelineEmitter(emitter: PipelineEventEmitter): void; //# sourceMappingURL=pipeline-emitter.d.ts.map