import type { LTMilestone } from '../../types'; /** * Publish a milestone event. Called from handleCompletion (workflow * interceptor), ltCompleteTask (orchestrator activity), and the * activity interceptor's after phase. */ export declare function publishMilestoneEvent(params: { source: 'interceptor' | 'orchestrator' | 'activity'; workflowId: string; workflowName: string; taskQueue: string; taskId?: string; activityName?: string; milestones: LTMilestone[]; data?: Record; }): Promise; /** * Publish a task lifecycle event. * Subject: system.task.{taskId}.{action} */ export declare function publishTaskEvent(params: { type: 'task.created' | 'task.started' | 'task.completed' | 'task.escalated' | 'task.failed'; source: string; workflowId: string; workflowName: string; taskQueue: string; taskId: string; originId?: string; status: string; milestones?: LTMilestone[]; data?: Record; }): Promise; /** * Publish an escalation lifecycle event. * Subject: system.escalation.{escalationId}.{action} */ export declare function publishEscalationEvent(params: { type: 'escalation.created' | 'escalation.resolved' | 'escalation.claimed' | 'escalation.released' | 'escalation.cancelled'; source: string; workflowId: string; workflowName: string; taskQueue: string; taskId?: string; escalationId: string; originId?: string; status: string; data?: Record; }): Promise; /** * Publish an activity lifecycle event for YAML workflow steps. * Subject: system.activity.{workflowId}.{activityName}.{action} */ export declare function publishActivityEvent(params: { type: 'activity.started' | 'activity.completed' | 'activity.failed'; workflowId: string; workflowName: string; taskQueue: string; activityName: string; data?: Record; }): Promise; /** * Publish a knowledge lifecycle event. * Subject: system.knowledge.{domain}.{action} */ export declare function publishKnowledgeEvent(params: { type: 'knowledge.stored' | 'knowledge.deleted'; domain: string; key: string; }): Promise; /** * Publish a file storage event. * Subject: system.file.{action} */ export declare function publishFileEvent(params: { type: 'file.stored' | 'file.deleted'; path: string; size?: number; mime?: string; }): Promise; /** * Publish an agent lifecycle event. * Subject: system.agent.{agentName}.{action} */ export declare function publishAgentEvent(params: { type: 'agent.started' | 'agent.completed' | 'agent.failed' | 'agent.status_changed'; agentId: string; agentName: string; status?: string; data?: Record; }): Promise; /** * Publish a workflow lifecycle event. * Subject: system.workflow.{workflowId}.{action} */ export declare function publishWorkflowEvent(params: { type: 'workflow.started' | 'workflow.completed' | 'workflow.failed'; source: string; workflowId: string; workflowName: string; taskQueue: string; taskId?: string; originId?: string; status: string; data?: Record; }): Promise;